|
|
@ -75,6 +75,7 @@ public class EmbedServer {
|
|
|
|
.addLast(new IdleStateHandler(0, 0, 30 * 3, TimeUnit.SECONDS)) // beat 3N, close if idle
|
|
|
|
.addLast(new IdleStateHandler(0, 0, 30 * 3, TimeUnit.SECONDS)) // beat 3N, close if idle
|
|
|
|
.addLast(new HttpServerCodec())
|
|
|
|
.addLast(new HttpServerCodec())
|
|
|
|
.addLast(new HttpObjectAggregator(5 * 1024 * 1024)) // merge request & reponse to FULL
|
|
|
|
.addLast(new HttpObjectAggregator(5 * 1024 * 1024)) // merge request & reponse to FULL
|
|
|
|
|
|
|
|
//执行
|
|
|
|
.addLast(new EmbedHttpServerHandler(executorBiz, accessToken, bizThreadPool));
|
|
|
|
.addLast(new EmbedHttpServerHandler(executorBiz, accessToken, bizThreadPool));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
})
|
|
|
|
})
|
|
|
@ -85,7 +86,7 @@ public class EmbedServer {
|
|
|
|
|
|
|
|
|
|
|
|
logger.info(">>>>>>>>>>> xxl-job remoting server start success, nettype = {}, port = {}", EmbedServer.class, port);
|
|
|
|
logger.info(">>>>>>>>>>> xxl-job remoting server start success, nettype = {}, port = {}", EmbedServer.class, port);
|
|
|
|
|
|
|
|
|
|
|
|
// start registry
|
|
|
|
//注册当前节点
|
|
|
|
startRegistry(appname, address);
|
|
|
|
startRegistry(appname, address);
|
|
|
|
|
|
|
|
|
|
|
|
// wait util stop
|
|
|
|
// wait util stop
|
|
|
|