Docker环境下搭建Rabbitmq以及用Python实现生产

Rabbitmq的用处以后再说。

Rabbitmq的存储也以后再说。

先上Docker命令，我只挂载了一个目录，可以把消息队列的内容挂载到本机上，这样容器重启数据也不会丢，消息队列信息也不会丢。

sudo docker run -d  -p 5672:5672 -p 15672:15672  -v /你的目录:/var/lib/rabbitmq/: rabbitmq:management

然后我们去到

https://www.rabbitmq.com/getstarted.html

点击Topic下的Python查看

其中P是消息生产者，C是消息消费者。

X是交换机，消息首先来到交换机这里。

*.orange.*是key，根据消费者P传来的key，匹配后传给对应的队列Q，匹配的队列可以是一个、多个和没有。

然后我们打开http://localhost:15672/

这是rabbitmq的管理界面，默认登录用户密码为guest/guest。

我们建了一个交换机，叫Java，Type选择了Topic，Durability这个选择了Durable（Durable可以让你的交换机一直存在，不然重启一次就没了）。

我们建立一个队列叫Spring4，对应的Durability也选择Durable。

我们点击Exchanges中的Java。

然后我们绑定 交换机和队列，key为LaLa.*

我们用python发送一条消息。

然后我们去队列里看一下这条消息。

然后我们消费一下。

然后我们去web那看一下。

这个消息被消费了已经没了。然后消费者正常是要返回给Rabbitmq一个ack表明已经消费此条消息的，这个以后再写，生产者对应也需要发送一个标志告诉Rabbitmq的，这个也以后再写。

先结束了。