问题标签 [spring-amqp]

我想使用 Spring AMQP 发送和使用自定义对象，如下所示。

生产者代码

记录记录 = new Record("message1", new Date());
rabbitTemplate.convertAndSend(record);

任何人都可以提供用于发送和消费消息的 spring amqp @configuration 设置。谢谢！！！

在队列中，我推送了 10K 个对象。时间戳是对象中的属性之一。那么，如何使用 spring amqp 编写消费者代码呢？

谁可以帮我这个事。

我正在使用 spring3 和 spring-amqp 将消息从我的 Web 应用程序发送到rabbitmq服务器。

目前我能够将纯文本发送到rabbitmq服务器。但现在我想将我的自定义 java 对象作为 json 发送到服务器。

谷歌搜索后，我发现我们可以使用JsonMessageConverter. 但我没有得到任何有用的网址来解释所需的步骤。

任何参考/网址将不胜感激。

我是推送通知的新手。我想使用 Spring AMQP 编写一个代码，它将通知消息发送到 APN。我有 .p12、认证和 .pem 文件。任何人都可以帮助我使用将发送通知消息的 Spring AMQP 编写代码。

提前致谢。

我有以下spring xml配置

现在在我的 Java 代码中，我有 2 个侦听器类：com.vzw.es.cosumer.SpringMessageListener 和 com.vzw.es.cosumer.SpringMessageListener1。现在，当我运行我的主类时，只有 1 个侦听器的 onMessage 方法被调用，即 SpringMessageListener1，我确实从 RabbitMQ 进行了检查，并且两个队列都有足够的消息来消费。

此外，当我从 xml SpringMessageListener 注释掉第二个队列及其侦听器时，它的效果也很好。

我同时开始生产者和消费者。6 小时后，生产者在队列中生成了大约 6 千万条消息，并在 6 小时后停止了生产者，但消费者仍在持续运行，即使在运行 18 小时后仍有 4 千万条消息在队列中。谁能告诉我为什么消费者的表现很慢？

提前致谢！

Spring AMQP 同步事务回滚不起作用。这里源中的数据库事务不由 Spring 处理。我需要在一个事务中接收和发送 Spring AMQP 消息。以下是相关代码的快照。如果您需要其他任何东西，请告诉我。

我们正在使用 Spring-AMQP 实现 RabbitMQ，我们的要求是在多个线程中运行消费者以使用来自单个队列的消息。是否需要完成任何服务器（RabbitMQ）端脚本或任何其他方式我们可以在消费者级别为单个队列运行多个线程？

提前致谢！

我目前正在使用 spring AMQP API 连接到 RabbitMQ。基本上在我的消费者代码中，我正在异步读取消息并在弹性搜索中进行批量插入。当我执行 ack = AUTO 时，我的速度适中，为 400-500 msg/sec（从队列中读取）。当我做 ack = NONE 时，阅读速度的提高是巨大的，即达到 5000-6000 msg/sec。

配置如下：

• 具有 32GB RAM 的 Linux 机器
• JVM参数：

-server -Xms1g -Xmx1g -Xss384k PermSize=256m MaxPermSize=256m

现在的问题是，当我在执行 ack = NONE 时，虽然我的速度很快，但 JVM 在一段时间后会出现 OutOfMemory，我可以看到在这种情况下发生了很多 GC。

我计划使用 Spring 集成中的 QueueChannel，我可以将通道的大小限制为它可以包含多少消息。

如何使用 RabbitMQ 实现这一点还有其他方法可以在不崩溃 JVM 的情况下实现 4000-5000 msg/sec 这样的良好读取速度吗？

我正在开发具有 1 个磁盘和 2 个 ram 节点的集群环境。谁能解释一下如何使用 Spring AMQP 注释配置策略以在 RabbitMQ 代理中创建镜像队列。

提前致谢。