Logo

#消息队列

Logo of Openaibot
Openaibot
Openaibot是一款开源的多平台聊天机器人。其支持通过pip安装插件,配以消息队列机制确保高效的插件运行。此外,项目的一键部署功能及详尽的部署文档可协助用户上手使用。
Logo of spring-amqp
spring-amqp
Spring AMQP是一个开源项目,为Java开发者提供AMQP 0.9.1协议和RabbitMQ的集成支持。该框架简化了消息传递系统的开发,支持异步通信和分布式系统。项目包含详细文档和示例,并有活跃的社区支持,有助于开发者构建可靠的消息驱动应用。
Logo of automq
automq
AutoMQ是一款云原生消息队列系统,通过将持久性分离到S3和EBS,实现高效经济的消息处理。该系统采用无服务器架构,支持秒级扩缩容和自动负载均衡,同时保持与Kafka完全兼容。AutoMQ不仅降低云端运营成本,还提供更高可靠性和简化管理,适合企业级流数据处理需求。
Logo of mqcloud
mqcloud
MQCloud是一个开源的企业级Apache RocketMQ服务平台,集成了客户端SDK、运维工具、监控系统和预警机制。它支持跨集群管理、消息堆积预警和生产消费监控,并提供直观的用户和管理员界面。该平台在大规模环境中经过验证,现管理5个以上集群,服务370多个topic,日处理消息量超10亿条,总数据量超1TB。
Logo of jeromq
jeromq
JeroMQ是ZeroMQ的纯Java实现,提供高性能消息传递功能。支持ZMTP/3.0协议和多种传输方式,实现PLAIN和CURVE安全机制。性能表现优异,每秒处理450万条100字节消息。提供与原生ZeroMQ相同的开发体验,支持Maven和Ant构建。适用于Java环境下需要高效消息传递的应用场景。
Logo of CAP
CAP
CAP是基于.NET Standard的开源库,为分布式系统提供可靠的事务处理和事件总线功能。通过本地消息表与数据库集成,CAP确保事件消息在分布式环境中的一致性。支持多种主流消息队列和数据库,配置简单,使用方便。作为轻量级高效的集成工具,CAP适用于SOA和微服务架构。此外,CAP提供实时监控仪表板,便于查看消息状态和系统运行情况。
Logo of llama-agents
llama-agents
llama-agents是一个异步框架,用于构建和部署多智能体系统。它支持智能体间通信、分布式工具执行和人机交互。框架将智能体视为服务,通过消息队列处理任务,由控制平面管理整个网络。支持本地和服务器启动模式,适合开发和生产环境。内置监控工具便于系统观察和交互。
Logo of server
server
Mochi-MQTT是一款完全兼容MQTT v5和v3.1.1协议的高性能Go语言MQTT服务器。它可独立运行或嵌入应用程序中,设计轻量快速,支持多种网络协议,提供持久化存储和访问控制功能。该服务器适用于物联网和遥测项目开发,可作为独立服务器或嵌入式组件使用。
Logo of spring-amqp-samples
spring-amqp-samples
Spring AMQP示例项目包含多个实用案例,如HelloWorld、Stocks应用和RabbitMQ教程的Spring Boot版本。项目涵盖同步异步消费者、Web界面和命令行操作等多种场景,并提供详细的构建说明。开发者可通过这些示例深入学习Spring与AMQP的集成应用,是掌握Spring AMQP技术的实践指南。
Logo of kafka-beginners-course
kafka-beginners-course
该项目提供Apache Kafka入门学习资源,包含Java编程基础、Wikimedia生产者、OpenSearch消费者和Kafka Streams示例。项目由Conduktor团队开发,旨在简化Kafka学习过程。内容适合初学者和希望提升技能的开发人员,提供实用的学习材料和实践案例。
Logo of smoothmq
smoothmq
SmoothMQ是一个开源的SQS替代解决方案,旨在优化开发体验。该项目提供了功能完善的用户界面、可观测性、追踪、消息调度和速率限制等功能。SmoothMQ支持在各类云平台上部署私有SQS实例,采用单个Go二进制文件部署,并保持与现有SQS客户端的兼容性。这一工具为开发团队提供了高效且灵活的消息队列选择。
Logo of kafka-go
kafka-go
kafka-go是一款Go语言开发的高性能Kafka客户端库,提供低级和高级API与Kafka交互。该库实现Go标准库接口,易于使用和集成,支持生产者、消费者和消费者组功能。它具备自动重试、重连和偏移量管理等特性,适用于Kafka 0.10.1.0至2.7.1版本,需要Go 1.15或更高版本。
Logo of kaskade
kaskade
Kaskade是一个基于Textual构建的Apache Kafka文本用户界面(TUI)工具。它提供主题管理、消费者操作、多种数据格式反序列化和Schema Registry支持等功能。Kaskade支持Linux和macOS系统,可进行SSL加密和Confluent Cloud配置,为Kafka开发和管理提供便利。
Logo of pgmq
pgmq
PGMQ是基于PostgreSQL的轻量级消息队列扩展,无需后台进程和外部依赖。它保证在可见性超时内精确传递消息一次,支持消息归档和重放,并提供类似AWS SQS的API。PGMQ适用于PostgreSQL 12-16版本,是一个高效可靠的开源消息队列方案。