java学习笔记: 实现简易局域网聊天程序

so_brave

java学习笔记: 实现简易局域网聊天程序

Java代码

1. /*  
   
2. 使用UDP模式,编写一个聊天程序  
   
3. 有发送和接收数据2部分,  
   
4. 一个线程接收,一个线程发送  
   
5. 
   
6. 由于发送和接收动作是不一致的,所以要使用2个run方法  
   
7. 而且这两个方法要封装到不同的类中  
   
8. 
   
9. 本程序忽略了部分异常的处理,也未加入UI组件  
   
10. 这样比较简洁  
    
11. 
    
12. 发送端口9998  
    
13. 接受端口9999  
    
14. 用的是局域网广播地址,所以自己发的消息自己也收到了  
    
15. 
    
16. [示例]:简易控制台聊天程序  
    
17. */  
    
18. import java.net.*;   
    
19. import java.io.*;   
    
20. class Demo   
    
21. {   
    
22.   public static void main(String[] args) throws Exception   
    
23.   {   
    
24.     DatagramSocket sendSocket = new DatagramSocket(9998);  //发送端   
    
25.     DatagramSocket receSocket = new DatagramSocket(9999);  //接收端   
    
26.     new Thread(new MsgSend(sendSocket)).start();           //发送线程   
    
27.     new Thread(new MsgRece(receSocket)).start();           //接受线程   
    
28.   }   
    
29. }   
    
30.   
    
31. class MsgSend implements Runnable     //发送   
    
32. {   
    
33.   private DatagramSocket dsock;   
    
34.   public MsgSend(DatagramSocket dsock)   
    
35.   {   
    
36.     this.dsock= dsock;   
    
37.   }   
    
38.   
    
39.   public void run()   
    
40.   {   
    
41.     BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));   
    
42.     String lineStr = null;   
    
43.     try  
    
44.     {           
    
45.       while(true)   
    
46.       {   
    
47.         lineStr = bufr.readLine();   
    
48.         if(lineStr!=null)   
    
49.         {   
    
50.           if(lineStr.equals("over886"))   
    
51.           {   
    
52.             break;   
    
53.           }   
    
54.           else  
    
55.           {   
    
56.             byte[] dataBuf = lineStr.getBytes();   
    
57.             DatagramPacket dataPack =   //数据打包   
    
58.             new DatagramPacket( dataBuf,   
    
59.                                 dataBuf.length,   
    
60.                                 InetAddress.getByName("192.168.1.255"), //广播   
    
61.                                 9999 //目标端口   
    
62.                               );   
    
63.             dsock.send(dataPack);   
    
64.           }   
    
65.         }   
    
66.       }   
    
67.       bufr.close();   
    
68.       dsock.close();   
    
69.     }   
    
70.     catch(Exception e)   
    
71.     {   
    
72.       throw new RuntimeException("发送失败!");   
    
73.     }   
    
74.   }   
    
75. }   
    
76.   
    
77. class MsgRece implements Runnable    //接收   
    
78. {   
    
79.   private DatagramSocket dsock;   
    
80.   public MsgRece(DatagramSocket dsock)   
    
81.   {   
    
82.     this.dsock= dsock;   
    
83.   }   
    
84.   
    
85.   public void run()   
    
86.   {   
    
87.     try  
    
88.     {   
    
89.       while(true)   
    
90.       {   
    
91.           byte[] dataBuf = new byte[1024];   
    
92.           DatagramPacket dataPack = new DatagramPacket(dataBuf,dataBuf.length);   
    
93.           dsock.receive(dataPack);  //将获取的数据保存到指定的数据包   
    
94.           String ip = dataPack.getAddress().getHostAddress();   
    
95.           String data = new String(dataPack.getData(),0,dataPack.getLength());   
    
96.           int port = dataPack.getPort();   
    
97.           System.out.println();   
    
98.           System.out.println("来自ip为 "+ip+" <对方端口>: "+port+" 的消息");   
    
99.           System.out.println(data);           
    
100.       }   
     
101.     }   
     
102.     catch(Exception e)   
     
103.     {   
     
104.       throw new RuntimeException("接受失败!");   
     
105.     }   
     
106.     finally  
     
107.     {   
     
108.       dsock.close();   
     
109.     }   
     
110.   }   
     
111. }  

复制代码

梦境照进现实

谢谢分享

sychangchun

学习了。不错的。谢谢分享。