java UDP 通信记录

快来打我* 2022-05-14 15:29 295阅读 0赞

## java UDP 通信记录 ##

### 1. UDP和TCP通信的区别 ###

*  TCP面向连接（如打电话要先拨号建立连接）;UDP是无连接的，即发送数据之前不需要建立连接。
 *  TCP提供可靠的服务。也就是说，通过TCP连接传送的数据，无差错，不丢失，不重复，且按序到达;UDP尽最大努力交付，即不保证可靠交付。
 *  TCP面向字节流，实际上是TCP把数据看成一连串无结构的字节流;UDP是面向报文的。UDP没有拥塞控制，因此网络出现拥塞不会使源主机的发送速率降低（对实时应用很有用，如IP电话，实时视频会议等）
 *  每一条TCP连接只能是点到点的;UDP支持一对一，一对多，多对一和多对多的交互通信。
 *  TCP首部开销20字节;UDP的首部开销小，只有8个字节
 *  TCP的逻辑通信信道是全双工的可靠信道，UDP则是不可靠信道。

### 2. UDP通信的优势 ###

*  网速的提升给udp的稳定性提供了可靠的网络保障。丢包率很低，如果使用应用层重传，能够确保传输的可靠性。
 *  udp协议设计简单，传输速度快。tcp设计过于冗余，速度难以进一步提升。

### 3.java UDP通信的相关介绍 ###

*  \*\*DatagramSocket类：\*\*此类表示用来发送和接收数据报包的套接字。 数据报套接字是包投递服务的发送或接收点。
    
    构造方法：
    
    > DatagramSocket():表示创建一个默认的套接字，并绑定到本地地址和一个随机的端口号
    > 
    > DatagramSocket(int port) 创建数据报套接字并将其绑定到本地主机上的指定端口。
    > 
    > DatagramSocket(int port, InetAddress iad):表示创建一个套接字，绑定到特定的端口号及指定地址
    > 
    > DatagramSocket(SocketAddress sad);　表示创建一个套接字，绑定到特定的套接字地址
    
    基本方法：
    
    > recevie(DatagramPacket dp):　接受数据报
    > 
    > send(DatagramPacket dp):　发送数据报
    > 
    > close():关闭套接字
    > 
    > bind(SocketAddress addr) 将此 DatagramSocket 绑定到特定的地址和端口。
    > 
    > connect(InetAddress address, int port) 将套接字连接到此套接字的远程地址。
    > 
    > connect(SocketAddress addr) 将此套接字连接到远程套接字地址（IP 地址 + 端口号）。
    > 
    > disconnect() 断开套接字的连接。
    > 
    > getInetAddress() 返回此套接字连接的地址。
    > 
    > InetAddress getLocalAddress()；获取套接字绑定的本地地址。
 *  \*\*DatagramPacket类：\*\*如果把DatagramSocket比作创建的港口码头，那么DatagramPacket就是发送和接收数据的集装箱。
    
    常用方法：
    
    > DatagramPacket(byte\[\] buf, int length)?):构造方法，用来接受长度为length的buf数据(即数据存于字节数组buf中)
    > 
    > DatagramPacket(byte\[\] buf, int length, InetAddress address, int port);将length长的buf数据发送到指定的地址的端口号处
    > 
    > DatagramPacket(byte\[\] buf, int length, SocketAddress address);将length长的buf数据发送到指定的套接字地址处
    > 
    > getAddress() 返回接收或发送此数据报文的机器的 IP 地址。
    > 
    > getData() 返回接收的数据或发送出的数据。
    > 
    > getLength()；返回发送出的或接收到的数据的长度。
    > 
    > getPort() 返回接收或发送该数据报文的远程主机端口号
 *  **InetAddress类**：InetAddress用于表示计算机IP地址的一个类，而在日常应用中的IP地址用"192.168.0.1","[WWW.it315.org][]"等字符串格式表示的。
    
    > 常用的方法有：
    > 
    > getByName方法  
    > getHostAddress方法

### UDP 通信示例 ###

*  发送方代码：

public class UDPSender { 
    
        public static void main(String[] args) { 
            try { 
                // 创建发送方的套接字，IP默认为本地，端口号随机
                DatagramSocket sendSocket = new DatagramSocket();
                //设置要发送的消息
                String message = "你好！接收方！";
                //由于数据报的数据 是以字符数组的形式存储的，所以要把数据格式转换成这种格式。
                byte[] buf = message.getBytes();
                //确定发送方的IP地址及端口号，地址为本地机器地址
                int port = 8888;
                InetAddress ip = InetAddress.getLocalHost();
                DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, ip, port);
                //通过套接字来发送数据
                sendSocket.send(sendPacket);
                // 确定接受反馈数据的缓冲存储器，即存储数据的字节数组
                byte[] getBuf = new byte[1024];
                //创建接受类型的数据报
                DatagramPacket getPacket = new DatagramPacket(getBuf, getBuf.length);
    // 通过套接字来接收返回的数据
                sendSocket.receive(getPacket);
    // 解析反馈的数据
                String backStr = new String(getBuf, 0, getPacket.getLength());
                System.out.println(backStr);
    
                sendSocket.close();
    
            } catch (SocketException e) { 
                e.printStackTrace();
            } catch (UnknownHostException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            }
    
        }
    }

*  接收方代码

import java.io.IOException;
    import java.net.*;
    
    public class UDPReceiver { 
    
        public static void main(String[] args) { 
    
            try { 
                //确定接受方的IP和端口号
                InetAddress ip = InetAddress.getLocalHost();
                int port = 8888;
    
                DatagramSocket getSocket = new DatagramSocket(port,ip);
    
                byte[] buf = new byte[1024];
    
                DatagramPacket getPacket = new DatagramPacket(buf, buf.length);
                getSocket.receive(getPacket);
    
                String getMes = new String(buf, 0, getPacket.getLength());
                System.out.println(getMes);
    
                //通过数据报得到发送方的IP和端口号
                InetAddress sendIp = getPacket.getAddress();
                int sendPort = getPacket.getPort();
                System.out.println("sendIp " + sendIp);
                System.out.println("sendPort "+ sendPort);
                //通过数据报等到发送方的地址
                SocketAddress sendAddress = getPacket.getSocketAddress();
                System.out.println("sendAddress" + sendAddress);
    
                String feedbak = "发送方，你的消息我收到了";
                byte[] bakbuf = feedbak.getBytes();
    
                DatagramPacket sendpacket = new DatagramPacket(bakbuf, bakbuf.length, sendAddress);
                getSocket.send(sendpacket);
                getSocket.close();
    
            } catch (UnknownHostException e) { 
                e.printStackTrace();
            } catch (SocketException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    }

测试时先启动接收方代码，再启动发送方代码。

参考文章：

*  [https://blog.csdn.net/not\_give\_up\_/article/details/80154226][https_blog.csdn.net_not_give_up_article_details_80154226]
 *  [https://www.cnblogs.com/hq-antoine/archive/2012/02/11/2346908.html][https_www.cnblogs.com_hq-antoine_archive_2012_02_11_2346908.html]
 *  [https://www.cnblogs.com/hq-antoine/archive/2012/02/11/2346908.html][https_www.cnblogs.com_hq-antoine_archive_2012_02_11_2346908.html]

[WWW.it315.org]: http://WWW.it315.org
[https_blog.csdn.net_not_give_up_article_details_80154226]: https://blog.csdn.net/not_give_up_/article/details/80154226
[https_www.cnblogs.com_hq-antoine_archive_2012_02_11_2346908.html]: https://www.cnblogs.com/hq-antoine/archive/2012/02/11/2346908.html