SignalRems.Server 0.1.0-preview

SignalR EMS

Description

SignalRems is one Enterprise Messaging System (EMS) implemented by .NET Standard SignalR. It provides two communication models, RPC and PUB/SUB. This library will provide strong typed API to help client application communicate with server. It is using MessagePack binary format for serialization/deserialization . In PUB/SUB mode, it subscribe with filter of Lambda expression.

Dependency

This libiary is built on SingalR, hence the server application must be using "Microsoft.NET.Sdk.Web" SDK. The client side could use any .net 6.0 SDK.

API usage

RPC Server

1. Configure WebApplication builder;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddSignalRemsService();

2. Setup endpoint for app instance:

var app = builder.Build();
app.MapSignalRemsRpcHub("/signalr/ems/example/rpc");

3. Register RPC handler in IRpcService instance. IRpcService instance is singleton and can be get from dependency injection, handler implements IRpcHandler<,> interface to handle the RPC logic;

IRpcService rpcService;
IRpcHandler<GetUserNameRequest, GetUserNameResponse> handler;
rpcService.RegisterHandler<GetUserNameRequest, GetUserNameResponse>(handler);

RPC Client

1. Get RPC client from dependency injection;

_rpcClient = ServiceProvider.GetRequiredService<IRpcClient>();

2. Make connection and call:

await _rpcClient.ConnectAsync("https://localhost:7198", "/signalr/ems/example/rpc", stoppingToken);
var request = new GetUserNameRequest() { UserId = i.ToString() };
var response = await _rpcClient.SendAsync<GetUserNameRequest, GetUserNameResponse>(request);

PUB/SUB Server

1. Configure WebApplication builder;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddSignalRemsService();

2. Setup endpoint for app instance:

var app = builder.Build();
app.MapSignalRemsPublisherHub("/signalr/ems/example/pubsub");

3. Create publisher from IPublisherService, IPublisherService is singleton instance;

IPublisherService publisherService;
var publisher =  _publisherService.CreatePublisher<Person, int>("Message");

4. Publish item to topic

publisher.Publish(new Person() { Id = id, Age = random.Next(95), Name = $"Person_{id:000}" });

PUB/SUB Client

1. Get subscriber client from dependency injection;

_subscriberClient = ServiceProvider.GetRequiredService<ISubscriberClient>();

2. Make connection and call. It supports Lambda expression as filter. This Lambda expression must be able to be explained from both server and client.

ISubscriptionHandler<Person> handler;
await _subscriberClient.ConnectAsync("https://localhost:7198", "/signalr/ems/example/pubsub", stoppingToken);
var subscription = await _subscriberClient.SubscribeAsync("Message", handler, p=> p.Age > 60);

3. The handler

License

This project is open source and follows MIT license.