86 lines
2.4 KiB
C#
86 lines
2.4 KiB
C#
using MasstransferCommon.Utils;
|
|
using MasstransferCommunicate.Process.Client;
|
|
using MasstransferCommunicate.Process.Model;
|
|
using Serilog;
|
|
|
|
namespace MasstransferCommunicate.Process.Service;
|
|
|
|
/// <summary>
|
|
/// 进程间通讯器
|
|
/// </summary>
|
|
public class ProcessCommunicator
|
|
{
|
|
private static readonly Dictionary<string, List<Delegate>> Subscribers = new();
|
|
|
|
private static ProcessHelper? _helper;
|
|
|
|
/// <summary>
|
|
/// 启动连接
|
|
/// </summary>
|
|
public static async Task Connect()
|
|
{
|
|
_helper = await ProcessHelper.CreateServer("Masstransfer");
|
|
_helper.MessageReceived += HandleMessageReceived;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 订阅某个主题
|
|
/// </summary>
|
|
/// <param name="topic"></param>
|
|
/// <param name="delegate"></param>
|
|
public static void Subscribe(string topic, Delegate @delegate)
|
|
{
|
|
if (!Subscribers.ContainsKey(topic))
|
|
{
|
|
Subscribers.Add(topic, []);
|
|
}
|
|
|
|
Subscribers[topic].Add(@delegate);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 发送消息
|
|
/// </summary>
|
|
/// <param name="topic"></param>
|
|
/// <param name="message"></param>
|
|
public static async Task<bool> Send<T>(string topic, T message)
|
|
{
|
|
await _helper?.SendMessageAsync(JsonUtil.ToJson(new Message<T>(topic, message)))!;
|
|
return true;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 处理接收到的消息
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private static void HandleMessageReceived(string? message)
|
|
{
|
|
if (message == null) return;
|
|
|
|
var dictionary = JsonUtil.ToDictionary(message);
|
|
if (dictionary == null) return;
|
|
|
|
var topic = dictionary["Topic"] as string;
|
|
var data = dictionary["Data"];
|
|
|
|
if (!Subscribers.TryGetValue(topic, out var subscribers)) return;
|
|
|
|
foreach (var subscriber in subscribers)
|
|
{
|
|
try
|
|
{
|
|
var methodInfo = subscriber.Method;
|
|
var parameters = methodInfo.GetParameters();
|
|
if (parameters.Length != 2) continue;
|
|
var type = parameters[1].ParameterType;
|
|
// 通知订阅者
|
|
subscriber.DynamicInvoke(topic, JsonUtil.FromJson(type, message));
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
Log.Error(exception, "订阅主题 {Topic} 时发生错误", topic);
|
|
}
|
|
}
|
|
}
|
|
} |