c# - 使用 c# stan.client 的 Nats 流式重新传递问题

Question

我正在使用nats 流服务器和stan.client作为客户端库。

我的订户可以做长时间的工作。有时它们大于默认的确认等待时间（30 秒）。所以我尝试手动确认我的消息，这样做：

StanSubscriptionOptions sOpts = StanSubscriptionOptions.GetDefaultOptions();

    sOpts.ManualAcks = true;

    EventHandler<StanMsgHandlerArgs> msgHandler = (sender, args) =>

    {

        args.Message.Ack();

        Thread.Sleep(40000);

    };

    sOpts.DurableName = "my-durable";

    var s = c.Subscribe(subject, qGroup, sOpts, msgHandler);

我设置了手动确认，然后在工作之前将消息确认为第一个操作。

在这段代码中，订阅者做了 40 秒的工作。如果我发送 2 条消息，则第二条总是重新发送。

我的错误是什么？

Answer 1

第一条消息将在收到后立即确认，因此不会重新发送。

如果第二条消息被传递到客户端库并在回调处理之前过期，则 NATS 流服务器将重新传递它。

使用 30 秒的确认等待和 40 秒的延迟，这很可能会发生。

我通过 StanSubscriptionOptions.AckWait 选项解决了增加 AckWait 的问题。