黑马程序员技术交流社区

标题: 【分享】UDP多线程操作 [打印本页]
作者: 暗影流光    时间: 2014-7-12 10:16
标题: 【分享】UDP多线程操作
  1. public class TestUDP {

  3.         /**
  4.          * @param args
  5.          * @throws IOException
  6.          */
  7.         public static void main(String[] args) throws IOException {
  8.                 DatagramSocket send = new DatagramSocket();
  9.                 Send s = new Send(send);
  10.                 DatagramSocket rece = new DatagramSocket(10001);
  11.                 Receive r = new Receive(rece);
  12.                 new Thread(s).start();
  13.                 new Thread(r).start();
  14.         }

  16. }
  17. public class Send implements Runnable {
  18.         private DatagramSocket ds;

  20.         Send(DatagramSocket ds) {
  21.                 this.ds = ds;
  22.         }

  24.         @Override
  25.         public void run() {
  26.                 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  27.                 String line = null;
  28.                 try {
  29.                         while ((line = br.readLine()) != null) {
  30.                                 byte[] bys = line.getBytes();
  31.                                 InetAddress in = InetAddress.getLocalHost();
  32.                                 DatagramPacket dp = new DatagramPacket(bys, bys.length, in,
  33.                                                 10001);
  34.                                 ds.send(dp);
  35.                                 if(line.equalsIgnoreCase("over"))
  36.                                         break;
  37.                         }
  38.                 } catch (IOException e) {
  39.                         e.printStackTrace();
  40.                 }
  41.         }
  42. }
  43. public class Receive implements Runnable {
  44.         private DatagramSocket ds;

  46.         Receive(DatagramSocket ds) {
  47.                 this.ds = ds;
  48.         }

  50.         @Override
  51.         public void run() {
  52.                 byte[] bys = new byte[1024];
  53.                 DatagramPacket dp = new DatagramPacket(bys, bys.length);
  54.                 try {
  55.                         while (true) {
  56.                                 ds.receive(dp);
  57.                                 String data=new String(dp.getData(),0,dp.getLength());
  58.                                 System.out.println(dp.getAddress().getHostAddress()+":"+data);
  59.                         }
  60.                 } catch (IOException e) {
  61.                         e.printStackTrace();
  62.                 }
  63.         }

  65. }
复制代码


作者: jwx555    时间: 2014-7-12 13:12
一句注释都没有，懒得看了都
作者: 導ぷ仙″兲蕐    时间: 2014-7-12 13:21
额 ,提问结束??



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