Linlin xiao

mee too python36

依据我的理解，netty就开放了一个容器服务。websocket从协议上，netty也可以支持实现的，就好比如，activemq：支持AMQP，也支持MQTT等协议一样。

mqttws31.js 前端用这个组件连接下，或者找个java的mqtt组件连接一下。确认下服务是OK的

你这个是跨域

1.并行的情况下，这个有序性确实很难保障，我们的场景是做缓存和ES，所以当时没有将有序性考虑进去，如果你们的业务需要保证有序性建议就是上MQ,canal也支持MQ。 2.这里的采用的是异步，也就是达到快速消化binlog日志的目的，此外disruptor是个循环队列，如果消费者不及时也会覆盖原有的内容，如果disruptor设置过大也会很容易导致OOM。 3.我们当前的架构已经更换成MQ：Canal client -> Mq(Mongdb) ->业务处理(Redis、ES等) ，这样既可以做有序性的保证，也可以做可靠性性保证

这个核心原理思路是这样走的，现有的架构加入了MQ变得了复杂很多，而且定制化比较高。只要明白核心思路，其他的都是依据自身业务来扩展的。

2023.3.1版本 同样的问题