vefacaglar|packages

CustomPubSub.WebSocket

CustomPubSub.WebSocket

ASP.NET Core WebSocket middleware for room-based broadcasting, built on top of CustomPubSub.

Installation

dotnet add package CustomPubSub.WebSocket

Quick Start

using CustomPubSub.WebSocket;

builder.Services.AddCustomPubSubWebSocket();

var app = builder.Build();

app.UseCustomPubSubWebSocket();

WebSocket Endpoint

ws://localhost:<port>/ws/{room}
const socket = new WebSocket('ws://localhost:5000/ws/myroom');
socket.onmessage = (event) => console.log(event.data);

Options

services.AddCustomPubSubWebSocket(keepAliveInterval: TimeSpan.FromSeconds(60));

How It Works

  • Accepts WebSocket connections at `/ws/{room}`.
  • Tracks connected sockets per room in memory.
  • Subscribes to RabbitMQ for each active room via `IMessageSubscriber`.
  • Broadcasts incoming messages to all WebSocket clients in that room.
  • Reference-counts room subscriptions — shared across clients, cleaned up when the last client disconnects.

Requirements

Requires a `CustomPubSub` implementation (e.g. `CustomPubSub.RabbitMq`) to be registered.

Links