TryReceiveRequest 被无限次调用

Question

我构建了一个自定义绑定，以便能够从其他源接收 HTTP 消息。 然而，它还不是没有错误的。

我观察到，一旦处理第一个请求，我的服务就会将 CPU 使用率推至 100%，并且随着进来的请求越来越多，服务变得越来越慢。在将日志记录命令插入到每个单个请求中后，可以看到这种行为的原因。绑定的功能。

在第一个请求进入之前，一切正常：

ChannelListener: OnBeginAcceptChannel
ChannelListener: OnAcceptChannel

然后，第一条消息的处理完成：

Channel: static constructor
Channel: constructor
ChannelListener: OnEndAcceptChannel (completes)
ChannelListener: Uri get
ChannelListener: OnBeginAcceptChannel
ChannelListener: OnAcceptChannel
Channel: OnOpen
Channel: BeginTryReceiveRequest
Channel: TryReceiveRequest
Channel: WaitForRequest
Channel: ReceiveRequest
Context: constructor
Channel: EndTryReceiveRequest (completes)
Context: RequestMessage get
`Channel: BeginTryReceiveRequest`
Context: Reply noTimeout
Context: Reply
Context: Close noTimeout
`Channel: TryReceiveRequest`
`Channel: WaitForRequest`
`Channel: ReceiveRequest (hangs)`
`Channel: EndTryReceiveRequest (doesn't complete since receive hangs)`
`Channel: BeginTryReceiveRequest`
`and so on...`

通道实现 IReplyChannel 接口，因此应该只能获取请求、回复请求，然后关闭通道。 ServiceModel 不只是关闭通道，而是不断向已使用的通道发送 TryReceiveRequest 垃圾邮件，而不管过去已使用过该通道。

有什么方法可以正确解决这个问题吗？ 为什么 ServiceModel 在关闭回复上下文后不关闭通道，尽管在使用通道后保持通道打开是没有用的？

Answer 1

所以，也许有人仍然需要解决这个问题。 在 BeginTryReceiveRequest 和 EndTryReceiveRequest 处检查通道的 State 属性。

…………

public IAsyncResult BeginTryReceiveRequest(TimeSpan timeout, AsyncCallback callback, object state)
        {
            if (State == CommunicationState.Closed)
            {
                return null;
            }
            return new TryReceiveRequestAsyncResult(timeout, this, callback, state);
        }

​

public bool EndTryReceiveRequest(IAsyncResult result, out RequestContext context)
            {
                if (State == CommunicationState.Closed)
                {
                    context = null;
                    return false;
                }
                return TryReceiveRequestAsyncResult.End(result, out context, this);
            }