InterceptHandler精品文章

• 

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

  ...d notifyClientConnected(final MqttConnectMessage msg) { for (final InterceptHandler handler : this.handlers.get(InterceptConnectMessage.class)) { LOG.debug(Sending MQTT CONNECT ...

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

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

  ...); this.handlers = new HashMap(); for (Class messageType : InterceptHandler.ALL_MESSAGE_TYPES) { this.handlers.put(messageType, new CopyOnWriteArrayList()); } ...

  cfanr 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
• 

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

  ...攔截器處理其它業務 */ @Autowired @Qualifier(safetyInterceptHandler) private InterceptHandler safetyinterceptHandler; private Server mqttServer; public void startServer() throws IO...

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

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

  ...繁上下線和兩個設備ClientId一樣相互頂替連接的情況下，InterceptHandler的onConnect和onConnectionLost的方法調用沒有先后順序，如果在這兩個方法里面來記錄設備上下線狀態，會造成狀態不對。 io.moquette.spi.impl.ProtocolProcessor中的processConn...

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