java实现网络编程之 UDP多线程在线聊天（超详细）

这个涉及到多线程
发送端：

package chat;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;

public class TalkSend implements Runnable{

DatagramSocket socket = null;
BufferedReader reader = null;

private int fromPort;
private String toIp;
private int toPort;


public TalkSend(int fromPort, String toIp, int toPort) {
    this.fromPort = fromPort;
    this.toIp = toIp;
    this.toPort = toPort;
    try {
        socket = new DatagramSocket(fromPort);
        reader = new BufferedReader(new InputStreamReader(System.in));
    } catch (Exception e) {
        e.printStackTrace();
    }
}
@Override
public void run() {
    while(true) {
        String data = null;
        try {
            data = reader.readLine();
            byte[] datas = data.getBytes();
            DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress(this.toIp, this.toPort));
            socket.send(packet);

            if(data.equals("bye")) {
                break;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    socket.close();
}

}

接收端：

package chat;

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

public class TalkReceive implements Runnable {
DatagramSocket socket = null;
private String msgFrom;
private int port;

public TalkReceive(int port, String msgFrom) {
    this.port = port;
    this.msgFrom = msgFrom;
    try {
        socket = new DatagramSocket(port);
    } catch (SocketException e) {
        e.printStackTrace();
    }
}

@Override
public void run() {
    try {
        while(true) {
            //准备接收包裹
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container, 0, container.length);
            socket.receive(packet); //阻塞式接收包裹

            //断开连接
            byte[] data = packet.getData();
            String receiveData = new String(data, 0, data.length);
            System.out.println(msgFrom + ":" + receiveData);
            if(receiveData.equals("bye")) {
                break;
            }
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
    socket.close();
}

}

测试代码：
学生端：

package chat;

public class TalkStudent {
public static void main(String[] args) {
//开启两个线程
new Thread(new TalkSend(7777, “localhost”, 9999)).start();
new Thread(new TalkReceive(8888, “老师”)).start();
}
}

老师端：

package chat;

public class TalkTeacher {
public static void main(String[] args) {
new Thread(new TalkSend(555, “localhost”, 8888)).start();
new Thread(new TalkReceive(9999, “学生”)).start();
}
}

测试结果：

————————————————
版权声明：本文为CSDN博主「太阳石笑笑」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/weixin_45806131/article/details/109089984