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);
            }