数据报通道基础

通道特性与创建方式

java.nio.channels.DatagramChannel类实例代表数据报通道，默认处于阻塞模式。通过configureBlocking(false)方法可将其配置为非阻塞模式。创建数据报通道需调用其静态open()方法，若用于IP组播则需指定组播组的地址类型（协议族）作为参数：

// 标准数据报通道
DatagramChannel channel = DatagramChannel.open();// IPv4组播通道
DatagramChannel ipv4MulticastChannel = DatagramChannel.open(StandardProtocolFamily.INET);// IPv6组播通道  
DatagramChannel iPv6MulticastChannel =DatagramChannel.open(StandardProtocolFamily.INET6);

连接模式控制

未连接的通道可向任意远程主机收发数据报。若需限定通信对象，需通过connect()方法绑定特定主机：

// 连接特定主机（此后仅能与该主机通信）
channel.connect(new InetSocketAddress("192.168.1.100", 8080));

通道选项配置

通过setOption()方法设置套接字选项，关键选项包括：

选项名称类型说明
SO_SNDBUFInteger套接字发送缓冲区大小（字节）
SO_RCVBUFInteger套接字接收缓冲区大小（字节）
SO_REUSEADDRBoolean允许多个程序绑定相同地址（IP组播时必须启用）
SO_BROADCASTBoolean允许广播数据报传输
IP_MULTICAST_IFNetworkInterface指定组播网络接口
IP_MULTICAST_TTLInteger组播数据报生存时间（0-255）

配置示例：

// 启用地址复用
channel.setOption(StandardSocketOptions.SO_REUSEADDR, true);// 设置组播TTL
channel.setOption(StandardSocketOptions.IP_MULTICAST_TTL, 64);

地址绑定与数据传输

通过bind()方法绑定本地地址，null参数表示自动绑定可用地址：

// 自动绑定可用地址
channel.bind(null);  // 绑定指定地址
InetSocketAddress sAddr = new InetSocketAddress("localhost", 8989);
channel.bind(sAddr);

数据收发操作示例：

// 发送数据报
String msg = "Hello";
ByteBuffer buffer = ByteBuffer.wrap(msg.getBytes());
InetSocketAddress target = new InetSocketAddress("localhost", 8989);
channel.send(buffer, target);// 接收数据报
ByteBuffer recvBuffer = ByteBuffer.allocate(1024);
SocketAddress sender = channel.receive(recvBuffer);

完整示例：回显服务器

// 服务器端
try (DatagramChannel server = DatagramChannel.open()) {server.bind(new InetSocketAddress("localhost", 8989));ByteBuffer buffer = ByteBuffer.allocate(1024);while (true) {SocketAddress clientAddr = server.receive(buffer);buffer.flip();byte[] bytes = new byte[buffer.remaining()];buffer.get(bytes);System.out.println("Received: " + new String(bytes));buffer.rewind();server.send(buffer, clientAddr);buffer.clear();}
}

// 客户端端
try (DatagramChannel client = DatagramChannel.open()) {client.bind(null);ByteBuffer buffer = ByteBuffer.wrap("Hello".getBytes());client.send(buffer, new InetSocketAddress("localhost", 8989));buffer.clear();client.receive(buffer);buffer.flip();System.out.println("Echo: " + new String(buffer.array()));
}

关键注意点：组播通道必须设置SO_REUSEADDR选项，非阻塞模式下receive()会立即返回null。IPv6地址在URL中需用方括号包裹（如http://[::1]）。

通道配置与选项设置

标准套接字选项详解

DatagramChannel 提供七种核心配置选项，通过 StandardSocketOptions 类常量定义：

  1. 缓冲区配置

    • SO_SNDBUF：发送缓冲区大小（整数类型，单位字节）
    • SO_RCVBUF：接收缓冲区大小（整数类型，单位字节）
    // 设置128KB发送缓冲区
channel.setOption(StandardSocketOptions.SO_SNDBUF, 131072);

  2. 地址复用控制

    • SO_REUSEADDR：布尔值，允许多个套接字绑定相同地址（IP组播必备）
    // 必须设置在bind()之前
