黑马程序员技术交流社区

标题: java基础： [打印本页]
作者: 韩秀山    时间: 2013-5-14 20:54
标题: java基础：
今天老师说：使用线程和Io流可以实现局域网聊天。谁能帮我做一个，要有详细的注释，说明每个语句的意思？？谢谢大家了。。
作者: 尹丽峰    时间: 2013-5-14 21:10
  1. import java.io.BufferedReader;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4. import java.net.*;

  6. public class duoxianchengliaotian
  7. {
  8.         public static void main(String[]args) throws Exception
  9.         {
  10.                 DatagramSocket sendSocket = new DatagramSocket();
  11.                 DatagramSocket resceSocket = new DatagramSocket(10000);
  12.                 send s = new send(sendSocket);
  13.                 resce r = new resce(resceSocket);
  14.                 Thread t1 = new Thread(s);
  15.                 Thread t2 = new Thread(r);
  16.                 t1.start();
  17.                 t2.start();
  18.         }
  19. }

  21. class send implements Runnable {
  22.         private DatagramSocket ds;
  23.         public  send(DatagramSocket ds)
  24.         {
  25.                 this.ds=ds;
  26.         }
  27.         public void run()
  28.         {
  29.                 String line =null;
  30.                 BufferedReader bfr = new BufferedReader(new InputStreamReader(System.in));
  31.                 try {
  32.                         while((line=bfr.readLine())!=null)
  33.                         {
  34.                                 byte[] buf  = line.getBytes();
  35.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.0.102"),10000);
  36.                                 ds.send(dp);
  37.                                
  38.                         }
  39.                 } catch (IOException e) {
  40.                         // TODO Auto-generated catch block
  41.                         e.printStackTrace();
  42.                 }
  43.         }

  45. }

  47. class resce implements Runnable
  48.         {
  49.                 private DatagramSocket ds;
  50.                 public  resce(DatagramSocket ds)
  51.                 {
  52.                         this.ds=ds;
  53.                 }
  54.                 public void run()
  55.                 {
  56.                         String line =null;
  57.                        
  58.                         while(true)
  59.                         {
  60.                                 byte[]buf = new byte[1024];
  61.                                 DatagramPacket dp = new DatagramPacket(buf, buf.length);
  62.                                 try {
  63.                                         ds.receive(dp);
  64.                                         String ip = dp.getAddress().getHostAddress();
  65.                                         String data = new String(dp.getData(),0,dp.getLength());
  66.                                         System.out.println(ip+":::"+data);
  67.                                        
  68.                                 } catch (IOException e) {
  69.                                         // TODO Auto-generated catch block
  70.                                         e.printStackTrace();
  71.                                 }
  72.                                 //ds.close();
  73.                         }
  74.                 }
  75.         }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2