moquette精品文章

• 

  moquette改造筆記(一)：整合到SpringBoot

  Moquette簡介 Mqtt作為物聯(lián)網(wǎng)比較流行的協(xié)議現(xiàn)在已經(jīng)被大范圍使用，其中也有很多開源的MQTT BROKEN。Moquette是用java基于netty實(shí)現(xiàn)的輕量級的MQTT BROKEN. Moquette基于Netty實(shí)現(xiàn)，性能問題至少前期可以不用考慮，在使用過程中還算穩(wěn)定...

  young.li 2019-08-19 11:12 評論0 收藏0
• 

  moquette改造筆記(三)：優(yōu)化BrokerInterceptor 中的線程池

  發(fā)現(xiàn)問題 在io.moquette.spi.impl.BrokerInterceptor的構(gòu)造函數(shù)中，新建了一個線程池，代碼如下： private BrokerInterceptor(int poolSize, List handlers) { LOG.info(Initializing broker interceptor. InterceptorIds={}, getInter...

  cfanr 2019-08-19 11:12 評論0 收藏0
• 

  moquette改造筆記(五)：設(shè)備連接頻繁上下線或者相互頂替出現(xiàn)的設(shè)備上下線狀態(tài)錯亂問題

  發(fā)現(xiàn)問題 在moquette使用中發(fā)現(xiàn)在設(shè)備頻繁上下線和兩個設(shè)備ClientId一樣相互頂替連接的情況下，InterceptHandler的onConnect和onConnectionLost的方法調(diào)用沒有先后順序，如果在這兩個方法里面來記錄設(shè)備上下線狀態(tài)，會造成狀態(tài)不對。 ...

  betacat 2019-08-19 11:13 評論0 收藏0
• 

  moquette改造筆記(二)：優(yōu)化BrokerInterceptor notifyTopicPu

  發(fā)現(xiàn)問題 下面部分是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()。經(jīng)過調(diào)試發(fā)現(xiàn)是MoquetteIdleTimeoutHandler中的代碼導(dǎo)致的，代碼如下： @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { ...

  joyqi 2019-08-19 11:13 評論0 收藏0