AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Java基础 | 网络编程

2022-10-17 171
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Java中的网络编程

网络编程

（一）网络编程入门

1.网络编程概述

在这里插入图片描述

网络编程

  • 在网络通信协议下，实现网路互连的不同计算机上运行的程序间可以进行数据交换

2.网络编程三要素

在这里插入图片描述

3.IP地址

在这里插入图片描述

常用命令：

  • ipconfig：查看本机IP地址
  • ping IP地址：检查网路是否连通

特殊IP地址：

  • 127.0.0.1：是回送地址，可以代表本机地址，一般用来测试使用

4.InetAddress的使用

在这里插入图片描述

代码演示：

import java.net.InetAddress;
import java.net.UnknownHostException;

public class InetAddressDemo {
    public static void main(String[] args) throws UnknownHostException {
//        InetAddress address = InetAddress.getByName("PC-202111286656");
        InetAddress address = InetAddress.getByName("192.168.1.105");
        String name = address.getHostName();
        String ip = address.getHostAddress();

        System.out.println(name);//PC-202111286656
        System.out.println(ip);//192.168.1.105
    }
}

5.端口

在这里插入图片描述

6.协议

在这里插入图片描述

在这里插入图片描述

（二）UDP通信程序

1.UDP通信原理

UDP协议是一种不可靠的网路协议，它在通信的两端各建立一个Socket对象，但是这两个Socket只是发送，接收数据的对象 因此对于基于UDP协议的通信双方而言，没有所谓的客户端和服务器的概念

Java提供了DatagramSocket类作为UDP协议的Socket

2.UDP发送数据

在这里插入图片描述

代码演示：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPDemo {
    public static void main(String[] args) throws IOException {
        //DatagramSocket()  构建一个数据报套接字绑定到本地主机的任何可用的端口。
        DatagramSocket ds = new DatagramSocket();
        byte[] bys = "hello java".getBytes();
        DatagramPacket dp = new DatagramPacket(bys,bys.length, InetAddress.getByName("192.168.1.105"),10086);
        
        ds.send(dp);
        ds.close();
    }
}

3.UDP接收数据

在这里插入图片描述

代码演示：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        DatagramSocket ds = new DatagramSocket(10086);
        //创建数据包，用于接收数据
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys, bys.length);
        //接收数据
        ds.receive(dp);

        //解析数据
        byte[] datas = dp.getData();
        int len = dp.getLength();
        System.out.println("数据是：" + new String(datas, 0, len)); //数据是：hello java

        //注意接收数据，先运行接收端，再运行发送端
        
        //关闭接收端
        ds.close();
    }
}

4.案例（聊天室）

定义发送端：

import java.io.IOException;
import java.net.*;
import java.util.Scanner;

public class SendDemo {
    public static void main(String[] args) throws IOException {
        //创建发送端Socket对象
        DatagramSocket ds = new DatagramSocket();

        Scanner sc = new Scanner(System.in);
        System.out.println("请输入传输的数据：");
        String ss = "";
        while (!ss.equals("886")) {
            ss = sc.nextLine();
            //创建数据包
            byte[] bys = ss.getBytes();
            DatagramPacket dp = new DatagramPacket(bys, bys.length, InetAddress.getByName("192.168.1.105"), 10086);
            //发送数据
            ds.send(dp);
        }
        ds.close();
    }
}

定义接收端：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class Receive {
    public static void main(String[] args) throws IOException {
        //创建接收端对象
        DatagramSocket ds = new DatagramSocket(10086);

        //创建数据包
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys,bys.length);

        while(true){
            //接收数据
            ds.receive(dp);
            //解析数据
            byte[] data = dp.getData();
            int length = dp.getLength();
            System.out.println("数据是："+new String(data,0,length));
        }
    }
}

（三）TCP通信程序

1.TCP通信原理

在这里插入图片描述

2.TCP发送数据

发送数据的步骤

1.创建客户端的Socket对象(Socket)

Socket(String host,int port)

2.获取输出流，写数据

OutputStream getOutputStream()

3.释放资源

void close()

代码演示：

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

public class TCP_sendDemo {
    public static void main(String[] args) throws IOException {
        //Socket(InetAddress address, int port)
//        Socket s = new Socket(InetAddress.getByName("192.168.1.105"),10000);
        //创建客户端对象 Socket(String host,int port)
        Socket s =new Socket("192.168.1.105",8888);

        //获取输出流写数据
        OutputStream os = s.getOutputStream();
        os.write("TCP我来了".getBytes());

        //释放资源
        s.close();
    }
}

3.TCP接收数据

接收数据的步骤

1.创建服务器端的Socket对象(ServerSocket)

