Python通过RabbitMQ服务器实现交换机功能的实例教程(Python通过行和列提取数据)

编辑：rootadmin

推荐整理分享Python通过RabbitMQ服务器实现交换机功能的实例教程(Python通过行和列提取数据)，希望有所帮助，仅作参考，欢迎阅读内容。

文章相关热门搜索词:Python通过按键触发代码执行,Python通过什么语句可以直接创建变量,Python通过按键触发代码执行,Python通过值找对应的键,Python通过值找对应的键,Python通过类可以创建对象,有且只有一个对象,Python通过行和列提取数据,Python通过类可以创建对象,有且只有一个对象,内容如对您有帮助，希望把文章链接给更多的朋友！

快速回顾一下RabbitMQ服务器的安装：

Python使用RabbitMQ需要Pika库：

好了，接下来我们先看交换机的工作原理：消息发送端先将消息发送给交换机，交换机再将消息发送到绑定的消息队列，而后每个接收端都能从各自的消息队列里接收到信息。

下面用send.py和receive.py来模拟实现交换机的功能。send.py表示发送端，receive.py表示接收端。

receive.py：

上例代码中，queue_declare的参数exclusive=True表示当接收端退出时，销毁临时产生的队列，这样就不会占用资源。运行这个程序，然后使用rabbitmqctl list_exchanges命令来查看交换机信息：

Python通过RabbitMQ服务器实现交换机功能的实例教程(Python通过行和列提取数据)

其中红色框就是上例定义的交换机了。再使用rabbitmqctl list_queues查看下消息队列情况：

其中红色框就是随机产生的消息队列了。

send.py：

上例代码中， basic_publish方法的参数exchange被设定为相应交换机，因为是要广播出去，发送到所有队列，所以routing_key就不需要设定了。

exchange如果为空，表示是使用匿名的交换机，在上面交换机信息的图片中可以看到有amq.*这样的交换机，就是系统默认的交换机了。routing_key在使用匿名交换机的时候才需要指定，表示发送到哪个队列的意思。第一篇的例子演示了这个功能。

打开另外一个终端，执行send.py，可以观察到receive.py接收到了消息。如果有多个终端执行receive.py，那么每个receive.py都会接收到消息。

Python操作RabbitMQ服务器实现消息队列的路由功能 Python使用Pika库（安装：sudopipinstallpika）可以操作RabbitMQ消息队列服务器（安装：sudoapt-getinstallrabbitmq-server），这里我们来看一下MQ相关的路由功能。路由

详解Python操作RabbitMQ服务器消息队列的远程结果返回先说一下笔者这里的测试环境：Ubuntu.+Python2.7.4RabbitMQ服务器sudoapt-getinstallrabbitmq-serverPython使用RabbitMQ需要Pika库sudopipinstallpika远程结果返回消息发送端

浅谈python中set使用浅谈python中set使用In[2]:a=set()#常用操作1In[3]:aOut[3]:set()In[4]:type(a)Out[4]:setIn[5]:b=set([1,3])In[6]:bOut[6]:{1,3}In[7]:type(b)Out[7]:setIn[8]:b.update(2)------------------------------