我們已經了解了UDP的協議，那么現在我們就簡單的做一個UDP的聊天室

我們定義一個?UDPChatDemo類，里面有主方法，還定義一個發送端的線程類SendThread，為了記錄名字，所以用繼承方式，一個接收端的線程類Receive，主線程啟動1個接收端，2個發送端。

package com.wangLuo;import java.io.*; import java.net.*; import java.util.Date;/*** @author 林高祿* @create 2020-05-21-17:32*/ public class UDPChatDemo{public static void main(String[] args) {Receive receive = new Receive();Thread thread = new Thread(receive);thread.setPriority(10);thread.start();createSent("林高祿");createSent("徐輝強");}public static void createSent(String name){SendThread sendThread = new SendThread(name);sendThread.start();} }class SendThread extends Thread{public SendThread(String name) {super(name);}@Overridepublic void run() {try {send();} catch (IOException e) {e.printStackTrace();}}private void send() throws IOException {DatagramSocket ds = new DatagramSocket();BufferedReader br = new BufferedReader(new InputStreamReader(System.in));String line;while((line = br.readLine())!= null){String newLine = Thread.currentThread().getName()+"--"+new Date().toString()+"\n\r"+line;byte[] bytes = newLine.getBytes();DatagramPacket dp = new DatagramPacket(bytes,bytes.length, InetAddress.getByName("192.168.1.55"),10);ds.send(dp);if("6了".equals(line)){break;}}ds.close();}}class Receive implements Runnable{@Overridepublic void run() {try {receive();} catch (IOException e) {e.printStackTrace();}}private void receive() throws IOException {DatagramSocket ds = new DatagramSocket(10);while(true){byte[] bys = new byte[1024];DatagramPacket dp = new DatagramPacket(bys,bys.length);ds.receive(dp);byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data,0,length));}} }

?聊天記錄：

?

灰色的字是鍵盤輸入的，白色的字是接收端輸出的，這個聊天記錄有點亂，還有空行什么的，是因為我們是用多線程來做，鍵盤輸入的時候線程時隨機的，并且輸入完畢的時候，不一定到接收線程接收，有可能是另一個客戶端線程，所以會出現這種情況，如果想改進，那就得把客戶端單獨拿出來另一個主方法，我們修改一下

接收端代碼

package com.wangLuo;import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket;/*** @author 林高祿* @create 2020-05-22-17:18*/ public class Receive {public static void main(String[] args) throws IOException {Receive receive = new Receive();receive.receive();}private void receive() throws IOException {DatagramSocket ds = new DatagramSocket(10);while(true){byte[] bys = new byte[1024];DatagramPacket dp = new DatagramPacket(bys,bys.length);ds.receive(dp);byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data,0,length));}} }

客戶端（發送端）代碼

package com.wangLuo;import java.io.*; import java.net.*; import java.util.Date;/*** @author 林高祿* @create 2020-05-22-16:56*/ public class Send {private String name;public Send(String name) {this.name = name;}public static void main(String[] args) throws IOException {Send send = new Send("林高祿");send.send();}private void send() throws IOException {DatagramSocket ds = new DatagramSocket();BufferedReader br = new BufferedReader(new InputStreamReader(System.in));String line;while((line = br.readLine())!= null){String newLine = this.getName()+"--"+new Date().toString()+"\n\r"+line;byte[] bytes = newLine.getBytes();DatagramPacket dp = new DatagramPacket(bytes,bytes.length, InetAddress.getByName("192.168.1.55"),10);ds.send(dp);if("6了".equals(line)){break;}}ds.close();}public String getName() {return name;}public void setName(String name) {this.name = name;} }

啟動接收端，啟動客戶端，然后把客戶端的名字改一下，再啟動一次客戶端，此時一共啟動了2個客戶端

package com.wangLuo;import java.io.*; import java.net.*; import java.util.Date;/*** @author 林高祿* @create 2020-05-22-16:56*/ public class Send {private String name;public Send(String name) {this.name = name;}public static void main(String[] args) throws IOException {Send send = new Send("徐輝強");send.send();}private void send() throws IOException {DatagramSocket ds = new DatagramSocket();BufferedReader br = new BufferedReader(new InputStreamReader(System.in));String line;while((line = br.readLine())!= null){String newLine = this.getName()+"--"+new Date().toString()+"\n\r"+line;byte[] bytes = newLine.getBytes();DatagramPacket dp = new DatagramPacket(bytes,bytes.length, InetAddress.getByName("192.168.1.55"),10);ds.send(dp);if("6了".equals(line)){break;}}ds.close();}public String getName() {return name;}public void setName(String name) {this.name = name;} }

那么就進入連天了，以下是聊天記錄

客戶端的記錄：

?

接收端的聊天記錄：

?

?

?

?

總結

以上是生活随笔為你收集整理的UDP聊天室（代码）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。