并且当多个客户端，连接到同一个canal 服务端，如果此时客户端感兴趣的数据库和表是相同的，则只有一个客户端能够接收到具体的Binlog数据，从而避免重复消费；canal server在默认情况下使用了RocketMQ作为消息队列，用于将解析出的binlog数据发送到下游的消费端，实现数据的异步传输和消息的可靠投递。至此消息消费的代码完成，从消费端可以看到，通过定义好的CanalConnector

1 Nginx 介绍：Nginx（发音为“engine-x”）是用于 HTTP、HTTPS、SMTP、POP3 和 IMAP 协议的开源反向代理服务器，以及负载平衡器、HTTP 缓存和 Web 服务器（源服务器）2 搜索nginx：docker search nginx3 下载nginx 镜像：docker pull docker.io/nginx4 查看nginx 镜像：docker image

docker 安装xxl-job

Zookeeper1 新建 Zookeeper 目录，data 及log 目录解释：conf 用于存放配置文件Data 用于存放内存数据库的快照Datalog : 用于存放数据库的事务日志2 配置zoo.cfgclientPort=2181dataDir=/datadataLogDir=/datalogtickTime=2000initLimit=5syncLimit=3autopurge.sna

参考：https://www.runoob.com/docker/docker-install-mysql.html1 查看mysql 的版本docker search mysql2 下载mysql 的：docker pull mysql:tagTag 为要下载的版本，可参考下面地址https://hub.docker.com/_/mysql?tab=tags3 查看镜像docker images

2.1）首先KafkaTemplate 它默认没有开启事务的支持，所以需要先开启事务（事务开启的方式可能跟kafka客户端的版本有关，此处不在进行列举 本篇的demo 通过配置transactional.id 参数开启事务消息），需要注意的是当一个 KafkaTemplate 对象开启了事务之后，仅可以发送事务消息，而不能发送非事务消息，所以需要在项目中定义两个KafkaTemplate ，一个用

在这种情况下，如果开启了 mandatory 参数，那么无法匹配到队列的消息就会被视为不可路由，从而触发 ReturnCallback，同时也会在消息到期后被重新路由到延迟队列中，如果在ReturnCallback 方法中重写进行消息的发送，最终会有两条相同的消息，导致该消息被重复消费，这就是同时收到延迟消息和路由失败消息的原因。RabbitMQ 提供了可靠的消息传递机制，能够保证消息的可靠性和可

作为一个国产的消息中间件，阿里参考Kafka 开发了RocketMq 进行消息通信，它具有分布式，高可用、高吞吐、可伸缩的特性，本文对于其模型进行探究；模型图中已经展示了RocketMq的几个重要组件，与kafka 不同的是这里多出了一个叫NameServer的组件；对broker 进行维护，并对消息消息进行路由；

Docker--Mqtt(eclipse-mosquitto)安装

封装数据库连接池和连接的获取逻辑：AbstractRoutingDataSource 通过封装多个数据源连接池的实现细节，屏蔽底层数据源的细节，使得业务代码不需要关心连接的获取和释放，从而简化了业务代码的编写。(3). 实现数据源的动态切换：AbstractRoutingDataSource 可以通过动态切换数据源，实现数据源的动态切换，从而在不影响系统正常运行的情况下，能够对数据源进行升级、迁移