moquette精品文章

• 

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

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

  young.li 2019-08-19 11:12 評(píng)論0 收藏0
• 

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

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

  cfanr 2019-08-19 11:12 評(píng)論0 收藏0
• 

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

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

  betacat 2019-08-19 11:13 評(píng)論0 收藏0
• 

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

  發(fā)現(xiàn)問(wè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 評(píng)論0 收藏0
• 

  moquette改造筆記(四)：解決InterceptHandler中的onConnectionLo

  ...常斷開(kāi),InterceptHandler中的onConnectionLost()。經(jīng)過(guò)調(diào)試發(fā)現(xiàn)是MoquetteIdleTimeoutHandler中的代碼導(dǎo)致的，代碼如下： @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { ...

  joyqi 2019-08-19 11:13 評(píng)論0 收藏0