RabbitMQ发送端接收端生产者消费者的示例分析

这篇文章给大家分享的是有关RabbitMQ发送端接收端生产者消费者的示例分析的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

创新互联专注于企业营销型网站、网站重做改版、晋中网站定制设计、自适应品牌网站建设、H5网站设计、成都商城网站开发、集团公司官网建设、成都外贸网站制作、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为晋中等各大城市提供网站开发制作服务。

rabbit_conn_send_producer.py
importpika

connection = pika.BlockingConnection(pika.ConnectionParameters(
    'localhost'))#rabbit默认端口5672 建立一个基本的 socket连接
channel = connection.channel()#声明一个管道在管道里面发消息

# 声明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名字
                      body='Hello World!') #body 发送的消息
print(" [x] Sent 'Hello World!'")
connection.close()

rabbit_conn_recive_consumer.py
# _*_coding:utf-8_*_
__author__ = 'Alex Li'
importpika

connection = pika.BlockingConnection(pika.ConnectionParameters(
    'localhost')) #rabbit默认端口5672 建立一个基本的 socket连接
channel = connection.channel()#声明一个管道在管道里面收消息

# You may ask why we declare the queue again ‒ we have already declared it in our previous code.
# We could avoid that if we were sure that the queue already exists. For example if send.py program
# was run before. But we're not yet sure which program to run first. In such cases it's a good
# practice to repeat declaring the queue in both programs.
#channel.queue_declare(queue='hello')#声明queue

defcallback(ch, method, properties, body):#处理消息
    print("---->",ch,method,properties)#ch 管道内存对象地址 method:发给queue的信息
    print(" [x] Received %r"% body)

channel.basic_consume(#消费消息
           callback,#如果收到消息，就调用CALLBACK函数来处理消息
           queue='hello',#从哪个队列里收消息
           no_ack=True) #不需要确认消息是否接收

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()#启动开始收消息一直收，没有就卡主

rabbit_conn_recive_consumer_no_ack.py
# _*_coding:utf-8_*_
__author__ = 'Alex Li'
importpika,time

connection = pika.BlockingConnection(pika.ConnectionParameters(
    'localhost')) #rabbit默认端口5672 建立一个基本的 socket连接
channel = connection.channel()#声明一个管道在管道里面收消息

# You may ask why we declare the queue again ‒ we have already declared it in our previous code.
# We could avoid that if we were sure that the queue already exists. For example if send.py program
# was run before. But we're not yet sure which program to run first. In such cases it's a good
# practice to repeat declaring the queue in both programs.
#channel.queue_declare(queue='hello')#声明queue

defcallback(ch, method, properties, body):#回调函数
    print("---->",ch,method,properties)#ch 管道内存对象地址 method:发给queue的信息
    time.sleep(5)#模拟消息处理时间
    print(" [x] Received %r"% body)

channel.basic_consume(#消费消息
  callback,#如果收到消息，就调用CALLBACK函数来处理消息
           queue='hello',#从哪个队列里收消息
#no_ack=True)#no acknowledgement 不确认开启的话表示不确认消息是否接收接没接收都不会给服务器端发消息如果客户端没收到消息就忽略了
#关闭的话就要服务器就要确认消息是否接收，没有确认到接收消息就会一直保留消息,会自动转到另一个客户端，socket一断，rabbitMQ就将消息转给另一个客户端
#发送端生产者发送一条消息，被消费者接受者收到了，消费者接收端处理完之后自动给生产者发送端发一个确认，说消息处理完了，然后生产者发送端才会把消息从队列里删除，只要没收到确认就不会删除，如果生产者发送端没收到确认，就会把消息转给另一个消费者接收端
          )

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()#启动开始收消息一直收，没有就卡主

感谢各位的阅读！关于“RabbitMQ发送端接收端生产者消费者的示例分析”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！

分享文章：RabbitMQ发送端接收端生产者消费者的示例分析
分享地址：http://6mz.cn/article/pcpgco.html

网站建设知识

RabbitMQ发送端接收端生产者消费者的示例分析

其他资讯