1. 程式人生 > >MQTT---HiveMQ源代碼具體解釋(七)Netty-SSL/NoSSL

MQTT---HiveMQ源代碼具體解釋(七)Netty-SSL/NoSSL

都是 strac 解釋 mod key cto split slc watermark

源博客地址:http://blog.csdn.net/pipinet123


MQTT交流群:221405150


實現功能

依據用戶配置的不同的Listener(TcpListener、TlsTcpListener、WebsocketListener、TlsWebsocketListener),為pipeline中加入不同的Handler

實現步驟

1、依據Listener不同,生成不同的Handler
2、加入到pipeline中。讓其為每個client服務

類圖

技術分享

由上圖能夠看出針對不同的Listener都會有相應類型的ChannelInitializer去初始化Transport Channel,明確這一點,那就好理解了。


1、ChannelInitializerFactory是AbstractChannelInitializer的一個工廠類,針對不同的Listener,能夠生成不同的ChannelInitializer。

2、ChannelInitializerFactory去推斷Listener類型。去創建相應的AbstractChannelInitializer,
TlsTcpChannelInitializer、
WebsocketChannelInitializer、
TlsWebsocketChannelInitializer都是AbstractChannelInitializer的實現類。

3、通過實現AbstractChannelInitializer的initTransportChannel。將相應的Handler加入到pipeline中。

4、若是TcpListener、WebsocketListener。則將NoSslHandler加入到pipeline中,來阻止ssl連接

技術分享

5、SslContextStore是持有Tls和SslContext的映射關系的一個倉庫。加單點說就是key為Tls,value為SslContext的map的封裝類。

6、SslFactory通過Channel和Tls創建SslHandler,並設置SSLEngine, 以達到SSL認證,詳細的認證過程以及處理都是屬於標準ssl處理流程。 使用netty的SslHandler去完畢。什麽是雙向認證、單向認證等概念。 就須要大家自行研究,不屬於本博文的內容。

借此我們就能夠知道hivemq實際上是通過Listener的類型不同,

創建不同的AbstractChannelInitializer,實現initTransportChannel方法,

去為pipeline中加入SslHandler/NoSslHandler

MQTT---HiveMQ源代碼具體解釋(七)Netty-SSL/NoSSL