redis - 使用 Redis 的 Camel 保证交付

Question

谁能告诉我如何使用 camel-redis 进行保证交付？

我的用例如下:-

from("jetty:http://localhost:8888/hello").to("redis://...") 

一旦消息写入redis，就会向http客户端发送一个成功的响应，这样客户端就不会阻塞等待响应。

然后在另一个路由中我想像下面这样处理来自redis的消息，然后在处理成功时从redis中删除它

from("redis://...").to(...)

Answer 1

好方法 - 它被称为“存储和转发”模式。

and the message is not delivered to the final destination?

那么 - “try/catch”呢？尝试发送消息，失败时，将其放回redis。

通常此模式是使用消息传递 (JMS) 实现的，其中消息传递具有一些重要特征:目的地、重试计数、重试周期和死信队列等。

使用任何更简单的存储(redis、jdbc 等)，您将必须自己实现这些消息传递功能。 (我必须管理员，我不擅长使用 Redis，但是使用简单的 JDBC 作为消息存储也会出现同样的问题)。

至少添加重试次数和“下次发送时间戳”。当消息在预定义的计数后未传递时会发生什么 - 这取决于你 - 发送邮件，写日志，停止世界..