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