<JavaEE> 基于 UDP 的 Socket 通信模型

2023-12-26 22:45
文章标签 java udp ee socket 通信模型

本文主要是介绍<JavaEE> 基于 UDP 的 Socket 通信模型,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

一、认识相关API

1)DatagramSocket

2)DatagramPacket

3)InetSocketAddress

二、UDP数据报套接字通信模型概述

三、回显客户端-服务器通信

1)服务器代码

2)客户端代码


一、认识相关API

1)DatagramSocket

DatagramSocket 常用构造方法
DatagramSocket()创建UDP数据报Scoket套接字,绑定本机任意端口(通常用于客户端)。
DatagramSocket(int port)创建UDP数据报Scoket套接字,绑定本机指定端口(通常用于服务器)。
DatagramSocket 常用方法
void receive(DatagramPacket p)接收数据报并写入参数p中,没有收到则会阻塞等待。
void send(DatagramPacket p)发送数据报。
void close()关闭DatagramSocket套接字。

2)DatagramPacket

DatagramPacket 用构造方法
DatagramPacket(byte[] buf, int length)构造用于存储数据报的容器,指定字节数组和数组长度。
DatagramPacket(byte[] buf,  int length, SocketAddress address)构造用于存储数据报的容器,指定字节数组、数组长度、目的地IP地址和端口号。
DatagramPacket 常用方法
InetAddress getAddress()从数据报中获取目的地的IP地址。
int getPort()从数据报中获取目的地的端口号。
byte[] getData()从数据报中获取字节数据。

3)InetSocketAddress

InetSocketAddress是SocketAddress的子类。
InetSocketAddress 用构造方法
InetSocketAddress(String ip, int port)构造Socket地址,包含IP地址和端口号。
InetSocketAddress(InetAddress addr, int port)构造Socket地址,包含IP地址和端口号。

二、UDP数据报套接字通信模型概述

UDP协议具有无连接,面向数据报的特征。每次通信,双方都是没有建立连接的,并且一次性发送或接收全部通信内容。
UDP通信,使用DatagramSocket类构建套接字,使用DatagramPacket类构建数据报。
UDP通信流程:客户端构造请求->发出请求->服务器接收请求->解析请求->处理请求->构造响应->返回响应->客户端接收响应->解析响应->处理响应

三、回显客户端-服务器

1)服务器代码

public class UDP_Echo_Server {private DatagramSocket socket = null;public UDP_Echo_Server(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());//通过process方法对请求报进行处理,并形成响应;String response = process(request);//将响应转换为数据报,数据包中已经指定了目的地IP;DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,requestPacket.getSocketAddress());//将数据报(响应)发送;socket.send(responsePacket);//打印日志;System.out.printf("[%s,%d] req=%s res=%s\n",requestPacket.getAddress().toString(),requestPacket.getPort(),request,response);}}private String process(String request) {return request;}public static void main(String[] args) throws IOException {UDP_Echo_Server server = new UDP_Echo_Server(端口号);server.start();}
}

2)客户端代码

