!! 重新整理SendMessageAsync异步发送消息的匹配超时架构。rocketmq的8个Task一起发送请求,其中1个超时,MatchQueue把它置为取消,上层await抛出TaskCanceledException异常,导致rocketmq层直接关闭连接,再次影响到MatchQueue,整体Clear取消所有Task。
大石头
authored at
2023-07-05 18:21:30
大石头
committed at
2023-07-06 18:19:38
X
<Project Sdk="Microsoft.NET.Sdk" ToolsVersion="Current">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>net20</TargetFramework>
<OutputPath>..\Bin\Test20\</OutputPath>
<LangVersion>latest</LangVersion>
<Version>1.0.0.1130</Version>
<FileVersion>1.0.0.1130</FileVersion>
<AssemblyVersion>1.0.*</AssemblyVersion>
<Deterministic>false</Deterministic>
<AppendTargetFrameworkToOutputPath>false</AppendTargetFrameworkToOutputPath>
<NoWarn>1701;1702;NU5104;NETSDK1138;CS7035</NoWarn>
</PropertyGroup>
<ItemGroup>
<ProjectReference Include="..\NewLife.Core\NewLife.Core.csproj" />
</ItemGroup>
</Project>
|