Add multi-worker serve mode for Sendspin Party

README.md

@@ -390,3 +390,15 @@ uvx sendspin serve /path/to/media.mp3
 # Connect to specific clients
 sendspin serve --demo --client ws://192.168.1.50:8927/sendspin --client ws://192.168.1.51:8927/sendspin
 ```
+
+### Multi-Worker Mode
+
+For serving many concurrent listeners, use `--workers` to run multiple server processes behind a reverse proxy:
+
+```bash
+sendspin serve --demo --workers 4
+```
+
+This spawns 4 worker processes on consecutive ports starting from `--port` (default 8927), so ports 8927-8930. Place a reverse proxy (e.g., nginx, Caddy) in front with load balancing across these ports.
+
+Note: `--client` is not supported with `--workers`.

sendspin/cli.py

@@ -291,6 +291,12 @@ def _build_parser() -> argparse.ArgumentParser:
         default=[],
         help="Client URL to connect to (can be specified multiple times)",
     )
+    serve_parser.add_argument(
+        "--workers",
+        type=int,
+        default=1,
+        help="Number of server worker processes (default: 1)",
+    )
 
     # Daemon subcommand
     daemon_parser = subparsers.add_parser(
@@ -503,7 +509,7 @@ def _resolve_preferred_format(
 
 async def _run_serve_mode(args: argparse.Namespace) -> int:
     """Run the server mode."""
-    from sendspin.serve import ServeConfig, run_server
+    from sendspin.serve import ServeConfig, run_server, run_server_multi
 
     # Load settings for serve mode
     settings = await get_serve_settings()
@@ -539,6 +545,17 @@ async def _run_serve_mode(args: argparse.Namespace) -> int:
         name=args.name,
         clients=args.clients or settings.clients,
     )
+    if args.workers < 1:
+        print("Error: --workers must be at least 1")
+        return 1
+
+    if args.workers > 1 and serve_config.clients:
+        print("Error: --client is not supported with --workers")
+        return 1
+
+    if args.workers > 1:
+        return await run_server_multi(serve_config, workers=args.workers, log_level=args.log_level)
+
     return await run_server(serve_config)
 
 

sendspin/serve/__init__.py

@@ -286,3 +286,18 @@ def on_server_event(server: SendspinServer, event: SendspinEvent) -> None:
             await server.close()
 
     return 0
+
+
+async def run_server_multi(config: ServeConfig, *, workers: int, log_level: str) -> int:
+    """Run the multi-worker Sendspin server."""
+    from sendspin.serve.coordinator import ServeCoordinator
+
+    coordinator = ServeCoordinator(
+        source=config.source,
+        source_format=config.source_format,
+        port=config.port,
+        name=config.name,
+        workers=workers,
+        log_level=log_level,
+    )
+    return await coordinator.run()