python之rabbitmq使用大全（pika）

【摘要】 如果你觉得该文章对你有用，麻烦关注我，谢谢。
 
1 最简单的生产消费方式（此模式未申明exchange，实际是exchange被默认为了队列名。记住，rabbitmq，是离不开exchange的，因为exchange，才让生产者和消费者完全解耦。）
生产者从不把消息发给队列，它也不知道队列名是什么，只有消费者关心队列，是消费者去创建了队列，去订阅了该topic。而此处…

如果你觉得该文章对你有用，麻烦关注我，谢谢。

1 最简单的生产消费方式（此模式未申明exchange，实际是exchange被默认为了队列名。记住，rabbitmq，是离不开exchange的，因为exchange，才让生产者和消费者完全解耦。）

生产者从不把消息发给队列，它也不知道队列名是什么，只有消费者关心队列，是消费者去创建了队列，去订阅了该topic。而此处的topic主要就和exchange和routing_key相关联了。

而routing_key的好处就是，同一个队列，我们可以指定多个映射关系（binding_key）。同一个exchange，可以指定多个routing_key。多个队列，可以指定同一个binding_key。（记住这句话，这是核心思想）

下面我们来进行一些简单的python编程来对rabbitmq进行初步认知。这里我们用到的核心库是pika，主要靠它和rabbitmq打交道。

send.py

      # -*- coding: utf-8 -*-

      """

       时间 : 2021-04-19 14:45

       作者 : 胡桓

       文件名 : send.py

       邮箱: 1641143982@qq.com

      """

      import pika

      connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

      channel = connection.channel()

      channel.queue_declare(queue='hello')

      channel.basic_publish(exchange='',

       routing_key='hello',

       body='Hello RabbitMq!')

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

      connection.close()

  


                    
        
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
软件开发