#消息队列

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