Show HN:PicoMQ – 基于对象存储、通过 HTTP 实现的持久化流
Show HN: PicoMQ – Durable Streams over HTTP, on object storage

原始链接: https://picomq.com/

无限流 为每个用例创建一个流,而不是将同类记录全部塞入同一个主题中。每个流都是独立寻址的、无底的,并且可以从空闲状态扩展到高吞吐量。 无限流 零磁盘架构 解耦层 高吞吐量 简易部署

PicoMQ 是一款基于 Rust 的新型服务器,专为由对象存储(如 S3)支撑的“持久化流”(Durable Streams)而设计。它为 Kafka 等重型流处理系统提供了一种具备成本效益且可通过 URL 寻址的替代方案,非常适合聊天应用、会话管理或追踪单个实体等细粒度应用场景。 主要特性和见解包括: * **设计:** 与针对大规模、单体管道进行优化的 Kafka 不同,PicoMQ 鼓励创建细粒度的流。它使用 Postgres 命令日志进行协调,并基于 S3Stream 引擎构建。 * **性能:** 虽然对象存储通常会引入延迟,但 PicoMQ 通过共享预写日志(WAL)、服务端批处理以及 HTTP/2 流水线技术缓解了这一问题。其持久化确认(ACK)延迟通常约为 250 毫秒,未来计划支持磁盘分段 WAL 以实现更快的性能。 * **运维便捷:** 它作为无状态的单二进制文件部署,易于扩展和运维。 * **使用场景:** 它定位为一种方案明确、对开发者友好的实时应用解决方案,专门避免了 Kafka 或 S2-Lite 的运维复杂性。创作者指出,虽然它不是高吞吐企业级管道中 Kafka 的直接替代品,但在灵活性、经济性和实施难度方面表现卓越。
相关文章

原文

Unlimited streams

Create a stream per use case instead of packing every record of a kind into one topic. Each stream is independently addressable, bottomless, and can scale from idle to high throughput.

联系我们 contact @ memedata.com