Spring Batch集成消费RabbitMq消息

文章/答案/技术大牛

发布

1回答

spring-batch、spring-integration、spring-integration-amqp

我当前正在使用IntegrationFlow在RabbitMq消息到达队列时触发作业执行。我遇到的问题是集成流的AmqpInboundChannelAdapter读取RabbitMQ消息，然后ItemReader无法再找到该消息。可能是因为IntegrationFlow在作业启动之前确认了该消息。有没有一种方法可以防止IntegrationFlow使用/确认消息，将其留在队列中，以便ItemReader可以作为管理员工作？我尝试将AmqpI

浏览 45提问于2020-12-11得票数 1

回答已采纳

1回答

弹簧启动、弹簧集成、RabbitMQ和AWS运动集成

spring-integration、spring-cloud-stream、spring-amqp、spring-integration-aws

我需要使用来自rabbitMQ的消息，进行一些处理，并最终将消息发布到Kinase数据流。我们已经在使用Spring、和SpringIntegrationAQMP5.5.1集成流来消费来自RabbitMQ的消息。我们没有在任何项目中使用。对于用例，您建议什么样的spring库将消息发布到Kinesis数据流？在浏览了Spring文档之后，我看到了一些可用的选项。你能告诉我哪一个是最好的吗？s

浏览 8提问于2021-09-15得票数 1

回答已采纳

1回答

Zipkin与RabbitMQ集成以进行跟踪

java、rabbitmq、zipkin、brave

我有两个微服务(Spring引导应用程序)。为了进行跟踪，我使用了<artifactId>spring-cloud-sleuth-zipkin</artifactId>和zipkin。服务A是生产者，使用RabbitMQ broker发送消息。另一方面，服务B是消费者，他们是@RabbitListener。我想从服务A到服务B交换traceId(具有跨度详细信息)。我已经看到了 (使用brave)，但无法将zipkin与rabbitMQ和跟踪传播

浏览 12提问于2018-08-03得票数 0

回答已采纳

1回答

针对不同用户的每个消息的主题

spring、spring-cloud、spring-cloud-stream

我要寻找的拓扑是到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？更新spring.rabbitmq.host=localhost spri

浏览 0提问于2018-05-05得票数 2

回答已采纳

1回答

Spring集成RabbitMQ -侦听器与重试

spring、rabbitmq、spring-integration、spring-amqp

下面是我在rabbitmq侦听器的xml文件中的声明式配置。

浏览 0提问于2015-10-17得票数 1

2回答

Java Spring* RabbitMq使用者*

rabbitmq、spring-amqp、spring-rabbit

我正在尝试在Java Spring框架中创建一个RabbitMq消费者。我需要实现RabbitMq RPC模型，所以基本上消费者应该从RabbitMq broker接收一些消息，对其进行处理，然后将其发送回相关的应答队列。有没有人能给我一个在Spring中实现这个需求的整洁的示例代码？提前谢谢。

浏览 1提问于2015-10-21得票数 0

1回答

RabbitMQ & Spring amqp重试，不阻塞消费者

rabbitmq、spring-amqp、spring-retry

我正在使用RabbitMQ和Spring amqp，我不希望丢失消息。通过对重试使用指数退避策略，我可能会阻止我的消费者，他们可能正在处理他们可以处理的消息。我想给失败的消息几天的时间来重试指数退避策略，但我不希望消费者阻塞几天，我想让它在其他消息上继续工作。我知道我们可以用ActiveMQ()来实现这类功能，但无法为RabbitMQ找到类似的解决方案。有没有办法用Spring amqp和RabbitMQ<

浏览 4提问于2014-06-28得票数 0

8回答

Python的面向Java的芹菜项目的等价物是什么？

java、python、celery、batch-processing、spring-batch

我正在尝试为Java环境寻找一个等效的芹菜项目，我看过Spring Batch，但是有没有更好的分布式任务队列替代方案呢？谢谢。

浏览 1提问于2012-03-06得票数 42

1回答

要发布到远程计算机上的消息队列

rabbitmq、spring-amqp、spring-rabbit

我正在使用Springbatch来读取、处理和写入消息队列。我已经使用了AmqpItemWriter并尝试发布到消息队列。它运行良好，并将消息发布到我本地的消息队列中。=truespring.rabbitmq.username=guestspring.rabbitmq</em

浏览 0提问于2019-05-17得票数 0

1回答

如何在春季正确获取来自RabbitMQ的所有队列消息？

spring、rabbitmq、mqtt、stomp、spring-websocket

我使用Spring、Spring、STOMP作为我的应用程序，RabbitMQ作为代理。我需要记录通过RabbitMQ到Postgresql表的所有消息。我知道我可以在Spring中编写@MessageMapping并在那里登录，但我的问题是，一些客户端通过MQTT协议直接与RabbitMQ对话，而Spring还不支持它()。此外，浏览器客户端使用STOMP协议通过Spring与RabbitMQ进行通信。 R

浏览 4提问于2015-05-21得票数 6

回答已采纳

1回答

Spring集成队列:队列驻留在哪里？

spring-integration

我是Spring集成的新手；如果我没理解错的话，spring集成有3个关键角色；2个订阅者我能理解使用DB/文件系统作为队列的发布者和订阅者框架。spring集成队列驻留在哪里？如果发布者和订阅者本身是单独进程，它们如何共享通道？通道是否可供发布者进程和订阅者进程访问，因为它们运行在相同的JVM中？这是否意味着，如果publisher运行在一台机器上，而subscriber运行在另一台机器上，我们就不能使用Spring集成</

