首页 / RABBITMQ / RabbitMQ消息队列
RabbitMQ消息队列
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了RabbitMQ消息队列，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1362字，纯文字阅读大概需要2分钟。
内容图文
RabbitMQ
1.什么是rabbitmq
在生产者和消费者之间加了一个中间件——消息队列，用它可以来干嘛呢？
它是来做消息转发的，当请求过来之后，不是直接发给服务器，而是发给消息队列，然后消息队列把消息中转一下再发给服务器
2.作用
- 存储消息、数据
- 保证消息的顺序
- 保证数据的正确交付
3.rabbitmq安装
安装rabbitmq之前先安装erlang
1.网址选择下载软件
2.安装一直下一步即可
4.安装erlang
1.网址下载
2.安装一直下一步即可
python使用rabbitmq
https://www.rabbitmq.com/install-windows.html
1.安装pika
#pika是python操作rabbitmq的模块
pip3 install pika
2.生产者代码
import
pika
#
1.链接到rabbitmq
connection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel = connection.channel()
#2.创建消息队列并命名
channel.queue_declare(queue=‘hello‘)
#3.发送消息
channel.basic_publish(exchange=‘‘,
routing_key=‘hello‘, #消息队列名
body=‘Hello World!‘) #要发送的消息print(" [x] Sent ‘Hello World Done!‘")
#4.关闭链接
connection.close()
3.消费者代码
import
pika
#
1.链接rabbitmq代码
connection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel = connection.channel()
#2.队列名
channel.queue_declare(queue=‘hello‘)
#3.回调函数:body:要接受的数据为二进制字符串def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(queue=‘hello‘, #队列名
auto_ack=True, #告诉消费者已经拿到了数据
on_message_callback=callback) #回调函数print(‘ [*] Waiting for messages. To exit press CTRL+C‘)
#4
channel.start_consuming()
4.运行
生产者cmd窗口
python3 生产者文件名.py
消费者cmd窗口2
python3 消费者者文件名.py
原文：https://www.cnblogs.com/tfzz/p/12101393.html
内容总结
以上是互联网集市为您收集整理的RabbitMQ消息队列全部内容，希望文章能够帮你解决RabbitMQ消息队列所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。