UDP

1. /*
   
2. UDP:User Datagram protocol 用户数据报协议
   
3.         特点：将数据和源和目的封装成数据包，不需要建立连接
   
4.                         每个数据的大小限制在64k
   
5.                         不需要建立连接，速度快
   
6.                         是不可靠传输协议
   
7. 
   
8. Socket:
   
9.         Socket就是为网络服务提供的一种机制。通信的两端都有Socket.
   
10.         网络通信其实就是两个Socket建的通信，数据在两个Socket间通过IO传输
    
11. 
    
12. UDP传输：
    
13.         DatagramSocket(用来发送和接收数据包的套接字）
    
14.         DatagramPacket(数据报包）
    
15.        
    
16.         流程：
    
17.                 1 建立udp的socket服务
    
18.                 2 将发送数据封装至DatagramPacket
    
19.                 3 通过udp的Socket服务将包发送出去
    
20.                 4 关闭服务
    
21. 
    
22. */
    
23. /*
    
24. DatagramSocket:
    
25.         构造方法：
    
26.                 DatagramSocket(int port); 绑定本地端口
    
27.                 DatagramSocket(int port,InetAddress addr); 绑定本地端口 和 本地ip 地址
    
28.                 DatagramSocket(SocketAddress addr); 绑定本地SocketAddress地址（ip地址和端口）
    
29. 
    
30.                         InetSocketAddress(InetAddress addr, int port);根据 IP 地址和端口号创建套接字地址
    
31. 
    
32.         方法：
    
33.                 bind(SocketAddress addr); //绑定地址和端口
    
34.                 close();
    
35.                 connect(InetAddress addr,int port);
    
36.                 connect(SocketAddress addr);
    
37.                 disconnect(); //断开连接
    
38. 
    
39.                 boolean isBound(); 是否绑定
    
40.                 boolean isClose();
    
41.                 boolean isConnected();
    
42. 
    
43.                 receive(DatagramPacket p); 从此套接字接收数据包
    
44.                 send(DatagramPacket p); 从此套接字发送数据包
    
45. 
    
46. DatagramPacket
    
47.         构造函数：
    
48.                 DatagramPacket(byte[] buf, int length)
    
49.                         构造 DatagramPacket，用来接收长度为 length 的数据包
    
50.                 DatagramPacket(byte[] buf,int offset,int len,InetAddress addr,int port);
    
51.                         构造数据包，长度为len，目的主机时 addr ，端口号是 port
    
52.                 DatagramPacket(byte[] buf,int offset,int len,SocketAddress saddr);
    
53.                         构造数据包，长度为len，目的主机时 saddr
    
54.        
    
55.         方法：
    
56.                 InetAddress getAddress();
    
57. 
    
58.                 byte[] getData(); 返回数据包内的数据
    
59.                 void   setData(byte[] buf); 设置数据包的数据信息
    
60.                
    
61.                 int getPort(); 返回远程主机的端口号
    
62.                 setAddress();
    
63.                 setPort();
    
64.                 setSocketAddress();               
    
65. */
    
66. import java.net.*;
    
67. class UdpSendDemo
    
68. {
    
69.         public static void main(String[] args) throws Exception
    
70.         {
    
71.                 //1 建立DatagramSocket，并指定端口
    
72.                 DatagramSocket dss = new DatagramSocket(9999);
    
73. 
    
74.                 //2 建立数据包，并将发送数据装包
    
75.                 String msg = "我是发送包，叮叮叮。。。";
    
76.                 byte[] buf = msg.getBytes();
    
77.                 DatagramPacket dp =
    
78.                                 new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.31.248"),10000);
    
79. 
    
80.                 //3 发送数据包
    
81. //                dss.send(dp);
    
82. //                buf = ("发送数据的长度:"+buf.length).getBytes();
    
83. //                dp.setData(buf,0,buf.length);
    
84.                 dss.send(dp);
    
85. 
    
86.                 //4 关闭服务
    
87.                 dss.close();
    
88.                 System.out.println("Hello World!");
    
89.         }
    
90. }
    
91. 
    
92. 
    
93. class UdpReceiveDemo
    
94. {
    
95.         public static void main(String[] args) throws Exception
    
96.         {
    
97.                 DatagramSocket ds = new DatagramSocket(10000);
    
98. 
    
99.                 byte[] buf = new byte[1024];
    
100.                
     
101.                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
     
102. 
     
103.                 ds.receive(dp);//阻塞式
     
104. 
     
105.                 String ip = dp.getAddress().getHostAddress(); //获取发送包的主机的地址
     
106.                 String name = dp.getAddress().getHostName();//获取远端主机名
     
107.                 int port = dp.getPort();
     
108.                 int len = dp.getLength();//获取接受到的数据的长度
     
109. 
     
110.                 byte[] buf1 = dp.getData();//获取信息
     
111.                 System.out.println("自动创建的缓冲数组的长度："+buf1.length);
     
112.                 String msg = new String(buf,0,dp.getLength());
     
113.                 System.out.println("远端主机："+name+": "+ip+" :"+msg+" port: "+port+" length: "+len);
     
114.                 ds.close();
     
115.         }
     
116. }

复制代码

