WCF发布/订阅:如何处理客户端超时，以免丢失信息

Question

基于此示例，我有一个简单的WCF发布/订阅并正在运行。我正在使用启用了reliableSession的netTcpBinding。所有功能都很好（订阅的客户端按预期接收发布的数据），但在某个时刻，如果连接空闲了一段时间，就会超时。我可以设置发布服务器在超时时重新连接，但订阅的客户端将丢失。有办法让他们回来吗？我不希望只是增加暂停时间，因为这可能会导致其他问题。

Answer 1

我最终提出的解决方案是为发布的每条消息分配一个唯一的标识符，并将发布的消息缓存在服务适配器中（与我存储对订阅客户端的回调的位置相同）。每当我发布消息时，订阅方都会收到消息和相应的唯一id。然后，订阅者可以使用该频道。使用以上次接收的消息id为参数的特殊方法重新连接并重新订阅服务的故障事件。

服务代码：

    /// <summary>
    /// Operation used by the subscriber to subscribe to events published.
    /// </summary>
    public void Resubscribe(int lastReceivedMessageId)
    {
        // Get callback contract
        IPubSubCallback callback = OperationContext.Current.GetCallbackChannel<IPubSubCallback>();
        ThreadPool.QueueUserWorkItem(delegate(object state)
        {
            adapter.Resubscribe(lastReceivedMessageId, callback);
        }); 
    }

适配器代码：

/// <summary>
    /// Operation used by the subscriber to resubscribe to events published.
    /// </summary>
    public void Resubscribe(int lastReceivedMessageId, IPubSubCallback callback)
    {
        try
        {
            // Send the subscriber any missed messages
            foreach (KeyValuePair<int, string> missedMessage in publishedMessages.Where(x => x.Key > lastReceivedMessageId))
            {
                callback.MessagePublished(missedMessage.Value, missedMessage.Key);
            }
            // Add the subscriber callback to the list of active subscribers
            if (!callbacks.Contains(callback))
            {
                callbacks.Add(callback);
            }
        }
        catch
        {
            // ignore subscription, callbacks failed again
        }
    }

然后，该服务可以计算出客户端遗漏了什么，并按正确的顺序重新发送这些消息。

这个解决方案对我来说似乎很有效，但我觉得必须有更好的方法来做到这一点。欢迎评论/补充答案！：）