Spring 当其中一个容器在处理消息时出现故障时,XD 是否会重新处理同一条消息?
Does Spring XD re-process the same message when one of it's container goes down while processing the message?
应用程序数据流:
JSon Messages--> Active MQ --> Spring XD-- Business Login(Transform JSon to Java Object)--> Save Data to Target DB-->数据库
问题:
Sprin-Xd 运行 集群模式,配置了 Radis。
Spring XD 从活动消息队列 (AMQ) 中获取消息。所以消息不再在 AMQ 中。现在,当使用某些业务逻辑处理此消息的容器之一突然关闭时。在这种情况下-
- Spring-XD 框架会自动重新处理该特定消息吗?这背后的机制是什么?
谢谢,
阿比
不使用 Redis 传输; Redis 没有支持这种要求的基础设施("transactional" 读取)。您需要使用 rabbit 或 kafka 传输。
编辑:
见Application Configuration (scroll down to RabbitMQ) and Message Bus Configuration。
具体来说,默认的 ackMode
是 AUTO
,这意味着消息在成功时被确认。
应用程序数据流: JSon Messages--> Active MQ --> Spring XD-- Business Login(Transform JSon to Java Object)--> Save Data to Target DB-->数据库
问题:
Sprin-Xd 运行 集群模式,配置了 Radis。
Spring XD 从活动消息队列 (AMQ) 中获取消息。所以消息不再在 AMQ 中。现在,当使用某些业务逻辑处理此消息的容器之一突然关闭时。在这种情况下-
- Spring-XD 框架会自动重新处理该特定消息吗?这背后的机制是什么?
谢谢,
阿比
不使用 Redis 传输; Redis 没有支持这种要求的基础设施("transactional" 读取)。您需要使用 rabbit 或 kafka 传输。
编辑:
见Application Configuration (scroll down to RabbitMQ) and Message Bus Configuration。
具体来说,默认的 ackMode
是 AUTO
,这意味着消息在成功时被确认。