黑马程序员技术交流社区

标题: UDP 接收 [打印本页]
作者: fmi110    时间: 2015-9-17 17:46
标题: UDP 接收
  1. package net.program;

  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;

  8. public class UdpSendDemo {

  10.         /**
  11.          *         192.168.11.248
  12.                 255.255.255.0
  13.                 192.168.11.1
  14.          * UDP数据报协议发送数据流程：
  15.          *         1 创建发送端的Socket对象，DatagramSocket
  16.          *  2 创建数据，并将数据封包，底层为IO数据流
  17.          *  3 调用DatagramSocket对象的发送方法，将数据发送
  18.          *  4 释放资源
  19.          * @throws IOException
  20.          */
  21.         public static void main(String[] args) throws IOException {
  22.                 //DatagramSocket()
  23. //        构造数据报套接字并将其绑定到本地主机上任何可用的端口。
  24.                 DatagramSocket ds = new DatagramSocket();
  25.                 //创建数据
  26.                 byte[] bys = "This is UDP demo".getBytes();
  27.                 int length = bys.length;
  28.                 //数据封装DatagramPacket
  29.                 //DatagramPacket(byte[] buf, int length, InetAddress address, int port)
  30.                 InetAddress address = InetAddress.getByName("192.168.11.248");
  31. //                System.out.println(address.getHostAddress()+"..."+address.getHostName());
  32.                 DatagramPacket dp = new DatagramPacket(bys, length, address,10086);
  33.                 ds.send(dp);
  34.                 //释放资源
  35.                 ds.close();
  36.         }

  38. }
复制代码


作者: fmi110    时间: 2015-9-17 17:48
  1. package net.program;

  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;

  8. public class UdpReceiveDemo {

  10.         /**
  11.          * UDP接收程序：
  12.          *  1 创建UDP套接字对象，DatagramSocket,并指定接收端口
  13.          *  2 创建接收数据包DatagramPacket
  14.          *  3 调用DatagramSocket的接收方法，接收数据，放入DatagramPacket
  15.          *  4 解析数据包并输出到控制台
  16.          *  5 释放资源
  17.          * @throws IOException
  18.          */
  19.         public static void main(String[] args) throws IOException {
  20.                 //创建套接字
  21.                 DatagramSocket ds = new DatagramSocket(10086);
  22.                 //创建接收容器，数据报包
  23.                 byte[] buf = new byte[1024];
  24.                 DatagramPacket dp = new DatagramPacket(buf, 1024);
  25.                 //接收数据报包
  26.                 ds.receive(dp);//该方法在接收到数据报之前一直阻塞
  27.                 //获取ip地址
  28.                 InetAddress address = dp.getAddress();
  29.                 System.out.println(address.getHostName()+"..."+address.getHostAddress()+" 发来消息:");
  30.                 //解析数据包内容，数据+长度
  31.                 byte[] datas = dp.getData();
  32.                 int length = dp.getLength();
  33.                 String message = new String(datas,0,length);
  34.                 System.out.println(message);
  35.                 //释放资源
  36.                 ds.close();
  37.         }

  39. }
复制代码




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