由于公司业务需求，需要搭建一套实时处理数据平台，基于多方面调研选择了Flink. 初始化Swarm环境(也可以选择k8s) 　　部署zookeeper集群 基于docker-compos ...

SMQTT是一款开源的MQTT消息代理Broker， SMQTT基于Netty开发，底层采用Reactor3反应堆模型,支持单机部署，支持容器化部署，具备低延迟，高吞吐量，支持百万TCP连接，同时 ...

Spring WebFlux 教程：如何构建反应式 Web 应用程序 反应式系统提供了我们在高数据流世界中所需的无与伦比的响应能力和可扩展性。然而，反应式系统需要经过专门培训的工具和开发人员来实 ...

前言 在Java8中引入的流API可能仍然是Java在过去几年中包含的最重要的新特性。我认为每个Java开发人员在其职业生涯中都有机会使用JAVA STRAM API。或者我更愿意说，你可能 ...

前言 HTTP/1.1协议为现在网络提供了20年的支持。从那时起，网站已经从静态的、文本驱动的文档发展为交互式的、富媒体的应用程序。在此期间底层协议保持不变这一事实正好说明了它的通用性和能力。但随着 ...

SMQTT是一款开源的MQTT消息代理Broker， SMQTT基于Netty开发，底层采用Reactor3反应堆模型,支持单机部署，支持容器化部署，具备低延迟，高吞吐量，支持百万TCP连接，同时支 ...

欢迎阅读Rmessage文档 技术栈 Rmessage是采用Reactor3,基于reactor-netty项目构建的实时消息推送api。 什么是Reactor3? Reactor 是一 ...