发送端：

1. import java.io.BufferedReader;
   
2. import java.io.IOException;
   
3. import java.io.InputStreamReader;
   
4. import java.io.Reader;
   
5. import java.net.DatagramPacket;
   
6. import java.net.DatagramSocket;
   
7. import java.net.InetAddress;
   
8. 
   
9. /*
   
10. * 发送端程序：用于发送信息
    
11. */
    
12. public class SendMessage implements Runnable {
    
13.         /*
    
14.          * 发送端成员变量： socket对象 目的地ip地址 通信端口号
    
15.          */
    
16.         private DatagramSocket socket;
    
17.         private InetAddress ip;
    
18.         private int port;
    
19. 
    
20.         public SendMessage(DatagramSocket socket, InetAddress ip, int port) {
    
21.                 super();
    
22.                 this.socket = socket;
    
23.                 this.ip = ip;
    
24.                 this.port = port;
    
25.         }
    
26. 
    
27.         @Override
    
28.         public void run() {
    
29.                 // 缓冲输入流用于读取用户输入
    
30.                 Reader in = new InputStreamReader(System.in);
    
31.                 BufferedReader reader = new BufferedReader(in);
    
32.                 while (true) {
    
33.                         try {
    
34.                                 // 读取用户输入，并打包数据
    
35.                                 String line = reader.readLine();
    
36.                                 int length = line.getBytes().length;
    
37.                                 DatagramPacket dp = new DatagramPacket(line.getBytes(), length, ip, port);
    
38.                                 // 发送数据报包
    
39.                                 socket.send(dp);
    
40.                                 // 如果输入886，结束循环
    
41.                                 if("886".equals(line)){
    
42.                                         break;
    
43.                                 }
    
44.                                
    
45.                         } catch (IOException e) {
    
46.                                 e.printStackTrace();
    
47.                         }
    
48.                 }
    
49.                 // 关闭资源
    
50.                 try {
    
51.                         reader.close();
    
52.                         socket.close();
    
53.                 } catch (IOException e) {
    
54.                         e.printStackTrace();
    
55.                 }
    
56.         }
    
57. 
    
58. }

复制代码

接收端：

1. import java.io.IOException;
   
2. import java.net.DatagramPacket;
   
3. import java.net.DatagramSocket;
   
4. 
   
5. /*
   
6. * 接收端程序：用于接收信息
   
7. */
   
8. public class ReceiveMessage implements Runnable {
   
9.         /*
   
10.          * 接收端成员变量： 接收端socket对象
    
11.          */
    
12.         private DatagramSocket socket;
    
13. 
    
14.         public ReceiveMessage(DatagramSocket socket) {
    
15.                 super();
    
16.                 this.socket = socket;
    
17.         }
    
18. 
    
19.         @Override
    
20.         public void run() {
    
21.                 while (true) {
    
22.                         // 接收数据并打印到控制台
    
23.                         DatagramPacket dp = new DatagramPacket(new byte[1024], 0, 1024);
    
24.                         try {
    
25.                                 socket.receive(dp);
    
26.                         } catch (IOException e) {
    
27.                                 e.printStackTrace();
    
28.                         }
    
29.                         String data = new String(dp.getData(), 0, dp.getLength());
    
30.                         System.out.println(dp.getAddress().getHostName() + "-" + dp.getPort() + " : " + data);
    
31.                        
    
32.                 }
    
33.         }
    
34. 
    
35. }

复制代码

客户端1：

1. import java.io.IOException;
   
2. import java.net.DatagramSocket;
   
3. import java.net.InetAddress;
   
4. 
   
5. public class Client1 {
   
6.         public static void main(String[] args) throws IOException {
   
7.                 SendMessage sm = new SendMessage(new DatagramSocket(), InetAddress.getByName("kaven-PC"), 10010);
   
8.                 ReceiveMessage rm = new ReceiveMessage(new DatagramSocket(10011));
   
9.                
   
10.                 Thread t1 = new Thread(sm);
    
11.                 Thread t2 = new Thread(rm);
    
12.                
    
13.                 t1.start();
    
14.                 t2.start();
    
15.         }
    
16. }
    

复制代码

客户端2：

1. import java.io.IOException;
   
2. import java.net.DatagramSocket;
   
3. import java.net.InetAddress;
   
4. 
   
5. public class Client1 {
   
6.         public static void main(String[] args) throws IOException {
   
7.                 SendMessage sm = new SendMessage(new DatagramSocket(), InetAddress.getByName("kaven-PC"), 10010);
   
8.                 ReceiveMessage rm = new ReceiveMessage(new DatagramSocket(10011));
   
9.                
   
10.                 Thread t1 = new Thread(sm);
    
11.                 Thread t2 = new Thread(rm);
    
12.                
    
13.                 t1.start();
    
14.                 t2.start();
    
15.         }
    
16. }
    

复制代码

运行结果：

自己跟自己说话呢？

这个年代 自娱自乐也需要技术

不错不错要是我会建立个图形化界面有有趣很多呵呵

℃葫芦 发表于 2015-8-17 16:57
自己跟自己说话呢？

。。。。。。。