内容简介:Magician 1.1.6,作为第一个正式的版本,内部对NIO的实现部分做了大量优化与重构,采用了事件组管理机制,具体模型如下图所示: 采用了两个事件组来进行事件和线程池的管理,一个叫ioEventGroup,一个叫workerEve...
Magician 1.1.6,作为第一个正式的版本,内部对NIO的实现部分做了大量优化与重构,采用了事件组管理机制,具体模型如下图所示:
采用了两个事件组来进行事件和线程池的管理,一个叫ioEventGroup,一个叫workerEventGroup,都是通过EventGroup类创建。 每个EventGroup 都对应一个EventRunner,每个EventRunner对应一个任务队列,可以管理多个事件。 当队列空了以后,可以去其他的EventRunner窃取任务,不会造成资源浪费。
ioEventGroup是用来管理Selector的,一个端口对应一个EventRunner里的一个事件,也就是说如果要监听多个端口就需要在ioEventGroup初始化多个EventRunner,这么做是因为EventRunner是按顺序消费事件的,如果多个监听事件都给一个EventRunner管理,可能会执行不到后面的事件,因为Selector是一个死循环 他会一直占用当前线程。
workerEventGroup是用来管理 业务事件的,一个连接对应一个EventRunner,一个EventRunner对应多个连接,当连接里有了read事件就会往EventRunner里添加一个事件,EventRunner会按顺序消费这些事件,在消费时 如果发现协议报文不完整会立刻停止该事件 继续执行下一个,如果报文完整会调用handler执行业务逻辑。 建议按照CPU的核心数来合理的设置workerEventGroup里的EventRunner数量。
具体如何使用
一、创建TCP服务(默认使用http解码器)
创建Handler
public class DemoHandler implements MagicianHandler<MagicianRequest> {
@Override
public void request(MagicianRequest magicianRequest) {
// 响应数据
magicianRequest.getResponse()
.sendJson(200, "{'status':'ok'}");
}
}
创建服务(默认线程池配置)
Magician.createTCPServer()
.httpHandler("/", new DemoHandler())
.bind(8080);
创建服务(自定义线程池配置)
EventGroup ioEventGroup = new EventGroup(1, Executors.newCachedThreadPool());
EventGroup workerEventGroup = new EventGroup(10, Executors.newCachedThreadPool());
// 当前EventRunner没任务的时候,允许从其他EventRunner窃取任务
workerEventGroup.setSteal(EventEnum.STEAL.YES);
Magician.createTCPServer(ioEventGroup, workerEventGroup)
.httpHandler("/", new DemoHandler())
.bind(8080);
创建服务(监听多端口)
// 监听几个端口,ioEventGroup的第一个参数就写几
EventGroup ioEventGroup = new EventGroup(2, Executors.newCachedThreadPool());
EventGroup workerEventGroup = new EventGroup(10, Executors.newCachedThreadPool());
// 当前EventRunner没任务的时候,允许从其他EventRunner窃取任务
workerEventGroup.setSteal(EventEnum.STEAL.YES);
TCPServer tcpServer = Magician
.createTCPServer(ioEventGroup, workerEventGroup)
.httpHandler("/", new DemoHandler())
tcpServer.bind(8080);
tcpServer.bind(8088);
二、创建WebSocket
只需要在创建http服务的时候加一个handler即可
Magician.createTCPServer()
.httpHandler("/", new DemoHandler())
.webSocketHandler("/websocket", new DemoSocketHandler())
.bind(8080);
三、创建UDP服务
Magician.createTCPServer()
.httpHandler("/", new DemoHandler())
.webSocketHandler("/websocket", new DemoSocketHandler())
.bind(8080);
除了这种写法,也可以单独创建handler,在这里add进去
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网
猜你喜欢:- Monibuca 2.0 发布,采用新型转发机制
- 所有开发人员都注意了!苹果将正式采用Notarization机制
- Lua 5.4.0 Beta 发布:采用新一代的垃圾回收机制
- 分布式中采用Logback的MDC机制与AOP切面结合串联日志
- 【译】采用微前端架构
- DevOps采用现状情况报告
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。