TCP可以實(shí)現(xiàn)聊天，UDP也可以實(shí)現(xiàn)消息發(fā)送及聊天。不同的是，TCP需要有服務(wù)端和客戶端的連接，但UDP不需要，只需要有發(fā)送方和接收方即可。

一、實(shí)現(xiàn)消息發(fā)送

發(fā)送方：

1. package com.kuang.lesson03;
2.  
3. import java.net.DatagramPacket;
4. import java.net.DatagramSocket;
5. import java.net.InetAddress;
6. import java.net.SocketException;
7.  
8. //不需要連接服務(wù)器
9. public class UdpSenderDemo01 {
10. public static void main(String[] args) throws Exception {
11. //1、建議一個Socket
12. DatagramSocket socket = new DatagramSocket();
13.  
14. //2、建立包
15. String msg = "你好啊，服務(wù)器!";
16. InetAddress localhost = InetAddress.getByName("localhost");
17. int port = 9090;
18.  
19. //數(shù)據(jù)、數(shù)據(jù)的長度起始，要發(fā)送給誰
20. DatagramPacket packet = new DatagramPacket(msg.getBytes(),0,msg.getBytes().length,localhost,port);
21.  
22. //3、發(fā)送包
23. socket.send(packet);
24.  
25. //4、關(guān)閉流
26. socket.close();
27. }
28. }

接收方：

1. package com.kuang.lesson03;
2.  
3. import java.net.DatagramPacket;
4. import java.net.DatagramSocket;
5. import java.net.SocketException;
6.  
7. // 不是服務(wù)端，但是還是要等待客戶端的連接。
8. // 也就是說只有存在這個才能獲得客戶端發(fā)來的消息
9. public class UdpReceiveDemo01 {
10. public static void main(String[] args) throws Exception {
11. //開放端口
12. DatagramSocket socket = new DatagramSocket(9090);
13.  
14. //接收數(shù)據(jù)包
15. byte[] buffer = new byte[1024];
16. DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length);
17.  
18. socket.receive(packet);//阻塞接收
19.  
20. System.out.println(packet.getAddress().getHostAddress());
21. System.out.println(new String(packet.getData(),0,packet.getLength()));
22.  
23. //關(guān)閉連接
24. socket.close();
25. }
26. }

運(yùn)行結(jié)果：

1、啟動接收方開放端口，可以看到一直在運(yùn)行，也就是在等待消息發(fā)來。

2、啟動發(fā)送方，可以看到運(yùn)行結(jié)束，說明消息已發(fā)送

3、查看接收方，收到消息。

既然UDP能實(shí)現(xiàn)消息發(fā)送，那么也可以實(shí)現(xiàn)聊天。

二、實(shí)現(xiàn)聊天

發(fā)送方：

1. package com.kuang.chat;
2.  
3. import java.io.BufferedReader;
4. import java.io.InputStreamReader;
5. import java.net.DatagramPacket;
6. import java.net.DatagramSocket;
7. import java.net.InetSocketAddress;
8. import java.net.SocketException;
9.  
10. public class UdpSenderDemo01 {
11. public static void main(String[] args) throws Exception {
12. DatagramSocket socket = new DatagramSocket(8888);
13.  
14. //準(zhǔn)備數(shù)據(jù)，控制臺讀取System.in
15. BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
16. while (true) {
17. String data = reader.readLine();
18. byte[] datas = data.getBytes();
19. DatagramPacket packet = new DatagramPacket(datas,0,datas.length,new InetSocketAddress("localhost",6666));
20.  
21. socket.send(packet);
22. if (data.equals("bye")) {
23. break;
24. }
25. }
26. socket.close();
27. }
28. }

接收方：

1. package com.kuang.chat;
2.  
3. import java.net.DatagramPacket;
4. import java.net.DatagramSocket;
5. import java.net.SocketException;
6.  
7. public class UdpReceiveDemo01 {
8. public static void main(String[] args) throws Exception {
9. DatagramSocket socket = new DatagramSocket(6666);
10. while (true) {
11. //準(zhǔn)備接收數(shù)據(jù)
12. byte[] container = new byte[1024];
13. DatagramPacket packet = new DatagramPacket(container,0,container.length);
14. socket.receive(packet);//阻塞式接受包裹
15.  
16. //斷開連接 bye
17. byte[] data = packet.getData();
18. String receiveData = new String(data,0,data.length);
19.  
20. System.out.println(receiveData);
21. if (receiveData.equals("bye")) {
22. break;
23. }
24. }
25. socket.close();
26. }
27. }

運(yùn)行結(jié)果：

1、先啟動接收方

2、啟動發(fā)送方

3、在發(fā)送方控制臺輸入信息并回車

4、查看接收方，可以看到信息

這里只實(shí)現(xiàn)了單方面的發(fā)送，單方面的接收，要實(shí)現(xiàn)雙方的聊天

請看：【Java】網(wǎng)絡(luò)編程UDP 實(shí)現(xiàn)多線程在線聊天

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持我們。

原文鏈接：https://blog.csdn.net/weixin_44668898/article/details/107313821