SignalRems.Core 1.0.20

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 Newtonsoft.json or MessagePack for serialization/deserialization. In PUB/SUB mode, it subscribes 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 SDK. Currently this project runs under dotnet core 8.0 and above.

API usage

RPC Server

1. Configure WebApplication builder;

var builder = WebApplication.CreateBuilder(args);
// Using Json serialization/deserialization
builder.Services.AddSignalRemsService(); 

// Or, using MessagePack serialization/deserialization
// builder.Services.AddSignalRemsService(true); 

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. Config RPC client into dependency injection;

services.AddSignalRemsClient(); // Using Json serialization/deserialization
// services.AddSignalRemsClient(true); // MessagePack serialization/deserialization

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. Config subscriber client into dependency injection;

services.AddSignalRemsClient();

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);
// Subscribe people whose age is over 60.
var subscription = await _subscriberClient.SubscribeAsync("Message", _personHandler, p=> p.Age > 60);

// Or, subscribe people with given Id 1, 2, 3, as one client can only make one subscription, this example shows in comment. 
// var subscriptionByKeys = await _subscriberClient.SubscribeWithKeysAsync("Message", _personHandler, 1, 2, 3);

Please note, if using subscription without keys, one client can only be used to do one subscription. The dispose method will stop the subscription and disconnect from server. We can get multiple client instances from DI container to subscribe with differnet topic/filter. If using subscription by keys mode, the client can be used to subscribe/unsubscribe by keys multiple times, but it can't subscribe without given keys.

License

This project is open source and follows MIT license.