python快速连接RabbitMQ

偏执的太偏执、 2024-04-01 12:46 110阅读 0赞 
  1. pip install pika

1.消费消息：

  1. import pika
  3. # 账号密码
  4. credentials = pika.PlainCredentials(username='admin', password='123456')
  5. # 连接
  6. connection = pika.BlockingConnection(pika.ConnectionParameters(
  7.     host='192.168.7.91', port=8018, virtual_host='jntG2UQH', credentials=credentials))
  8. channel = connection.channel()
  11. # 回调处理函数
  12. def callback(ch, method, properties, body):
  13.     print(body.decode('utf-8'))
  16. channel.basic_consume(
  17.     'user-104',  # 队列名称
  18.     callback,
  19.     # auto_ack=False  # 是否应答（True就是消费掉）
  20. )
  22. print('[*] Waiting for messages. To exit press CTRL+C')
  23. channel.start_consuming()

2.生产消息：

  1. import pika
  3. # 账号密码
  4. credentials = pika.PlainCredentials(username='admin', password='123456')
  6. # 连接地址
  7. connection = pika.BlockingConnection(pika.ConnectionParameters(
  8.     host='192.168.7.91', port=8018, virtual_host='jntG2UQH', credentials=credentials))
  10. # 连接通道
  11. channel = connection.channel()
  13. # 生产消息
  14. channel.basic_publish(exchange='',
  15.                       routing_key='user-104',
  16.                       body='Hello World!'.encode('UTF-8'))
  17. # 关闭连接
  18. connection.close()

发表评论

表情：
评论列表 （有 0 条评论，110人围观）

还没有评论，来说两句吧...

相关阅读

    相关 RabbitMQ快速尝鲜

    > 原创：微信公众号 【阿Q说代码】，欢迎分享，转载请保留出处。 [上文][Link 1]我们已经完成了`RabbitMQ`的安装，安完就要让它发挥点作用，今天就在`Spri

    忘是亡心i忘是亡心i/ 0 赞/ 173 阅读

    相关 RabbitMq安装快速教程

    引言： 消息系统是互联网公司在应对大流量、高负载系统中非常常用的一种系统通信机制，它除了可以将不同系统解耦，还可以实现不同的多点系统之间的同步或异步通信机制，它的高性能、高扩展

    矫情吗；*矫情吗；*/ 0 赞/ 237 阅读