Message-Streams

Build

Message-Streams with CompletableFutures

Demo for Message streams - very fast GRPC-like & GRPC-compatible services on JVM with rich streaming models - using familiar, widespread non-streaming API - jdk's CompletableFutures.

It complements 1 million streams stress test report and message-streams interop example with
common single request-reply model found within each REST API server.

Example showcases how to transfer java CompletableFutures over TCP, unix sockets, websockets-over-http2, or consume with GRPC clients.

Also It outlines some properties of Message-Streams based applications:

  • Services,APIs / networking,runtime decoupling
  • Tiny service Jar & app distribution size
  • Fast startup / first request time
  • Small memory footprint
  • Instant startup / even smaller memory footprint with graalvm native image