python学习笔记-（十五）RabbitMQ队列

rabbitMQ是消息队列；想想之前的我们学过队列queue：threading queue（线程queue，多个线程之间进行数据交互）、进程queue（父进程与子进程进行交互或者同属于同一父进程下的多个子进程进行交互）；如果两个独立的程序，那么之间是不能通过queue进行交互的,这时候我们就需要一个中间代理即rabbitMQ

消息队列：

RabbitMQ
ZeroMQ
ActiveMQ
...........

一. 安装

1.1 安装: sudo apt-get install rabbitmq-server

1.2 启动rabbitmq web服务：

sudo invoke-rc.d rabbitmq-server stop
sudo invoke-rc.d rabbitmq-server start
启动web管理：sudo rabbitmq-plugins enable rabbitmq_management

1.3 远程访问rabbitmq，自己增加一个用户，步骤如下：

创建一个admin用户：sudo rabbitmqctl add_user admin 123123
设置该用户为administrator角色：sudo rabbitmqctl set_user_tags admin administrator
设置权限：sudo rabbitmqctl set_permissions -p '/' admin '.' '.' '.'
重启rabbitmq服务：sudo service rabbitmq-server restart

之后就能用admin用户远程连接rabbitmq server了。

2. 安装python rabbitMQ modul：

管理员打开cmd，切换到python的安装路径，进入到Scripts目录下（如：C:\Users\Administrator\AppData\Local\Programs\Python\Python35\Scripts）；
执行以下命令：pip install pika
校验是否安装成功：进入到python命令行模式，输入import pika，无报错代表成功；

二. 代码实现

1. 实现最简单的队列通信

python学习笔记-（十五）RabbitMQ队列

发送端：

import pika

credentials = pika.PlainCredentials('admin', '123123')

connection = pika.BlockingConnection(pika.ConnectionParameters(

    '192.168.16.82', 5672, '/', credentials))

channel = connection.channel()
#声明queue

channel.queue_declare(queue='hello')
#n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.

channel.basic_publish(exchange='',

                      routing_key='hello',

                      body='Hello World!')

print(" [x] Sent 'Hello World!'")
connection.close() 

接收端：

import pika

credentials = pika.PlainCredentials('admin', '123123')

connection = pika.BlockingConnection(pika.ConnectionParameters(

    '192.168.16.82', 5672, '/', credentials))

channel = connection.channel()

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):

    print(" [x] Received %r" % body)
channel.basic_consume(callback,

                      queue='hello',

                      no_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

2. RabbitMQ消息分发轮询

先启动消息生产者，然后再分别启动3个消费者，通过生产者多发送几条消息，你会发现，这几条消息会被依次分配到各个消费者身上

python学习笔记-（十五）RabbitMQ队列

在这种模式下，RabbitMQ会默认把p发的消息公平的依次分发给各个消费者(c),跟负载均衡差不多

import pika

credentials = pika.PlainCredentials('admin', '123123')
connection = pika.BlockingConnection(pika.ConnectionParameters(
    '192.168.16.82', 5672, '/', credentials)) 


channel = connection.channel()      #声明一个管道(管道内发消息)

channel.queue_declare(queue='cc')    #声明queue队列

channel.basic_publish(exchange='',
                      routing_key='cc',  #routing_key 就是queue名
                      body='Hello World!'
)
print("Sent 'Hello,World!'")
connection.close()      #关闭