rabbitMQ简单使用

#send.pyimport pika
import sys# 创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
# 创建channel
channel = connection.channel()
message = " ".join(sys.argv[1:]) or "hello world"
# 创建队列，并持久化存储
channel.queue_declare(queue="hello", durable=True)channel.basic_publish(exchange='', routing_key="hello", body="message",properties=pika.BasicProperties(delivery_mode=2))
connection.close()

#receive.pyimport pika
import time# 创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
# 创建channel
channel = connection.channel()
# 创建队列
channel.queue_declare(queue="hello", durable=True)# 回调函数
def callback(ch, method, properties, body):print("[x] Received %r" % (body,))print(type(body))time.sleep(5)print("[x] Done")ch.basic_ack(delivery_tag=method.delivery_tag)# 公平调度，让每个消费者执行时间相近
channel.basic_qos(prefetch_count=1)channel.basic_consume(callback, queue="hello")
# 阻塞，等待接收
channel.start_consuming()

转载于:https://www.cnblogs.com/akuma233/p/9630004.html

rabbitMQ简单使用相关推荐

[喵咪MQ(1)]RabbitMQ简单介绍准备工作
[喵咪MQ(1)]RabbitMQ简单介绍准备工作前言哈喽大家好呀! 看标题就知道我们这次要讲MQ,之前博客中有提到的KafKa理论上来说也是一个优秀的MQ队列软件,比较知名的MQ有:Go语言编写 ...
消息队列--RabbitMQ简单使用
安装使用地址:http://www.rabbitmq.com/ 需要根据不同的版本选择不同的erlang 安装erlang 安装RabbitMQ首先需要安装erlang环境,根据GitHub上erl ...
RabbitMQ简单队列模式
简单队列模式红色:队列 P:消息的生产者 C:消息的消费者生产者,将消息发送到队列消费者,从队列中获取消息配置依赖导入RabbitMQ客户端依赖 <dependency>< ...
rabbitmq简单收发服务搭建
消息发送.接收简单代码示例 mq.xml//rabbitmq config spring.rabbitmq.host=ip:port spring.rabbitmq.username= spring. ...
centos7安装rabbitmq简单方式
安装rabbitmq前要准备的基础环境 yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make g ...
rabbitmq简单入门
这里写自定义目录标题一.rabbitMq的概念二.为什么使用rabbitMq 三.使用rabbitMq的缺点四.MQ的选择五.安装rabbitmq 六.RabbitMQ工作原理图七.代码实现 ...
MULE配置RabbitMQ简单示例
环境版本 mule-standalone 3.9.0 anypoint-studio 6.4.0 MULE提供了AMQP Connector,因此可以使用该Connector来配置RabbitMQ. ...
RabbitMQ 简单入门（微服务）
简单实现"消息的生成"以及"消息的消费" 创建了两个项目 ,一个是 Producer项目 ,一个Customer 项目分别在两个项目添加的Rabbit依赖: ...
RabbitMQ简单介绍+Windows环境安装
文章目录文章目录文章目录 1.RabbitMQ简介 2.RabbitMQ与其他MQ有什么不同 3.RabbitMQ环境安装 3.1 安装erlang 3.2 安装rabbitmq-server 4 ...
SpringBoot 结合 RabbitMQ 简单项目
https://git.coding.net/dgutllx/RabbitmqStudy.git 上面就是我博客里面的项目,感谢大大,学习到不少 publisher-confirms,实现一个监听器用 ...

rabbitMQ简单使用

rabbitMQ简单使用相关推荐

最新文章

热门文章