zoukankan      html  css  js  c++  java
  • RabbitMQ之pika模块

    发布/订阅 系统

    send.py

    import pika
    import time
    s_conn = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1'))  # 创建连接
    chan = s_conn.channel()  # 在连接上创建一个频道
    
    chan.queue_declare(queue='hello')  # 声明一个队列,生产者和消费者都要声明一个相同的队列,用来防止万一某一方挂了,另一方能正常运行
    
    while 1:
        time.sleep(1)
        chan.basic_publish(exchange='',  # 交换机
                           routing_key='hello',  # 路由键,写明将消息发往哪个队列,本例是将消息发往队列hello
                           body='Ye:当前时间%s ' % time.strftime('%m-%d %H:%M:%S'))  # 生产者要发送的消息
        print("[生产者] send 'hello world")
    
    s_conn.close()  # 当生产者发送完消息后,可选择关闭
    

    recv.py

    import pika
    
    s_conn = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1'))  # 创建连接
    chan = s_conn.channel()  # 在连接上创建一个频道
    
    chan.queue_declare(queue='hello')  # 声明一个队列,生产者和消费者都要声明一个相同的队列,用来防止万一某一方挂了,另一方能正常运行
    
    
    def callback(ch, method, properties, body):  # 定义一个回调函数,用来接收生产者发送的消息
        print(ch, method, properties, )
        print(body.decode('utf8'))
    
    
    chan.basic_consume('hello',  # 指定取消息的队列名,
                       callback,  # 调用回调函数,从队列里取消息
                       auto_ack=True)  # 取完一条消息后,给生产者发送确认消息,默认是False的,即  默认不给rabbitmq发送一个收到消息的确认
    # 如果auto_ack=True则消失接收之后就会删除也就是只能取一次
    print('[消费者] waiting for msg .')
    chan.start_consuming()  # 开始循环取消息
    
  • 相关阅读:
    链表 2.4
    链表 2.3
    链表 2.2
    链表 2.1
    数组与字符串 1.8
    数组与字符串 1.7
    数组与字符串 1.6
    CounterBreach安装测试的全部过程
    数据库管理软件 Navicat Premium12 破解步骤
    webgote的例子(6)SQL注入(盲注)
  • 原文地址:https://www.cnblogs.com/qq752059037/p/10819740.html
Copyright © 2011-2022 走看看