ServerSocket(int port)

2.监听客户端连接，返回一个Socket对象

Socket accept()

3.获取输入流，读数据，并把数据显示在控制台

InputStream getInputStream()

4.释放资源

void close()

代码演示：

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TCP_acceptDemo {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接，返回Socket对象
        Socket s = ss.accept();

        //获取输入流，读数据，并把数据显示在控制台
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        System.out.println("数据是：" + new String(bys, 0, len));

        //释放资源
        ss.close();
    }
}

（四）TCP通信练习

练习一：

  • 客户端：发送数据，接收服务器反馈
  • 服务器：接受数据，给出反馈

代码实现：

客户端：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket(InetAddress.getByName("192.168.1.105"), 8888);

        //获取输出流，写数据
        OutputStream os = s.getOutputStream();
        os.write("服务端我来了".getBytes());

        //接收服务端反馈
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys, 0, len);
        System.out.println("服务端:" + data);//服务端:数据收到了

        //释放资源
        s.close();

    }
}

服务器：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接
        Socket s = ss.accept();

        //获取输入流对象，读数据
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys, 0, len);
        System.out.println("数据是：" + data);//数据是：服务端我来了

        //给客户端反馈
        OutputStream os = s.getOutputStream();
        os.write("数据收到了".getBytes());

        //释放资源
        ss.close();

    }
}

练习二：

  • 客户端：数据来自键盘录入，直到输入的数据是886，发送数据结束
  • 服务器：接收到的数据在控制台输出

代码实现：

客户端：

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class ClientDemo2 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket(InetAddress.getByName("192.168.1.105"), 8888);
     
        //键盘录入
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //封装字符输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {

            bw.write(line);
            bw.newLine();
            bw.flush();
            //服务端反馈
            InputStream is = s.getInputStream();
            byte[] bys = new byte[1024];
            int len = is.read(bys);
            String ss = new String(bys, 0, len);
            System.out.println("服务端：" + ss);

            if (line.equals("886")) {
                break;
            }
        }
        //释放资源
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo2 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接
        Socket s = ss.accept();

        //封装字符输入流，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            System.out.println("数据是：" + line);
            //给客户端反馈
            OutputStream os = s.getOutputStream();
            os.write("服务端收到了数据".getBytes());
        }
        
        //释放资源
        ss.close();
    }
}

练习三：

  • 客户端：数据来自键盘录入，直到输入的数据是886，结束数据发送
  • 服务器：接收到的数据写入文本文件

客户端：

import java.io.*;
import java.net.Socket;

public class ClientDemo3 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("192.168.1.105", 8888);
        //封装字符输入流对象，键盘录入数据
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //获取输出流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            if (line.equals("886")) {
                break;
            }
            bw.write(line);
            bw.newLine();
            bw.flush();

            //服务端给出反馈
            InputStream is = s.getInputStream();
            byte[] bys = new byte[1024];
            int len = is.read(bys);
            String ss = new String(bys, 0, len);
            System.out.println("服务端：" + ss);
        }
        //释放资源
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo3 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);

        //监听客户端连接
        Socket s = ss.accept();
        //封装字符输入流对象，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //创建把数据写入文本
        BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\sd3.txt"));

        String line;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();

            //给客户端反馈
            OutputStream os = s.getOutputStream();
            os.write("数据已写入文本中".getBytes());
        }
        //释放资源
        bw.close();//此处BufferedWriter指向的是文本而不是Socket所以需要进行单独释放
        ss.close();
    }
}

练习四：

客户端：数据来自文本文件

服务器：接收到的数据写入文本文件

客户端：

import java.io.*;
import java.net.Socket;

public class ClientDemo4 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("192.168.1.105", 8888);
        //封装文本文件的数据
        BufferedReader br = new BufferedReader(new FileReader("src\\TEMP\\TEMP29\\sd3.txt"));
        //封装输出流写数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();

            //服务端反馈
            InputStream is = s.getInputStream();
            byte[] bys = new byte[1024];
            int len = is.read(bys);
            String data = new String(bys, 0, len);
            System.out.println("服务端：" + data);
        }

        //释放资源
        br.close();
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo4 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);
        //监听客户端连接
        Socket s = ss.accept();
        //封装字符输入流，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本
        BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\sd4.txt"));

        String line;
        while((line = br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();

            //给客户端反馈
            OutputStream os = s.getOutputStream();
            os.write("数据已读取并写入目标文本中".getBytes());
        }


        //释放资源
        bw.close();
        ss.close();
    }
}

