标签:publish llb cli rop href min receive oca 一个
kafaka. --微博在用的 比rabbitmq强大的多
activemq
rockemq
mq--就是队列
防止大流量的并发,做一个缓冲
点击 Download+Installation
using the Pika Python client -->使用pika作为python链接rabbitmq的客户端
? pip3 install pika
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()
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()
标签:publish llb cli rop href min receive oca 一个
原文地址:https://www.cnblogs.com/zhuyuanying123--/p/12494919.html