spring-rabbitmq 相关问题

基于AMQP的消息传递的Spring组件。

连接到队列或在spring-rabbitmq中创建不存在

我正在使用带有spring-rabbitmq的spring-boot。我的连接工厂在application.properties中配置,看起来很不错。我的目标是:在开始检查期间是否存在特定名称的队列,...

回答 1 投票 1

在RabbitListener中设置reply_to属性

我是RabbitMQ的新手。我在Spring配置中使用以下监听器:@RabbitListener(queues =“$ {rabbitmq.queue.a}”)@ SendTo(“$ {rabbitmq.queue.b}”)public ResponseMessage receive(...

回答 1 投票 0

处理Spring-Boot-RabbitMQ中的连接

嗨,我正在开发Spring-boot-RabbitMQ版本1.6。我在开发应用程序时几乎没有查询。阅读文档并浏览其他堆栈溢出问题,但我无法清楚地了解一些事情(...

回答 2 投票 1

Spring Batch AmqpItemReader确认

当我想要在我的服务停止后将数据返回队列时,在阅读批量数据后,我遇到了问题。如果我在amqp中理解了goos我可以使用确认,但在春季沐浴文档中我...

回答 1 投票 1

使用RabbitMQ实现Push和Pull

我们可以使用可配置参数在RabbitMQ中实现推送和拉取机制吗?这可能是一个广泛的问题,但寻求帮助设计SPA。更新:我们是新闻发布商网站。 ...

回答 1 投票 0

我如何(可以吗?)检测到RabbitMQ队列创建失败?

我正在尝试解决RabbitMQ中与服务器相关的竞争条件,在网络/套接字断开后及时收到独占队列,并导致恢复代码...

回答 1 投票 1

RabbitMQ Stomp无法获得连续的大型消息

我正在使用带有Stomp的Spring RabbitMQ来构建一个事件流应用程序,其中服务器将大约100KB的大消息连续地放到TopicExchange amp.topic中,绑定密钥为...

回答 1 投票 1

绑定交换以通过Spring cloud stream与rabbitmq binder交换

我正在寻找一种通过Spring云流将RabbitMQ交换绑定到另一个的方法。我知道我可以通过设置producer.requiredGroups属性将队列绑定到交换:spring.cloud ....

回答 1 投票 0

Springcloud总线自定义消息无法通过rabbitmq发送

使用springcloud总线时,会创建一个自定义消息并通过rabbitmq发送,但在发送消息后,它不会转到rabbitmq。当您尝试呼叫/执行器/总线刷新时,您可以......

回答 1 投票 1

spring amqp默认启用重试,并根据指定的异常阻止它

在例外情况下A:重试有限次数,最后当重试次数耗尽时,消息写入死信队列。如果是异常B:简单地说,消息应该......

回答 2 投票 0

如何在rabbitmq中配置队列的使用者来监听多种数据类型的消息?

我正在尝试使用rabbitmq的队列来生成和使用多种数据类型的消息。例如。我能够使用jackson序列化程序和字符串推送员工对象(以json格式)...

回答 1 投票 0

我需要在Rabbit mq中保存消息,并在我的工作成功完成后删除它

我需要在兔子mq中保存m条消息。我在SimpleMessageListenerContainer中使用acknowledgeMode作为MANUAL。这有助于我将价值存储在兔子mq中。但即使在工作之后......

回答 1 投票 0

如何从收听者发送回复

我正在从事Java和RabbitMQ学习的家庭作业。我对Spring和RabbitMQ并不熟悉,但我无法解决这个问题。我有2个单一的申请。第一个,......

回答 1 投票 0

Spring Boot AMQP @RabbitListener没有收到消息

我有一个Spring Boot应用程序,我正在尝试通过RabbitMQ发送和接收消息。问题我可以将消息成功发送到队列(即我在RabbitMQ的队列中看到它们...

回答 2 投票 3

在消费者归零后,rabbit-mq队列不会自动删除

我将选项autoDelete设置为队列的true,但有时即使consumer为0,队列仍然存在我如何才能找到原因?以及如何删除?谢谢

回答 1 投票 -2

如何使用spring rabbitmq配置不同队列中的超时,重试或最大尝试次数

是否可以为每个队列进行这些设置?我有重要的队列,所以我需要更多的重试,但有不太重要的队列,我不想配置重试,...

回答 3 投票 2

带有rabbitmq集群和spring amqp的负载均衡器

我想在负载均衡器后面设置一个rabbitmq集群,并使用spring amqp连接到它。问题:Spring客户端是否需要知道RMQ集群中每个节点的地址,或者它是......

回答 1 投票 0

在将AsyncRabbitTemplate与请求/回复模式一起使用时,如何构建非阻塞使用者

我是rabbitmq的新手,目前正在尝试使用非阻塞消费者来实现非阻塞生成器。我已经构建了一些测试生产者,我在其中使用了typereference:@Service public class ...

回答 1 投票 3

spring cloud stream两个不同组的不同并发设置不起作用

我已经配置了默认并发设置,我有另一个需要不同并发级别的组,但第二个是默认的并发性为1。它工作得很好......

回答 1 投票 0

Spring AMQP中的消息重试策略

我正在使用spring-amqp在我的Web应用程序中使用来自RabbitMQ的消息。 Web应用程序由多个组件组成,例如(Redis,OracleDB)现在我有一个场景,如果有的话......

回答 1 投票 2

© www.soinside.com 2019 - 2024. All rights reserved.