Event.cs
5.77 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
using NCC.Dependency;
using NCC.Extensions;
using NCC.IPCChannel;
using NCC.JsonSerialization;
using NCC.Reflection;
using System;
using System.Reflection;
using System.Threading.Tasks;
namespace NCC.EventBridge
{
/// <summary>
/// 事件总线静态类
/// </summary>
[SuppressSniffer]
public static class Event
{
/// <summary>
/// 发射消息
/// </summary>
/// <param name="eventCombineId">分类名:事件Id</param>
/// <param name="payload"></param>
/// <returns></returns>
public static void Emit(string eventCombineId, object payload = default)
{
EmitAsync(eventCombineId, payload).GetAwaiter().GetResult();
}
/// <summary>
/// 发射消息
/// </summary>
/// <param name="eventCombineId">分类名:事件Id</param>
/// <param name="payload"></param>
/// <returns></returns>
public static async Task EmitAsync(string eventCombineId, object payload = default)
{
var eventCombines = eventCombineId?.Split(':', System.StringSplitOptions.RemoveEmptyEntries);
if (eventCombines == null || eventCombines.Length <= 1) throw new InvalidCastException("Is not a valid event combination id.");
// 解析注册的事件存储提供器
var eventStoreProvider = App.GetService<IEventStoreProvider>();
// 获取事件处理程序元数据
var eventHandlerMetadata = await eventStoreProvider?.GetEventHandlerAsync(eventCombines[0]);
if (eventHandlerMetadata == null) return;
var nonPayload = payload == null;
var payloadType = payload?.GetType();
// 追加一条事件消息
await eventStoreProvider.AppendEventMessageAsync(new EventMessageMetadata
{
AssemblyName = eventHandlerMetadata.AssemblyName,
Category = eventHandlerMetadata.Category,
CreatedTime = DateTimeOffset.UtcNow,
TypeFullName = eventHandlerMetadata.TypeFullName,
EventId = eventCombines[1],
Payload = nonPayload ? default : (payloadType.IsValueType ? payload.ToString() : JSON.Serialize(payload)),
PayloadAssemblyName = nonPayload ? default : Reflect.GetAssemblyName(payloadType),
PayloadTypeFullName = nonPayload ? default : payloadType.FullName,
});
}
/// <summary>
/// 发射消息
/// </summary>
/// <typeparam name="TEventHandler"></typeparam>
/// <param name="eventId"></param>
/// <param name="payload"></param>
/// <returns></returns>
public static Task EmitAsync<TEventHandler>(string eventId, object payload = default)
where TEventHandler : class, IEventHandler
{
return EmitAsync($"{GetEventHandlerCategory(typeof(TEventHandler))}:{eventId}", payload);
}
/// <summary>
/// 发射消息
/// </summary>
/// <typeparam name="TEventHandler"></typeparam>
/// <param name="eventId"></param>
/// <param name="payload"></param>
/// <returns></returns>
public static void Emit<TEventHandler>(string eventId, object payload = default)
where TEventHandler : class, IEventHandler
{
EmitAsync<TEventHandler>(eventId, payload).GetAwaiter().GetResult();
}
/// <summary>
/// 发射消息
/// </summary>
/// <param name="eventMessageMetadata"></param>
/// <returns></returns>
public static async Task EmitAsync(EventMessageMetadata eventMessageMetadata)
{
// 反射创建承载数据
var payload = DeserializePayload(eventMessageMetadata);
await ChannelContext<EventMessage, EventDispatcher>.BoundedChannel.Writer.WriteAsync(new EventMessage(eventMessageMetadata.Category, eventMessageMetadata.EventId, payload));
}
/// <summary>
/// 反序列化承载数据
/// </summary>
/// <param name="eventMessageMetadata"></param>
/// <returns></returns>
public static object DeserializePayload(EventMessageMetadata eventMessageMetadata)
{
object payload = null;
// 反序列化承载数据
if (eventMessageMetadata.Payload != null)
{
// 获取承载数据运行时类型
var payloadType = Reflect.GetType(eventMessageMetadata.PayloadAssemblyName, eventMessageMetadata.PayloadTypeFullName);
// 转换承载数据为具体值
if (payloadType.IsValueType) payload = eventMessageMetadata.Payload.ChangeType(payloadType);
else payload = typeof(JSON).GetMethod("Deserialize").MakeGenericMethod(payloadType)
.Invoke(null, new object[] { eventMessageMetadata.Payload, null, null });
}
return payload;
}
/// <summary>
/// 获取事件处理程序分类名
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
internal static string GetEventHandlerCategory(Type type)
{
// 如果定义了 [EventHandler] 特性，使用 Category，否则使用类型名（默认去除 EventHandler）结尾
var defaultCategory = type.Name.ClearStringAffixes(1, "EventHandler");
var eventCategory = type.IsDefined(typeof(EventHandlerAttribute), false)
? type.GetCustomAttribute<EventHandlerAttribute>(false).Category ?? defaultCategory
: defaultCategory;
return eventCategory;
}
}
}