如何使用RabbitMQ策略将交换设置为持久交换
RabbitMQ是一个开源的消息队列中间件，它实现了高效的消息传递机制，可以在分布式系统中进行异步通信。使用RabbitMQ的策略将交换设置为持久交换，可以确保交换在服务器重启后仍然存在。
要将交换设置为持久交换，需要在创建交换时指定durable参数为true。下面是一个使用RabbitMQ策略将交换设置为持久交换的示例代码：
import pika
# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 创建一个持久化的交换
channel.exchange_declare(exchange='my_exchange', exchange_type='direct', durable=True)
# 关闭与RabbitMQ服务器的连接
connection.close()在上述示例中，我们使用pika库连接到RabbitMQ服务器，并创建了一个名为"my_exchange"的持久化交换。通过将durable参数设置为True，我们确保了该交换在服务器重启后仍然存在。
除了设置交换为持久交换，还可以设置队列和消息为持久化。这样可以确保在服务器重启后，队列和消息也能够被恢复。要将队列和消息设置为持久化，需要在声明队列和发布消息时指定durable参数为true。
RabbitMQ的持久化机制可以保证消息的可靠性传递，适用于需要确保消息不丢失的场景，例如任务队列、日志收集等。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ，详情请参考腾讯云消息队列 CMQ产品介绍。
相关·内容
当我使用python在rabbitmq中运行headersExchange的Consumer.py时，它得到如下错误:我已经在下面提到了消费者和发布程序
Traceback (most recent call last):
File "headersConsumer.py", line 32, in <module>
main()
File "headersConsumer.py", line 14, in main
channel.exchange_declare(exchange = 'headers_logs&#
浏览 3提问于2021-06-03得票数 0
1回答
我在我的服务器中实现了RabbitMQ。因此，基本上它所做的就是主服务器将消息传递给工作服务器。我面临的问题是，我传递的所有消息都不会被服务器接收到。也就是说，如果我发送10条消息，只会收到其中的4条。
知道我哪里错了吗。
接收代码
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello&
浏览 0提问于2016-05-02得票数 2
Consumer.py：
#！/usr/bin/ connection导入pika，sys，os def ()：connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel()
channel.exchange_declare(exchange='headers_logs', exchange_type='headers')
channel.queue_declare(queue='
浏览 4提问于2021-06-02得票数 0
我一直在试图找出使用RabbitMQ.Client库(pika/aiopika)的最佳方法，而当我使用dotnet库(RabbitMQ.Client)做同样的事情时，我注意到我得到了非常不同的结果。
python：
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
exchange_name = "test-load"
channel.exchange_declare(exc
浏览 0提问于2020-02-16得票数 2
我希望开发一个应用程序，在python代码中使用rabbitmq发送消息，而使用者是Spring引导的rabbitmq代码。
sender.py
#!/usr/bin/env python
import pika
import sys
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='topic_logs',
浏览 0提问于2018-03-27得票数 0
回答已采纳
我最近发现了允许您延迟消息的RabbitMQ特性，虽然我找不到任何与我需要的类似的示例，但它工作得很好：
假设有三种类型的消息: A、B和C。我们有2个delay_queues，具有1小时和2小时的'x-message-ttl值。还有3种类型的destination_queues --每种类型用于特定的消息类型。
我想要实现的是，在一个delay_queues中的消息到达其TTL之后，它将根据其类型被路由到一个destination_queues。就像这样：
这甚至可以使用RabbitMQ消息属性吗？有什么想法吗？我的代码将消息发送到延迟队列(过期后将消息发送到hello队列
浏览 0提问于2015-05-28得票数 1
回答已采纳
1回答
我正在尝试从驻留在服务器上的RabbitMQ那里获得通知。我被告知要使用这段代码，它应该打印进度通知。但是，当运行代码并向队列提交作业时，我没有看到任何东西。代码没有打印任何内容：
import pika
rabbitMqHost = 'host'
rabbitMqUser = 'user'
rabbitMqPass = 'password'
exchangeName = 'ProgressNotification'
credentials = pika.PlainCredentials(rabbitMqUser, rabb
浏览 0提问于2018-12-14得票数 1
回答已采纳
1回答
我是一个完全的新手，狂犬病短信，抱歉，如果这个问题是愚蠢的，或我的设置完全梨形。
我使用rabbitmq的设置是发送来自某些探测的消息。每个探针都有一个唯一的名称。然后，我有一个集中的服务器，我在那里处理数据--如果需要的话。
我使用与探测名称对应的直接交换和路由密钥。
我按照以下方式声明我的使用者(服务器)(这或多或少来自rabbitmq教程)：
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.
浏览 3提问于2017-04-12得票数 0
回答已采纳
2回答
无法接收消息RabbitMQ
、、、、
我遵循教程4 ()。以下是send.py的代码
import pika
import sys
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='direct_logs',
type='direct')
severity = sys.
浏览 0提问于2016-11-06得票数 0
回答已采纳
1回答
我正在使用django，django rest框架和Rabbitmq，我想要的是使用Rabbitmq在用户创建评论(如长轮询)后向客户端发送通知。我在这里遵循。
下面是我用来创建评论的view.py：
class CommentList(generics.ListCreateAPIView):
permission_classes = (permissions.IsAuthenticatedOrReadOnly,)
queryset = Comment.objects.all()
serializer_class = CommentSerializer
def
浏览 1提问于2016-03-29得票数 0
1回答
使用spring 1.5.9发行版，代码如下所示
@Configuration
@EnableRabbit
public class RabbitmqConfig {
@Autowired
ConnectionFactory connectionFactory;
@Bean//with or without this bean, neither works
public AmqpAdmin amqpAdmin() {
return new RabbitAdmin(connectionFactory);
}
@Bean
浏览 0提问于2019-03-05得票数 0
回答已采纳
我想写一个应用程序，其中我需要一个生产者发送消息使用spring boot rabbitmq和接收器是用python编写的。接收器部分很简单-
receive.py
#!/usr/bin/env python
import pika
import sys
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='topic_logs
浏览 1提问于2018-03-27得票数 0
我有一个Python，它使用Pika包(0.9.13)，并从RabbitMQ集群中的一个节点检索数据。集群由放置在两个不同主机(url_1和url_2)中的两个节点组成。如何使Python客户端订阅两个节点？
这是我的代码的主要结构：
import pika
credentials = pika.PlainCredentials(user, password)
connection = pika.BlockingConnection(pika.ConnectionParameters(host=url_1,
creden
浏览 0提问于2014-05-14得票数 8
回答已采纳
我正在编写一个python客户机，以接受来自RabbitMQ代理的作业消息，并处理作业，将结果返回到另一个服务器。我将消息发送到RabbitMQ代理的脚本启动正常，但我的工作线程在运行channel.declare_queue(queue='task_queue')时抛出以下错误
pika.exceptions.AMQPChannelError：(406，"PRECONDITION_FAILED - vhost中队列'task_queue‘的参数/’不等价‘)
客户端：
import pika
connection = pika.BlockingConn
浏览 0提问于2012-09-06得票数 7
回答已采纳
1回答
我正试图使用RabbitMQ topic exchange从发布服务器向多个使用者可靠地发送消息。
我已经配置了持久队列(每个消费者一个)，并且我正在发送持久消息delivery_mode=2。我还将频道设置为confim_delivery模式，并添加了mandatory=True标志以进行发布。
现在，服务是相当可靠的，但是如果消息在代理重新启动期间停留，然后是消息发布，消息就会丢失给其中一个使用者。
似乎代理可以在重新启动时恢复队列和消息，但它似乎没有保留使用者和队列之间的绑定。因此，信息只会到达其中一个消费者，而对于一个处于瘫痪状态的消费者来说，信息就会丢失。
注意:如果代理在消费者停机
浏览 1提问于2019-02-12得票数 2
Channel.basic_consume的函数返回什么？如何使用变量访问消息?我想使用消息并在浏览器中显示它？我构建了django应用程序，将消息发送到rabbitmq，并使用其中的消息在浏览器中显示消息，如聊天
import pika, sys
global message
def consume(room,username):
credentials = pika.PlainCredentials('admin', 'admin')
parameters = pika.ConnectionParameters('192.168.1.14',
浏览 0提问于2021-07-24得票数 0
2回答
我有两个队列，比如q1和q2，它们对应于具有绑定密钥b1和b2的e1和e2交换。我想并行运行消费者函数，比如c1和c2，它们将分别听q1和q2。我尝试了以下方法：
def c1():
connection = pika.BlockingConnection(pika.ConnectionParameters(host=constants.rmqHostIp))
channel = connection.channel()
channel.exchange_declare(exchange='e1', durable='true',
浏览 5提问于2017-07-16得票数 3
回答已采纳
我正在Ubuntu工作站上运行一些测试。这些基准测试从填充队列开始，队列运行非常慢：
import pika
import datetime
if __name__ == '__main__':
try:
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare
浏览 3提问于2016-03-09得票数 4
回答已采纳
1回答
试图使用Python将数据发送到RabbitMQ队列。
我还没有配置服务器，但它正在为其他进程运行。我有一个工作的登录，可以访问网页输出没有问题。
RabbitMQ为python提供的示例代码使用Pika：
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='xxx.xxx.xxx.xxx:xxxxx'))
channel = connection.channel()
channel.queue_decl
浏览 7提问于2016-05-06得票数 3
回答已采纳
1回答
编写一个简单的RabbitMQ生产者/消费者示例，我无法让我的使用者容器继续在docker-compose up -d上运行。它应该在无限循环上运行。
如您所见，我可以让它在运行docker-compose run consumer和docker-compose run -d consumer时保持不间断。
app.py
#!/usr/bin/env python
import argparse
import pika
import json
connection = None
channel = None
TYPES = ['producer', 'con
浏览 3提问于2017-11-22得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
