Redisson RStreams 不接收消息
Redisson RStreams not receiving messages
我正在尝试使用 Reddison 库将流与 redis 一起使用。我在接收消息时使用 code StreamReadGroupArgs.neverDelivered()。但是，如果我不确认它，那么下次调用 readGroup 时，它就不会收到这些消息。问题是，如果节点崩溃或网络出现故障，我无法处理这些消息怎么办。然后，即使我没有确认它，我也不会再收到这些消息。是否有解决此问题或我可以做的其他事情？
这是正确的行为。否则你每次都会收到多余的信息。
要么你必须确认，要么你必须明确要求redis重新发送你没有确认的消息。因为 StreamReadGroupArgs.neverDelivered() 不是正确的选项。因为已经发货了。但是你不知何故丢失了消息。
您的用例的正确选项是以下选项，它将发送未确认的消息。
StreamReadGroupArgs.greaterThan(new StreamMessageId(0))
我正在尝试使用 Reddison 库将流与 redis 一起使用。我在接收消息时使用 code StreamReadGroupArgs.neverDelivered()。但是，如果我不确认它，那么下次调用 readGroup 时，它就不会收到这些消息。问题是，如果节点崩溃或网络出现故障，我无法处理这些消息怎么办。然后，即使我没有确认它，我也不会再收到这些消息。是否有解决此问题或我可以做的其他事情？
这是正确的行为。否则你每次都会收到多余的信息。
要么你必须确认，要么你必须明确要求redis重新发送你没有确认的消息。因为 StreamReadGroupArgs.neverDelivered() 不是正确的选项。因为已经发货了。但是你不知何故丢失了消息。
您的用例的正确选项是以下选项，它将发送未确认的消息。
StreamReadGroupArgs.greaterThan(new StreamMessageId(0))