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的,这个也以后再写。
先结束了。