ReactiveX / RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
ReactiveX / RxJava
aeron-io / aeron
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
hs-web / hsweb-framework
hsweb (haʊs wɛb) 是一个基于spring-boot 2.x开发 ,首个使用全响应式编程的企业级后台管理系统基础项目。
jetlinks / jetlinks-community
JetLinks 基于Java,Spring Boot ,WebFlux,Netty,Vert.x,Reactor等开发, 是一个全响应式的企业级物联网平台。支持统一物模型管理,多种设备,多种厂家,统一管理。统一设备连接管理,多协议适配(TCP,MQTT,UDP,CoAP,HTTP等),屏蔽网络编程复杂性,灵活接入不同厂家不同协议等设备。实时数据处理,设备告警,消息通知,数据转发。地理位置,数据可视化等。能帮助你快速建立物联网相关业务系统。
strimzi / strimzi-kafka-operator
Apache Kafka® running on Kubernetes
reactor / reactor-core
Non-Blocking Reactive Foundation for the JVM
line / armeria
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
Snailclimb / interview-guide
基于 Spring Boot 4.1、Java 25、Spring AI 2.0、React、PostgreSQL/pgvector、Redis 和 RustFS 构建的开源 AI 面试平台，支持简历智能分析、模拟面试、语音面试和知识库 RAG。
uber / AutoDispose
Automatic binding+disposal of RxJava streams.
reactor / reactor-netty
TCP/HTTP/UDP/QUIC client/server with Reactor over Netty
amaembo / streamex
Enhancing Java Stream API
jOOQ / jOOL
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
hantsy / spring-reactive-sample
Spring Reactive playground
hivemq / hivemq-mqtt-client
HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support
pgjdbc / r2dbc-postgresql
Postgresql R2DBC Driver
apple / servicetalk
A networking framework that evolves with your application
authorjapps / zerocode
zerocode-tdd is a community-developed, free, open-source, outcome-driven automated testing framework for Data Pipelines, ETL, REST API, Kafka(Data Streams), Databases and Load scenarios. all defined in simple JSON or YAML — with zero coding.
smallrye / smallrye-mutiny
An Intuitive Event-Driven Reactive Programming Library for Java
LegacyLands / legacy-lands-library
Enterprise-grade modular framework for Minecraft server development with multi-tier caching, Redis Streams, resilient data processing, and modern Java concurrency. Built on Fairy Framework for production-scale plugin development.
apache / streampipes
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
pivovarit / parallel-collectors
Parallel Collectors is a toolkit easing parallel collection processing in Java using Stream API.
akarnokd / RxJavaExtensions
RxJava 4.x extra sources, operators and components and ports of many 1.x companion libraries.
scalecube / scalecube-services
Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing
google / mug
A small Java 8 library (string manipulation, BiStream, Structured Concurrency, SQL Templates)
zj-unicom-ai / vision-hub-platform
Build visual detection tasks fast with an open-source platform. Connect cameras, video streams, and heterogeneous vision models; define algorithms with prompts; configure frame sampling and detection regions; and manage alerts. Everything you need to put visual AI to work, in one place.