黑马程序员技术交流社区

标题: 聊天程序 [打印本页]
作者: YC匪帮    时间: 2015-9-8 16:24
标题: 聊天程序
  1. /*
  2. 编写聊天程序。
  3. 有收数据的部分和发数据的部分。
  4. 这两部分需要同时执行。
  5. 那就需要用到多线程技术。


  8. 因为收和发动作是不一致的，所以要定义两个run方法。
  9. 而且这两个方法要封装到不同的类中。
  10. */
  11. import java.io.*;
  12. import java.net.*;

  14. class Send implements Runnable
  15. {
  16.         private DatagramSocket ds;
  17.         public Send(DatagramSocket ds)
  18.         {
  19.                 this.ds=ds;
  20.         }
  21.         public void run()
  22.         {
  23.                 try
  24.                 {
  25.                         BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));

  27.                         String line = null;

  29.                         while ((line=bufr.readLine())!=null)
  30.                         {
  31.                                 if ("886".equals(line))
  32.                                 {
  33.                                         break;
  34.                                 }
  35.                                 byte[] buf= line.getBytes();

  37.                                 DatagramPacket dp =
  38.                                         new DatagramPacket(buf,buf.length,InetAddress.getByName("222.199.193.2"),10002);

  40.                                 ds.send(dp);
  41.                         }
  42.                 }
  43.                 catch (Exception e)
  44.                 {
  45.                         throw new RuntimeException("发送端失败");
  46.                 }
  47.         }
  48. }

  50. class Rece implements Runnable
  51. {
  52.         private DatagramSocket ds;
  53.         public Rece(DatagramSocket ds)
  54.         {
  55.                 this.ds=ds;
  56.         }
  57.         public void run()
  58.         {
  59.                 try
  60.                 {
  61.                         while (true)
  62.                         {
  63.                                 byte[] buf = new byte[1024];
  64.                                 DatagramPacket dp = new DatagramPacket(buf,buf.length);

  66.                                 ds.receive(dp);

  68.                                 String ip = dp.getAddress().getHostAddress();
  69.                                 String data = new String(dp.getData(),0,dp.getLength());

  71.                                 System.out.println(ip+":"+data);
  72.                         }
  73.                 }
  74.                 catch (Exception e)
  75.                 {
  76.                         throw new RuntimeException("接收端失败");
  77.                 }
  78.                
  79.         }
  80. }

  82. class  ChatDemo
  83. {
  84.         public static void main(String[] args) throws Exception
  85.         {
  86.                 DatagramSocket sendSocket = new DatagramSocket();
  87.                 DatagramSocket receSocket = new DatagramSocket(10002);

  89.                 new Thread(new Send(sendSocket)).start();
  90.                 new Thread(new Rece(receSocket)).start();

  92.         }
  93. }
复制代码




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