UDP数据报套接字编程入门


public class UdpEchoServer {
    private DatagramSocket socket=null;
 
    public UdpEchoServer(int port) throws SocketException {
        socket=new DatagramSocket(port);
    }
}

代码说明：

（1）socket=new DatagramSocket(port);

在运行一个服务器的时候，通常会手动指定一个端口号。

补：一个主机上的端口号，只能被一个进程绑定，但一个进程可以绑定多个端口号。

（2）throws SocketException

通常表示socket创建失败。

比如：端口号已经被别的进程占用了。

3.1.2服务器的运行方法start()

工作内容：

1. 读取请求并解析

2. 根据请求计算响应 (对于回显服务器来说, 这一步啥都不用做)

3. 把响应返回到客户端.

4.打印日志

代码：


import java.io.IOException;
import java.net.*;
 
 
public class UdpEchoServer {
    private DatagramSocket socket = null;
 
    public UdpEchoServer(int port) throws SocketException {
        socket = new DatagramSocket(port);
    }
 
    public void start() throws IOException {
        System.out.println("服务器启动");
        while (true) {
            DatagramPacket requestpacket = new DatagramPacket(new byte[4096], 4096);
            socket.receive(requestpacket);
            String request = new String(requestpacket.getData(), 0, requestpacket.getLength());
            String response = process(request);
            DatagramPacket responsepacket = new DatagramPacket(response.getBytes(), response.getBytes().length, requestpacket.getSocketAddress());
            socket.send(responsepacket);
            // 打印日志
            System.out.printf("[%s:%d] req: %s, resp: %s\n", requestpacket.getAddress().toString(),
                    requestpacket.getPort(), request, response);
        }
    }
 
    private String process(String request) {
        return request;
    }
}

代码说明：

1. while (true) {~~~}

对于服务器来说，需要不停的收到请求，返回响应，收到请求，返回响应

2. DatagramPacket requestpacket = new DatagramPacket(new byte[4096], 4096);

（1）byte[4096]->4096 表示的是载荷长度。

这个数组存的是消息正文（应用层数据包）也就是UDP数据包载荷部分。

（2） socket.receive(requestpacket);

如果执行到socket.receive(requestpacket)的时候，还没有客户端发来请求，则会先堵塞等待。

（3 ）requestpacket.getSocketAddress()

由于requestpacket是从客户端来的数据报，故得到的InetAddress对象就会包含了客户端的IP和端口号。

3.1.3main部分

代码：


public static void main(String[] args) throws IOException {
        UdpEchoServer server = new UdpEchoServer(9090);
        server.start();
    }

代码说明：

UdpEchoServer server = new UdpEchoServer(9090);

9090->这个端口号可以指定任何你想要指定的端口号。

3.1.4.完整代码

代码：


package network;
 
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.nio.charset.StandardCharsets;
 
public class UdpEchoServer {
    private DatagramSocket socket = null;
 
    public UdpEchoServer(int port) throws SocketException {
        socket = new DatagramSocket(port);
    }
 
    // 服务器的启动逻辑.
    public void start() throws IOException {
        System.out.println("服务器启动!");
        while (true) {
            // 每次循环, 就是处理一个请求-响应过程.
            // 1. 读取请求并解析
            DatagramPacket requestPacket = new DatagramPacket(new byte[4096], 4096);
            socket.receive(requestPacket);
            // 读到的字节数组, 转成 String 方便后续的逻辑处理.
            String request = new String(requestPacket.getData(), 0, requestPacket.getLength());
            // 2. 根据请求计算响应 (对于 回显服务器来说, 这一步啥都不用做)
            String response = process(request);
            // 3. 把响应返回到客户端.
            //    构造一个 DatagramPacket 作为响应对象
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(), response.getBytes().length,
                    requestPacket.getSocketAddress());
            socket.send(responsePacket);
 
            // 打印日志
            System.out.printf("[%s:%d] req: %s, resp: %s\n", requestPacket.getAddress().toString(),
                    requestPacket.getPort(), request, response);
        }
    }
 
    public String process(String request) {
        return request;
    }
 
    public static void main(String[] args) throws IOException {
        UdpEchoServer server = new UdpEchoServer(9090);
        server.start();
    }
}

