记得在学习Celery的时候,官方文档就建议我们的broker使用RabbitMQ或Redis,可是当然由于Redis使用比较习惯,并且不用在去另外安装,因此好长时间都没有去学习这个东西.首先RabbitMQ绝对不像大众所认识的那样,是JAVA或者Python,GO写的,而是一种交换机语言ERLang,前段时间这个语言的发明人的离世也是轰动了整个IT界,而作为程序员的我因为时间问题没有学习RabbitMQ,很是后悔呀,所以现在赶紧学习学习,废话不多说,请欣赏...

这是什么东西?

  • RabbitMQ是一个消息队列的中间件,通俗点讲就是饮料生产商(康师傅,达利园等等)生产东西放入超市,然后用户去超市里拿.这里的超市就是我们的RabbitMQ,饮料生产商就是所谓的生产者,用户就是消费者,这里生产者可以好多种消息(茉莉,红茶等等)放入到队列中,消费者也可以根据名称去拿(我只能去买),这就是其功能.

点击进入安装教程
但是不要以为这样就能开始,当你运行以下代码就会发现报错:

530, "NOT_ALLOWED - access to vhost '/' refused for user 'jim'"

这是怎么回事呢?我也给大家解决了,点击查看
__生产者__:

import pikaclass Produce:    def __init__(self, host, port, credentials):        # 创建连接参数对象        parameters = pika.ConnectionParameters(host, port, credentials=credentials)        # 创建连接对象        self._conn = pika.BlockingConnection(parameters)        # 创建一个默认channel        self._channel = self._conn.channel()    def create_channel(self, num):        """ 创建channel """        self._channel = self._conn.channel(num)    def create_queue(self, name):        """ 创建queue """        self._channel.queue_declare(queue=name)        self._key = name    def run(self, body):        """ 生产消息 """        self._channel.basic_publish(exchange='', routing_key=self._key, body=body, )        print(" [x] Sent Message Successful! ")        self._conn.close()if __name__ == '__main__':    host = 'localhost'    port = 5672    credentials = pika.PlainCredentials('jim', 'adminjim')    produce = Produce(host, port, credentials)    produce.create_queue('你傻不傻')    produce.run('你就是一个垃圾')

__消费者__:

import pikaclass Custumer:    def __init__(self, host, port, credentials):        # 连接到rabbitmq服务器        self.conn = pika.BlockingConnection(pika.ConnectionParameters(host, port, credentials=credentials))        self.channel = self.conn.channel()    def create_or_user_queue(self, name):        # 声明消息队列，消息将在这个队列中进行传递。如果队列不存在，则创建        self._key = name        self.channel.queue_declare(queue=name)    def _callback(self, ch, method, properties, body):        """ 定义一个回调函数来处理，这边的回调函数就是将信息打印出来。 """        print(" [x] Received %r" % (body, ))    # 告诉rabbitmq使用callback来接收信息    def run(self):        self.channel.basic_consume(on_message_callback=self._callback, queue=self._key, auto_ack=True)  # no_ack=True表示在回调函数中不需要发送确认标识        print(' [*] Waiting for messages. To exit press CTRL+C')        self.channel.start_consuming()  # 开始接收信息，并进入阻塞状态，队列里有信息才会调用callback进行处理。if __name__ == '__main__':    host = 'localhost'    port = 5672    credentials = pika.PlainCredentials('jim', 'adminjim')    custumer = Custumer(host, port, credentials)    custumer.create_or_user_queue('你傻不傻')    custumer.run()

有没有学会呢,学不会或者觉得简单的都不要着急,我会学深入了再来满足大家.