library/simapi-net
1
0
Fork 0
Code Pull Requests Activity

Compare commits

base: library/simapi-net:8.4.4
Branches Tags
library/simapi-net:master
library/simapi-net:10.26.8.11 library/simapi-net:10.26.8.10 library/simapi-net:10.26.8.9 library/simapi-net:10.26.8.8 library/simapi-net:10.26.8.7 library/simapi-net:10.26.7.2 library/simapi-net:10.26.7.1 library/simapi-net:10.26.6.12 library/simapi-net:10.7.0 library/simapi-net:10.2606.10 library/simapi-net:10.26.6.11 library/simapi-net:10.26.06.11 library/simapi-net:10.06.10 library/simapi-net:10.6.9 library/simapi-net:10.6.8 library/simapi-net:10.6.7 library/simapi-net:10.6.6 library/simapi-net:10.6.5 library/simapi-net:10.6.3 library/simapi-net:10.6.2 library/simapi-net:10.6.1 library/simapi-net:10.6.0 library/simapi-net:10.5.2 library/simapi-net:10.5.1 library/simapi-net:10.5.0 library/simapi-net:10.4.0 library/simapi-net:10.3.5 library/simapi-net:10.3.4 library/simapi-net:10.3.3 library/simapi-net:10.3.2 library/simapi-net:10.3.1 library/simapi-net:10.3.0 library/simapi-net:10.2.1 library/simapi-net:10.2.0 library/simapi-net:10.1.8 library/simapi-net:10.1.7 library/simapi-net:10.1.6 library/simapi-net:10.1.5 library/simapi-net:10.1.4 library/simapi-net:10.1.3 library/simapi-net:10.1.2 library/simapi-net:10.1.1 library/simapi-net:10.1.0 library/simapi-net:10.0.4 library/simapi-net:10.0.3 library/simapi-net:10.0.2 library/simapi-net:10.0.1 library/simapi-net:10.0.0 library/simapi-net:9.1.4 library/simapi-net:9.1.3 library/simapi-net:9.1.2 library/simapi-net:9.1.1 library/simapi-net:9.1.0 library/simapi-net:9.0.8 library/simapi-net:9.0.7 library/simapi-net:9.0.6 library/simapi-net:9.0.5 library/simapi-net:9.0.4 library/simapi-net:9.0.3 library/simapi-net:9.0.2 library/simapi-net:9.0.1 library/simapi-net:9.0.0 library/simapi-net:8.4.7 library/simapi-net:8.4.6 library/simapi-net:8.4.5 library/simapi-net:8.4.4 library/simapi-net:8.4.3 library/simapi-net:8.4.2 library/simapi-net:8.4.1 library/simapi-net:8.4.0 library/simapi-net:8.3.5 library/simapi-net:8.3.4 library/simapi-net:8.3.3 library/simapi-net:8.3.2 library/simapi-net:8.3.1 library/simapi-net:8.3.0 library/simapi-net:8.2.9 library/simapi-net:8.2.8 library/simapi-net:8.2.7 library/simapi-net:8.2.6 library/simapi-net:8.2.5 library/simapi-net:8.2.4 library/simapi-net:8.2.3 library/simapi-net:8.2.2 library/simapi-net:8.2.1 library/simapi-net:8.2.0 library/simapi-net:8.1.9 library/simapi-net:8.1.8 library/simapi-net:8.1.7 library/simapi-net:8.1.6 library/simapi-net:8.1.5 library/simapi-net:8.1.4 library/simapi-net:8.1.3 library/simapi-net:8.1.2 library/simapi-net:8.1.1 library/simapi-net:8.1.0 library/simapi-net:8.0.9 library/simapi-net:8.0.8 library/simapi-net:8.0.7 library/simapi-net:8.0.6 library/simapi-net:8.0.5 library/simapi-net:8.0.4 library/simapi-net:8.0.3 library/simapi-net:8.0.2 library/simapi-net:8.0.1 library/simapi-net:8.0.0 library/simapi-net:7.0.9 library/simapi-net:7.0.8 library/simapi-net:7.0.7 library/simapi-net:7.0.6 library/simapi-net:7.0.5 library/simapi-net:7.0.4 library/simapi-net:7.0.3 library/simapi-net:7.0.2 library/simapi-net:6.1.7 library/simapi-net:6.1.6 library/simapi-net:6.1.5 library/simapi-net:6.1.4 library/simapi-net:6.1.3 library/simapi-net:6.1.2 library/simapi-net:6.1.1 library/simapi-net:6.1.0 library/simapi-net:6.0.9 library/simapi-net:6.0.8 library/simapi-net:6.0.7 library/simapi-net:6.0.6 library/simapi-net:6.0.5 library/simapi-net:6.0.4 library/simapi-net:6.0.3 library/simapi-net:6.0.2 library/simapi-net:6.0.1 library/simapi-net:6.0.0 library/simapi-net:5.7.3 library/simapi-net:5.7.2 library/simapi-net:5.7.1 library/simapi-net:5.7.0 library/simapi-net:5.6.8 library/simapi-net:5.6.3 library/simapi-net:5.6.2 library/simapi-net:5.6.1 library/simapi-net:5.6.0 library/simapi-net:5.5.5 library/simapi-net:5.5.1 library/simapi-net:5.5.0 library/simapi-net:5.4.1 library/simapi-net:5.4.0 library/simapi-net:5.3.4 library/simapi-net:5.3.3 library/simapi-net:5.3.2 library/simapi-net:5.3.1 library/simapi-net:5.3.0 library/simapi-net:5.2.3 library/simapi-net:5.2.2 library/simapi-net:5.2.1 library/simapi-net:5.2.0 library/simapi-net:5.1.1 library/simapi-net:5.1.0 library/simapi-net:5.0.6 library/simapi-net:5.0.5 library/simapi-net:5.0.4 library/simapi-net:5.0.3 library/simapi-net:5.0.2 library/simapi-net:5.0.1 library/simapi-net:5.0.0 library/simapi-net:1.1.3 library/simapi-net:1.1.2 library/simapi-net:1.1.1 library/simapi-net:1.1.0 library/simapi-net:1.0.5 library/simapi-net:1.0.3 library/simapi-net:1.0.2 library/simapi-net:1.0.1 library/simapi-net:1.0.0 library/simapi-net:0.5.1 library/simapi-net:0.5.0 library/simapi-net:0.4.5 library/simapi-net:0.4.2 library/simapi-net:0.4.1 library/simapi-net:0.4.0 library/simapi-net:0.3.6 library/simapi-net:0.3.5 library/simapi-net:0.3.4 library/simapi-net:0.3.3 library/simapi-net:0.3.2 library/simapi-net:0.3.1 library/simapi-net:0.3.0 library/simapi-net:0.2.10 library/simapi-net:0.2.9 library/simapi-net:0.2.8 library/simapi-net:0.2.7 library/simapi-net:0.2.6 library/simapi-net:0.2.5 library/simapi-net:0.2.4 library/simapi-net:v0.2.1 library/simapi-net:v0.1.3 library/simapi-net:v0.1.0
...
compare: library/simapi-net:8.4.6
Branches Tags
library/simapi-net:master
library/simapi-net:10.26.8.11 library/simapi-net:10.26.8.10 library/simapi-net:10.26.8.9 library/simapi-net:10.26.8.8 library/simapi-net:10.26.8.7 library/simapi-net:10.26.7.2 library/simapi-net:10.26.7.1 library/simapi-net:10.26.6.12 library/simapi-net:10.7.0 library/simapi-net:10.2606.10 library/simapi-net:10.26.6.11 library/simapi-net:10.26.06.11 library/simapi-net:10.06.10 library/simapi-net:10.6.9 library/simapi-net:10.6.8 library/simapi-net:10.6.7 library/simapi-net:10.6.6 library/simapi-net:10.6.5 library/simapi-net:10.6.3 library/simapi-net:10.6.2 library/simapi-net:10.6.1 library/simapi-net:10.6.0 library/simapi-net:10.5.2 library/simapi-net:10.5.1 library/simapi-net:10.5.0 library/simapi-net:10.4.0 library/simapi-net:10.3.5 library/simapi-net:10.3.4 library/simapi-net:10.3.3 library/simapi-net:10.3.2 library/simapi-net:10.3.1 library/simapi-net:10.3.0 library/simapi-net:10.2.1 library/simapi-net:10.2.0 library/simapi-net:10.1.8 library/simapi-net:10.1.7 library/simapi-net:10.1.6 library/simapi-net:10.1.5 library/simapi-net:10.1.4 library/simapi-net:10.1.3 library/simapi-net:10.1.2 library/simapi-net:10.1.1 library/simapi-net:10.1.0 library/simapi-net:10.0.4 library/simapi-net:10.0.3 library/simapi-net:10.0.2 library/simapi-net:10.0.1 library/simapi-net:10.0.0 library/simapi-net:9.1.4 library/simapi-net:9.1.3 library/simapi-net:9.1.2 library/simapi-net:9.1.1 library/simapi-net:9.1.0 library/simapi-net:9.0.8 library/simapi-net:9.0.7 library/simapi-net:9.0.6 library/simapi-net:9.0.5 library/simapi-net:9.0.4 library/simapi-net:9.0.3 library/simapi-net:9.0.2 library/simapi-net:9.0.1 library/simapi-net:9.0.0 library/simapi-net:8.4.7 library/simapi-net:8.4.6 library/simapi-net:8.4.5 library/simapi-net:8.4.4 library/simapi-net:8.4.3 library/simapi-net:8.4.2 library/simapi-net:8.4.1 library/simapi-net:8.4.0 library/simapi-net:8.3.5 library/simapi-net:8.3.4 library/simapi-net:8.3.3 library/simapi-net:8.3.2 library/simapi-net:8.3.1 library/simapi-net:8.3.0 library/simapi-net:8.2.9 library/simapi-net:8.2.8 library/simapi-net:8.2.7 library/simapi-net:8.2.6 library/simapi-net:8.2.5 library/simapi-net:8.2.4 library/simapi-net:8.2.3 library/simapi-net:8.2.2 library/simapi-net:8.2.1 library/simapi-net:8.2.0 library/simapi-net:8.1.9 library/simapi-net:8.1.8 library/simapi-net:8.1.7 library/simapi-net:8.1.6 library/simapi-net:8.1.5 library/simapi-net:8.1.4 library/simapi-net:8.1.3 library/simapi-net:8.1.2 library/simapi-net:8.1.1 library/simapi-net:8.1.0 library/simapi-net:8.0.9 library/simapi-net:8.0.8 library/simapi-net:8.0.7 library/simapi-net:8.0.6 library/simapi-net:8.0.5 library/simapi-net:8.0.4 library/simapi-net:8.0.3 library/simapi-net:8.0.2 library/simapi-net:8.0.1 library/simapi-net:8.0.0 library/simapi-net:7.0.9 library/simapi-net:7.0.8 library/simapi-net:7.0.7 library/simapi-net:7.0.6 library/simapi-net:7.0.5 library/simapi-net:7.0.4 library/simapi-net:7.0.3 library/simapi-net:7.0.2 library/simapi-net:6.1.7 library/simapi-net:6.1.6 library/simapi-net:6.1.5 library/simapi-net:6.1.4 library/simapi-net:6.1.3 library/simapi-net:6.1.2 library/simapi-net:6.1.1 library/simapi-net:6.1.0 library/simapi-net:6.0.9 library/simapi-net:6.0.8 library/simapi-net:6.0.7 library/simapi-net:6.0.6 library/simapi-net:6.0.5 library/simapi-net:6.0.4 library/simapi-net:6.0.3 library/simapi-net:6.0.2 library/simapi-net:6.0.1 library/simapi-net:6.0.0 library/simapi-net:5.7.3 library/simapi-net:5.7.2 library/simapi-net:5.7.1 library/simapi-net:5.7.0 library/simapi-net:5.6.8 library/simapi-net:5.6.3 library/simapi-net:5.6.2 library/simapi-net:5.6.1 library/simapi-net:5.6.0 library/simapi-net:5.5.5 library/simapi-net:5.5.1 library/simapi-net:5.5.0 library/simapi-net:5.4.1 library/simapi-net:5.4.0 library/simapi-net:5.3.4 library/simapi-net:5.3.3 library/simapi-net:5.3.2 library/simapi-net:5.3.1 library/simapi-net:5.3.0 library/simapi-net:5.2.3 library/simapi-net:5.2.2 library/simapi-net:5.2.1 library/simapi-net:5.2.0 library/simapi-net:5.1.1 library/simapi-net:5.1.0 library/simapi-net:5.0.6 library/simapi-net:5.0.5 library/simapi-net:5.0.4 library/simapi-net:5.0.3 library/simapi-net:5.0.2 library/simapi-net:5.0.1 library/simapi-net:5.0.0 library/simapi-net:1.1.3 library/simapi-net:1.1.2 library/simapi-net:1.1.1 library/simapi-net:1.1.0 library/simapi-net:1.0.5 library/simapi-net:1.0.3 library/simapi-net:1.0.2 library/simapi-net:1.0.1 library/simapi-net:1.0.0 library/simapi-net:0.5.1 library/simapi-net:0.5.0 library/simapi-net:0.4.5 library/simapi-net:0.4.2 library/simapi-net:0.4.1 library/simapi-net:0.4.0 library/simapi-net:0.3.6 library/simapi-net:0.3.5 library/simapi-net:0.3.4 library/simapi-net:0.3.3 library/simapi-net:0.3.2 library/simapi-net:0.3.1 library/simapi-net:0.3.0 library/simapi-net:0.2.10 library/simapi-net:0.2.9 library/simapi-net:0.2.8 library/simapi-net:0.2.7 library/simapi-net:0.2.6 library/simapi-net:0.2.5 library/simapi-net:0.2.4 library/simapi-net:v0.2.1 library/simapi-net:v0.1.3 library/simapi-net:v0.1.0
2 Commits
8.4.4 ... 8.4.6
Author SHA1 Message Date
xrain 67cc7346dc use concurrentDic 2025-05-17 21:17:43 +08:00
xrain 8627ae61fa use lock 2025-05-17 21:11:27 +08:00
1 changed files with 5 additions and 5 deletions
Expand all files Collapse all files
Synapse/RpcClient.cs
+5 -5
View File
@@ -1,20 +1,19 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text.Json;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.Logging;
using MQTTnet;
using MQTTnet.Packets;
using SimApi.Communications;
using SimApi.Helpers;
using System.Collections.Concurrent;
namespace SimApi;
public partial class Synapse
{
private Dictionary<string, TaskCompletionSource<string>> ResponseCompletionSources { get; } = new();
private ConcurrentDictionary<string, TaskCompletionSource<string>> ResponseCompletionSources { get; } = new();
private string EventClientTopicPrefix => $"{Options.SysName}/{Options.AppName}/rpc/client/{Options.AppId}/";
@@ -27,7 +26,7 @@ public partial class Synapse
var messageId = e.ApplicationMessage.Topic.Replace(EventClientTopicPrefix, string.Empty);
if (!ResponseCompletionSources.TryGetValue(messageId, out var tcs)) return Task.CompletedTask;
tcs.SetResult(reqBody);
ResponseCompletionSources.Remove(messageId);
ResponseCompletionSources.Remove(messageId, out _);
return Task.CompletedTask;
};
SubRpcClientTopic();
@@ -43,6 +42,7 @@ public partial class Synapse
private string? FireRpc(string app, string action, object? param, Dictionary<string, string>? headers = null,
int? timeout = null)
{
// 移除锁语句
string paramJson;
if (param is string strParam)
{
@@ -56,7 +56,7 @@ public partial class Synapse
var topic = $"{Options.SysName}/{app}/rpc/server/{action}";
var messageId = Guid.NewGuid().ToString();
var tcs = new TaskCompletionSource<string>();
ResponseCompletionSources.Add(messageId, tcs);
ResponseCompletionSources.TryAdd(messageId, tcs);
var messageBuilder = new MqttApplicationMessageBuilder()
.WithTopic(topic)
.WithPayload(paramJson)