Disruptor 学习项目,基于 3.4.2 版本
基于 Disruptor 3.4.2 版本
disruptor-study
- disruptor-common: 基础工具包
- disruptor-source: 官方源码包
- disruptor-demo:新增 Case
- disruptor-netty-server: Disruptor 整合 Netty 服务端
- disruptor-netty-client: Disruptor 整合 Netty 客户端
以完成 Disruptor Case 包括:
jit.wxs.disruptor.demo.quickstart
jit.wxs.disruptor.demo.quickstart2
jit.wxs.disruptor.demo.multi
jit.wxs.disruptor.demo.ringbuffer
jit.wxs.disruptor.demo.ringbuffer2
以完成 Test Case 包括:
jit.wxs.disruptor.demo.flashsharing
jit.wxs.disruptor.demo.oom
该 Case 的重点并不是 Netty,因此关于 Netty 部分使用了最简单的启动代码。
实现的效果是客户端向服务端通过 Netty 长连接的方式发送数据,Netty 端接收到数据后,根据用户所属的分片,分发到对应的 RingBuffer 中进行消费。
jit.wxs.disruptor.netty.server.NettyServerMain
jit.wxs.disruptor.netty.client.NettyClientMain