channel.setOption(StandardSocketOptions.SO_REUSEADDR, true);

  3. 广播与组播

    • SO_BROADCAST：启用广播传输（布尔值）
    • IP_MULTICAST_IF：指定组播网络接口（NetworkInterface类型）
    • IP_MULTICAST_TTL：组播生存时间（0-255整数）

  4. 服务质量

    • IP_TOS：IP头部服务类型字段（整数）

选项操作方法

通道提供三种核心操作方法：

// 设置选项（需在bind前调用部分选项）
channel.setOption(StandardSocketOptions.SO_RCVBUF, 65536);// 获取当前选项值
Integer rcvBuf = channel.getOption(StandardSocketOptions.SO_RCVBUF);// 检查支持的选项
Set> supported = channel.supportedOptions();

关键规范：SO_REUSEADDR和IP_MULTICAST_IF等选项必须在调用bind()方法前设置，否则会抛出IllegalArgumentException。

地址绑定策略

通过bind()方法实现两种绑定方式：

  1. 自动分配模式

    // 系统自动选择可用地址和端口
channel.bind(null);

  2. 指定绑定模式

    // 绑定到本地回环地址的8989端口
InetSocketAddress sAddr = new InetSocketAddress("localhost", 8989);
channel.bind(sAddr);// 组播通道需配合SO_REUSEADDR
channel.setOption(StandardSocketOptions.SO_REUSEADDR, true);
channel.bind(new InetSocketAddress(8989)); // 绑定所有接口

组播配置示例

完整组播通道初始化流程：

// 创建IPv4组播通道
DatagramChannel mcChannel = DatagramChannel.open(StandardProtocolFamily.INET).setOption(StandardSocketOptions.SO_REUSEADDR, true).bind(new InetSocketAddress(9999));// 设置组播参数
NetworkInterface ni = NetworkInterface.getByName("eth0");
mcChannel.setOption(StandardSocketOptions.IP_MULTICAST_IF, ni);
mcChannel.setOption(StandardSocketOptions.IP_MULTICAST_TTL, 64);

异常处理要点

  1. 选项冲突：尝试设置不支持的选项会抛出UnsupportedOperationException
  2. 绑定顺序：部分选项修改需在通道未绑定状态下进行
  3. 类型安全：错误的选项值类型会触发IllegalArgumentException

通过合理配置这些选项，可以优化数据报传输性能并满足特定网络场景需求。建议在生产环境中始终检查supportedOptions()返回集合并实现完备的异常处理逻辑。

数据报收发实战

send()方法特性与自动绑定

DatagramChannel的send()方法具有自动绑定特性：当在未绑定的通道上调用时，该方法会自动将通道绑定到可用地址。发送数据时需要准备ByteBuffer和目标地址：

// 准备发送内容（注意使用wrap()方法自动设置position/limit）
String msg = "Hello";
ByteBuffer buffer = ByteBuffer.wrap(msg.getBytes());// 指定目标地址
InetSocketAddress serverAddress = new InetSocketAddress("localhost", 8989);// 发送数据报（未绑定时自动绑定）
channel.send(buffer, serverAddress);

缓冲区注意事项：

  1. wrap()方法创建的缓冲区position为0，limit为数据长度
  2. 发送操作从buffer的position开始，到limit结束
  3. 发送后position会移动到limit位置

receive()方法行为差异

接收方法在不同阻塞模式下表现不同：

ByteBuffer buffer = ByteBuffer.allocate(1024);// 阻塞模式（默认）
SocketAddress remoteAddress = channel.receive(buffer); // 阻塞直到收到数据// 非阻塞模式
channel.configureBlocking(false);
SocketAddress remoteAddress = channel.receive(buffer); // 立即返回null（无数据时）

缓冲区处理要点：

  • 接收数据从buffer的position位置开始存储
  • 若剩余空间不足，多余数据会被静默丢弃
  • 接收成功后position会移动到数据末尾

ByteBuffer操作时序

完整的数据收发需要严格遵循缓冲区操作顺序：

