0

tcpTransport を使用するため、カスタム チャネルに IDuplexSessionChannel を実装します。そのカスタム チャネルでは、サービス呼び出しの応答をキャッシュします (クライアント側のキャッシュ)。しかし、それにはエラーがあります。IRequestChannel では正常に動作します。TryMessage メソッドでメッセージを変更するにはどうすればよいですか。私のコード:

public Message Receive(TimeSpan timeout)
    {
        Message response = null;
        response = CommunicationCacheManager.Get(_request.Headers.Action, _request);

        if (response == null)
        {
            response = this.InnerChannel.Receive(timeout);
            int cacheTimeout = 0;
            if (response.Headers.FindHeader(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE) > -1)
            {
                cacheTimeout = response.Headers.GetHeader<int>(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE);
            }
            if (cacheTimeout > 0 && response != null &&
                    !response.IsFault &&
                    !response.IsEmpty)
            {
                CommunicationCacheManager.Add(_request.Headers.Action, cacheTimeout, ref response);
            }
        }
        return response;
    }

    public Message Receive()
    {
        return this.InnerChannel.Receive();
    }

    public bool TryReceive(TimeSpan timeout, out Message message)
    {
        ThrowIfDisposedOrNotOpen();
        message = null;
        bool timedout = false;
        try
        {
            message = this.Receive(timeout);
        }
        catch (TimeoutException)
        {
            timedout = true;
        }
        return (!timedout);
    }

CacheManager が動作します。そして、応答キャッシュを取得します。しかし、tryReceive を再度実行し、Message を見ると。メッセージは閉じています。どうすれば修正できますか

4

1 に答える 1

0

問題は解決しました。

Tcp バインディングは、メッセージに RelatesTo ヘッダーを追加します。したがって、コードは次のように変更されます

public Message Receive(TimeSpan timeout)
{
    Message response = null;
    response = CommunicationCacheManager.Get(_request.Headers.Action, _request);

    if (response == null)
    {
        response = this.InnerChannel.Receive(timeout);
        int cacheTimeout = 0;
        if (response.Headers.FindHeader(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE) > -1)
        {
            cacheTimeout = response.Headers.GetHeader<int>(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE);
        }
        if (cacheTimeout > 0 && response != null &&
                !response.IsFault &&
                !response.IsEmpty)
        {
            CommunicationCacheManager.Add(_request.Headers.Action, cacheTimeout, ref response);
        }
    }
    else
    {
       response.Headers.RelatesTo=_request.Header.MessageId;
    }
    return response;
}
于 2011-10-18T10:13:43.413 に答える