[聚合文章] MQTT---HiveMQ源码详解(五)Netty-启动与Listeners加载

---

public ListenableFuture<List<ListenerStartResult>> startListeners() {//为netty注册Shutdown，为了使netty主线程在关闭时，能够关闭掉worker和boss        this.shutdownRegistry.register(new NettyShutdown(this.childEventLoop, this.parentEventLoop, this.hiveMQConfigurationService.internalConfiguration().getInt(Internals.EVENT_LOOP_GROUP_SHUTDOWN_TIMEOUT)));        //记录Listener启动的结果的Future列表，方便在日志/控制台中打印出Listener绑定的结果。        List<ListenerStartFuture> startFutures = new ArrayList<>();        //如果用户未配置Listener，那么将默认添加一个绑定到1883端口TcpListener        addDefaultListenerWhenListenersIsEmpty();//从用户配置中获得到TcpListeners绑定到netty上 startFutures.addAll(startTcpListeners(this.listenerConfigurationService.getTcpListeners()));//从用户配置中获得到TlsTcpListeners绑定到netty上         startFutures.addAll(startTlsTcpListeners(this.listenerConfigurationService.getTlsTcpListeners()));//从用户配置中获得到WebsocketListeners绑定到netty上startFutures.addAll(startWebsocketListeners(this.listenerConfigurationService.getWebsocketListeners()));//从用户配置中获得到TlsWebsocketListeners绑定到netty上startFutures.addAll(startTlsWebsocketListeners(this.listenerConfigurationService.getTlsWebsocketListeners()));//将一堆启动的Future转换成一个Future，让调用者（HiveMQServer）方便使用。        return getStartResult(startFutures);    }

由上面的过程可以知道,具体代码处理流程
1、由HiveMQServer，调用NettyServer的start，启动netty。
2、然后再调用startListeners,将配置的Listeners绑定到netty上

---

MQTT交流群:221405150

RocketMQ交流群:10648794

NewSQL交流群:153575008

注：本文内容来自互联网，旨在为开发者提供分享、交流的平台。如有涉及文章版权等事宜，请你联系站长进行处理。