Cross-Platform WebSockets Proxy

Usage for API - Service Layer

Startup ConfigureServices

// Add NetCoreStack Native Socket Services.
services.AddNativeWebSockets<ServerWebSocketCommandInvocator>();

Startup Configure

 app.UseNativeWebSockets();

Controller with dependency injection

public MyController(IConnectionManager connectionManager)
{
 _connectionManager = connectionManager;
}
[HttpPost(nameof(SendAsync))]
public async Task<IActionResult> SendAsync([FromBody]SimpleModel model)
{
 var echo = $"Echo from server '{model.Message}' - {DateTime.Now}";
 var obj = new { message = echo };
 var webSocketContext = new WebSocketMessageContext { Command = WebSocketCommands.DataSend, Value = obj };
 await _connectionManager.BroadcastAsync(webSocketContext);
 return Ok();
}

Clients

Startup ConfigureServices

// WebSockets for Browsers
services.AddNativeWebSockets<AgentsWebSocketCommandInvocator>();
// Client WebSocket - Proxy connections
var builder = services.AddProxyWebSockets();
var connectorname = $"TestWebApp-{Environment.MachineName}";
builder.Register<CustomWebSocketCommandInvocator>(connectorname, "localhost:7803");
// Runtime context factory
builder.Register<AnotherEndpointWebSocketCommandInvocator, CustomInvocatorContextFactory>();

Startup Configure

// Client WebSocket - Proxy connections
app.UseProxyWebSockets();
// WebSockets for Browsers
app.UseNativeWebSockets();
// Use MVC
app.UseMvc();

Invocator With Dependency Injection on Clients

public class CustomWebSocketCommandInvocator : IClientWebSocketCommandInvocator
{
 private readonly IConnectionManager _connectionManager;
 public CustomWebSocketCommandInvocator(IConnectionManager connectionManager)
 {
 _connectionManager = connectionManager;
 }
 public Task InvokeAsync(WebSocketMessageContext context)
 {
 // Sending incoming data from backend to the clients (Browsers)
 _connectionManager.BroadcastAsync(context);
 return Task.CompletedTask;
 }
}

public class ClientDiscoveryController : Controller
{
 private readonly IWebSocketConnector _connector;
 public ClientDiscoveryController(IWebSocketConnector<CustomWebSocketCommandInvocator> connector)
 {
 _connector = connector;
 }
 [HttpGet]
 public async Task<IActionResult> KeepAlive()
 {
 await _connector.SendAsync(new WebSocketMessageContext
 {
 Command = WebSocketCommands.DataSend,
 Value = new { Id = 1, Name = "Hello World!", DateTime = DateTime.Now }
 });
 return Ok();
 }
}

Prerequisites