// 接收阶段
buffer.clear();          // 准备接收（position=0, limit=capacity）
channel.receive(buffer); // 数据存入buffer
buffer.flip();           // 切换为读模式（limit=position, position=0）// 处理数据
byte[] bytes = new byte[buffer.remaining()];
buffer.get(bytes);       // 从buffer读取数据// 回发阶段
buffer.rewind();         // position重置为0（保持limit不变）
channel.send(buffer, clientAddr);
buffer.clear();          // 重置缓冲区准备下次使用

关键方法对比：

方法作用position变化limit变化
clear()重置为写入模式0=capacity
flip()切换为读取模式0=原position
rewind()重读数据（保持limit）0不变

Echo服务案例解析

服务端实现
public class DGCEchoServer {public static void main(String[] args) throws IOException {try (DatagramChannel server = DatagramChannel.open()) {server.bind(new InetSocketAddress("localhost", 8989));ByteBuffer buffer = ByteBuffer.allocate(1024);while (true) {// 接收阶段SocketAddress clientAddr = server.receive(buffer);buffer.flip();// 数据转换byte[] bytes = new byte[buffer.remaining()];buffer.get(bytes);String msg = new String(bytes);// 回发阶段buffer.rewind();server.send(buffer, clientAddr);buffer.clear(); // 必须清空以接收新数据}}}
}
客户端实现
public class DGCEchoClient {public static void main(String[] args) throws IOException {try (DatagramChannel client = DatagramChannel.open()) {client.bind(null); // 自动绑定// 发送消息ByteBuffer buffer = ByteBuffer.wrap("Hello".getBytes());client.send(buffer, new InetSocketAddress("localhost", 8989));// 接收回显buffer.clear();client.receive(buffer);buffer.flip();System.out.println("Server响应: " + new String(buffer.array(), 0, buffer.limit()));}}
}

典型输出示例：

// 服务端
Waiting for message at localhost/127.0.0.1:8989
Client at /127.0.0.1:53922 says: Hello// 客户端
Server响应: Hello

异常处理建议

  1. 缓冲区溢出：应确保接收缓冲区足够大（建议至少1024字节）
  2. 通道状态：在非阻塞模式下需检查receive()返回的null值
  3. 资源释放：使用try-with-resources确保通道关闭
  4. 网络中断：捕获IOException处理网络异常情况

完整实现展示了NIO数据报通道的核心工作流程，特别需要注意缓冲区状态转换的时序控制，这是保证数据正确收发的前提条件。

IP地址体系进阶

IPv4地址表示原理

IPv4采用32位二进制地址，通过点分十进制表示法转换为人类可读格式。每个十进制数对应8位二进制值（0-255范围），例如二进制11000000 10101000 00000001 11100111转换为192.168.1.231。地址分为网络标识（前缀）和主机标识（后缀）两部分，通过子网掩码确定分界位置。

// 二进制转点分十进制示例
int[] octets = { (binary >> 24) & 0xFF,  // 192(binary >> 16) & 0xFF,  // 168 (binary >> 8) & 0xFF,   // 1binary & 0xFF           // 231
};

五类网络划分标准

IPv4地址空间被划分为A-E五类网络：

类别前缀长度首位标识网络数主机数/网络
A8位012616,777,214
B16位1016,38465,534
C24位1102,097,152254
D-1110组播专用-
E-1111实验保留-

典型地址浪费场景：

  • C类网络仅需10个主机地址时，剩余244个地址闲置
  • B类网络连接300台主机需申请两个C类地址

CIDR与子网划分实践

无类别域间路由(CIDR)采用IP地址/前缀长度表示法（如192.168.1.0/24），突破传统类别的限制。通过子网掩码实现灵活划分：

// 计算网络地址示例
byte[] ip = { (byte)192, (byte)168, 1, 231 };
byte[] mask = { (byte)255, (byte)255, (byte)252, 0 }; // /22
byte[] network = new byte[4];
for (int i=0; i<4; i++) {network[i] = (byte)(ip[i] & mask[i]); // 192.168.0.0
}

关键操作：

  • 子网划分：借用主机位扩展网络位（如/24→/26）
  • 超网聚合：合并连续网络地址（如两个/24合并为/23）

IPv6地址表示法

128位IPv6地址采用8组4位十六进制数表示，零压缩规则允许用::替换连续的零值段（仅限使用一次）：

原始地址：2001:0db8:0000:0000:0000:ff00:0042:8329
压缩后：2001:db8::ff00:42:8329

混合表示法兼容IPv4：

::ffff:192.168.1.1

CIDR表示示例：

2001:db8:a0b:12f0::1/64

特殊规范：URL中使用IPv6地址必须用方括号包裹，如http://[2001:db8::1]:8080

技术总结

DatagramChannel 实现了 UDP 协议的高效 NIO 操作模型，其核心特性包括：

  1. 非阻塞模式优化：通过 configureBlocking(false) 启用可显著提升吞吐量
  2. 选项配置时序：关键选项如 SO_REUSEADDR 必须在 bind() 前设置
  3. 地址体系革新：IPv6 的 128 位地址空间彻底解决 IPv4 地址枯竭问题

典型开发注意事项：

// 必须设置的组播选项
channel.setOption(StandardSocketOptions.SO_REUSEADDR, true);
channel.setOption(StandardSocketOptions.IP_MULTICAST_IF, networkInterface);// 非阻塞模式最佳实践
channel.configureBlocking(false);
ByteBuffer buffer = ByteBuffer.allocate(2048); // 建议2KB最小缓冲区
while(true) {SocketAddress addr = channel.receive(buffer);if(addr == null) continue; // 非阻塞模式需处理null// ...数据处理逻辑
}

IPv6 特殊处理要求：

