使用spring-cloud-stream错误地调用了rabbitmq消息使用者上的流侦听器
是指在使用spring-cloud-stream框架时，错误地调用了rabbitmq消息使用者上的流侦听器。
Spring Cloud Stream是一个用于构建消息驱动的微服务的框架，它提供了一种简单且灵活的方式来连接消息代理（如RabbitMQ、Kafka等）和应用程序。而RabbitMQ是一个开源的消息代理，它实现了AMQP（高级消息队列协议）并提供了可靠的消息传递机制。
当使用spring-cloud-stream框架时，我们可以通过定义绑定器（Binder）来连接消息代理和应用程序。绑定器负责将消息代理的消息与应用程序中的流进行绑定，使得应用程序可以方便地接收和发送消息。
然而，在使用spring-cloud-stream时，如果错误地调用了rabbitmq消息使用者上的流侦听器，可能会导致以下问题：
- 消息丢失：如果错误地调用了消息使用者上的流侦听器，可能会导致消息无法正确地被消费，从而造成消息丢失的问题。
- 消息重复消费：如果错误地调用了消息使用者上的流侦听器，可能会导致消息被重复消费的问题，从而影响系统的一致性和性能。
为了避免这种错误，我们应该正确地使用spring-cloud-stream框架和rabbitmq消息使用者上的流侦听器。具体而言，我们可以按照以下步骤进行操作：
- 确保正确配置spring-cloud-stream框架：在应用程序的配置文件中，需要正确配置spring-cloud-stream框架的相关属性，包括绑定器的类型、消息代理的地址等。
- 定义消息消费者：在应用程序中，需要定义一个消息消费者，用于接收和处理消息。可以使用注解（如@StreamListener）来标识消息消费者的方法。
- 绑定消息消费者和消息代理：通过在消息消费者的方法上使用注解（如@Input）来指定消息消费者与消息代理之间的绑定关系。这样，消息代理上的消息就可以被正确地传递到消息消费者中。
- 处理消息：在消息消费者的方法中，可以编写具体的业务逻辑来处理接收到的消息。可以使用spring-cloud-stream提供的一些工具和类来简化消息的处理过程。
总结起来，正确使用spring-cloud-stream框架和rabbitmq消息使用者上的流侦听器是确保消息驱动的微服务能够正常运行的关键。通过正确配置框架、定义消息消费者、绑定消息消费者和消息代理，并编写合适的消息处理逻辑，可以确保消息的可靠传递和正确处理。
腾讯云相关产品推荐：
- 腾讯云消息队列 CMQ：腾讯云提供的消息队列服务，可实现高可靠、高可用的消息传递。链接地址：https://cloud.tencent.com/product/cmq
- 腾讯云云服务器 CVM：腾讯云提供的弹性云服务器，可用于部署和运行应用程序。链接地址：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库 MySQL：腾讯云提供的高性能、可扩展的云数据库服务，适用于各种应用场景。链接地址：https://cloud.tencent.com/product/cdb
相关·内容
我在春季引导应用程序中使用了rabbitmq。我正在使用aws ecs进行部署。现在假设我的服务正在运行多个实例。和rabbitmq监听订单创建是通过直接交换注册的。那么下订单后会发生什么呢？我的两个服务实例会得到相同的消息吗？如果是，如何防止在这两个侦听器上重复消息？
浏览 0提问于2019-01-23得票数 3
回答已采纳
在我的系统中，我使用spring-cloud-stream和RabbitMQ来发送和接收事件。我的RabbitMQ运行，服务A up和服务B停机。服务A向服务B发送事件。然后我打开了我的服务B，现在我希望兔子会对这一事件感到高兴--但什么也没发生。行为正确吗？我是RabbitMQ的新手，但我认为它应该保证所有事件最终都能找到它的接收者。我的应用程序很简单，基于，没有额外的配置。我错过了什么？
浏览 1提问于2017-12-12得票数 0
回答已采纳
3回答
如何将任务排队到C#的芹菜中？
、、、、
正如我所理解的，像RabbitMQ这样的消息代理为用不同语言/平台编写的不同应用程序相互通信提供了便利。因此，由于芹菜可以使用RabbitMQ作为消息代理，所以我相信我们可以将任务从任何应用程序排队到芹菜，即使生产者不是用Python编写的。
现在，我试图弄清楚如何通过C#通过RabbitMQ编写应用程序，将任务排队到芹菜。但我还找不到这样的例子。
我发现的唯一接近这个的信息是
所接受的答案建议使用芹菜消息格式协议将消息从Java排队到RabbitMQ。但是，在答案中给出的链接没有任何示例，只有消息格式。
此外，在此协议中需要消息格式says (UUID)进行通信。我的C#应用程序如何知道芹菜
浏览 3提问于2016-10-13得票数 13
回答已采纳
我们正在开发一个使用spring-cloud-stream的项目，使用rabbitmq作为消息代理和gradle。
出于测试目的，我们正在运行一个带有rabbitmq实例的docker容器。
application.yaml：
spring
rabbitmq:
host: localhost
我有这样的测试：
@DirtiesContext(classMode = BEFORE_EACH_TEST_METHOD)
@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = RANDOM_PORT)
public cla
浏览 0提问于2018-04-19得票数 0
1回答
我正在努力深入了解客户机和RabbitMQ服务器之间的Push通信是如何工作的。
如我所知--但请纠正我的情况--客户端打开与代理(RabbitMQ)的TCP连接，并将此连接保持在客户端决定关闭它之前。但在此连接期间，客户端可以立即获得消息。
我的问题是，在此连接期间，客户端是否监视代理向他请求消息，或者当代理将消息转发到队列(客户端订阅的队列中)时，只需使用连接并将数据推送到客户端？
第一种情况:客户端监视代理获取消息
最后一种情况:客户机不需要监视代理，代理只需推送数据
还是其他的？
浏览 0提问于2017-10-05得票数 2
回答已采纳
1回答
我在rabbitMQ服务器(版本3.3.5)中有一个队列，一个发布者在这个队列上发布消息。我有一个消费者，它监听这些消息。有时，使用者会停止接收队列中发布的消息。这在开发环境中不会发生。但是，它发生在测试环境中。使用的交换类型是主题交换。有人能在这方面帮我吗？
提前谢谢。
浏览 3提问于2016-05-23得票数 0
我正在尝试使用RabbitMQ客户端API与RabbitMQ服务器交互。我从上读到
根据经验，在线程之间共享通道实例是必须避免的。应用程序应该更喜欢使用每个线程的通道，而不是在多个线程之间共享相同的通道。
我试图使用带有ThreadPoolExecutor 1的corePoolSize，并添加可运行的任务，以便将消息保存到RabbitMQ队列中。下面是我使用的代码：
package common;
import java.io.IOException;
import java.io.InputStream;
import java.security.KeyManagementExce
浏览 4提问于2017-06-15得票数 1
1回答
我想使用来自rabbitMq队列的Storm中的消息。
现在，我们使用Spring异步地发送和接收来自RabbitMq的消息。
Spring提供了机制(创建侦听器或使用注释@RabbitListner)从队列中读取消息。
问题是，我可以让一个侦听器从队列中读取消息。但是，我如何将这条信息发送给我的Storm Spout，它正在运行在风暴集群上？
拓扑将启动一个集群，但是在我的nextTuple()方法中，我需要从这个队列中读取消息。Spring能在这里使用吗？
我有一个侦听器配置为从队列读取消息：
@RabbitListener(queues = "queueName")
pu
浏览 2提问于2015-09-29得票数 2
回答已采纳
我是RabbitMQ的新手。
对于我的应用程序，我有一个用例，我正在尝试使用RabbitMQ：
生产者向队列发送一些消息。
用户处理并发送回复
根据回复制片人的行为
对于上面的场景，我使用了convertSendAndReceive，当生产者和消费者都在同一台RabbitMQ服务器上时，它就像一种魅力。但是当队列被铲掉时，同样的情况就不起作用了。
如果我使用了错误的方法/配置w.r.t RabbitMQ，请告诉我。
提前谢谢。
加码
消费者
public static void main(String[] args) throws InterruptedException
浏览 4提问于2015-07-27得票数 1
回答已采纳
我已经在我的项目的rabbitmq中创建了一个队列，并将最大年龄配置为1分钟。我向队列发送了一条消息，所有的消费者都使用了该消息，但是消息仍然保留在队列中(我等待了1分钟以上)，作为“就绪”。我担心的是在rabbitmq实例的HD中信息的积累。
所以，我的问题是，所有标记为“就绪”的讯息，即使是在所有消费者都吃了之后，也会储存在房屋署内？如果是的话，我如何才能清除(在这种情况下，最大年龄不起作用)这些消息从HD的狂犬病实例？
浏览 9提问于2022-03-17得票数 0
1回答
我们的系统中有几个RabbitMQ队列，我们使用Spring Integration amqp:inbound-channel-adapter来使用消息。Spring应用程序在5个JBoss节点上运行(不在集群中)
RabbitMQ端是一个具有负载均衡器、持久队列的两个集群节点，在应用程序端的监听器定义相当简单，连接工厂定义如下：
<rabbit:connection-factory id="amqpConnectionFactory" username="${orts.rabbitmq.username}" password="${orts.ra
浏览 0提问于2016-08-30得票数 0
我已经安装了rabbitmq，在python中使用pika，在C中使用rabbitmq-c进行测试。
除了将侦听器端口修改为我自己的端口之外，我没有对rabbitmq做任何事情。
制作人一整晚都在把足够多的信息放进“狂犬病”，大约1000 K的持久信息。
客户是用C和python编写的，但它的qps仅为每个队列80。
互联网上的文章说，他们的单一队列可以达到15000 qps，那么我的队列有什么问题呢？我需要配置一些有关狂犬病的基本知识吗？
每条消息大约是100 Btyes长，我使用消费ack，并且队列和消息都是持久的。
浏览 2提问于2012-09-12得票数 0
1回答
我正在做一个与RabbitMQ一起工作的POC，并有一个关于如何有条件地侦听队列的问题！
我们正在使用队列中的消息，一旦消息被使用，该消息将参与到根据文件大小需要更长时间的上载过程中。当文件较大时，有时我们调用的外部服务会耗尽内存，如果多个消息被使用，并且前一条消息的上传过程仍在继续。
也就是说，一旦当前/上一条消息被完全处理，我们只想消费队列中的下一条消息。我是JMS的新手，不知道该怎么做。
我现在的想法是，当代码流完成前一条消息的处理时，它将手动从队列中拉出下一条消息，因为该流知道它已经完成了处理，但如果该侦听器只在代码流中用于手动调用，那么它将如何拉出第一条消息！
浏览 0提问于2019-09-20得票数 0
我正在Python项目中工作。
它的功能之一是有人从web应用程序中发送一些数据，将数据提前发送到移动设备。
对于此功能，应用程序使用第三方服务作为和。以下是应用程序的数据流。
Web应用
由于Amazon端可能存在网络延迟、操作延迟和故障等问题，web应用程序使用作为调度器应用程序来实现异步、重试等行为，并将SNS发送任务存储在队列中并进行异步处理。
芹菜作为调度器使用RabbitMQ作为它的代理应用程序。以下是数据流。
Web >芹菜-> RabbitMQ -> Amazon > GCM -> Android设备
确定了一个与芹菜和Rabbit
浏览 0提问于2018-04-11得票数 0
1回答
我试图在两个或更多的spring应用程序之间传递数据。为此，我在RabbitMQ中使用了Spring。现在，我还需要Pub体系结构，在这里，所有订阅者都应该得到消息。目前，在RabbitMQ中，Pub为每个用户创建每个队列。这个我不想要。
我还在查看Pub消息传递系统的列表，这将解决我的问题。
Publisher------>Data----->Subscriber 1
----->Subscriber 2
雷迪斯
阿帕奇卡夫卡
请推荐最佳的消息传递系统。
浏览 1提问于2016-09-08得票数 0
1回答
所以，一步一步地，我想做什么：
如果发送到另一个系统时发生错误，我将接收数据，然后将数据发送到rabbitMQ：
@Override
public void updateAnketaIfThrowThenSendMessageInRabbit(ProfileId profileId, ChangeClientAnketaRequest anketa, String profileVersion) {
try {
anketaService.updateAnketa(profileId, anketa, profileVersion);
浏览 1提问于2020-07-20得票数 0
回答已采纳
我们现在使用的是带有WCF激活功能的MSMQ，它使我们能够不拉队列来读取消息。它喜欢将消息推送到应用程序。
当我们看到从MSMQ到RabbitMQ的移植时，我们需要从消息队列中完成所需的工作。
关于RabbitMQ .net客户端支持从订阅队列接收消息通知，我什么都不能做？
RabbitMQ中有什么.net可以推送通知给订阅者的东西，比如MSMQ?
或者我们需要不断检查消息的服务运行？
浏览 3提问于2010-10-14得票数 8
2回答
以下属性之间的主要区别是什么：
1)spring.rabbitmq.listener.direct.prefetch= #单次请求处理的消息数。它应该大于或等于事务大小(如果使用)。
2)spring.rabbitmq.listener.simple.prefetch= #单次请求处理的消息数。它应该大于或等于事务大小(如果使用)。
浏览 2提问于2018-09-21得票数 1
这是我当前的spring配置
<rabbit:connection-factory id="rabbitConnectionFactory"
port="${rabbitmq.port}" host="${rabbitmq.host}" username="${rabbitmq.username}" password="${rabbitmq.password}"/>
<rabbit:admin id="rabbitmqAdmin" connection-factory=&
浏览 0提问于2014-05-19得票数 3
回答已采纳
2回答
我有两个应用程序使用RabbitMQ交换数据。我使用Spring实现了这个功能。我有这样的场景:一旦从使用者那里消费了消息，在处理过程中可能会遇到异常。
如果出现任何异常，我计划登录到数据库中。无论消息是成功处理还是遇到错误，一旦消息到达使用者，我就必须显式地从队列中删除消息。
如何强制从队列中删除消息，否则，如果我的应用程序无法处理它，它就会出现？
下面是我的侦听器代码
@RabbitListener(containerFactory="rabbitListenerContainerFactory",queues=Constants.JOB_QUEUE)
浏览 7提问于2016-08-27得票数 1
1回答
为了避免队列读取器进程崩溃时的数据丢失，我们需要以未确认的方式从RabbitMQ获取消息。对于每1000条消息，我们将消息数据提交到磁盘，然后将这些消息标记为已确认和使用。有没有办法让他们不被承认，然后专门针对那些我们刚刚得到的？例如，我们是否可以将它们添加到列表中，然后遍历该列表以查找消息？这是在RabbitMQ .net FYI。
浏览 2提问于2016-03-22得票数 1
我在OpenShift上运行了一个MQTV3.6.10实例，并启用了RabbitMQ插件。我有多个Spring Boot应用程序，使用来自RabbitMQ队列的消息。所有消费者都使用MqttDefaultFilePersistence。将持久化数据写入到持久化卷上的目录/tmp/mqtt，配额为100M。这是我为连接到RabbitMQ队列而编写的代码：
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(pass
浏览 1提问于2017-11-24得票数 0
我有处理传入消息的RabbitMq使用者(RabbitMQ.Client.Events.EventingBasicConsumer)。
但是我注意到，如果关闭连接和模型，它们不会等待完成库处理线程。例如：
如果我将线程休眠几秒钟添加到回调中，那么我注意到在完成Close函数之后，Close函数(Close() of IModel和IConnection)在退出消费者回调之前已经完成，我继续收到一些消息给EventingBasicConsumer::Received回调。<code>H 212</code><code>G 213</code>
那么
浏览 4提问于2020-10-30得票数 2
我正在尝试使用spring cloud stream在kafka上发送和接收消息。这方面的示例使用了一个使用时间戳作为消息的简单示例。当我在上遇到这个拦截器时，我正试图更深入地了解现实世界的应用程序
“使用@InboundChannelAdapter批注的方法不能接受任何参数”
我试着这样使用它：
@InboundChannelAdapter(value = ChannelManager.OUTPUT)
public EventCreated createCustomerEvent(String customerId, String thingId) {
return new Even
浏览 0提问于2017-07-27得票数 0
2回答
我想并行地处理来自rabbitMq队列的消息。队列被配置为autoAck =false。我正在使用camel-rabbitMQ对的支持，它支持threadPoolSize参数，但这并没有达到预期的效果。消息仍然是在队列之外连续处理的，即使在threadpoolsize=20时也是如此。
通过代码调试，我可以看到线程池大小参数用于创建一个ExecutorService，用于像描述的那样传递给兔子连接工厂。这一切看起来都很好，直到你进入兔子ConsumerWorkService。在这里，消息以最大大小为16条的块进行处理。块中的每条消息都是串行处理的，如果有更多的工作要做，则会用下一个块调用exe
浏览 2提问于2013-10-08得票数 9
我从RabbitMq服务器上得到了这个错误
服务器关闭的通道: 406 (前提-失败)，带有消息"PRECONDITION_FAILED -未知传递标记80“
之所以会发生这种情况，是因为连接在使用者任务期间丢失，而在最后，当消息被加/捕获时，我会得到这个错误，因为我无法在与我所得到的消息不同的信道上插入一个消息。
下面是RabbitMq连接的代码
async connect({ prefetch = 1, queueName }) {
this.queueName = queueName;
console.log(`[AMQP][${this.queueNam
浏览 14提问于2021-07-01得票数 0
回答已采纳
我能够停止消费并重新启动消费，但问题是，当我重新启动消费时，我能够处理已经发布的消息，但是当我发布无法处理的新消息时。
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Consumer;
@Component
public class RabbitMqueue implements Consumer {
int count = 0;
@RabbitListener(queues="dataQueue")
public void receivedData(@Payload Event msg, C
浏览 3提问于2018-07-02得票数 4
回答已采纳
我正在使用spring-cloud-data-flow-server-yarn，并在我的yarn集群中成功地部署了我的spring-cloud-stream应用程序。
现在我面临一个问题：
当我部署我的scs应用程序时，spring.cloud.stream.bindings.output.destination的属性值将被重写为streamName.groupName，我认为这是通道名称的默认值。
如何让scs-app内的频道名称属性生效？我的意思是不使用部署属性，而只是让scs-app中的属性生效。
浏览 3提问于2017-05-31得票数 0
1回答
我正在尝试向我的Django应用程序添加一些实时特性，因为我在django项目中使用了RabbitMQ和Celery，所以我想要做的是:我有一个外部Python脚本，它将数据从RabbitMQ >发送到RabbitMQ --应该从Django应用程序中检索。
我正在发送一些木偶数据，如：
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='Te
浏览 3提问于2020-03-31得票数 0
回答已采纳
我在玩春云流和RabbitMQ.
我有一个REST端点，它生成消息。
@SpringBootApplication
@EnableBinding(MyProcessor.class)
public class ProducerDemoApplication {
public static void main(String[] args) {
SpringApplication.run(ProducerDemoApplication.class, args);
}
}
@RestController
class ProducerController {
浏览 0提问于2018-10-14得票数 0
回答已采纳
我正在尝试同步我拥有的三个微服务。
为了做到这一点，我实现了RabbitMQ。现在似乎一切正常，但我不确定我是否在遵循最佳实践，我找不到参考资料来查找它，也许有人能帮我做这件事？
简要介绍我要做的事情：我有一个服务应该更新另外两个，每个服务都应该接收发送的消息。我有两种类型的消息(保存和删除资源)。*在出现错误时，队列应恢复并重新发送消息。
我正在做的事情：，我已经设置了一个交换，我的每个使用者连接到两个不同的队列，每种类型的消息(保存/删除)一个。我已经使用了一个直接的交换来过滤以后的消息，即使目前我不需要过滤它们。
每个队列都是命名的，交换和消息都是持久的，我正在添加我使用过的消息。
问题
浏览 4提问于2016-07-11得票数 3
回答已采纳
我是RabbitMQ的新手。在RabbitMQ中，一旦消息被使用者使用，它是否仍然在队列中可用？来自特定队列的单个消息能被多个使用者使用吗？与卡夫卡不同，在文件系统中存储消息是如何在RabbitMq中存储的？
浏览 4提问于2017-06-12得票数 1
回答已采纳
1回答
我们目前正在创建一个微服务(Nodev8.3.0)，它必须每秒消耗大约60-150条RabbitMQ消息(RabbitMQ 3.6.12，Erlang19.2.1)。有时候，它就像一种魅力，队列中没有剩下的消息。但是，大多数情况下，只有5-20条消息每秒被处理并累积到队列中的3M条消息。
现在我们真的很好奇如何用一个用户来处理所有这些消息。因为已经有一些Java使用者不延迟地处理所有这些消息。我们使用基于的。此外，处理程序立即确认传入的消息-业务逻辑绝对是异步的。因此，即使没有任何业务逻辑，它也会陷入困境。交换的类型是topic，它不是durable，队列启用了auto-deleting功能。
浏览 3提问于2017-11-02得票数 1
回答已采纳
2回答
使用get messages命令后无法查看rabbitmq队列消息。
rabbitmqadmin get queue='queue_name' -H localhost -P 15672 -u rmq -p rmq --vhost=/ count=100
队列计数显示100条消息，不能再次使用上面的命令查看消息。
浏览 15提问于2022-06-06得票数 0
我一直在考虑使用Redis /Sub作为RabbitMQ的替代品。
据我所知，Redis的pub/sub与每个订阅者都有一个持久的连接，如果连接被终止，所有未来的消息都将丢失并丢弃在地板上。
一种可能的解决方案是使用一个列表(和阻塞等待)来存储所有消息和发布/订阅，作为一种通知机制。我认为，这使我的方式，但我仍然有一些担心的失败案例。
当订阅者死亡并返回联机时会发生什么，它应该如何处理所有挂起的消息？
当系统中出现格式错误的消息时，如何处理这些异常？DeadLetter队列？
是否有执行重试策略的标准做法？
浏览 1提问于2011-05-31得票数 58
回答已采纳
1回答
我知道RabbitMQ不支持JMSXGroupId，而且从上看，这个特性似乎很快就会被整合到RabbitMQ中。对于使用交换/队列/主题的组合，有什么解决方法吗？这是我的用例。
假设我有一个生产者服务器和两个消费者服务器，其中有多个消费者线程在使用队列中的线程。生产者服务器创建一个网络、一个子网和多个端口。所有这些请求都被转换为json/stomp并放入队列中。现在，我如何保证同一线程处理属于同一网络的所有这些请求。在ActiveMQ或Artemis中，我们可以将JMSXGroupId设置为网络名称，并确保消息由相同的线程拾取/确保属于同一网络组的消息是有序的。如何在RabbitMQ中实现这一
浏览 2提问于2017-05-19得票数 1
1回答
目前，我们正在使用“RabbitMQ”进行可靠的消息传递，我们计划通过TCP移动SQS.RMQP监视器，当队列的任何使用者关闭时，它将自动重新排队处理消息。
SQS会监视它的所有奴隶吗？如果其中一个使用者在处理消息时停机，该消息在队列中是否可见？
我试图从文件中找出同样的情况，但却找不到。
浏览 7提问于2016-01-27得票数 1
回答已采纳
我开始阅读RabbitMQ来决定是否可以将它用于一个新的网络项目--我现在非常兴奋：)
我看到的所有示例都以使用者的身份在控制台应用程序中使用了一些while(true)循环。在windows平台上实现消费者的可靠和容错的方法。我想是窗户服务吧？是否有人这样做，并在生产中运行，也许可以分享他的经验？
我想做的只是将MQ放在一台服务器上，将消息从web应用程序中推入，并使用第二台服务器连接到第一台服务器上的MQ，轮询消息(每秒钟一次)并执行一些操作。这与RabbitMQ是可能的吗？
Thx Eau
浏览 3提问于2012-06-12得票数 0
回答已采纳
2回答
我创建了一个Spring，它使用了应用程序中的。我使用的是带有RabbitMQ绑定的。这将自动使用我的路由器表达式的结果创建RabbitMQ交换(类型:主题)。我认为下一步是为每个路由器结果创建新的数据流。但是，只能将配置为从队列中读取。当然，我可以手动创建队列并将它们绑定到自动创建的交换，但这就是我应该做的吗？或者，是否有一些我缺少的配置会导致队列自动创建和绑定？
浏览 0提问于2018-01-16得票数 1
回答已采纳
我需要知道是否有可能从正在处理的RabbitMQ (消费者)那里知道或收到一条消息(可能需要很长时间)。但是，我不想停止这项服务。我希望我的问题足够清楚。
浏览 0提问于2016-10-13得票数 0
回答已采纳
我正在学习https://www.rabbitmq.com/tutorials/tutorial-one-python.html上的教程 我已经使用docker设置了RabbitMQ。在那里定义了交换，等等。 管理UI显示创建的exchange。当第一次执行发送者脚本时，队列也会显示在UI中。 我首先运行消费者&然后是发布者。但是，当消息被发布时(假设消息已经发布，因为send脚本没有抛出任何错误)，消费者不会收到任何消息。我可以看到AMQP连接被正确地建立和关闭(在发布者的情况下)。但是队列是空的。 管理UI还显示一个空队列。我尝试使用UI本身发布持久和非持久消息，但即使在那里，当
浏览 257提问于2021-10-24得票数 0
我正在使用.NET /RabbitMQ的生产者/消费者场景中的2个核心控制台应用程序。我需要确保，即使没有消费者启动和运行，来自生产者的消息仍然成功排队。这似乎不适用于Publish() --消息只是消失了，所以我使用Send()代替。消息至少会排队，但是如果没有任何用户运行这些消息，所有消息都会在"_skipped“队列中结束。
这就是我的第一个问题：这是基于需求的正确方法(即使没有消费者正在运行，来自生产者的消息仍在成功排队)？
使用Send()，我的使用者确实可以工作，但是仍然有许多消息从漏洞中掉下来，被抛到"_skipped“队列中。消费者的逻辑是最小的(目前只是记录消
浏览 1提问于2019-05-08得票数 1
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？
RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
我正在使用spring，如果它失败了，我想重试获得到RabbitMQ和MongoDB的连接。
我知道它适用于sql数据库：。
但是，我不知道应该为RabbitMQ和MongoDB包装哪些类。
我还试图包装ConnectionFactory for RabbitMQ，但是AbstractConnectionFactory有一些最后的方法，我不能重写它来将调用传递给委托工厂。
浏览 1提问于2018-05-15得票数 1
回答已采纳
我正在使用Spring 和RabbitMQ。
使用RabbitMQ启动码头后：
sudo docker run -t -i --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
我执行了发行者和订阅者应用程序的示例来观察消息的行为。
我在管理面板()中注意到的一件事是，在启动订阅服务器时创建的队列被配置为auto-delete: true。因此，当没有订阅服务器运行时，队列就不会创建，发布者发送的每一条消息都是丢弃的。这不是我所期望的默认配置！
因此，我想将创建的队列更改为auto-delete: false，因为这
浏览 2提问于2018-02-15得票数 1
回答已采纳
我正在考虑设置一个RabbitMQ代理来处理java应用程序的基本任务处理。其基本思想是，生产者是一个web服务器，希望快速处理请求，但也需要进行一些数据处理。为了实现这一点，它了解一些可以序列化为AMQP消息的jobs，还有一个消费者知道如何处理这些作业。太经典了。
在阅读了RabbitMQ文档之后，我仍然有几个问题要问。
我希望使用者应用程序充分利用它的CPU处理消息，我想知道RabbitMQ是否已经提供了工作池。假设我想要4个工作线程，那么在相同的连接上注册4个通道、每个用户注册4个通道是否足够？在这种情况下，工作将在handleDelivery()中完成，如果它成功完成，将发送一个
浏览 5提问于2014-04-07得票数 2
1回答
我需要关于如何编写涉及rabbitMQ消息代理的集成测试的帮助。
这是整个系统架构
服务(生产者) -->消息中介(环境1) -->控制器(我们的应用程序) -->消息代理(环境2) -->消费者设备
我计划将我的集成测试程序放在服务级别，在其中我将模拟要发送到消息代理的消息。稍后，我将侦听并断言响应。
虽然它是一个异步系统，但测试同步方式似乎是一种简单的方法。
有没有更好的方法来对我的应用程序流进行集成测试。你能给我一些集成测试的指点吗？
谢谢，芭拉。
浏览 0提问于2020-02-05得票数 0
使用Spring-AMQP抽象API，如何实现工作或任务队列？我只有一个生产者和多个工人消费者。消费者从队列中挑选下一项并对其进行处理。当您直接使用Spring时，这是受支持的，但我在RabbitMQ -AMQP中看不到任何支持。我是不是漏掉了什么？有没有其他实现工作队列的方法？
浏览 0提问于2015-04-17得票数 2
我使用的是RabbitMQ版本3.0.2 &我在错误队列中看到了接近1000条消息。我想知道
在什么时候消息被移动到错误队列？
有办法知道为什么某个消息被移动到错误队列中吗？
是否有任何方法将消息从错误队列移动到正常队列？
谢谢
浏览 3提问于2013-12-11得票数 14
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
