本文共 3206 字，大约阅读时间需要 10 分钟。

在线咨询：两个人都可以是发送方，也都可以是接收方

一个线程发送，一个线程接收，同时开启两个线程 在线聊天

发送信息客户端:

package com.li.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 {
       //发送到另一个服务端口,需要IP和端口号    //接收服务端发的信息，需要自身的端口号    private String toIP;//服务端的IP    private int toPort;//服务端的端口    private int sendPort;//自身发送端口    DatagramSocket socket = null;    public TalkSend(String toIP, int toPort, int sendPort) throws Exception {
           this.toIP = toIP;        this.toPort = toPort;        this.sendPort = sendPort;        socket = new DatagramSocket(sendPort);    }    @Override    public void run() {
           //循环发送信息        while (true) {
               //建立连接            try {
                   //读取数据，建包                BufferedReader bd = new BufferedReader(new InputStreamReader(System.in));                String data = bd.readLine();                DatagramPacket packet = new DatagramPacket(data.getBytes(), 0, data.getBytes().length, new InetSocketAddress(toIP, toPort));                //发包                socket.send(packet);                if (data.equals("bye")) {
                       break;                }            } catch (Exception e) {
                   e.printStackTrace();            }        }    }}

接收信息服务端：

package com.li.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 int receivePort;//自身接收端口    private String msgForm;//信息来源    public TalkReceive(int receivePort, String msgForm) {
           this.receivePort = receivePort;        this.msgForm = msgForm;    }    @Override    public void run() {
           //开放端口        try {
               socket = new DatagramSocket(receivePort);        } catch (SocketException e) {
               e.printStackTrace();        }        //准备接收包        while (true) {
               byte[] container = new byte[1024];            DatagramPacket packet = new DatagramPacket(container,0,container.length);            //阻塞式接收包            try {
                   socket.receive(packet);            } catch (IOException e) {
                   e.printStackTrace();            }            byte[] data = packet.getData();            String receiveData = new String(data, 0, packet.getLength());            System.out.println(msgForm + ":" + receiveData);        }    }}

老师线程开启：

package com.li.chat;public class TalkTeacher {
       public static void main(String[] args) throws Exception {
           //老师6666端口发送到学生8888端扣，同时9999接收学生的，(老师发送时的端口可以不确定，但接收的端口要确定)        new Thread(new TalkSend("localhost",8888,6666)).start();        new Thread(new TalkReceive(9999,"学生")).start();    }}

学生线程开启：

package com.li.chat;public class TalkStudent {
       public static void main(String[] args) throws Exception {
           //学生7777端口发送到老师9999端口，同时8888接收老师的信息(老师发送时的端口可以不确定，但接收的端口要确定)        new Thread(new TalkReceive(8888,"老师")).start();        new Thread(new TalkSend("localhost",9999,7777)).start();    }}

转载地址：https://blog.csdn.net/l1341886243/article/details/118460146 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！