一个通过UDP协议传输键盘输入数据的案例代码
发送端代码

1. import java.io.BufferedReader;
   
2. import java.io.IOException;
   
3. import java.io.InputStreamReader;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. 
   
8. public class SendMessage implements Runnable {
   
9.         private DatagramSocket socket;
   
10. 
    
11.         public SendMessage(DatagramSocket socket) {
    
12.                 super();
    
13.                 this.socket = socket;
    
14.         }
    
15. 
    
16.         @Override
    
17.         public void run() {
    
18.                 // 不停获取用户的输入
    
19.                 while (true) {
    
20.                         BufferedReader br = new BufferedReader(new InputStreamReader(
    
21.                                         System.in));
    
22.                         try {
    
23.                                 // 读取数据
    
24.                                 String message = br.readLine();
    
25.                                 // 打包数据
    
26.                                 DatagramPacket dp = new DatagramPacket(message.getBytes(),
    
27.                                                 message.getBytes().length,
    
28.                                                 InetAddress.getByName("kaven-PC"), 10086);
    
29.                                 // 发送数据
    
30.                                 socket.send(dp);
    
31.                                 // 判断是否结束发送
    
32.                                 if ("bye".equals(message)) {
    
33.                                         break;
    
34.                                 }
    
35.                         } catch (IOException e) {
    
36.                                 e.printStackTrace();
    
37.                         }
    
38.                 }
    
39.                 socket.close();
    
40.         }
    
41. 
    
42. }
    

复制代码

接收端代码

1. import java.io.IOException;
   
2. import java.net.DatagramPacket;
   
3. import java.net.DatagramSocket;
   
4. 
   
5. public class ReceiveMessage implements Runnable {
   
6.         private DatagramSocket socket;
   
7. 
   
8.         public ReceiveMessage(DatagramSocket socket) {
   
9.                 super();
   
10.                 this.socket = socket;
    
11.         }
    
12. 
    
13.         @Override
    
14.         public void run() {
    
15.                 // 循环接收数据
    
16.                 while (true) {
    
17.                         DatagramPacket dp = new DatagramPacket(new byte[1024], 0, 1024);
    
18.                         try {
    
19.                                 socket.receive(dp);
    
20.                                 System.out.println(dp.getAddress().getHostName() + ":"
    
21.                                                 + new String(dp.getData()));
    
22.                         } catch (IOException e) {
    
23.                                 e.printStackTrace();
    
24.                         }
    
25.                 }
    
26. }
    
27. 
    
28. }
    

复制代码

测试类

1. import java.io.IOException;
   
2. import java.net.DatagramSocket;
   
3. 
   
4. public class ChatDemo {
   
5.         public static void main(String[] args) throws IOException {
   
6.                 //创建两个socket服务对象：一个用于发送数据，一个用于接收数据
   
7.                 DatagramSocket sendSocket = new DatagramSocket();
   
8.                 DatagramSocket receiveSocket = new DatagramSocket(10086);
   
9.                 //创建发送端对象和接收端对象
   
10.                 SendMessage send = new SendMessage(sendSocket);
    
11.                 ReceiveMessage receive = new ReceiveMessage(receiveSocket);
    
12.                 //创建两个线程用于发送和接收数据
    
13.                 Thread sendThread = new Thread(send, "send");
    
14.                 Thread receiveThread = new Thread(receive, "receive");
    
15.                 //启动线程
    
16.                 sendThread.start();
    
17.                 receiveThread.start();
    
18.         }
    
19. }

复制代码

一个通过UDP协议传输键盘输入数据的案例代码
发送端代码

1. import java.io.BufferedReader;
   
2. import java.io.IOException;
   
3. import java.io.InputStreamReader;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. 
   
8. public class SendMessage implements Runnable {
   
9.         private DatagramSocket socket;
   
10. 
    
11.         public SendMessage(DatagramSocket socket) {
    
12.                 super();
    
13.                 this.socket = socket;
    
14.         }
    
15. 
    
16.         @Override
    
17.         public void run() {
    
18.                 // 不停获取用户的输入
    
19.                 while (true) {
    
20.                         BufferedReader br = new BufferedReader(new InputStreamReader(
    
21.                                         System.in));
    
22.                         try {
    
23.                                 // 读取数据
    
24.                                 String message = br.readLine();
    
25.                                 // 打包数据
    
26.                                 DatagramPacket dp = new DatagramPacket(message.getBytes(),
    
27.                                                 message.getBytes().length,
    
28.                                                 InetAddress.getByName("kaven-PC"), 10086);
    
29.                                 // 发送数据
    
30.                                 socket.send(dp);
    
31.                                 // 判断是否结束发送
    
32.                                 if ("bye".equals(message)) {
    
33.                                         break;
    
34.                                 }
    
35.                         } catch (IOException e) {
    
36.                                 e.printStackTrace();
    
37.                         }
    
38.                 }
    
39.                 socket.close();
    
40.         }
    
41. 
    
42. }
    

复制代码

接收端代码

1. import java.io.IOException;
   
2. import java.net.DatagramPacket;
   
3. import java.net.DatagramSocket;
   
4. 
   
5. public class ReceiveMessage implements Runnable {
   
6.         private DatagramSocket socket;
   
7. 
   
8.         public ReceiveMessage(DatagramSocket socket) {
   
9.                 super();
   
10.                 this.socket = socket;
    
11.         }
    
12. 
    
13.         @Override
    
14.         public void run() {
    
15.                 // 循环接收数据
    
16.                 while (true) {
    
17.                         DatagramPacket dp = new DatagramPacket(new byte[1024], 0, 1024);
    
18.                         try {
    
19.                                 socket.receive(dp);
    
20.                                 System.out.println(dp.getAddress().getHostName() + ":"
    
21.                                                 + new String(dp.getData()));
    
22.                         } catch (IOException e) {
    
23.                                 e.printStackTrace();
    
24.                         }
    
25.                 }
    
26. }
    
27. 
    
28. }
    

复制代码

测试类

1. import java.io.IOException;
   
2. import java.net.DatagramSocket;
   
3. 
   
4. public class ChatDemo {
   
5.         public static void main(String[] args) throws IOException {
   
6.                 //创建两个socket服务对象：一个用于发送数据，一个用于接收数据
   
7.                 DatagramSocket sendSocket = new DatagramSocket();
   
8.                 DatagramSocket receiveSocket = new DatagramSocket(10086);
   
9.                 //创建发送端对象和接收端对象
   
10.                 SendMessage send = new SendMessage(sendSocket);
    
11.                 ReceiveMessage receive = new ReceiveMessage(receiveSocket);
    
12.                 //创建两个线程用于发送和接收数据
    
13.                 Thread sendThread = new Thread(send, "send");
    
14.                 Thread receiveThread = new Thread(receive, "receive");
    
15.                 //启动线程
    
16.                 sendThread.start();
    
17.                 receiveThread.start();
    
18.         }
    
19. }

复制代码