Server Configuration

// The only required configuration is port number
Server server = Server.withPort(8080 /* port */)
  // Host on which we are listening
  .host("0.0.0.0")
  // The number of connection-handling event loops to run concurrently.
  // You likely want the number of CPU cores as per below
  .concurrency(Runtime.getRuntime().availableProcessors())
  // How long to permit a request to process before timing out
  .requestTimeout(Duration.ofSeconds(60))
  // How long to permit your request handler logic to run
  // (Resource Method + Response Marshaling)
  .requestHandlerTimeout(Duration.ofSeconds(60))
  // Maximum number of request handler tasks that may run concurrently.
  // Defaults to concurrency when virtual threads are unavailable, or concurrency * 16 when they are.
  .requestHandlerConcurrency(Runtime.getRuntime().availableProcessors() * 16)
  // Maximum queued request handler tasks before rejecting with 503.
  // Defaults to requestHandlerConcurrency * 64.
  .requestHandlerQueueCapacity(Runtime.getRuntime().availableProcessors() * 16 * 64)
  // How long to block waiting for the socket's channel to become ready.
  // If zero, block indefinitely
  .socketSelectTimeout(Duration.ofMillis(100))
  // How long to wait for request handler threads to complete on shutdown
  .shutdownTimeout(Duration.ofSeconds(5))
  // The biggest request we permit clients to make (10 MB)
  .maximumRequestSizeInBytes(1_024 * 1_024 * 10)
  // Requests are read into a byte buffer of this size.
  // Adjust down if you expect tiny requests.
  // Adjust up if you expect larger requests.
  .requestReadBufferSizeInBytes(1_024 * 64)
  // The maximum number of pending connections on the socket
  // (values < 1 use JVM platform default)
  .socketPendingConnectionLimit(0)
  // Maximum concurrent connections (0 means unlimited)
  .maximumConnections(0)
  // Request ID generator
  .idGenerator(IdGenerator.defaultInstance())
  // Multipart parser
  .multipartParser(MultipartParser.defaultInstance())
  .build();

// Use our custom server
SokletConfig config = SokletConfig.withServer(server)
  // Not shown: other Soklet builder customizations
  .build();

// Start it up
try (Soklet soklet = Soklet.fromConfig(config)) {
  soklet.start();
  System.out.println("Soklet started, press [enter] to exit");
  soklet.awaitShutdown(ShutdownTrigger.ENTER_KEY);
}

// The only required configuration is port number
ServerSentEventServer sseServer = ServerSentEventServer.withPort(8081 /* port */)
  // Host on which we are listening
  .host("0.0.0.0")
  // How long to permit an SSE handshake request to process before timing out
  .requestTimeout(Duration.ofSeconds(60))
  // How long to permit your SSE handshake handler logic to run
  .requestHandlerTimeout(Duration.ofSeconds(60))
  // Maximum number of SSE handshake tasks that may run concurrently.
  // Defaults to availableProcessors * 16.
  .requestHandlerConcurrency(Runtime.getRuntime().availableProcessors() * 16)
  // Maximum queued SSE handshake tasks before rejecting with 503.
  // Defaults to requestHandlerConcurrency * 64.
  .requestHandlerQueueCapacity(Runtime.getRuntime().availableProcessors() * 16 * 64)
  // How long to wait when writing SSE data before timing out
  // (0 disables write timeouts)
  .writeTimeout(Duration.ZERO)
  // How often to send heartbeat payloads to keep connections alive
  .heartbeatInterval(Duration.ofSeconds(15))
  // How long to wait for SSE threads to complete on shutdown
  .shutdownTimeout(Duration.ofSeconds(1))
  // The biggest SSE handshake request we permit clients to make (64 KB)
  .maximumRequestSizeInBytes(1_024 * 64)
  // Requests are read into a byte buffer of this size
  .requestReadBufferSizeInBytes(1_024)
  // Maximum concurrent SSE connections (global cap).
  // If exceeded, a 503 is returned via ResponseMarshaler::forServiceUnavailable
  .concurrentConnectionLimit(8_192)
  // Cache sizes for broadcasters (per-resource-path event fanout)
  // and resource path declarations (Route pattern lookups).
  // Increase if you have many distinct SSE URLs in circulation.
  .broadcasterCacheCapacity(1_024)
  .resourcePathCacheCapacity(8_192)
  // Maximum queued SSE writes per connection
  .connectionQueueCapacity(128)
  // Write an initial heartbeat to verify the connection after handshake
  .verifyConnectionOnceEstablished(true)
  // Request ID generator
  .idGenerator(IdGenerator.defaultInstance())
  .build();

SokletConfig config = SokletConfig.withServer(
  Server.fromPort(8080)
).serverSentEventServer(sseServer)
 .build();