From 753f1f88766cb075b927131ca25e57aef7040e74 Mon Sep 17 00:00:00 2001 From: fanliang11 <137629448@qq.com> Date: Thu, 20 Jun 2024 11:02:39 +0800 Subject: [PATCH] Update DotNettyMessageSender.cs --- .../DotNettyMessageSender.cs | 59 ++++--------------- 1 file changed, 10 insertions(+), 49 deletions(-) diff --git a/src/Surging.Core/Surging.Core.DotNetty/DotNettyMessageSender.cs b/src/Surging.Core/Surging.Core.DotNetty/DotNettyMessageSender.cs index 802dd6b7..1698fe71 100644 --- a/src/Surging.Core/Surging.Core.DotNetty/DotNettyMessageSender.cs +++ b/src/Surging.Core/Surging.Core.DotNetty/DotNettyMessageSender.cs @@ -8,7 +8,7 @@ namespace Surging.Core.DotNetty { - /// <summary> + /// <summary> /// 基于DotNetty的消息发送者基类。 /// </summary> public abstract class DotNettyMessageSender @@ -62,18 +62,9 @@ public void Dispose() /// <returns>一个任务。</returns> public async Task SendAsync(TransportMessage message) { - var buffer = GetByteBuffer(message); - try - { - await _channel.WriteAndFlushAsync(buffer); - } - finally - { - if (buffer != null) - { - ReferenceCountUtil.Release(buffer); - } - } + var buffer = GetByteBuffer(message); + await _channel.WriteAndFlushAsync(buffer); + } /// <summary> @@ -83,18 +74,8 @@ public async Task SendAsync(TransportMessage message) /// <returns>一个任务。</returns> public async Task SendAndFlushAsync(TransportMessage message) { - var buffer = GetByteBuffer(message); - try - { - await _channel.WriteAndFlushAsync(buffer); - } - finally - { - if (buffer != null) - { - ReferenceCountUtil.Release(buffer); - } - } + var buffer = GetByteBuffer(message); + await _channel.WriteAndFlushAsync(buffer); } #endregion Implementation of IMessageSender @@ -121,18 +102,8 @@ public DotNettyServerMessageSender(ITransportMessageEncoder transportMessageEnco /// <returns>一个任务。</returns> public async Task SendAsync(TransportMessage message) { - var buffer = GetByteBuffer(message); - try - { - await _context.WriteAsync(buffer); - } - finally - { - if (buffer != null) - { - ReferenceCountUtil.Release(buffer); - } - } + var buffer = GetByteBuffer(message); + await _context.WriteAsync(buffer); } /// <summary> @@ -142,18 +113,8 @@ public async Task SendAsync(TransportMessage message) /// <returns>一个任务。</returns> public async Task SendAndFlushAsync(TransportMessage message) { - var buffer = GetByteBuffer(message); - try - { - await _context.WriteAndFlushAsync(buffer); - } - finally - { - if (buffer != null) - { - ReferenceCountUtil.Release(buffer); - } - } + var buffer = GetByteBuffer(message); + await _context.WriteAndFlushAsync(buffer); } #endregion Implementation of IMessageSender