由於公司業務需求，需要搭建一套實時處理數據平台，基於多方面調研選擇了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 是一 ...