Java网络编程UDP实现消息发送及聊天

TCP可以实现聊天，UDP也可以实现消息发送及聊天。不同的是，TCP需要有服务端和客户端的连接，但UDP不需要，只需要有发送方和接收方即可。

一、实现消息发送

发送方：

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. //不需要连接服务器
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 = "你好啊，服务器!";
16. InetAddress localhost = InetAddress.getByName("localhost");
17. int port = 9090;
18.  
19. //数据、数据的长度起始，要发送给谁
20. DatagramPacket packet = new DatagramPacket(msg.getBytes(),0,msg.getBytes().length,localhost,port);
21.  
22. //3、发送包
23. socket.send(packet);
24.  
25. //4、关闭流
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. // 不是服务端，但是还是要等待客户端的连接。
8. // 也就是说只有存在这个才能获得客户端发来的消息
9. public class UdpReceiveDemo01 {
10. public static void main(String[] args) throws Exception {
11. //开放端口
12. DatagramSocket socket = new DatagramSocket(9090);
13.  
14. //接收数据包
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. //关闭连接
24. socket.close();
25. }
26. }

运行结果：

1、启动接收方开放端口，可以看到一直在运行，也就是在等待消息发来。

2、启动发送方，可以看到运行结束，说明消息已发送

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

既然UDP能实现消息发送，那么也可以实现聊天。

二、实现聊天

发送方：

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. //准备数据，控制台读取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. //准备接收数据
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. }

运行结果：

1、先启动接收方

2、启动发送方

3、在发送方控制台输入信息并回车

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

这里只实现了单方面的发送，单方面的接收，要实现双方的聊天

请看：【Java】网络编程UDP 实现多线程在线聊天

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

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