moquette

moquette精品文章

• 

  moquette改造笔记(一)：整合到SpringBoot

  Moquette简介 Mqtt作为物联网比较流行的协议现在已经被大范围使用，其中也有很多开源的MQTT BROKEN。Moquette是用java基于netty实现的轻量级的MQTT BROKEN. Moquette基于Netty实现，性能问题至少前期可以不用考虑，在使用过程中还算稳定...

  young.li 2019-08-19 11:12 评论0 收藏0
• 

  moquette改造笔记(三)：优化BrokerInterceptor 中的线程池

  发现问题 在io.moquette.spi.impl.BrokerInterceptor的构造函数中，新建了一个线程池，代码如下： private BrokerInterceptor(int poolSize, List handlers) { LOG.info(Initializing broker interceptor. InterceptorIds={}, getInter...

  cfanr 2019-08-19 11:12 评论0 收藏0
• 

  moquette改造笔记(五)：设备连接频繁上下线或者相互顶替出现的设备上下线状态错乱问题

  发现问题 在moquette使用中发现在设备频繁上下线和两个设备ClientId一样相互顶替连接的情况下，InterceptHandler的onConnect和onConnectionLost的方法调用没有先后顺序，如果在这两个方法里面来记录设备上下线状态，会造成状态不对。 ...

  betacat 2019-08-19 11:13 评论0 收藏0
• 

  moquette改造笔记(二)：优化BrokerInterceptor notifyTopicPu

  发现问题 下面部分是io.moquette.spi.impl.BrokerInterceptor.java部分源码 @Override public void notifyClientConnected(final MqttConnectMessage msg) { for (final InterceptHandler handler : this.handlers.ge...

  liangzai_cool 2019-08-19 11:12 评论0 收藏0
• 

  moquette改造笔记(四)：解决InterceptHandler中的onConnectionLo

  ...常断开,InterceptHandler中的onConnectionLost()。经过调试发现是MoquetteIdleTimeoutHandler中的代码导致的，代码如下： @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { ...

  joyqi 2019-08-19 11:13 评论0 收藏0