练习五：

  • 客户端：数据来自文本文件，接收服务器反馈
  • 服务器：接收的数据写入文本文件，给出反馈
  • 出现问题：程序一直等待
  • 原因：读数据的方法是阻塞式的
  • 解决办法：自定义结束标语；使用shutdownOutput()方法 (推荐)

客户端：

import java.io.*;
import java.net.Socket;

public class ClientDemo4 {
    public static void main(String[] args) throws IOException {
        //创建客户端对象
        Socket s = new Socket("192.168.1.105", 8888);
        //封装文本文件的数据
        BufferedReader br = new BufferedReader(new FileReader("src\\TEMP\\TEMP29\\sd3.txt"));
        //封装输出流写数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        //结束标语
        s.shutdownOutput();

        //接收服务端反馈
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys, 0, len);
        System.out.println("服务端：" + data);

        //释放资源
        br.close();
        s.close();
    }
}

服务器：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo4 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);
        //监听客户端连接
        Socket s = ss.accept();
        //封装字符输入流，读取数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本
        BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\sd4.txt"));

        String line;
        while((line = br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        //给客户端反馈
        OutputStream os = s.getOutputStream();
        os.write("数据已读取并写入目标文本中".getBytes());

        //释放资源
        bw.close();
        ss.close();
    }
}

练习六：

  • 客户端：数据来自文本文件，接收服务器反馈
  • 服务器：接收到的数据写入文本文件，给出反馈，代码用线程进行封装，为每一个客户端开启一个线程

服务器线程类：

import java.io.*;
import java.net.Socket;

public class ServerThread implements Runnable {
    private Socket s;

    public ServerThread(Socket s) {
        this.s = s;
    }

