zoukankan      html  css  js  c++  java
  • python测试rabbitmq简易实例

    生产者

    import pika
    #coding=utf8
    credentials = pika.PlainCredentials('guest', '密码')
    connection = pika.BlockingConnection(pika.ConnectionParameters('IP',5672,'/',credentials))
    channel = connection.channel()
    channel.queue_declare(queue='hello')
    
    channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='rabbitmq test!')
    print("开始队列")
    connection.close()
    

     

    消费者

    import pika
    #coding=utf8
    credentials = pika.PlainCredentials('guest', '密码')
    connection = pika.BlockingConnection(pika.ConnectionParameters('IP',5672,'/',credentials))
    channel = connection.channel()
    
    
    # rabbitmq消费端仍然使用此方法创建队列。这样做的意思是:若是没有就创建。和发送端道理道理。目的是为了保证队列一定会有
    channel.queue_declare(queue='hello')
    
    
    # 收到消息后的回调
    def callback(ch, method, properties, body):
        print(" [x] Received %r" % body)
    channel.basic_consume(callback, queue='hello', no_ack=True)
    print(' [*] Waiting for messages.')
    channel.start_consuming()
    

      

  • 相关阅读:
    js 前端 table 导出 excel
    js调用RadioButton1
    柱状图
    html锚点定位
    遍历所有lable并赋值
    MiniUI 在线示例
    sql更新语句
    生成word
    打开word
    操作word
  • 原文地址:https://www.cnblogs.com/uglyliu/p/8519693.html
Copyright © 2011-2022 走看看