RabbitMQ消息分发轮询-创新互联
我们首先下载pika,以及rabbitMQ,和ir语言,rabbitMQ是由ir语言编写的
站在用户的角度思考问题,与客户深入沟通,找到清河网站设计与清河网站推广的解决方案,凭借多年的经验,让设计与互联网技术结合,创造个性化、用户体验好的作品,建站类型包括:网站建设、网站设计、企业官网、英文网站、手机端网站、网站推广、国际域名空间、网站空间、企业邮箱。业务覆盖清河地区。消息队列的使用过程大概如下:
(1)客户端连接到消息队列服务器,打开一个channel。
channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务。
(2)客户端声明一个exchange,并设置相关属性。
Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
(3)客户端声明一个queue,并设置相关属性。
Queue:消息队列载体,每个消息都会被投入到一个或多个队列。
(4)客户端使用routing key,在exchange和queue之间建立好绑定关系。
Routing Key:路由关键字,exchange根据这个关键字进行消息投递。
(5)客户端投递消息到exchange。
Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
接下来写一个生产者:
import pika
connection = pika.BlockingConnection(
pika.ConnectionParameters('localhost'))
channel = connection.channel()#先通过socket建立一个实例,创建一个新的频道
# 声明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',#queue名字#路由键,写明将消息发往哪个队列,本例是将消息发往队列pikamq
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('--->',ch,method,properties)
print(" [x] Received %r"%body)
channel.basic_consume(callback,
queue='hello',
#no_ack=True #此处有的代码加了,但是python系统会自带,同时加了之后,一旦等待时间过长,生产者发送的消息,无法转移到另一个消费者中
)
channel.start_consuming()
另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
当前标题:RabbitMQ消息分发轮询-创新互联
文章出自:http://pwwzsj.com/article/dphdhj.html