    @Override
    public void run() {
        try {
            //接受数据写到文本文件
            BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
//            BufferedWriter bw = new BufferedWriter(new FileWriter("src\\TEMP\\TEMP29\\copyFile.txt"));
            //解决名称冲突问题
            int count = 0;
            File file = new File("src\\TEMP\\TEMP29\\copyFile[" + count + "].txt");
            while(file.exists()){
                count++;
                file =new File("src\\TEMP\\TEMP29\\copyFile[" + count + "].txt");
            }
            BufferedWriter bw = new BufferedWriter(new FileWriter(file));
            //写数据
            String line;
            while ((line = br.readLine()) != null) {
                bw.write(line);
                bw.newLine();
                bw.flush();
            }
            //给出反馈
            BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            bwServer.write("数据已读取并写入目标文本中");
            bwServer.newLine();
            bwServer.flush();
            //释放资源
            s.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

服务器：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo5 {
    public static void main(String[] args) throws IOException {
        //创建服务端对象
        ServerSocket ss = new ServerSocket(8888);
        while(true) {
            //监听客户端连接
            Socket s = ss.accept();
            //为每个客户端开启一个线程
            new Thread(new ServerThread(s)).start();
        }

//        ss.close();
    }
}
文章标签：
Java
网络协议
关键词：
Java网络
Java网络编程
网络编程java
Java基础
Java基础网络编程
BoBooY
目录
相关文章
陌陌谣
|
12天前
|
存储 监控 安全
单位网络监控软件：Java 技术驱动的高效网络监管体系构建
在数字化办公时代，构建基于Java技术的单位网络监控软件至关重要。该软件能精准监管单位网络活动，保障信息安全，提升工作效率。通过网络流量监测、访问控制及连接状态监控等模块，实现高效网络监管，确保网络稳定、安全、高效运行。
陌陌谣
42 11
东方睿赢
|
1月前
|
Java 程序员
JAVA程序员的进阶之路：掌握URL与URLConnection，轻松玩转网络资源！
在Java编程中，网络资源的获取与处理至关重要。本文介绍了如何使用URL与URLConnection高效、准确地获取网络资源。首先，通过`java.net.URL`类定位网络资源；其次，利用`URLConnection`类实现资源的读取与写入。文章还提供了最佳实践，包括异常处理、连接池、超时设置和请求头与响应头的合理配置，帮助Java程序员提升技能，应对复杂网络编程场景。
东方睿赢
64 9
东方睿赢
|
1月前
|
人工智能 Java 物联网
JAVA网络编程的未来：URL与URLConnection的无限可能，你准备好了吗？
随着技术的发展和互联网的普及，JAVA网络编程迎来新的机遇。本文通过案例分析，探讨URL与URLConnection在智能API调用和实时数据流处理中的关键作用，展望其未来趋势和潜力。
东方睿赢
47 7
兴化
|
1月前
|
网络协议 Java 物联网
Java网络编程知识点
Java网络编程知识点
兴化
50 13
龙大吉
|
1月前
|
Java 开发者
JAVA高手必备：URL与URLConnection，解锁网络资源的终极秘籍！
在Java网络编程中，URL和URLConnection是两大关键技术，能够帮助开发者轻松处理网络资源。本文通过两个案例，深入解析了如何使用URL和URLConnection从网站抓取数据和发送POST请求上传数据，助力你成为真正的JAVA高手。
龙大吉
66 11
喵帕斯先生
|
1月前
|
安全 Java API
深入探索Java网络编程中的HttpURLConnection：从基础到进阶
本文介绍了Java网络编程中HttpURLConnection的高级特性，包括灵活使用不同HTTP方法、处理重定向、管理Cookie、优化安全性以及处理大文件上传和下载。通过解答五个常见问题，帮助开发者提升网络编程的效率和安全性。
喵帕斯先生
115 9
东方睿赢
|
1月前
|
JSON 安全 算法
JAVA网络编程中的URL与URLConnection：那些你不知道的秘密！
在Java网络编程中，URL与URLConnection是连接网络资源的两大基石。本文通过问题解答形式，揭示了它们的深层秘密，包括特殊字符处理、请求头设置、响应体读取、支持的HTTP方法及性能优化技巧，帮助你掌握高效、安全的网络编程技能。
东方睿赢
69 9
java冯坚持
|
2月前
|
存储 缓存 Java
java基础：IO流 理论与代码示例（详解、idea设置统一utf-8编码问题）
这篇文章详细介绍了Java中的IO流，包括字符与字节的概念、编码格式、File类的使用、IO流的分类和原理，以及通过代码示例展示了各种流的应用，如节点流、处理流、缓存流、转换流、对象流和随机访问文件流。同时，还探讨了IDEA中设置项目编码格式的方法，以及如何处理序列化和反序列化问题。
java冯坚持
92 1
java基础：IO流 理论与代码示例（详解、idea设置统一utf-8编码问题）
龙大吉
|
1月前
|
JSON Java API
JAVA网络编程新纪元：URL与URLConnection的神级运用，你真的会了吗？
本文深入探讨了Java网络编程中URL和URLConnection的高级应用，通过示例代码展示了如何解析URL、发送GET请求并读取响应内容。文章挑战了传统认知，帮助读者更好地理解和运用这两个基础组件，提升网络编程能力。
龙大吉
56 5
进步`于辰
|
2月前
|
Java
[Java]Socket套接字（网络编程入门）
本文介绍了基于Java Socket实现的一对一和多对多聊天模式。一对一模式通过Server和Client类实现简单的消息收发；多对多模式则通过Server类维护客户端集合，并使用多线程实现实时消息广播。文章旨在帮助读者理解Socket的基本原理和应用。
进步`于辰
34 1

热门文章

最新文章

  • 1
    构建云上安全共同体 | 阿里云亮相2024年（第十三届）电信和互联网行业网络安全年会
  • 2
    针对MaxCompute经典网络域名下线，Dataphin应对策略的公告
  • 3
    网络诊断必备：Ping、Traceroute、Wireshark的实用技巧详解
  • 4
    猫狗宠物识别系统Python+TensorFlow+人工智能+深度学习+卷积网络算法
  • 5
    深入解析图神经网络：Graph Transformer的算法基础与工程实践
  • 6
    【宠物识别系统】Python+卷积神经网络算法+深度学习+人工智能+TensorFlow+图像识别
  • 7
    网络诊断指南：网络故障排查步骤与技巧
  • 8
    《docker高级篇（大厂进阶）：4.Docker网络》包括：是什么、常用基本命令、能干嘛、网络模式、docker平台架构图解
  • 9
    基于改进遗传优化的BP神经网络金融序列预测算法matlab仿真
  • 10
    阿里云DTS踩坑经验分享系列｜使用VPC数据通道解决网络冲突问题
  • 1
    Linux网络编程 网络基础知识
    75
  • 2
    网络编程知识点总结（7）
    55
  • 3
    网络编程知识点总结（6）
    54
  • 4
    网络编程知识点总结（5）
    53
  • 5
    网络编程知识点总结（4）
    47
  • 6
    网络编程知识点总结（3）
    54
  • 7
    网络编程知识点总结（2）
    50
  • 8
    网络编程知识点总结(1)
    48
  • 9
    【Java网络编程】网络编程概述、UDP通信（DatagramPacket 与 DatagramSocket）
    87
  • 10
    【网络编程】理解客户端和服务器并使用Java提供的api实现回显服务器
    57

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 容器的网络入门
  • 容器的自定义网络
  • 容器的共享网络模型
    • 下一篇
    手把手教你白嫖阿里云服务器(免费领服务器)