码迷,mamicode.com
首页 > 其他好文 > 详细

rabbitmq

时间:2020-03-14 23:39:41      阅读:69      评论:0      收藏:0      [点我收藏+]

标签:publish   llb   cli   rop   href   min   receive   oca   一个   

rabbitmq

kafaka. --微博在用的 比rabbitmq强大的多

activemq

rockemq

mq--就是队列

防止大流量的并发,做一个缓冲

下载安装

https://www.rabbitmq.com/

技术图片

点击 Download+Installation

using the Pika Python client -->使用pika作为python链接rabbitmq的客户端

? pip3 install pika

Producer.py:

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 World!')

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

Consumer.py:

import pika

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

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

channel.basic_consume(queue='hello',
                      auto_ack=True,
                      on_message_callback=callback)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

rabbitmq

标签:publish   llb   cli   rop   href   min   receive   oca   一个   

原文地址:https://www.cnblogs.com/zhuyuanying123--/p/12494919.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!