首页 > 代码库 > MQTT---HiveMQ源代码具体解释(七)Netty-SSL/NoSSL

MQTT---HiveMQ源代码具体解释(七)Netty-SSL/NoSSL

源博客地址: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

<script type="text/javascript"> $(function () { $(‘pre.prettyprint code‘).each(function () { var lines = $(this).text().split(‘\n‘).length; var $numbering = $(‘
    ‘).addClass(‘pre-numbering‘).hide(); $(this).addClass(‘has-numbering‘).parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($(‘
  • ‘).text(i)); }; $numbering.fadeIn(1700); }); }); </script>

MQTT---HiveMQ源代码具体解释(七)Netty-SSL/NoSSL