多线程实现双人聊天

ゝ一纸荒年。 2023-10-11 14:57 39阅读 0赞

这个demo模拟了老师和学生的对话聊天功能。使用网络编程和多线程方式实现。

*  实现模拟老师和学生聊天的关键点就是 学生端既可以是发送方，也可以是接收方
 *  老师端同样既可以是发送方，也可以是接收方
 *  这样的话学生端需要同时开启接收和发送程序，老师端也要同时开启接收和发送程序
 *  学生端的发送程序端口对应老师端的接收程序端口，老师端的发送程序端口对应学生端的接收程序端口。

**接收方**

public class TalkReceive implements Runnable {
        
        private String sender;
        private DatagramSocket socket = null;
        private int port;
    
        public TalkReceive(int port,String sender) throws SocketException {
        
            this.port = port;
            this.sender = sender;
            //服务器的端口
            socket = new DatagramSocket(port);
        }
    
        public void run() {
        
            while (true) {
        
                    try {
        
                        byte[] container = new byte[1024];
                        DatagramPacket packet = new DatagramPacket(container, 0, container.length);
                        socket.receive(packet);
                        byte[] data = packet.getData();
                        String msg = new String(data, 0, data.length);
                        System.out.println(this.sender + "对你说: " + msg);
                        if (msg.equals("bye")){
        
                            socket.close();
                            break;
                        }
                    }catch (Exception e){
        
                        e.printStackTrace();
                    }
            }
    
        }
    }

**发送方**

public class TalkSend implements Runnable {
        
    
        private DatagramSocket socket = null;
    
        private BufferedReader reader = null;
    
        private int sendPort; //发送端口
    
        private String ip;//发送到的ip
    
        private int fromPort;//接收方端口
    
        public TalkSend(int sendPort, String ip, int fromPort) throws SocketException {
        
            this.sendPort = sendPort;
            this.ip = ip;
            this.fromPort = fromPort;
            this.socket = new DatagramSocket(fromPort);
            this.reader = new BufferedReader(new InputStreamReader(System.in));
    
        }
    
        public void run() {
        
            while (true) {
        
                try {
        
                    String data = reader.readLine();
                    byte[] bytes = data.getBytes();
                    DatagramPacket packet = new DatagramPacket(bytes, 0, bytes.length, new InetSocketAddress(this.ip, this.sendPort));
                    socket.send(packet);
                    if ("bye".equals(data)) {
        
                        break;
                    }
    
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
            }
            socket.close();
    
        }
    }

**注意：**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUwNjU2_size_16_color_FFFFFF_t_70_pic_center]

**查看控制台**

![在这里插入图片描述][20201104104521592.png_pic_center]  
![在这里插入图片描述][20201104104528589.png_pic_center]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUwNjU2_size_16_color_FFFFFF_t_70_pic_center]: https://img-blog.csdnimg.cn/2020110410440487.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUwNjU2,size_16,color_FFFFFF,t_70#pic_center
[20201104104521592.png_pic_center]: https://img-blog.csdnimg.cn/20201104104521592.png#pic_center
[20201104104528589.png_pic_center]: https://img-blog.csdnimg.cn/20201104104528589.png#pic_center