Magician 1.1.6 发布，采用事件组管理机制

栏目: 软件资讯 · 发布时间: 4年前

内容简介：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进去

官网：http://magician-io.com/

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

现代信息检索

（西班牙） Ricardo Baeza-Yates、（巴西）Berthier Ribeiro-Neto / 机械工业出版社 / 2011-3 / 78.00元

本书不仅详细介绍了信息检索的所有主要概念和技术，以及有关信息检索面的所有新变化，而且其组织使读者既可以对现代信息检索有一个全面的了解，又可以获取现代信息检索所有关键主题的详细知识。本书的主要内容由信息检索领域的代表人物Baeza-Yates和Ribeiro-Neto编写，对于那些希望深入研究关键领域的读者，书中还提供了由其他主要研究人员编写的关于特殊主题的发展现状。与上一版相比，本版在内容......一起来看看《现代信息检索》这本书的介绍吧!

码农工具