JDK6.0学习笔记（十一）UDP通信服务器

1. /**
2.  * UDP开发，无连接的Socket操作采用UDP协议，一个数据报文是一个独立的单元，
3.  * 包含所有这次投递的信息：目的地址和要发送的内容。
4.  * UDP模式下，Socket不需要连接到一个目的地Socket，只是简单的投出数据
5.  * 无连接的操作是高效和快速的，但是数据传输的可靠性不佳
6.  * 常用于音频和视频的传输，偶尔丢失一两个数据包，不会对接受效果产生很大的影响
7.  * UDP不提供数据的分组，不能对数据包进行排序，报文发出后，无法得知其是否安全到达
8.  * 
9.  * UDP数据的接受方
10.  * 
11.  * 需要接受侦听的端口号作为输入参数
12.  * */
14. import java.net.InetAddress;
15. import java.net.DatagramPacket;
16. import java.net.DatagramSocket;
18. public class UDPReceive {
19.     public static void main(String args[]) {
20.         try {
21.             if (args.length != 1)
22.                 throw new IllegalArgumentException("Wrong number of args");
23.             int port = Integer.parseInt(args[0]);
24.             DatagramSocket dsocket = new DatagramSocket(port);// 创建实例，并固定监听port端口的报文
25.             byte[] buffer = new byte[2048];// 接受的数据存放到buffer的字节数组当中
26.             DatagramPacket packet = new DatagramPacket(buffer, buffer.length);// 处理报文
27.             for (;;) {
28.                 dsocket.receive(packet);// 接受数据报文到packet中，产生一个阻塞，
29.                 // 程序运行到这执行内部的循环，直到特定的事件被触发
30.                 String msg = new String(buffer, 0, packet.getLength());
31.                 System.out.println(packet.getAddress().getHostName() + ": "
32.                         + msg);
33.                 packet.setLength(buffer.length);
34.             }
35.         } catch (Exception e) {
36.             System.err.println(e);
37.         }
38.     }
39. }

 

1. /**
2.  * UDP数据的发送方
3.  * 
4.  * 需要接受3个输入参数，目标主机名、目标端口号、要发送的字符串 作为输入参数
5.  * */
7. import java.net.InetAddress;
8. import java.net.DatagramPacket;
9. import java.net.DatagramSocket;
11. public class UDPSend 
12. {
13.     public static void main(String args[]) 
14.   {
15.     try 
16.     {
17.         if (args.length < 3)     
18.         throw new IllegalArgumentException("Wrong number of args");
19.       String host = args[0];
20.       int port = Integer.parseInt(args[1]);
21.       byte[] message;
22.       String msg = args[2]; 
23.       message = msg.getBytes();
24.       InetAddress address = InetAddress.getByName(host);
25.       DatagramPacket packet = new DatagramPacket(message, message.length,address, port);
26.                                              //处理报文
27.       DatagramSocket dsocket = new DatagramSocket(); // 创建实例，没有特定监听的端口，用出客户端的编程
28.       dsocket.send(packet);//发送报文到packet
29.       dsocket.close();//关闭 DatagramSocket
30.     }
31.     catch (Exception e) 
32.     {
33.         System.err.println(e);
34.     }
35.   }
36. }