Rabbitmq pika.BasicProperties不发送消息中的属性
RabbitMQ是一种开源的消息中间件，用于在分布式系统中进行消息传递和异步通信。它基于AMQP（Advanced Message Queuing Protocol）协议，并提供了可靠的消息传递机制。
在RabbitMQ中，pika.BasicProperties是一个用于设置消息属性的类。它可以包含消息的各种元数据，例如消息的优先级、过期时间、持久化设置等。然而，如果使用pika.BasicProperties发送消息时不设置任何属性，则消息将被发送而不包含任何额外的属性。
这种情况可能发生在以下几种情况下：
- 开发者可能希望简化消息的传递过程，仅发送消息内容而不需要任何附加属性。
- 由于某些原因，开发者可能在发送消息之前没有设置任何属性。
尽管消息没有附加属性，但仍可以正常传递并被消费者接收。消费者可以根据自身需求对消息进行处理，无需依赖任何属性。然而，缺少属性可能会限制了某些高级功能的使用，例如消息的持久化、优先级排序等。
在腾讯云的产品中，可以使用云消息队列 CMQ（Cloud Message Queue）来实现消息传递和异步通信。CMQ提供了高可用性、可扩展性和可靠性的消息队列服务，能够满足各种场景下的需求。您可以参考腾讯云CMQ的官方文档了解更多信息：腾讯云云消息队列 CMQ
需要注意的是，本回答中没有提及其他云计算品牌商，这是为了符合问题要求。如果您需要了解更多关于云计算品牌商的信息，可以通过搜索引擎查询相关内容。
相关·内容
我试图从作为生产者的Flask服务器向RabbitMQ服务器队列发送一条消息。我用来产生消息的端口是'5672‘。
我已经在RabbitMQ的Management服务器上创建了一个exchange和一个队列，主要目标是在服务器队列中接收一条消息。
这是我目前拥有的代码，它不会产生任何错误并返回消息已经发送的消息：
@app.route("/create/<message>")
def create_bucket(message):
credentials = pika.PlainCredentials("guest", "gu
浏览 3提问于2022-10-02得票数 0
回答已采纳
我正在使用pika向rabbitmq发送消息。我需要发送额外的属性，所以我使用了pika.BasicProperties，但是当我在Wireshark中看到这条消息时，并没有添加任何属性。 我的代码： import pika, uuid
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='test_60', durab
浏览 40提问于2021-01-07得票数 0
回答已采纳
在MSMQ中有一个很好的特性，称为响应队列:作为消息的一部分，还可以发送一个(私有/不可见)队列，其中等待响应--非常类似于异步世界中的回调。从技术上讲，这个特性只是私有队列和队列名称的包装器。在RabbitMQ中有类似的地方吗？
浏览 2提问于2015-03-21得票数 0
回答已采纳
我有一个通过一系列测试循环的应用程序。在失败的测试中，它会将一条消息发布到RabbitMQ队列，其他应用程序将从该队列中监控和获取消息。有数百个测试，需要几分钟的时间才能全部完成。测试会被重复，因为应用程序是定期运行的。
我的问题是，是否最好打开一个连接一次，让它在循环所有测试之后才能发布？还是只在需要发布消息并在消息发送后关闭连接时才建立连接更好？
另外，如果我的队列已经存在，那么调用queue_declare是否会再次导致RabbitMQ/pika尝试重新创建或覆盖队列？
这条路：
message_con = pika.BlockingConnection(pika.URLParamete
浏览 4提问于2020-05-11得票数 1
回答已采纳
我想将一条消息从基于Python的微服务(使用Pika)发布到基于.NET的微服务(使用MassTransit作为事件总线)消耗的一个队列中。
Python发布服务器的示例代码如下所示：
connection = pika.BlockingConnection(pika.URLParameters('amqp://guest:guest@rabbitmq:5672/%2F'))
channel = connection.channel()
channel.queue_declare(queue='queue_net', durable=True)
chann
浏览 2提问于2021-09-16得票数 0
回答已采纳
我正在使用OpenTracing，并尝试通过RabbitMQ传播span。然而，我不明白我应该如何注入跨度，以及如何在以后提取它。
这是发送消息的代码
def send_message(self, message, tracer):
root_span = tracer.get_span()
with opentracing.tracer.start_span('Sending message to broker', child_of=root_span) as span:
connection = pika.BlockingConnection
浏览 4提问于2018-07-19得票数 6
我正在尝试使用RabbitMQ将python字典从python生产者发送到python消费者。生产者首先建立到本地RabbitMQ服务器的连接。然后，它创建一个队列，消息将被传递到该队列，并最终发送该消息。使用者首先连接到RabbitMQ服务器，然后通过创建相同的队列来确保队列存在。然后，它在回调函数中接收来自生产者的消息，并打印'id‘值(1)。以下是生产者和消费者的脚本：
producer.py脚本：
import pika
import sys
connection = pika.BlockingConnection(pika.ConnectionParameters(host
浏览 4提问于2015-12-31得票数 36
回答已采纳
我最近发现了允许您延迟消息的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回答
在使用pika将消息发布到rabbitmq代理时，我添加了一个标头key:value对，如下所示
channel.basic_publish(exchange=self.exchange,
routing_key=self.routing_key,
properties=pika.BasicProperties(
headers={'key': 'value'}
),
浏览 3提问于2020-12-31得票数 1
我想在Python中的客户机库中使用RabbitMQ的特性。它适用于一个基本的消费者。但是，它会对生成器使用者引发以下异常：
pika.exceptions.ChannelClosedByBroker：(406，'PRECONDITION_FAILED -快速回复消费者不存在‘)
是否有一种方法可以使用直接应答功能？
使用基本使用者的示例客户端代码(它可以工作)：
import pika
def handle(channel, method, properties, body):
message = body.decode()
print("rece
浏览 1提问于2019-07-01得票数 2
回答已采纳
我正在使用celery和rabbitmq处理大约1000万个任务。该任务的输出是存储在远程rabbitmq中的json。我使用Pika将消息发布到远程rabbitmq中的不同队列。目前我得到了这个错误pika.exceptions.ConnectionClosed: Connection，因为pika不是异步的。我发现了另一个异步客户端。但我无法在我的代码中实现它。是否需要为每个任务创建新的连接？下面是我的代码：
from __future__ import absolute_import
from test_celery.celery import app
import pika
cred
浏览 0提问于2017-11-02得票数 1
我尝试使用RabbitMQ制作聊天应用程序。
每个会话组都有fanout交换，组成员向其中推送消息并绑定其队列。
但是有了这样的路由成员就会收到自己的消息，所以我必须在客户端代码中过滤它们。
有没有办法进行排除模式匹配，这样exchange就不会用相同的键向队列发送消息？
浏览 3提问于2016-06-17得票数 0
回答已采纳
我正在编写一个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
回答已采纳
我希望我的python脚本在发送任务到queue之前不断运行并检查队列大小是否为零。下面是一个代码片段：
#!/usr/bin/env python
import pika
import sys
while True:
# establish connection with RabbitMQ server
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# create qu
浏览 0提问于2015-02-08得票数 0
从我的生产者代码中，我想知道消费者什么时候发布了basic.ack消息。
使用channel.confirm_delivery()和BlockingConnection，文档中不清楚这是否应该确认：( 1)代理接收了消息，或者( 2)确认收到消息的消费者。
运行此代码(没有使用者)：
import pika
import uuid
# Open a connection to RabbitMQ on localhost using all default parameters
connection = pika.BlockingConnection()
# Open the channel
浏览 3提问于2017-03-15得票数 8
回答已采纳
我们有需要通过RabbitMQ broker发送消息的C++软件，是否有人尝试过ActiveMQ CPP lib (内容管理系统)来发送/接收消息到RabbitMQ broker？
浏览 5提问于2010-02-15得票数 2
1回答
Apache从队列到队列
、、、
我必须实现一个微服务，它从rabbitmq队列中获取消息，转换它并将其推送到rabbitmq交换。
我使用Apache和Spring来实现这个功能，使用Java。在我的机器上，我正在使用(目前)一台rabbitmq服务器。配置如下所示：
from("rabbitmq://localhost:5672/exchange1?username=guest&password=guest&queue=q1&autoDelete=false");
.to("rabbitmq://localhost:5672/exchange2?username=gues
浏览 0提问于2017-11-29得票数 1
回答已采纳
我一直在阅读多个博客和文档，介绍如何正确设置用于发布的RabbitMQ连接。下面是我的场景
几乎没有执行某些任务并将输出发布到RabbitMQ 的计划作业--作业以不同的时间间隔运行，但是输出将发布到相同的RabbitMQ队列中。
以下是实现
def get_credentials(self):
print ("Host ", config_reader.get_lookup_data('RABBITMQ', 'host'))
credentials = pika.PlainCredentials(config_reader.ge
浏览 2提问于2020-01-01得票数 2
1回答
我试图在RabbitMQ上使用头文件交换，使用混合的java和python组件，我需要确认交付。
我似乎与python (pika)和java客户端的行为不同。
在python中：
channel.exchange_declare(exchange='headers_test',
¦ ¦ ¦ ¦ ¦ ¦ ¦type='headers',
¦ ¦ ¦ ¦ ¦ ¦ ¦durable=True)
channel.confirm_delivery()
result = channel.basic_publish(excha
浏览 3提问于2017-05-09得票数 4
回答已采纳
我正在使用rabbitmq在微服务中的两个服务之间发送消息。
我有个问题。是否可以将队列暂停推送消息设置为消费者，并在需要时继续处理消息？或者让消费者暂停，以便从队列中获取消息，并在需要时继续获取消息(但不要使用停止/启动消费者的方式。因为我不能在我的系统中这样做。)？
如果是，是否可以通过RabbitMQ管理HTTP API进行？
浏览 8提问于2017-02-23得票数 0
回答已采纳
我是RabbitMQ的新手。我与PhantomJS一起工作，并使用JavaScript来做一些事情。现在，我需要将我的一些结果发送到RabbitMQ，以便使用另一个脚本读取它们。我是说，我想让PhantomJS和RabbitMQ沟通。发送一些消息和从队列中读取一些消息。这有可能吗？PhantomJS是否可以通过它与RabbitMQ通信？
浏览 1提问于2015-03-05得票数 2
回答已采纳
我的堆栈是Django 1.3(Python2.7)+ Apache + mod_wsgi
Apache每个请求生成一个新的进程..。有时，在这些请求中，我必须向RabbitMQ发布一条消息，内容涉及稍后要完成的一些繁重任务(比如将刚发布的猫照片通知某人的追随者)。
发布涉及到连接到RabbitMQ，这是昂贵的。(参见这个问题：)
我也悲伤地意识到Python无法跨进程共享内存..。叹息:(
在这种情况下，如何防止创建和关闭每个RabbitMQ请求的连接的开销？
为了清晰起见，在这里使用RabbitMQ + pika是我尝试共享进程间连接的失败尝试：
def test_view(request
浏览 2提问于2012-10-24得票数 3
回答已采纳
2回答
我们有一个RabbitMQ交换，它在系统的几个组件之间交换消息。
每个组件都是交换的发行者和订阅者。
我们需要找到一种方法来确保每个应用程序不接收它发送到交换中的消息。
例如。
App 1发送一条刷新消息。除了应用程序1之外，我们希望该交换机的所有订阅者都能获得此服务。
我可以看到您可以指定路由属性，但这似乎定义了您想要的消息，而不是您不想要的消息。
有什么想法吗？
浏览 6提问于2016-01-15得票数 5
回答已采纳
我有一个发送消息到RabbitMQ队列的简单PHP代码，当我直接从控制台(#php script.php)执行它时，消息可以正确发布，但当我尝试使用浏览器(http://localhost/script.php)打开相同的脚本时，消息不会发送。所有前面的行都会被执行，但页面会阻塞在该行中 $connection = new AMQPConnection('$ipaddress', 5672, '$user', '$password'); 你知道为什么会发生这种情况吗？ 代码: script.php <?php
include_once(&
浏览 48提问于2019-04-17得票数 0
1回答
我用芹菜和RabbitMQ一起执行一些任务，有时我需要从工人那里返回一条信息给RabbitMQ，所以我用的是皮卡。
我目前正在使用BlockingConnection()来连接到RabbitMQ，但是过了一段时间，我得到了一个异常“连接丢失”。
我认为发生这种情况是因为芹菜是异步的，而且我使用的是BlockingConnection()。
这是我的密码：
class RabbitConnection(object):
def __init__(self):
self.connection = pika.BlockingConnection(pika.Connection
浏览 0提问于2014-11-26得票数 2
回答已采纳
我使用RabbitMQ铲子插件(动态铲子，见下文)在两个RabbitMQ代理之间通过一个不可靠的广域网链接提供单向消息。我在RabbitMQ服务器日志中看到了正常的连接丢失。
AMQP设置的相关部分对于两个代理都是相同的:一个交换(扇出，持久)和一个队列(持久)。消费应用程序要求在发送端以相同的顺序接收消息。
观察到的行为似乎表明情况并非如此，可能是由于重传等原因。RabbitMQ铲子插头是否保存消息顺序而不丢失消息？所需的配置选项是什么？
浏览 7提问于2015-08-11得票数 1
回答已采纳
1回答
我刚接触过rabbitmq，并试图弄清楚如何使用本教程()使客户端请求具有内存和CPU利用率信息的服务器。
因此，客户端请求CPU和内存(我相信我需要两个队列)，服务器用值进行响应。
是否可以使用Python中的Pika库简单地创建一个client.py和server.py。
浏览 2提问于2016-03-04得票数 0
回答已采纳
1回答
邮件在过期后不会被丢弃。使用Spring-兔子java客户端，我使用expiration:10000.设置的头发送消息。
作为参考，这里是Rabbitmq队列中的消息，
属性
优先次序:0
delivery_mode: 2
标题：
有效期: 10000
content_encoding: UTF-8
content_type:文本/纯文本
如果我需要在Rabbitmq服务器上设置任何内容，或者需要设置任何额外的参数，请帮助我吗？
浏览 0提问于2019-11-16得票数 0
回答已采纳
2回答
目前，我希望在生产者-消费者设置中开发一个RabbitMQ同步工作流。生产者将向队列发布一条消息，它将花费大约6-8秒的时间完成处理并将结果返回给使用者。然后生产者将得到结果并继续执行代码的其余部分，这需要从使用者那里得到结果。
我知道消息队列是设计为同步的，但是有什么方法来实现进程producer call -> consumer process -> consumer return result to producer同步吗？我搜索了一下，发现了，它在那里使用一个繁忙的循环来完成生产者端的等待：
rpc_client.py (制片人)
#!/usr/bin/env python
浏览 6提问于2022-04-10得票数 3
我正在使用SpringBoot2.0.2应用程序，我想配置RabbitMq，使其重试失败消息3次，每次重试间隔一段时间。
在SpringBoot1.5.1之前，我已经在application.properties上成功地设置了这个
spring.rabbitmq.listener.retry.enabled=true
spring.rabbitmq.listener.retry.initial-interval=45000
spring.rabbitmq.listener.retry.max-attempts=3
spring.rabbitmq.listener.retry.multiplie
浏览 1提问于2018-06-26得票数 0
回答已采纳
1回答
我正在尝试用Python语言中的RabbitMQ创建一个简单的文件下载和上传服务。我编写了服务器和客户机脚本，并定义了一些对象，用于序列化和反序列化请求的json，这样我就可以将文件uid或其他参数与二进制数据(用base64编码)一起发送。发送小文件时一切正常，但当我开始发送较大的文件(用1.4mb的文本文件测试)时，我开始收到JSONDecode错误。我将发送和接收的消息转储到文件，看起来发送的消息是一个格式正确的json。然而，收到的消息似乎很混乱，例如： 发送：{“uid”：“测试”，Rhc2Rhc2Rhc2Rhc2Rhc2Rhc2=="} 接收时间: Rhc2Rhc2{&#
浏览 14提问于2019-02-01得票数 0
回答已采纳
我想做一些电子邮件或短信服务器。
您向RabbitMQ发送一条带有“伪”标记的消息，而用户“伪”使用标记“message”侦听消息。
然而，在教程中，RabbitMQ没有提到这一点。有主题，路由密钥，.这看起来很相似，但在我看来，每个“主题”/“标记”/必须有一个队列.我想知道您是否可以拥有非常多的队列，或者RabbitMQ只是不适合这种使用。谢谢
浏览 2提问于2014-04-04得票数 0
回答已采纳
我有一个模块化的微服务架构，在这里我使用带有RabbitMQ的Rebus作为消息总线。
一个容器正在运行RabbitMQ。其他容器正在运行通过Rebus/RabbitMQ相互通信的服务。
我希望我的解决方案能够对容器重新启动具有弹性，因此，例如，如果RabbitMQ容器重新启动，我希望其他服务不受此影响。我希望在RabbitMQ关闭时发送的消息会排队等待发送服务中的Rebus传递，并且在恢复RabbitMQ连接时传递这些消息。
要验证我是否运行了这个测试场景：
服务A通过Rebus和RabbitMQ向服务B发送消息。效果很好。
我停止了RabbitMQ容器。
服务A通过Rebus和
浏览 1提问于2020-07-31得票数 1
回答已采纳
1回答
所以我在一个节点上测试RabbitMQ。简单明了，
一个生产者向队列发送消息，
多个使用者从该队列中获取任务。
目前消费者每秒执行数千条消息，他们太快了，所以我需要他们放慢速度。由于网络的不可靠性质，管理客户端节流是不可能的。
总体来说，使用者不能从该队列中每秒接收10条以上的消息。
是否有一种方法可以配置RabbitMQ，以便队列每秒最多发送10条消息？
浏览 5提问于2017-12-15得票数 0
回答已采纳
1回答
我要寻找的拓扑是
到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？
source.output().send(MessageBuilder.withPayload(myMessage).build());
不提供任何方式来设置主题，以供交易所路由到适当的使用者。
或者我不太明白什么？
更新
由于bindingRoutingKey是2222，并且我正在与routeTo 1111一起发送，所以我希望不会在消费者中接收消息。但我还是从消费者那里收到的。
制片性质：
spring.ra
浏览 0提问于2018-05-05得票数 2
回答已采纳
1回答
我有一个python客户端和一个symfony后端。他们可以使用rabbitmq发送和接收消息。
我在后端使用。
我向python客户端发送一个php实体的id，它让我通过api完成一些工作(繁重的工作)，并将结果存储在一个zip文件中。我想通过rabbitmq发送这个压缩文件。有可能吗？这个文件非常大(比如5mo)
如果可能的话，我该怎么做？(以有效的方式)
浏览 2提问于2017-06-20得票数 4
回答已采纳
我计划在java中使用RabbitMQ，并希望以Ack的顺序了解rabbitMQ行为。
这是我的设想。
考虑3条消息x，y，z由3个不同的消费者按相同的顺序选择。Y和z首先得到完整的ack，此时是否可以将负ack发送到消息x？我从他们的文档中得到的信息是，这是不可能的--这是rabbitMQ不可能做到的事情吗？
对于多个消费者，我认为这是一个常见的场景。还有其他排队的产品支持这一点吗？
浏览 3提问于2016-02-13得票数 2
回答已采纳
我有一个组件，它向等待返回结果的员工服务发送消息。
@Autowired
private RabbitTemplate rabbit;
[...]
Object response = rabbit.convertSendAndReceive("testQ", ...);
工人服务是用Apache Camel rabbitmq路由实现的：
from("rabbitmq://localhost/myExchange?declare=false&routingKey=testQ&queue=testQ")
.routeId("m
浏览 4提问于2015-06-09得票数 6
我们的应用程序有一个带有侦听器容器的amqp入站通道适配器，在这里我们动态地添加和删除队列名。
我们希望利用RabbitMQ的BCC (发件人选择分发)功能，您可以将BCC头设置为收件人路由密钥集合。这将有利于RabbitMQ分发消息，而不是让副本(可能有数千个)单独发送。
问题是，当RabbitMQ发送消息时，它会像预期的那样移除BCC字段，并且不会将收件人的路由密钥放在接收到的路由密钥头中。此外，似乎没有办法将消息映射到它来自的队列。因此，应用程序不知道消息的目标是谁(来自队列的队列名称/路由密钥)。
以前，我们已经使用接收到的路由密钥来识别收件人。
我们考虑了两种方法。
1)动态地为每个
浏览 2提问于2015-03-12得票数 1
回答已采纳
1回答
我正面临以下问题，这可能是由于我对RabbitMQ的理解不足所致。如果我不为RabbitMQ专家使用术语，我很抱歉。
简单地说，我想在队列中发布一些具有不同优先级的消息，我希望消费者首先处理更高的优先级。
我已宣布我的队列如下：
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.basic_qos(prefetch_count=1)
channel.queue_declare(queue=JOBS_PENDING, durable=True, argument
浏览 9提问于2022-07-19得票数 0
我是刚来码头的。我创建了一个.net核心5.0WebAPI项目。
UPDATE最初，我在启动时收到下面的错误。当我试图发送消息时，我目前正在接收错误。
目标：通过杂志社发送消息
MassTransit.RabbitMqTransport.RabbitMqConnectionException:错误：警告: MassTransit重试00:00:08.1220000: Broker不可访问:来宾@localhost:5672/代理不可达：@localhost:5672/-> RabbitMQ.Client.Exceptions.BrokerUnreachableException：->
浏览 4提问于2021-02-01得票数 1
我在.NET应用程序中使用RabbitMQ。它可以正常工作，我已经在ioc中配置和注册了MassTransit总线控件，现在我可以向我的RabbitMQ实例发送消息并使用它们。
现在，我需要有可能向另一个RabbitMQ实例发送消息。我该怎么做？我不需要使用来自另一个RabbitMQ的消息，我只需要发送一些东西。
我试图注入ISendEndpointProvider，并将GetSendEndpoint与其他RabbitMQ实例的URI一起使用，但这似乎行不通。我没有任何错误，但当我试图以这种方式发送消息时，我的另一个RabbitMQ没有收到任何消息。MassTransit文档没有提到连接到多个
浏览 1提问于2020-04-21得票数 0
回答已采纳
1回答
使用Erlang20.1安装并运行了RabbitMQ 3.5.7。我还在同一台服务器上运行了PostgreSQL 9.5。
在兔子中，我从这里安装了插件pgsql-listen-exchange：
根据rabbitmq-plugins list的说法，它是存在并运行的：
[E*] pgsql_listen_exchange 0.3.0-v3.5.x
我在兔子管理UI中创建了一个exchange和通道，将消息从PGSQL发送到：
当我从CLI登录到PGSQL并尝试发送NOTIFY消息时，它永远不会通过：
我错过了什么，我遵循了GIT页面上的说明
浏览 2提问于2017-12-19得票数 2
回答已采纳
1回答
我刚接触过rabbitmq，我正在尝试在rabbitmq中发送一个.sh文件。我已经安排好了排队和交换。我使用的是spring-amqp，我可以用listerner容器发送json消息。
public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
container.setQueues(top
浏览 2提问于2015-04-16得票数 0
回答已采纳
我注意到一些应用程序会向RabbitMQ中的某个队列发送不正确的消息。由于在我的环境中，很多应用程序都可以访问RabbitMQ，因此很难通过检查代码来识别生产者。 有没有办法找到制片人？我需要一些监控工具吗？
浏览 12提问于2019-02-15得票数 1
回答已采纳
2回答
当我们将消息发送到RabbitMQ时，如果队列不存在，消息就会丢失，而不会引发任何错误。
信息将被张贴到哪里？死队列？
浏览 2提问于2017-05-25得票数 7
回答已采纳
1回答
我想使用来自rabbitMq队列的Storm中的消息。
现在，我们使用Spring异步地发送和接收来自RabbitMq的消息。
Spring提供了机制(创建侦听器或使用注释@RabbitListner)从队列中读取消息。
问题是，我可以让一个侦听器从队列中读取消息。但是，我如何将这条信息发送给我的Storm Spout，它正在运行在风暴集群上？
拓扑将启动一个集群，但是在我的nextTuple()方法中，我需要从这个队列中读取消息。Spring能在这里使用吗？
我有一个侦听器配置为从队列读取消息：
@RabbitListener(queues = "queueName")
pu
浏览 2提问于2015-09-29得票数 2
回答已采纳
我正在研究简单的Wso2 RabbitMQ集成。我的入站端点使用该消息并将其发送到序列。然后序列存储消息。另一个正在记录错误的故障序列。我正在尝试从序列中再次发送队列上的消息。
SalesOrderQueueInboundEP
<?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="SalesOrderQueueInboundEP" onError="SalesOrderQueueErrorSeq" protocol="rabbitmq&
浏览 3提问于2020-11-08得票数 0
回答已采纳
当我们使用rabbitMQ主题交换时，我们可以在任何地方发送消息。我们的项目非常大，当我收到一条消息时，我们发现消息中存在问题，我们希望在发送消息的位置修改消息。但很难找到消息发送的地方。
rabbitMQ中是否有方法或命令工具可以找出该消息从何处发送。
浏览 0提问于2016-04-13得票数 0
1回答
我想知道，一旦消息到达代理，是否有一种方法可以覆盖路由密钥。
举个例子:有两个兔子服务器。向第一台服务器发送消息，RabbitMQ将路由密钥设置为s1。如果将其发送到第二台服务器，则路由密钥设置为s2。
我不想让制片人担心路由密钥。一旦消息到达代理，它是否可以被设置或重写？
RabbitMQ是否可以以这种方式设置，或者是否有一个插件可以实现此功能？
浏览 2提问于2020-03-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