3.2回显客户端

3.2.1UdpEchoClient类的创建

代码：


import java.io.IOException;
import java.net.*;
import java.util.Scanner;
 
public class UdpEchoClient {
    private DatagramSocket socket = null;
    private String serverIp;
    private int serverPort;
 
    public UdpEchoClient(String serverIp,int serverPort) throws SocketException {
        this.socket = new DatagramSocket();
        this.serverIp = serverIp;
        this.serverPort = serverPort;
    }
}

代码说明：

（1）this.socket = new DatagramSocket();

客户端这边一般不会手动指定端口好，会让系统自动分配一个端口号。

（2）private String serverIp;
private int serverPort;

客户端需要主动给服务器发送请求，发送请求的前提是知道服务器在哪。

3.2.2客户端的运行方法start()

工作内容：

1. 从控制台读取要发送的请求数据.

2. 构造请求并发送

3. 读取服务器的响应.

4. 把响应显示到控制台上

代码：


 public void start() throws IOException {
        System.out.println("客户端启动");
        Scanner scanner = new Scanner(System.in);
        while (true){
            System.out.print("->");
            if(!scanner.hasNext()){
                break;
            }
            String request=scanner.next();
            DatagramPacket requestpacket=new DatagramPacket(request.getBytes(),request.getBytes().length, InetAddress.getByName(serverIp),serverPort);
            socket.send(requestpacket);
            DatagramPacket responsepacket=new DatagramPacket(new byte[4096],4096);
            socket.receive(responsepacket);
            String response=new String(responsepacket.getData(),0,responsepacket.getLength());
            System.out.println(response);
        }
    }

代码说明：

InetAddress.getByName(serverIp)

把数据的单位从字符->字节。

3.2.3main部分

代码：


    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1", 9090);
        client.start();
    }

3.2.4 完整代码

代码：


import java.io.IOException;
import java.net.*;
import java.util.Scanner;
 
public class UdpEchoClient {
    private DatagramSocket socket = null;
    private String serverIp;
    private int serverPort;
 
 
    // 此处 ip 使用的字符串, 点分十进制风格. "192.168.2.100"
    public UdpEchoClient(String serverIp, int serverPort) throws SocketException {
        this.serverIp = serverIp;
        this.serverPort = serverPort;
        socket = new DatagramSocket();
    }
 
    public void start() throws IOException {
        System.out.println("客户端启动");
        Scanner scanner = new Scanner(System.in);
        while (true) {
            // 要做四个事情
            System.out.print("-> "); // 表示提示用户接下来要输入内容.
            // 1. 从控制台读取要发送的请求数据.
            if (!scanner.hasNext()) {
                break;
            }
            String request = scanner.next();
            // 2. 构造请求并发送.
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(), request.getBytes().length,
                    InetAddress.getByName(serverIp), serverPort);
            socket.send(requestPacket);
            // 3. 读取服务器的响应.
            DatagramPacket responsePacket = new DatagramPacket(new byte[4096], 4096);
            socket.receive(responsePacket);
            // 4. 把响应显示到控制台上.
            String response = new String(responsePacket.getData(), 0, responsePacket.getLength());
            System.out.println(response);
        }
    }
 
    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1", 9090);
        // UdpEchoClient client = new UdpEchoClient("139.155.74.81", 9090);
        client.start();
    }
}

运行结果：

小结：

以上为我个人的小分享，如有问题，欢迎讨论！！！

都看到这了，不如关注一下，给个免费的赞

相关阅读:
Web 端项目系统访问页面很慢，后台数据返回很快，网络也没问题，是什么导致的呢？
上传npm包到私有nexus仓库中《解决服务端安装npm依赖失败的问题》
mac下安装redis
LAS、CTC、RNN-T、NT、MoChA
c语言打印菱形图案
 [golang]channel源码
 MyBatis 操作数据库（构造动态 SQL）
ChatGPT手机电脑浏览器中使用免费的ChatGPT
List集合
 管理团队相关的梳理
原文地址：https://blog.csdn.net/WHabc2002/article/details/136356444