python_rabbitmq

python客户端采集上传rabbitmq到入库示例。解决一个消息队列到DB的幂等的问题。场景：多条命令提交队列，命令1清除用户对应的数据库表格，命令2-10插入和更新相关表，需要保证多条命令的执行顺序，否则提交数据会被清除。

1、springboot

2、mysql

3、rabbitmq

4、python 客户端

更新日志：

2019-11-8 跑通流程。python pika mqtt消息确认重发。消息体加密和解密传输。

2019-11-14 rabbitmq 增加路由队列，分发到俩个DB消费队列。

2019-11-14 rabbitmq DB消费队列增加24小时不处理完毕进入死信队列。

计划日志：

集群配置。

分布式DB的集成应用。

使用说明：

1、centos 7 下安装rabbitmq

docker search rabbitmq:management

docker pull rabbitmq:management

docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management

docker ps -a 查看容器

docker rm XXX删除容器

2、下载代码，下载consul

3、运行consul_start.cmd 。编译运行java -jar xxxx.jar

架构说明：