简介
MQCloud是一个专为RocketMQ设计的企业级一站式服务平台,集成了多种功能,包括客户端SDK、运维工具、监控系统和预警机制,旨在简化分布式消息队列的管理工作,提高系统的稳定性和安全性。它提供了一个跨集群的解决方案,使得管理多个RocketMQ集群变得轻松且透明。

功能特点
高可用性与可靠性:确保消息服务的持续可用,即使在部分节点故障的情况下也能保证服务的稳定性。
数据一致性:保证消息传递过程中数据的一致性,防止数据丢失。
高性能:支持高吞吐量、低延迟的消息传递,以满足大规模、高并发场景的需求。
可伸缩性:能够根据业务需求动态扩展资源,以应对数据量的增长。
多种消息协议支持:支持多种消息队列协议,如AMQP、MQTT、Kafka等。
消息排序:保证消息的顺序性。
消息持久化:确保消息不会因为系统故障而丢失。
消息过滤:允许根据特定标准筛选消息。
延迟投递:支持在未来某个时间点投递消息。
事务消息:保证分布式系统中的事务一致性。
安全性与合规性:提供数据加密、访问控制、审计日志等安全功能,确保数据传输的安全,符合相关的法律法规要求。
易于管理:提供友好的管理界面和监控工具,帮助用户管理和监控消息队列服务的状态。
服务集成:支持与企业现有系统和服务(如数据库、大数据平台、云服务等)的集成。
支持多种开发语言和平台:提供多语言客户端SDK,以便不同技术栈的开发者可以使用。
监控功能
集群状态监控:监控集群的整体运行状态,包括各个节点的健康状况。
主题和队列监控:监控特定主题和队列的生产和消费情况,包括消息数量、积压情况等。
生产者和消费者监控:实时监控生产者和消费者的连接状态、消息发送和接收速率。
消息流量监控:监控消息的流入和流出量,帮助用户了解系统的负载情况。
响应时间监控:监控消息从生产到消费的响应时间,确保服务的低延迟。
异常和错误监控:自动检测系统中的异常和错误,如消息发送失败、消费失败等。
资源使用监控:监控服务器资源的使用情况,如CPU、内存、磁盘空间等。
预警和报警:当监控到异常或达到预设阈值时,系统会自动发送预警或报警,通知运维人员。
历史数据分析:提供历史数据的统计和分析,帮助用户了解系统长期的趋势和潜在问题。
可视化仪表盘:通过图形化的界面展示监控数据,便于用户快速获取关键信息。
应用场景
MQCloud适用于各种需要高效、可靠消息传递的场景,尤其是大规模、高并发的互联网应用环境,如电子商务、在线支付、大数据分析等。它能帮助优化消息流转效率,及时发现并解决潜在问题,保证业务的正常运行。
如需了解更多信息,可以访问其官方网站或查阅相关的技术文档。
GitHub地址
https://github.com/sohutv/mqcloud?tab=readme-ov-file
官方文档
https://github.com/sohutv/mqcloud/wiki/%E6%BC%94%E7%A4%BA%E6%A8%A1%E5%BC%8F
安装教程
安装Docker
sudo apt updatesudo apt install -y docker.io docker-compose
拉取镜像
sudo docker pull registry.cn-hangzhou.aliyuncs.com/sohutv_mqcloud/mqcloud
启动服务
sudo docker run -p 18080:8080 \-p 1022:22 -t \-i registry.cn-hangzhou.aliyuncs.com/sohutv_mqcloud/mqcloud \/bin/bash
该镜像包含了部署好的MQCloud,一个部署好的RocketMQ集群(Nameserver+broker),自动创建的topic,一个模拟生产程序和一个模拟消费程序。
镜像启动后,由于涉及到broker注册的过程,可能需要2~3分钟左右才会正常观察到模拟生产和消费。
可以访问127.0.0.1:18080访问MQCloud。另外使用ssh工具,链接127.0.0.1 1022端口,用户名:root,密码:admin进行登录镜像。



更多内容也可看笔者出版图书!