UDP

1. /*
   
2. UDP:User Datagram protocol 用户数据报协议
   
3.         特点：将数据和源和目的封装成数据包，不需要建立连接
   
4.                         每个数据的大小限制在64k
   
5.                         不需要建立连接，速度快
   
6.                         是不可靠传输协议
   
7. 
   
8. Socket:
   
9.         Socket就是为网络服务提供的一种机制。通信的两端都有Socket.
   
10.         网络通信其实就是两个Socket建的通信，数据在两个Socket间通过IO传输
    
11. 
    
12. UDP传输：
    
13.         DatagramSocket(用来发送和接收数据包的套接字）
    
14.         DatagramPacket(数据报包）
    
15.        
    
16.         流程：
    
17.                 1 建立udp的socket服务
    
18.                 2 将发送数据封装至DatagramPacket
    
19.                 3 通过udp的Socket服务将包发送出去
    
20.                 4 关闭服务
    
21. 
    
22. */
    
23. /*
    
24. DatagramSocket:
    
25.         构造方法：
    
26.                 DatagramSocket(int port); 绑定本地端口
    
27.                 DatagramSocket(int port,InetAddress addr); 绑定本地端口 和 本地ip 地址
    
28.                 DatagramSocket(SocketAddress addr); 绑定本地SocketAddress地址（ip地址和端口）
    
29. 
    
30.                         InetSocketAddress(InetAddress addr, int port);根据 IP 地址和端口号创建套接字地址
    
31. 
    
32.         方法：
    
33.                 bind(SocketAddress addr); //绑定地址和端口
    
34.                 close();
    
35.                 connect(InetAddress addr,int port);
    
36.                 connect(SocketAddress addr);
    
37.                 disconnect(); //断开连接
    
38. 
    
39.                 boolean isBound(); 是否绑定
    
40.                 boolean isClose();
    
41.                 boolean isConnected();
    
42. 
    
43.                 receive(DatagramPacket p); 从此套接字接收数据包
    
44.                 send(DatagramPacket p); 从此套接字发送数据包
    
45. 
    
46. DatagramPacket
    
47.         构造函数：
    
48.                 DatagramPacket(byte[] buf, int length)
    
49.                         构造 DatagramPacket，用来接收长度为 length 的数据包
    
50.                 DatagramPacket(byte[] buf,int offset,int len,InetAddress addr,int port);
    
51.                         构造数据包，长度为len，目的主机时 addr ，端口号是 port
    
52.                 DatagramPacket(byte[] buf,int offset,int len,SocketAddress saddr);
    
53.                         构造数据包，长度为len，目的主机时 saddr
    
54.        
    
55.         方法：
    
56.                 InetAddress getAddress();
    
57. 
    
58.                 byte[] getData(); 返回数据包内的数据
    
59.                 void   setData(byte[] buf); 设置数据包的数据信息
    
60.                
    
61.                 int getPort(); 返回远程主机的端口号
    
62.                 setAddress();
    
63.                 setPort();
    
64.                 setSocketAddress();               
    
65. */
    
66. import java.net.*;
    
67. class UdpSendDemo
    
68. {
    
69.         public static void main(String[] args) throws Exception
    
70.         {
    
71.                 //1 建立DatagramSocket，并指定端口
    
72.                 DatagramSocket dss = new DatagramSocket(9999);
    
73. 
    
74.                 //2 建立数据包，并将发送数据装包
    
75.                 String msg = "我是发送包，叮叮叮。。。";
    
76.                 byte[] buf = msg.getBytes();
    
77.                 DatagramPacket dp =
    
78.                                 new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.31.248"),10000);
    
79. 
    
80.                 //3 发送数据包
    
81. //                dss.send(dp);
    
82. //                buf = ("发送数据的长度:"+buf.length).getBytes();
    
83. //                dp.setData(buf,0,buf.length);
    
84.                 dss.send(dp);
    
85. 
    
86.                 //4 关闭服务
    
87.                 dss.close();
    
88.                 System.out.println("Hello World!");
    
89.         }
    
90. }
    
91. 
    
92. 
    
93. class UdpReceiveDemo
    
94. {
    
95.         public static void main(String[] args) throws Exception
    
96.         {
    
97.                 DatagramSocket ds = new DatagramSocket(10000);
    
98. 
    
99.                 byte[] buf = new byte[1024];
    
100.                
     
101.                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
     
102. 
     
103.                 ds.receive(dp);//阻塞式
     
104. 
     
105.                 String ip = dp.getAddress().getHostAddress(); //获取发送包的主机的地址
     
106.                 String name = dp.getAddress().getHostName();//获取远端主机名
     
107.                 int port = dp.getPort();
     
108.                 int len = dp.getLength();//获取接受到的数据的长度
     
109. 
     
110.                 byte[] buf1 = dp.getData();//获取信息
     
111.                 System.out.println("自动创建的缓冲数组的长度："+buf1.length);
     
112.                 String msg = new String(buf,0,dp.getLength());
     
113.                 System.out.println("远端主机："+name+": "+ip+" :"+msg+" port: "+port+" length: "+len);
     
114.                 ds.close();
     
115.         }
     
116. }

复制代码