欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

java UDP 通信记录

程序员文章站 2022-03-04 20:43:04
...

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();
        }
    }
}

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

参考文章:

相关标签: udp