java网络通信(三):TCP通信、实现客户端-服务端消息通信

发布于:2024-12-06 ⋅ 阅读:(30) ⋅ 点赞:(0)

目录

1、什么是 TCP协议?

2、代码实现TCP协议的一发一收

2.1、客户端

2.2、服务端

2.3 结果演示

3、代码实现TCP协议的多发多收

3.1 客户端

3.2 服务端

3.3 结果演示


简介:本文章主要是演示如何用java代码以及TCP协议实现网络通信,实现客户端给服务端发送消息,服务端接收消息的功能。以及用代码演示如何手动输入消息并发送给服务端(类似聊天软件)。

不了解通信的同学可以先看看我上一篇发的文章,很详细

java网络通信(一):BS架构、CS架构、IP地址、端口号、协议、域名等基础概念,以及代码演示-CSDN博客

1、什么是 TCP协议?

面向连接、可靠通信

三次握手:建立可靠的连接,相当于客户端和服务器生成了一条端对端的管道、可以互相通信。

传输数据时会进行确认,例如客户端发信息给服务端,服务端收到消息后会进行确认,表示已经收到信息。若没有确认,则说明消息服务端并没有收到,则需要客户端再次发送,以此来保证数据传输的可靠性。

四次挥手:在断开连接的时候保证彼此的信息都收发完毕

2、代码实现TCP协议的一发一收

我们的TCP协议实现网络通信中,是端到端的,相当于两个端点形成了一条管道,相互传输数据,十分安全。

2.1、客户端

注意看注释

public class TCP_OneToOne_Clint {
    public static void main(String[] args) throws Exception {
        //1、创建Socket对象,并同时请求于服务端程序的连接
        Socket socket = new Socket("127.0.0.1",8888);

        //2、从socket得到一个字节输出流,用来发送数据给服务端
        OutputStream outputStream = socket.getOutputStream();

        //3、把低级的字节输出流包装成数据输出流
        DataOutputStream dataOutputStream = new DataOutputStream(outputStream);

        //4、开始写数据出去
        dataOutputStream.writeUTF("你好,我是TCP协议客户端发来的消息!");
        System.out.println("我是客户端,已发送消息");
        dataOutputStream.close();

        //5、关闭资源
        socket.close();;
    }
}

2.2、服务端

服务端:serverSocket等待客户端的链接请求,以便建立于客户端的通信管道

accept一但链接成功,就会形成一个可靠的连接通信管道。同时也会返回服务端的socket对象,这样服务端就可以拿到这个socket对象和客户端进行通信了

客户端程序执行到accept的时候,在等待客户端发送请求,一但接收到客户端的请求,就连接成功生成通信管道,且是端到端的,

流的格式一定是客户端和服务端一一对应,通信是非常严格的,否则会出问题。(比如客户端用的是数据流发消息,那么服务端就一定要用数据流读消息)

解释:客户端newSocket的时候,服务端的accept方法就会连接上

public class TCP_OneToOne_Server {

    public static void main(String[] args) throws Exception {
        System.out.println("服务端启动,等待客户端发送消息");
        //1、创建ServerSocket的对象,同时为服务端注册端口
        ServerSocket serverSocket = new ServerSocket(8888);

        //2、使用ServerSocket对象,调用一个accept方法,等待客户端的连接请求
        Socket socket = serverSocket.accept();

        //3、从通信管道中得到一个字节输入流
        InputStream inputStream = socket.getInputStream();

        //4、使用数据输入流包装成输入流(注意必须和客户端的一致)
        DataInputStream dataInputStream = new DataInputStream(inputStream);


          //5、使用数据输入流读取客户端发来的消息
        //当客户端消息还没发来,就会在这一步进行等待(如果客户端先发送信息来,服务端还没读取,没关系,客户端会先把消息缓存起来的
        // 因为是TCP可靠通信,是一定会保证消息被读取的)
        System.out.println(dataInputStream.readUTF());

        //获取客户端的IP地址
        System.out.println(socket.getRemoteSocketAddress());

        //6、关闭资源
        dataInputStream.close();
        socket.close();
    }
}

2.3 结果演示

第一步启动服务端

在客户端还没启动之前,服务端一直在等待客户端的消息

第二步启动客户端:

可以看到客户端将消息发送出去了

再回到服务端看日,可以看到服务端接收到了客户端的消息!

3、代码实现TCP协议的多发多收

3.1 客户端

public class TCP_Many_Clint {

    public static void main(String[] args) throws Exception {
        //1、创建Socket对象,并同时请求于服务端程序的连接
        Socket socket = new Socket("127.0.0.1",8888);

        //2、从socket得到一个字节输出流,用来发送数据给服务端
        OutputStream outputStream = socket.getOutputStream();

        //3、把低级的字节输出流包装成数据输出流
        DataOutputStream dataOutputStream = new DataOutputStream(outputStream);

        Scanner scanner = new Scanner(System.in);
        while (true){
            System.out.println("请说:");
            String msg = scanner.nextLine();
            if ("exit".equals(msg)){
                System.out.println("客户端下线!");
                dataOutputStream.close();
                //5、关闭资源
                socket.close();;
                break;
            }
            dataOutputStream.writeUTF(msg);
            System.out.println("我是客户端,已给服务端发送消息");
        }
    }
}

3.2 服务端

当客户端exit了,服务端就会报错,因为read不到数据了,所以我们可以加一个捕获异常,当读取信息报错时,说明客户端离线了

public class TCP_Many_Server {

    public static void main(String[] args) throws Exception {
        System.out.println("服务端启动,等待客户端发送消息");
        //1、创建ServerSocket的对象,同时为服务端注册端口
        ServerSocket serverSocket = new ServerSocket(8888);

        //2、使用ServerSocket对象,调用一个accept方法,等待客户端的连接请求
        Socket socket = serverSocket.accept();

        //3、从通信管道中得到一个字节输入流
        InputStream inputStream = socket.getInputStream();

        //4、使用数据输入流包装成输入流(注意必须和客户端的一致)
        DataInputStream dataInputStream = new DataInputStream(inputStream);


        while (true){
            try {
                System.out.println(dataInputStream.readUTF());
                System.out.println(socket.getRemoteSocketAddress());
            }catch (Exception e){
                //6、关闭资源
                System.out.println(socket.getRemoteSocketAddress() + "客户端下线!");
                dataInputStream.close();
                socket.close();
                break;
            }
        }
    }
}

3.3 结果演示

第一步启动服务端

在客户端还没启动之前,服务端一直在等待客户端的消息

第二步启动客户端:

输入想要发送的消息。按回车

在服务端就可以看到我们手动在客户端命令行输入的消息了

这就是我对javaTCP通信相关的理解,希望能帮到大家,有问题的地方欢迎大家一起讨论!

后续会不断更新作品,欢迎大家一起讨论学习。❤❤❤


网站公告

今日签到

点亮在社区的每一天
去签到