Multicaster.Distributed.Nats 0.1.12

Multicaster

该框架提供了一种代理，用于通过接口透明地调用多个 POCO 实例或远程客户端的方法。

例如，对 IGreeter.Hello 的单个调用可以调用几个对象上的方法或将调用广播到像 MagicOnion 或 SignalR 这样的远程客户端。

该框架集成了组的概念，将接收器（目标）打包在一起以启用透明调用，允许灵活地将接收器添加或从组中删除，以便于管理。

用法

内存中（普通的 CLR 对象）

public interface IGreeterReceiver
{
    void OnMessage(string sender, string message);
}

public class GreeterReceiver(string name) : IGreeterReceiver
{
    public void OnMessage(string sender, string message)
        => Console.WriteLine($"[{name}] <{sender}> {message}")
}

// Create receivers.
var receiverA = new GreeterReceiver("A");
var receiverIdA = Guid.NewGuid();
var receiverB = new GreeterReceiver("B");
var receiverIdB = Guid.NewGuid();
var receiverC = new GreeterReceiver("C");
var receiverIdC = Guid.NewGuid();

// Create a in-memory group provider.
var groupProvider = new InMemoryGroupProvider(DynamicInMemoryProxyFactory.Instance);

// Create a group and add receivers to the group.
var group = groupProvider.GetOrAddSynchronousGroup<Guid, IGreeterReceiver>("MyGroup");
group.Add(receiverIdA, receiverA);
group.Add(receiverIdB, receiverB);
group.Add(receiverIdC, receiverC);

// Call receivers via proxy.
group.All.OnMessage("System", "Hello");
group.Except([receiverIdA]).OnMessage("System", "Hello without A");

// Call the receiver directly. (Normal method call)
receiverA.OnMessage("DirectMessage", "Sent a message to the receiver directly.");

输出

[A] <System> Hello
[B] <System> Hello
[C] <System> Hello
[B] <System> Hello without A
[C] <System> Hello without A
[A] <DirectMessage> Sent a message to the receiver directly.

API

IMulticastGroupProvider 接口

• GetOrAddGroup<TKey, TReceiver>(string name);
• GetOrAddSynchronousGroup<TKey, TReceiver>(string name);

IMulticastGroup<TKey, T> 接口

• TReceiver All { get; }
• TReceiver Except(ImmutableArray<TKey> excludes);
• TReceiver Only(ImmutableArray<TKey> targets);
• TReceiver Single(TKey target);
• void Dispose()
  • 销毁并从组提供程序注销组。

IMulticastAsyncGroup<TKey, T> 接口（实现 IMulticastGroup<TKey, T>）

• ValueTask AddAsync(TKey key, TReceiver receiver, CancellationToken cancellationToken = default);
• ValueTask RemoveAsync(TKey key, CancellationToken cancellationToken = default);
• ValueTask<int> CountAsync(CancellationToken cancellationToken = default);

IMulticastSyncGroup<TKey, T> 接口（实现 IMulticastGroup<TKey, T>）

• void Add(TKey key, TReceiver receiver);
• void Remove(TKey key);
• int Count();

传输和支持的特性