黑马程序员技术交流社区

标题: udp传输问题。 [打印本页]
作者: 汪洋大海    时间: 2013-11-29 02:44
标题: udp传输问题。
各位同学们，你们好，我想问一下，一个程序可以设置多个接收端口吗？如果可以的设置多个端口，如何和多线程配合使用呢？
如果不可以，是为什么呢？
最好可以配上简单的代码，谢谢了哟。

作者: 冯晓骏    时间: 2013-11-29 04:12
服务器代码
  1. public class UdpServer {

  3.         /**
  4.          * @param args
  5.          */
  6.         public static void main(String[] args) throws Exception{
  7.                 // TODO Auto-generated method stub
  8.                
  9.                 //开启一个线程，监听端口10000的数据包
  10.                 Executors.newSingleThreadExecutor().execute(
  11.                                 new Runnable(){
  12.                                         public void run(){
  13.                                                 try {
  14.                                                         DatagramSocket ds = new DatagramSocket(10000);
  15.                                                         byte[] buf = new byte[1024];
  16.                                                         int length = 0;
  17.                                                         DatagramPacket dp = new DatagramPacket(buf, 1024);
  18.                                                         while (true) {
  19.                                                                 ds.receive(dp);
  20.                                                                 System.out.println(dp.getAddress()+"::"+dp.getLength()+":"+new String(dp.getData(), 0, dp.getLength()));
  21.                                                         }
  22.                                                 } catch (Exception e) {
  23.                                                         // TODO: handle exception
  24.                                                         e.printStackTrace();
  25.                                                 }
  26.                                         }
  27.                                 });
  28.                 //开启一个线程，监听端口10001的数据包
  29.                 Executors.newSingleThreadExecutor().execute(
  30.                                 new Runnable(){
  31.                                         public void run(){
  32.                                                 try {
  33.                                                         DatagramSocket ds = new DatagramSocket(10001);
  34.                                                         byte[] buf = new byte[1024];
  35.                                                         int length = 0;
  36.                                                         DatagramPacket dp = new DatagramPacket(buf, 1024);
  37.                                                         while (true) {
  38.                                                                 ds.receive(dp);
  39.                                                                 System.out.println(dp.getAddress()+"::"+dp.getLength()+":"+new String(dp.getData(), 0, dp.getLength()));
  40.                                                         }
  41.                                                 } catch (Exception e) {
  42.                                                         // TODO: handle exception
  43.                                                         e.printStackTrace();
  44.                                                 }
  45.                                         }
  46.                                 });
  47.         }

  49. }
复制代码

客户端代码
  1. public class UdpClient {

  3.         /**
  4.          * @param args
  5.          */
  6.         public static void main(String[] args) {
  7.                 // TODO Auto-generated method stub
  8.                
  9.                 //开启一个线程，向本机的10000端口发送数据包
  10.                 Executors.newSingleThreadExecutor().execute(
  11.                                 new Runnable(){
  12.                                         public void run(){
  13.                                                 try {
  14.                                                         DatagramSocket ds = new DatagramSocket();
  15.                                                         byte[] buf = "THIS IS NO.1".getBytes();
  16.                                                         InetAddress ia = InetAddress.getLocalHost();
  17.                                                         DatagramPacket dp = new DatagramPacket(buf, buf.length, ia, 10000);
  18.                                                         while (true) {
  19.                                                                 ds.send(dp);
  20.                                                                 try {
  21.                                                                         Thread.sleep(1000);
  22.                                                                 } catch (Exception e) {
  23.                                                                         // TODO: handle exception
  24.                                                                 }
  25.                                                         }
  26.                                                 } catch (Exception e) {
  27.                                                         // TODO: handle exception
  28.                                                         e.printStackTrace();
  29.                                                 }
  30.                                         }
  31.                                 });
  32.                 //开启一个线程，向本机的10001端口发送数据包
  33.                 Executors.newSingleThreadExecutor().execute(
  34.                                 new Runnable(){
  35.                                         public void run(){
  36.                                                 try {
  37.                                                         DatagramSocket ds = new DatagramSocket();
  38.                                                         byte[] buf = "this is No.2".getBytes();
  39.                                                         InetAddress ia = InetAddress.getLocalHost();
  40.                                                         DatagramPacket dp = new DatagramPacket(buf, buf.length, ia, 10001);
  41.                                                         while (true) {
  42.                                                                 ds.send(dp);
  43.                                                                 try {
  44.                                                                         Thread.sleep(1000);
  45.                                                                 } catch (Exception e) {
  46.                                                                         // TODO: handle exception
  47.                                                                 }
  48.                                                         }
  49.                                                 } catch (Exception e) {
  50.                                                         // TODO: handle exception
  51.                                                         e.printStackTrace();
  52.                                                 }
  53.                                         }
  54.                                 });
  55.         }

  57. }
复制代码
功能：客户端想服务端的不同端口发送请求


作者: 汪洋大海    时间: 2013-11-29 07:35
谢谢你了。原来是这样呀。



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