同步操作将从 54lyll/cooser 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
CSDN:https://blog.csdn.net/qq_42022528/article/details/109387773
Cooser是基于Netty框架搭建的Reactor模式高性能,可扩展的网络服务器。基于Netty对NIO的多路复用机制,高效利用cpu硬件资源,优化服务器并发连接性能,达到伸缩性要求。我司业务场景为常量连接(十百千),大量请求,作为底层TCP服务器,从数据传输体量、解析性能考虑,采用Google Protobuf通信协议,自定义传输数据结构。Disruptor是一款极速并发框架,Cooser引入它作为中间消息队列,将网络数据接收和业务处理逻辑单元解耦,极大提升服务器吞吐性能,同时保持低延迟。在网络请求处理链路的多个环节,开发了插拔组件API,如Channel生命周期监听,请求事件的前后置拦截器,业务处理类MVC模式,使cooser成为一个在业务上具有高扩展性的服务器开发框架。
ChannelFuture future = CooServer.newInstance(ProtocolMessage.DEFAULT_PROTOCOL)
.maxConnection(1024)
.componentScan("com.wonderzh.cooser.example")
.performance(CooServer.Performance.NORMAL)
.enableAnonymous(true)
.bind(8090);
基于springboot启动,在@SpringBootApplication启动类上使用@EnableCooser。 Apllication.yml文件配置参数
cooser:
server:
port: 8090 #端口号
max-connection: 5000 #最大连接数
heart-time: 300 #心跳监听时间,单位秒
component-scan: com.smartwater.data #组件扫描包路径
performance: normal #服务器业务消费侦听线程性能
anonymous-enable: false #是否允许匿名访问
服务器初始化主要做三件工作
服务器对网络请求处理的主要由三个功能模块承载,分别为请求消息生产MessageDuplexHandler、请求业务处理MessageProcessor以及综合调度FrameDispatcher。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。