  • URL 中必须使用方括号包裹地址（如 http://[::1]）
  • 支持零压缩表示法（FF01::1 等效于 FF01:0:0:0:0:0:0:1）
  • 组播地址范围 FF00::/8 需特殊配置

实际开发应优先考虑非阻塞模式，并注意缓冲区大小设置（建议不小于 MTU 的 1500 字节），同时需区分 IPv4/IPv6 的协议族选择（StandardProtocolFamily.INET/INET6）。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.pswp.cn/pingmian/88224.shtml
繁体地址，请注明出处：http://hk.pswp.cn/pingmian/88224.shtml
英文地址，请注明出处：http://en.pswp.cn/pingmian/88224.shtml

如若内容造成侵权/违法违规/事实不符，请联系英文站点网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

147.在 Vue3 中使用 OpenLayers 地图上 ECharts 模拟飞机循环飞行

147.在 Vue3 中使用 OpenLayers 地图上 ECharts 模拟飞机循环飞行

&#x1f9e9; 效果预览 &#x1f447; 飞机从多个城市起飞并向其他城市飞行&#xff0c;动画流畅&#xff0c;地图可缩放拖拽&#xff1a; &#x1f4e6; 一、项目技术栈 技术用途Vue 3现代前端框架OpenLayers地图底图渲染ECharts ol-echarts飞机飞行动画渲染ol-echarts将 …
阅读更多...
OCR与PDF解析的区别

OCR与PDF解析的区别

我们日常所接触的文档中&#xff0c;经常能碰到多语言混合的文档。比如论文试卷、财报研报、跨国票据都含有多种语言和文字。要将文档中的内容识别并提取务必需要使用到OCR技术&#xff0c;而传统的OCR工具在处理这类型文档的时候有局限性。早期的 OCR 系统识别精度有限&#x…
阅读更多...
Java 单例类详解：从基础到高级，掌握线程安全与高效设计

Java 单例类详解：从基础到高级，掌握线程安全与高效设计

作为一名Java开发工程师&#xff0c;你一定对**单例模式&#xff08;Singleton Pattern&#xff09;**不陌生。它是23种经典设计模式中最简单也是最常用的一种&#xff0c;用于确保一个类在整个应用程序中只有一个实例存在。单例广泛应用于系统配置、数据库连接池、日志管理器、…
阅读更多...
面向对象设计

面向对象设计

你列出的这些属于 C 高级开发中面向对象设计与架构设计的核心知识&#xff0c;也是面试高级工程师岗位必问的内容。下面我按顺序&#xff0c;深入讲解每一项概念、原理、用途&#xff0c;并穿插 C 示例。✅ 1. 设计原则&#xff08;SOLID&#xff09;SOLID 是面向对象设计的五大…
阅读更多...
IntelliJ IDEA让我的开发效率翻倍：从新手到高效开发者的进阶之路

IntelliJ IDEA让我的开发效率翻倍：从新手到高效开发者的进阶之路

IntelliJ IDEA让我的开发效率翻倍&#xff1a;从新手到高效开发者的进阶之路 &#x1f31f; 嗨&#xff0c;我是IRpickstars&#xff01; &#x1f30c; 总有一行代码&#xff0c;能点亮万千星辰。 &#x1f50d; 在技术的宇宙中&#xff0c;我愿做永不停歇的探索者。 ✨ 用…
阅读更多...
css sprites使用

css sprites使用

CSS Sprites 是一种将多个小图标或背景图像合并到一个大图中的技术。通过减少HTTP请求次数&#xff0c;可以显著提高页面加载速度。其核心原理是&#xff1a;通过设置元素的背景图&#xff08;background-image&#xff09;为这个大图&#xff0c;然后调整背景位置&#xff08;…
阅读更多...
分布式爬虫在电商平台商品数据大规模采集中的技术应用

分布式爬虫在电商平台商品数据大规模采集中的技术应用

在电商平台商品数据大规模采集场景中&#xff0c;分布式爬虫凭借其高效、可扩展、抗风险的特性&#xff0c;成为突破单节点爬虫性能瓶颈的核心技术方案。以下从技术架构、关键技术点、电商场景适配及挑战应对四个维度&#xff0c;解析其具体应用&#xff1a;一、分布式爬虫的核…
阅读更多...
Linux的`if test`和`if [ ]中括号`的取反语法比较 笔记250709

Linux的`if test`和`if [ ]中括号`的取反语法比较 笔记250709

Linux的if test和if 中括号的取反语法比较 笔记250709 Linux的 test命令&#xff08;或等价中括号写法 [空格expression空格]&#xff09;的用法详解. 笔记250709 四种取反语法: if ! test -e xxx ;then... 和 if test ! -e xxx ;then... 和 if ! [ -e xxx ] ;then... 和 if …
阅读更多...
记录使用ubuntu16.04编译aosp(android8.1与10)遇到的问题

记录使用ubuntu16.04编译aosp(android8.1与10)遇到的问题

一、前言&#xff1a; 本来打算用wsl来编译AOSP&#xff0c;但是折腾了好几天&#xff0c;以失败告终。后来使用vmware反而成功了。 本篇同样会把wsl遇到的问题与尝试记录下来。 环境&#xff1a;vmware ubuntu16.04。 为什么会使用ubuntu16.04呢&#xff0c;因为在公司有一…
阅读更多...
hiredis window之RFDMap

hiredis window之RFDMap

简介 RFDMap用于将socket分配映射成连续的文件描述符&#xff0c;同时管理回收的文件描述符&#xff0c;因为ae构架中管理fd与对应事件处理器使用的是数据&#xff0c;fd作为数组下标 结构 #mermaid-svg-zQz2LTrKRi0LQTII {font-family:"trebuchet ms",verdana,arial…
阅读更多...
RustFS一款Rust 驱动的 高性能 分布式存储系统

RustFS一款Rust 驱动的 高性能 分布式存储系统

演示地址&#xff1a;https://play.rustfs.com/browser 访问账号&#xff08;默认 rustfsadmin&#xff09;。 访问密钥&#xff08;默认 rustfsadmin&#xff09;。 下载mc https://dl.min.io/client/mc/release可以直接在 Linux 系统上安装 mc&#xff08;&#xff0c;然后访…
阅读更多...
微软 Bluetooth LE Explorer 实用工具的详细使用分析

微软 Bluetooth LE Explorer 实用工具的详细使用分析

微软 Bluetooth LE Explorer 实用工具的详细使用分析 文章目录 微软 **Bluetooth LE Explorer** 实用工具的详细使用分析1. **工具定位与核心功能**2. **关键特性与更新**3. **使用场景示例**4. **系统要求与依赖**5. **与专业工具对比**6. **局限性**7. **实践建议**结论以下是…
阅读更多...
centos 7.6安装mysql8

centos 7.6安装mysql8

在 CentOS 7.6 上安装 MySQL 8.0.42 的步骤如下&#xff0c;基于搜索结果中的最新信息&#xff1a; 下载 MySQL 8.0.42 安装包 https://dev.mysql.com/downloads/mysql/从 MySQL 官方网站下载 mysql-8.0.42-1.el7.x86_64.rpm-bundle.tar 文件&#xff1a; 官方下载地址&#xf…
阅读更多...
CentOS7更换阿里云yum源

CentOS7更换阿里云yum源

问题&#xff1a;刚刚在本地安装了CentOS7虚拟机&#xff0c;使用yum安装vim软件时&#xff08;最小化安装只有vi没有vim&#xff09;出现下面的报错原因 &#xff1a;CentOS7 已于2024-6-30停止维护&#xff0c;官方镜像源已不可用&#xff0c;可以更换为阿里云镜像源解决&…
阅读更多...
UE5内置插件 AnimToTexture 简单入门

UE5内置插件 AnimToTexture 简单入门

开启插件 首先安装插件&#xff0c;然后重启。打开显示插件内容我们就可以找到插件自带的转换内容将骨骼网格体转换为顶点动画有两种方式&#xff1a; 最简单的记录每个顶点的位置然后通过切换拾取颜色偏移实现记录骨骼的变换&#xff0c;然后通过贴图去修改骨骼位置计算 这两种…
阅读更多...
如何搭建Appium环境？

如何搭建Appium环境？

&#x1f345; 点击文末小卡片&#xff0c;免费获取软件测试全套资料&#xff0c;资料在手&#xff0c;涨薪更快1、安装Java Development Kit&#xff08;JDK&#xff09;前往Oracle官网下载JDK。在https://www.oracle.com/java/technologies/javase-jdk11-downloads.html 找到…
阅读更多...
Android kotlin 协程的详细使用指南

Android kotlin 协程的详细使用指南

Android Kotlin 协程的详细使用指南&#xff0c;结合核心概念、实战场景和最佳实践&#xff1a;一、协程基础概念‌协程本质‌协程是轻量级线程&#xff0c;通过挂起/恢复机制实现并发&#xff0c;相比线程节省90%以上的内存开销。其核心优势在于结构化并发和挂起函数的协作式调…
阅读更多...
什么是 AMR 格式？简鹿音频转换器轻松批量转换 AMR 为 MP3

什么是 AMR 格式？简鹿音频转换器轻松批量转换 AMR 为 MP3

AMR 格式是一种比较特殊但又常见的音频格式&#xff0c;而MP3 格式则是大家耳熟能详的通用音频格式。那么&#xff0c;它们之间有什么区别&#xff1f;又该如何把 AMR 文件转换成更常用的 MP3 呢&#xff1f;下面我们就来通俗地了解一下。一、什么是 AMR 格式&#xff1f;AMR&a…
阅读更多...
C++11 std::move与std::move_backward深度解析

C++11 std::move与std::move_backward深度解析

文章目录移动语义的革命性意义std::move&#xff1a;正向范围移动函数原型与核心功能关键特性与实现原理适用场景与代码示例危险区域&#xff1a;重叠范围的未定义行为std::move_backward&#xff1a;反向安全移动函数原型与核心功能关键特性与实现原理适用场景与代码示例重叠范…
阅读更多...
订单初版—2.生单链路中的技术问题说明文档

订单初版—2.生单链路中的技术问题说明文档

大纲1.生单链路的业务代码2.生单链路中可能会出现数据不一致的问题3.Seata AT模式下的分布式事务的原理4.Seata AT模式下的分布式事务的读写隔离原理5.Seata AT模式下的死锁问题以及超时机制6.Seata AT模式下的读写隔离机制的影响7.生单链路使用Seata AT模式的具体步骤8.生单链…
阅读更多...
最新文章

Copyright @ 2022~2023