|
@ -168,7 +168,6 @@ public class WebSocketMiddleware |
|
|
var buffer = ArrayPool<byte>.Shared.Rent(1024 * 4); |
|
|
var buffer = ArrayPool<byte>.Shared.Rent(1024 * 4); |
|
|
// 从对象池获取消息通道
|
|
|
// 从对象池获取消息通道
|
|
|
var messageChannel = _channelPool.Get(); |
|
|
var messageChannel = _channelPool.Get(); |
|
|
|
|
|
|
|
|
try |
|
|
try |
|
|
{ |
|
|
{ |
|
|
// 创建取消令牌源,设置连接超时
|
|
|
// 创建取消令牌源,设置连接超时
|
|
@ -334,6 +333,7 @@ public class WebSocketMiddleware |
|
|
connectionId, receiveResult.MessageType, receiveResult.Count); |
|
|
connectionId, receiveResult.MessageType, receiveResult.Count); |
|
|
await ProcessMessage(webSocket, connectionId, buffer, receiveResult, |
|
|
await ProcessMessage(webSocket, connectionId, buffer, receiveResult, |
|
|
messageChannel, messageStartTime, cancellationToken); |
|
|
messageChannel, messageStartTime, cancellationToken); |
|
|
|
|
|
messageStartTime = DateTime.UtcNow; |
|
|
} |
|
|
} |
|
|
else |
|
|
else |
|
|
{ |
|
|
{ |
|
@ -405,7 +405,7 @@ public class WebSocketMiddleware |
|
|
(long)processingTime); |
|
|
(long)processingTime); |
|
|
|
|
|
|
|
|
_messageBuffer.Reset(); |
|
|
_messageBuffer.Reset(); |
|
|
messageStartTime = DateTime.UtcNow; |
|
|
//messageStartTime = DateTime.UtcNow;
|
|
|
} |
|
|
} |
|
|
}); |
|
|
}); |
|
|
|
|
|
|
|
|