讲师中心 微信公众号
AI工具推荐 视频效率加速

如何使用NIO编写高并发的Echo回显聊天服务器后端逻辑

秋杰同学_4044

秋杰同学_4044

发布时间:2026-04-08 20:53:32

|

697人浏览过

|

来源于php中文网

原创

NIO高并发Echo服务器核心是Selector事件驱动与Buffer高效管理:初始化非阻塞ServerSocketChannel并注册OP_ACCEPT;ACCEPT时创建非阻塞SocketChannel并注册OP_READ;READ时用flip/decode处理粘包,clear/compact管理Buffer;WRITE未完成时追加OP_WRITE并暂存Buffer,就绪后继续写完再恢复OP_READ。

如何使用nio编写高并发的echo回显聊天服务器后端逻辑

用NIO写高并发Echo聊天服务器,核心是避免阻塞、复用线程、高效处理连接与读写。不依赖Tomcat或Netty,纯JDK NIO(java.nio.channels)即可实现万级并发连接,关键在Selector事件驱动模型和Buffer的合理使用。

初始化非阻塞ServerSocketChannel与Selector

启动时创建ServerSocketChannel并设为非阻塞,注册OP_ACCEPT事件到Selector:

  • 调用ServerSocketChannel.open()获取通道,configureBlocking(false)关闭阻塞
  • 绑定端口:socket().bind(new InetSocketAddress(port))
  • 注册到Selector:channel.register(selector, SelectionKey.OP_ACCEPT)
  • 后续所有I/O操作都基于selector.select()轮询就绪事件,不再调用accept()/read()/write()阻塞等待

处理ACCEPT事件:接收新连接并注册读事件

当selector检测到ServerSocketChannel就绪,说明有客户端connect,此时需主动accept并为新连接配置读事件:

  • 调用serverChannel.accept()获取SocketChannel,同样设为configureBlocking(false)
  • 为该SocketChannel分配一个ByteBuffer(如4KB),用于后续读取数据;可存入SelectionKey的attachment中便于复用
  • 注册OP_READ事件:clientChannel.register(selector, OP_READ, attachment)
  • 注意:不要在accept后立即read——此时TCP缓冲区可能为空,必须等下一次select触发READ就绪

处理READ事件:解析消息并触发ECHO逻辑

当某SocketChannel就绪READ,说明有数据到达,需从Buffer中提取完整消息(注意粘包/半包):

  • 调用channel.read(buffer),返回值>0表示读到字节,=0表示无数据(但已就绪,可能是空心跳),-1表示对端关闭
  • 切换buffer为读模式:buffer.flip(),然后用StandardCharsets.UTF_8.decode(buffer)转成字符串
  • 简单Echo场景可直接将原消息回写;若需按行或定长协议,需自行缓冲未完成的数据(例如把剩余字节复制到新buffer开头)
  • 清空buffer:buffer.clear(),为下次read准备;若消息较大,建议使用compact()保留未读部分

处理WRITE事件:异步回写响应并管理写状态

NIO写操作可能未一次完成(如网络慢、缓冲区满),不能直接write后就认为发送成功:

  • 向channel.write(buffer)后,检查返回值是否等于buffer.remaining();若小于,则说明未写完,需注册OP_WRITE等待再次就绪
  • 推荐做法:首次write后,若未写完,将channel的SelectionKey改为只关注OP_WRITE,并把待写buffer存在attachment中
  • 当OP_WRITE就绪,继续write剩余内容;写完后,取消OP_WRITE,重新注册OP_READ,恢复读取新消息
  • 避免频繁注册/取消事件,可用key.interestOps(ops | SelectionKey.OP_WRITE)追加,用&运算移除

整个流程围绕一个线程(或少量线程)+ Selector展开,没有每个连接一个线程的开销。消息编解码、连接生命周期、心跳保活等可在此骨架上扩展。不复杂但容易忽略缓冲区管理和事件状态切换。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

相关专题

更多
python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2403

2023.08.11

前端和后端的区别
前端和后端的区别

前端关注的是用户界面的设计和交互,而后端则注重数据处理和逻辑控制。想了解更多前端后端的相关内容,可以阅读本专题下面的文章。

6250

2024.03.19

后端的主要工作内容介绍
后端的主要工作内容介绍

后端是应用程序的服务端部分,负责核心任务,如数据库交互、业务逻辑处理和响应客户端请求。想了解更多后端的相关内容,可以阅读本专题下面的文章。

5606

2024.03.19

java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

10237

2023.06.15

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

7362

2023.07.05

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

6472

2023.07.31

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

1104

2023.08.01

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

908

2023.08.02

PixTV官网入口地址合集
PixTV官网入口地址合集

本专题汇总了 PixTV AI 一站式视频创作平台的官方入口与使用教程。无需下载软件,浏览器直接访问即可使用。平台将剧本、图像、视频、声音与剪辑整合在“无限画布”中,接入 GPT Image 2.5、Seedance 2.5 等头部模型。本专题整理了从新建画布、角色锚定、分镜拆分到视频生成与导出的完整操作指南,助你快速上手 AI 短剧与漫剧创作。

40

2026.10.10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn