spring-amqp相关内容

慢速网络中的大型 RabbitMQ 消息

我正在使用带有 Spring AMQP 的 RabbitMQ 大型消息(>100MB，102400KB) 小带宽 (低心跳间隔(10 秒) 单一经纪人 消费消息需要>= 200*8秒，超过了我的心跳间隔.来自 https://stackoverflow.com/a/42363685/418439 如果节点间的消息传递时间(60秒?)>节点间的心跳时间，会导致集群断线，消息松散 ..
发布时间：2022-01-11 17:32:11 其他开发

rabbitmq with spring amqp - 在 AmqpException 的情况下消息卡住

我在我的消费者体内抛出了一个 AmqpException.我的期望是消息会以先进先出的顺序返回队列，并在未来的某个时候被重新处理. 似乎 Spring AMQP 没有将消息释放回队列.而是尝试一遍又一遍地重新处理失败的消息.这会阻止处理新到达的消息.被卡住的那些在 AMQP 控制台中永远处于“解压"状态. 有什么想法吗? 解决方案 rabbitmq/Spring AMQP就是这 ..
发布时间：2022-01-11 17:32:03 其他开发

通过 RabbitMQ 发送文件

通过 RabbitMQ 发送大小约为 1Mb 的文件是个好主意吗?我想以 json 格式发送消息，其中包含与文件对应的二进制字段. 以及如何使用 spring-amqp 正确地做到这一点?只需通过下一个类发布对象? 类消息{字符串字段1；字节[] 文件字段1；字节[] 文件字段2；} 解决方案 我建议不仅要阅读那些发布的链接，还要自己做一些实验.我要关心的是服务级别和客户端级别的性能. ..
发布时间：2022-01-11 17:31:39 其他开发

Spring RabbitTemplate - 如何在发送时自动创建队列

我将 RabbitMQ 与 Spring 的 RabbitTemplate 一起使用. 当使用模板发送方法向队列发送消息时，我希望队列不存在时自动创建/声明. 这非常重要，因为根据我们的业务逻辑，队列名称是在运行时生成的，我无法提前声明它们. 之前我们使用 JmsTemplate 并且任何发送或接收的调用都会自动创建队列. 解决方案 是的，你可以使用 RabbitAdmi ..
发布时间：2022-01-11 17:30:57 Java开发

Spring 与 Rabbit AMQP 集成，用于“客户端发送消息 -"服务器接收&在返回队列中返回 msg -->客户端获取相关消息"

我可以使用 Rabbit Java API 编写一个 java 程序，执行以下操作: 客户端通过 Rabbit MQ 交换/队列发送带有相关 ID 的消息(比如 UUID -“348a07f5-8342-45ed-b40b-d44bfd9c4dde"). 服务器收到消息. 服务器通过 Rabbit MQ 交换/队列发送具有相同关联 ID - “348a07f5-8342-45ed ..
发布时间：2022-01-11 17:30:22 其他开发

rabbitmq中的预取计数与无确认有什么区别

我需要知道 rabbitmq 中的 prefetch count 和 no ack 有什么区别? 还有以下语句有什么区别:- 如果我将预取计数设置为 10，是否会创建 10 个消费者线程?或者—— 如果我注册 10 个 cosumer，它会创建 10 个线程吗? 以上哪个更高效 解决方案 预取计数:消费者应该从队列中读取多少条消息并保留在内部，而不是一次选择一条消息 ..
发布时间：2022-01-11 17:29:44 其他开发

Spring AMQP:将 BlockedListener 注册到连接

我正在尝试使用 Spring AMQP 的 RabbitTemplate 实现对 RabbitMQ 的阻塞侦听器.在我的代码中，我使用的是 Spring-amqp 1.1.3 版本的 jar 文件，而我也研究了 1.3.1 版本，这个版本也不支持.有谁知道我是否缺少任何支持将阻塞侦听器注册到 RabbitMQ 中的新连接的版本.或者是否有任何未来版本的 spring amqp 支持此功能. ..
发布时间：2022-01-11 17:29:25 其他开发

检查rabbitmq中是否存在指定名称的Exchange

我有一个场景，其中有一个应用程序正在生成不同类型的有趣事件(不是命令).生产者应用程序不关心事件由谁以及如何处理. 我正在实现一个消费者，他将监听一些已发布的事件并适当地处理它们.消费者应用程序想要检查发布者应用程序交换是否存在.那么，问题是如何利用spring提供的rabbit/AMQP库来检查是否存在特定名称的交换? 我想，这可以通过尝试将队列绑定到不存在的交换器来间接处理，从而导 ..
发布时间：2022-01-11 17:23:08 其他开发

在运行时向兔子侦听器动态添加队列

我有一个项目，我们将在 rabbit 中拥有数百个(可能数千个)队列，并且每个队列都需要被一个消费者池消费. 在 rabbit(使用 spring-amqp)中，你有 rabbitlistener 注释，它允许我静态分配这个特定消费者将处理的队列. 我的问题是 - 对于 rabbit 和 spring，我是否有一种干净的方式来获取一段队列(比如说以 ac 开头的队列)，然后还监听在消费 ..
发布时间：2022-01-11 17:15:09 Java开发

如何优雅地停止使用@RabbitListener 消费消息

有没有办法优雅地停止 ListenerContainer 及其关联的 Consumers. 我正在努力实现的目标. 停止使用消息. 优雅地停止 ListenerContainer. 等待长时间运行的消费者，完成后确认. 我可以使用 consumer.stop() 停止 ListenerContainers，但活动的长时间运行的消费者不会成功完成，处理的消息也不会acked 并 ..
发布时间：2022-01-11 17:14:12 Java开发

跨多个 rabbitMQ 实例的 RabbitMQ RPC

我有三个客户端，每个客户端都有自己的 RabbitMQ 实例，我有一个应用程序(我们称之为 appA)，它有自己的 RabbitMQ 实例，三个客户端应用程序(app1、app2、app3)想要使用应用A. appA上的服务需要RPC通信，app1、app2、app3各有一个booking.request队列和一个booking.response队列. 使用 shovel 插件，我可以 ..
发布时间：2022-01-11 17:12:35 其他开发

动态添加新的队列、绑定和交换作为 bean

我目前正在开发一个 rabbit-amqp 实施项目，并使用 spring-rabbit 以编程方式设置我的所有队列、绑定和交换.(spring-rabbit-1.3.4 和 spring-framework 版本 3.2.0) 在我看来，javaconfiguration 类或基于 xml 的配置中的声明都是静态的.我知道如何为队列设置更动态的值(例如名称)，交换或像这样绑定: @Con ..
发布时间：2022-01-11 17:12:27 其他开发

spring boot rabbitmq MappingJackson2MessageConverter 自定义对象转换

我正在尝试使用 spring boot 创建一个简单的 spring boot 应用程序，该应用程序向 rabbitmq 交换/队列“生成"消息，以及另一个“使用"这些消息的示例 spring boot 应用程序.所以我有两个应用程序(如果你愿意，也可以是微服务).1)“生产者"微服务2)“消费者"微服务 “生产者"有 2 个域对象.Foo 和 Bar 应该被转换为 json 并发送到 ra ..
发布时间：2022-01-11 17:11:11 Java开发

如何停止使用@RabbitListener 消费消息

当我使用 MessageListenerAdapter 处理消息时，我可以调用 SimpleMessageListenerContainer.stop() 来停止从队列中消费.但是我改用@RabbitListener 监听后，就找不到这样的方法了.我试过 CachingConnectionFactory.stop() 但不起作用.有人可以帮忙吗?非常感谢. 解决方案 给 @RabbitLi ..
发布时间：2022-01-11 17:06:09 其他开发

Spring Boot 多个 RabbitMQ 监听器到单个容器

我正在使用 spring boot(基于注释)开发 RabbitMQ.我正在尝试向单个容器添加多个侦听器，但只有一个侦听器可以工作. 我能够初始化两个容器并为每个容器分配单独的消息侦听器.这是否是添加多个侦听器的唯一方法，其中每个容器都有各自的侦听器?我正在使用 ChannelAwareMessageListener 接口，以便我可以单独处理消息并确认它们.我不想使用 RabbitListe ..
发布时间：2021-08-20 19:44:16 Java开发