毕老师视频中的UDP聊天小程序是将对方的IP地址写死的，我想可不可以在dos命令行下第一行输入对方IP地址，选择聊天对象后开始聊天呢？做了些小改动实现了一个小小的需求。代码经过实践检验，局域网条件下可以在DOS窗口运行该程序实现通过第一行输入对方IP地址进行选择聊天对象聊天。

1. package p2;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.IOException;
   
5. import java.io.InputStreamReader;
   
6. import java.net.DatagramPacket;
   
7. import java.net.DatagramSocket;
   
8. import java.net.InetAddress;
   
9. import java.net.SocketException;
   
10. 
    
11. public class UDP_ChatDemo {
    
12.        
    
13.         public static void main(String[] args) throws SocketException {
    
14.                 DatagramSocket send = new DatagramSocket(7778);
    
15.                 DatagramSocket rece = new DatagramSocket(10004);
    
16.                
    
17.                 new Thread(new Send_1(send)).start();
    
18.                 new Thread(new Rece_1(rece)).start();
    
19. 
    
20.         }
    
21. }
    
22. //创建发送任务
    
23. class Send_1 implements Runnable{
    
24.         //持有UDP套接字
    
25.         private DatagramSocket socket;
    
26.         /**
    
27.          * @param socket
    
28.          */
    
29.         public Send_1(DatagramSocket socket) {
    
30.                 super();
    
31.                 this.socket = socket;
    
32.         }
    
33.         @Override
    
34.         public void run() {
    
35.                 try {
    
36.                         //创建键盘读取流
    
37.                         BufferedReader bfr = new BufferedReader(new InputStreamReader(System.in));
    
38.                         //第一行读取输入的对方ip地址
    
39.                         String ip = bfr.readLine();
    
40.                         //读取聊天数据
    
41.                         String line = null;
    
42.                         while ((line=bfr.readLine())!=null) {
    
43.                                 if("over".equals(line))
    
44.                                         break;
    
45.                                 byte[] buf = line.getBytes();
    
46.                                 //创建数据包对象
    
47.                                 DatagramPacket packet = new DatagramPacket(buf, 0, buf.length,InetAddress.getByName(ip), 10004);
    
48.                                 //发送数据
    
49.                                 socket.send(packet);
    
50.                         }
    
51.                         bfr.close();
    
52.                 } catch (IOException e) {
    
53.                 }
    
54.                
    
55.         }
    
56.        
    
57. }
    
58. //创建接收任务
    
59. class Rece_1 implements Runnable{
    
60.         //持有UDP套接字
    
61.         private DatagramSocket socket;
    
62.         /**
    
63.          * @param socket
    
64.          */
    
65.         public Rece_1(DatagramSocket socket) {
    
66.                 super();
    
67.                 this.socket = socket;
    
68.         }
    
69.         @Override
    
70.         public void run() {
    
71.                 try {
    
72.                         //创建缓冲数组
    
73.                         byte[] buf = new byte[1024];
    
74.                         //创建数据包对象
    
75.                         DatagramPacket packet = new DatagramPacket(buf, buf.length);
    
76.                         while (true) {
    
77.                                 //接收数据包
    
78.                                 socket.receive(packet);
    
79.                                 //获取数据
    
80.                                 byte[] data = packet.getData();
    
81.                                 //控制台输出
    
82.                                 String text = new String(data,0,packet.getLength());
    
83.                                 String ip = packet.getAddress().getHostAddress();
    
84.                                 System.out.println(ip+"::"+text);
    
85.                         }
    
86.                 } catch (IOException e) {
    
87.                 }finally{
    
88.                         socket.close();
    
89.                 }
    
90.                
    
91.         }
    
92.        
    
93. }

复制代码

我就路过看看

乘梦而飞 发表于 2015-4-26 21:29
我就路过看看

いらっしゃい