InterceptHandler

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