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

 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

 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/