public class UDP_Echo_client {private DatagramSocket socket = null;private String serverIP = "";private int serverPort = 0;public UDP_Echo_client(String IP,int Port) throws SocketException {//作为客户端,需要显式知道服务器的IP和端口号;this.serverIP = IP;this.serverPort = Port;//客户端自己的端口号,由系统自行分配即可,根据系统分配的端口号创建一个数据报连接通道;socket = new DatagramSocket();}//调用该方法启动客户端;public void start() throws IOException {System.out.println("客户端启动!");Scanner sc = new Scanner(System.in);while (true){System.out.print("->");String request = sc.next();//将字符串转换为数据报(请求),并在数据报中指定了目的地IP及端口;DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,new InetSocketAddress(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);}}public static void main(String[] args) throws IOException {UDP_Echo_client client = new UDP_Echo_client(IP地址,端口号);client.start();}
}

阅读指针 -> 《 协议格式 -- 传输层协议 UDP 》

<JavaEE> 协议格式 -- 传输层协议 UDP-CSDN博客文章浏览阅读19次。介绍了传输层协议UDP的协议格式https://blog.csdn.net/zzy734437202/article/details/135185783

这篇关于<JavaEE> 基于 UDP 的 Socket 通信模型的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/541046

相关文章

Spring Boot 整合 SSE的高级实践(Server-Sent Events)

《SpringBoot整合SSE的高级实践(Server-SentEvents)》SSE(Server-SentEvents)是一种基于HTTP协议的单向通信机制,允许服务器向浏览器持续发送实... 目录1、简述2、Spring Boot 中的SSE实现2.1 添加依赖2.2 实现后端接口2.3 配置超时时

Spring Boot读取配置文件的五种方式小结

《SpringBoot读取配置文件的五种方式小结》SpringBoot提供了灵活多样的方式来读取配置文件,这篇文章为大家介绍了5种常见的读取方式,文中的示例代码简洁易懂,大家可以根据自己的需要进... 目录1. 配置文件位置与加载顺序2. 读取配置文件的方式汇总方式一:使用 @Value 注解读取配置方式二

一文详解Java异常处理你都了解哪些知识

《一文详解Java异常处理你都了解哪些知识》:本文主要介绍Java异常处理的相关资料,包括异常的分类、捕获和处理异常的语法、常见的异常类型以及自定义异常的实现,文中通过代码介绍的非常详细,需要的朋... 目录前言一、什么是异常二、异常的分类2.1 受检异常2.2 非受检异常三、异常处理的语法3.1 try-

Java中的@SneakyThrows注解用法详解

《Java中的@SneakyThrows注解用法详解》:本文主要介绍Java中的@SneakyThrows注解用法的相关资料,Lombok的@SneakyThrows注解简化了Java方法中的异常... 目录前言一、@SneakyThrows 简介1.1 什么是 Lombok?二、@SneakyThrows

Java中字符串转时间与时间转字符串的操作详解

《Java中字符串转时间与时间转字符串的操作详解》Java的java.time包提供了强大的日期和时间处理功能,通过DateTimeFormatter可以轻松地在日期时间对象和字符串之间进行转换,下面... 目录一、字符串转时间(一)使用预定义格式(二)自定义格式二、时间转字符串(一)使用预定义格式(二)自

Spring 请求之传递 JSON 数据的操作方法

《Spring请求之传递JSON数据的操作方法》JSON就是一种数据格式,有自己的格式和语法,使用文本表示一个对象或数组的信息,因此JSON本质是字符串,主要负责在不同的语言中数据传递和交换,这... 目录jsON 概念JSON 语法JSON 的语法JSON 的两种结构JSON 字符串和 Java 对象互转

JAVA保证HashMap线程安全的几种方式

《JAVA保证HashMap线程安全的几种方式》HashMap是线程不安全的,这意味着如果多个线程并发地访问和修改同一个HashMap实例,可能会导致数据不一致和其他线程安全问题,本文主要介绍了JAV... 目录1. 使用 Collections.synchronizedMap2. 使用 Concurren

Java Response返回值的最佳处理方案

《JavaResponse返回值的最佳处理方案》在开发Web应用程序时,我们经常需要通过HTTP请求从服务器获取响应数据,这些数据可以是JSON、XML、甚至是文件,本篇文章将详细解析Java中处理... 目录摘要概述核心问题:关键技术点:源码解析示例 1:使用HttpURLConnection获取Resp

Java的栈与队列实现代码解析

《Java的栈与队列实现代码解析》栈是常见的线性数据结构,栈的特点是以先进后出的形式,后进先出,先进后出,分为栈底和栈顶,栈应用于内存的分配,表达式求值,存储临时的数据和方法的调用等,本文给大家介绍J... 目录栈的概念(Stack)栈的实现代码队列(Queue)模拟实现队列(双链表实现)循环队列(循环数组

Java中Switch Case多个条件处理方法举例

《Java中SwitchCase多个条件处理方法举例》Java中switch语句用于根据变量值执行不同代码块,适用于多个条件的处理,:本文主要介绍Java中SwitchCase多个条件处理的相... 目录前言基本语法处理多个条件示例1:合并相同代码的多个case示例2:通过字符串合并多个case进阶用法使用