看看哪里不对，找不出来啊！

1. /*
   
2. 编写一个聊天程序。
   
3. 有收数据的部分，和发数据的部分
   
4. 这两部分需要同时执行，就需要用到多线程技术
   
5. 一个线程控制收 一个线程控制发
   
6. 因为收和发动作是不一致的，所以要定义两个run方法
   
7. 而且这两个方法要封装到不同的类中
   
8. */
   
9. 
   
10. //用键盘录入
    
11. class UdpSend_Thread implements Runnable{
    
12.         private DatagramSocket ds;
    
13.         public UdpSend_Thread(DatagramSocket ds){
    
14.                
    
15.         }
    
16.         public void run(){
    
17.                 try
    
18.                 {
    
19.                                 BufferedReader bufr = new BufferedReader(
    
20.                                         new InputStreamReader(System.in));       
    
21.                                 String line = null;
    
22.                        
    
23.                                 while((line=bufr.readLine())!=null){
    
24.                                                 if("886".equals(line)){
    
25.                                                                 break;
    
26.                                                         }
    
27.                                                 byte[] buf = line.getBytes();
    
28.                                                 DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10003);
    
29.                                                 //通过socket服务，将已有的数据包发送出去，通过send方法
    
30.                                                 ds.send(dp);
    
31.                                 }
    
32.                         }
    
33.                         catch(Exception e)
    
34.                         {
    
35.                                 throw new RuntimeException("发送失败");
    
36.                         }
    
37.                        
    
38.         }
    
39.        
    
40. }
    
41. 
    
42. //接收键盘录入
    
43. class UdpRece_Thread implements Runnable
    
44. {
    
45.         private DatagramSocket ds;
    
46.         public UdpRece_Thread(DatagramSocket ds){
    
47.                
    
48.         }
    
49.        
    
50.         public void run(){
    
51.                 try
    
52.                 {
    
53.                                 while(true){
    
54.                                         //定义数据包，用于存储数据
    
55.                                         byte[] buf = new byte[1024];
    
56.                                         DatagramPacket dp = new DatagramPacket(buf,buf.length);
    
57.                                        
    
58.                                         //通过服务的receive方法将受到的数据存入数据包中
    
59.                                         ds.receive(dp); //阻塞式方法，没数据就等
    
60.                        
    
61.                                         //通过数据包的方法获取其中的数据
    
62.                                         String ip = dp.getAddress().getHostAddress();//获取ip
    
63.                                         String data = new String(dp.getData(),0,dp.getLength());
    
64.                                         int port = dp.getPort();
    
65.                                        
    
66.                                         System.out.println(ip+data+port);
    
67.                                 }
    
68.                 }       
    
69.                 catch(Exception e)
    
70.                 {
    
71.                         throw new RuntimeException("接收失败");
    
72.                 }
    
73.         }
    
74.        
    
75.        
    
76. }
    
77. 
    
78. class LiaoTian{
    
79.        
    
80.         public static void main(String[] args) throws Exception{
    
81.                 DatagramSocket sendSocket = new DatagramSocket();
    
82.                 DatagramSocket receSocket = new DatagramSocket(10003);       
    
83.                
    
84.                 new Thread(new UdpSend_Thread(sendSocket)).start();
    
85.                 new Thread(new UdpRece_Thread(receSocket)).start();
    
86.         }       
    
87. }

复制代码

看看哪里不对，找不出来啊！

1. /*
   
2. 编写一个聊天程序。
   
3. 有收数据的部分，和发数据的部分
   
4. 这两部分需要同时执行，就需要用到多线程技术
   
5. 一个线程控制收 一个线程控制发
   
6. 因为收和发动作是不一致的，所以要定义两个run方法
   
7. 而且这两个方法要封装到不同的类中
   
8. */
   
9. 
   
10. //用键盘录入
    
11. class UdpSend_Thread implements Runnable{
    
12.         private DatagramSocket ds;
    
13.         public UdpSend_Thread(DatagramSocket ds){
    
14.                
    
15.         }
    
16.         public void run(){
    
17.                 try
    
18.                 {
    
19.                                 BufferedReader bufr = new BufferedReader(
    
20.                                         new InputStreamReader(System.in));       
    
21.                                 String line = null;
    
22.                        
    
23.                                 while((line=bufr.readLine())!=null){
    
24.                                                 if("886".equals(line)){
    
25.                                                                 break;
    
26.                                                         }
    
27.                                                 byte[] buf = line.getBytes();
    
28.                                                 DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10003);
    
29.                                                 //通过socket服务，将已有的数据包发送出去，通过send方法
    
30.                                                 ds.send(dp);
    
31.                                 }
    
32.                         }
    
33.                         catch(Exception e)
    
34.                         {
    
35.                                 throw new RuntimeException("发送失败");
    
36.                         }
    
37.                        
    
38.         }
    
39.        
    
40. }
    
41. 
    
42. //接收键盘录入
    
43. class UdpRece_Thread implements Runnable
    
44. {
    
45.         private DatagramSocket ds;
    
46.         public UdpRece_Thread(DatagramSocket ds){
    
47.                
    
48.         }
    
49.        
    
50.         public void run(){
    
51.                 try
    
52.                 {
    
53.                                 while(true){
    
54.                                         //定义数据包，用于存储数据
    
55.                                         byte[] buf = new byte[1024];
    
56.                                         DatagramPacket dp = new DatagramPacket(buf,buf.length);
    
57.                                        
    
58.                                         //通过服务的receive方法将受到的数据存入数据包中
    
59.                                         ds.receive(dp); //阻塞式方法，没数据就等
    
60.                        
    
61.                                         //通过数据包的方法获取其中的数据
    
62.                                         String ip = dp.getAddress().getHostAddress();//获取ip
    
63.                                         String data = new String(dp.getData(),0,dp.getLength());
    
64.                                         int port = dp.getPort();
    
65.                                        
    
66.                                         System.out.println(ip+data+port);
    
67.                                 }
    
68.                 }       
    
69.                 catch(Exception e)
    
70.                 {
    
71.                         throw new RuntimeException("接收失败");
    
72.                 }
    
73.         }
    
74.        
    
75.        
    
76. }
    
77. 
    
78. class LiaoTian{
    
79.        
    
80.         public static void main(String[] args) throws Exception{
    
81.                 DatagramSocket sendSocket = new DatagramSocket();
    
82.                 DatagramSocket receSocket = new DatagramSocket(10003);       
    
83.                
    
84.                 new Thread(new UdpSend_Thread(sendSocket)).start();
    
85.                 new Thread(new UdpRece_Thread(receSocket)).start();
    
86.         }       
    
87. }

复制代码