浏览 0提问于2017-03-10得票数 1

1回答

与RabbitMQ的Spark结构化流媒体集成

apache-spark、rabbitmq、spark-streaming

我想使用Spark structured来聚合从RabbitMQ消费的数据。我知道与apache kafka有官方的spark结构化流媒体集成，我想知道是否也存在与RabbitMQ的集成？由于我不能切换现有的消息传递系统(RabbitMQ)，我想使用kafka-connect在消息传递系统(Rabbit to kafka)之间移动数据，然后使用Spark structured streaming

浏览 0提问于2018-04-16得票数 0

1回答

使用Spring* AMQP监听许多短暂的、动态创建的队列*

java、rabbitmq、spring-amqp、spring-rabbit

我正在使用RabbitMQ/Spring/Spring AMQP构建一个应用程序，并且在处理我的队列布局时遇到了问题。从本质上讲，我有一个每个消费者都会监听的队列，每个消息基本上都说“这个队列已经准备好由一个消费者来处理了”。然后，使用者将侦听消息中指示的队列，使用该队列中的所有消息，最后在完成时将其删除。这些短暂的队列都是在数据进入处理时动态创建的，不能被多个使用者使用(无论哪个消费者获得了‘就绪’队列中的<em

浏览 41提问于2019-10-02得票数 0

回答已采纳

1回答

如何检查RabbitMQ服务器的队列是否处于活动状态

java、maven、rabbitmq、spring-jdbc

我对spring框架完全陌生。我正在尝试创建一个java maven项目，在该项目中我可以连接到rabbitMq，甚至在发布消息之前，我就想检查队列是否处于活动状态。我对这个rabbitMQ完全是新手。谢谢你的回答

浏览 4提问于2015-07-29得票数 3

1回答

如何使用Spring处理每个请求的多条消息？

java、spring、spring-boot、rabbitmq、spring-amqp

使用RabbitMQ，我让一个生产者在一个队列中产生大量消息(10秒数千条)。我想让使用者从队列中提取每个请求1000条消息的块。我们正在使用Spring实现来获取消息，但我们试图弄清楚如何在每个请求中实现一个以上的提取。预取似乎不是正确的选项，而批处理似乎需要在生产者端进行。有哪些选项可以使使用者请求获取要作为组处理的消息块？

浏览 23提问于2022-08-02得票数 0

1回答

ibm mq消息的强制格式

jms、spring-integration、ibm-mq

我们使用Spring集成将消息从RabbitMQ发送到MQSeries。这可以很好地工作。./> 对于一些消费者，我们需要强制使用ibm消息或字符集的格式。header-enricher id="theHeaderEnricher" input-channel="fromRabbit" output-channel="toJms" > 如何更改mq格式和消息字符集格式不是JmsHeade

浏览 10提问于2019-04-04得票数 0

1回答

Spring Boot兔mq spring.rabbitmq.listener.simple.concurrency从不工作

java、spring、spring-boot、rabbitmq、spring-rabbit

(Exception e) { throw e;到目前为止，消息到达主队列，消费者消费它们，如果消费者由于某种原因不能在给定的TTL 300000中消费它们，它们就会进入死信队列。例如，我将spring.rabbitmq.listener.simple.concurrency=3，设置为静止的，它创建一个

浏览 14提问于2017-07-31得票数 3

1回答

同步队列的所有使用者，使其一次只处理一条消息

java、rabbitmq、amqp、spring-cloud-stream

我正在运行一个Spring Cloud Stream应用程序，使用来自RabbitMq的消息。我想实现这样一种行为:给定的队列有三个消费者实例，只向其中任何一个实例传递一条消息，然后等待下一条消息传递，直到当前消息被确认(所有消费者之间的某种同步)。我认为这可以使用启用全局选项的https://www.rabbitmq.com/consumer-prefetch.html来完成，但我找不到使用sp

浏览 17提问于2020-12-02得票数 0

回答已采纳

1回答

使用AKKA参与者在java中使用来自RabbitMQ的多个消息

java、spring-boot、rabbitmq、akka、spring-rabbit

我是RabbitMQ的新手，我想要使用来自RabbitMQ的多个消息，这样工作就可以并行完成，并且只有当任何参与者完成其任务时才发送确认，以免丢失消息。我应该如何继续，我想为AKKA使用spring支持。我可以使用一个参与者作为消费者，或者它应该是一个普通的消费者，它可以消费多个消息而不发送对任何消息的确认，或者应该是我有多个类/线程作为消费者实例化，一次只监听一个消息，

浏览 0提问于2017-08-19得票数 0

1回答

JMSXGroupId的RabbitMQ解决方法

java、spring、rabbitmq、spring-rabbit

我知道RabbitMQ不支持JMSXGroupId，而且从上看，这个特性似乎很快就会被整合到RabbitMQ中。对于使用交换/队列/主题的组合，有什么解决方法吗？这是我的用例。假设我有一个生产者服务器和两个消费者服务器，其中有多个消费者线程在使用队列中的线程。生产者服务器创建一个网络、一个子网和多个端口。所有这些请求都被转换为json/stomp并放入队列中。在ActiveMQ或Artemis中，我们可以将JMSXGroupId设置为网络名称，并确保消息由相同的线程拾取&#x

浏览 2提问于2017-05-19得票数 1

点击加载更多