发版说明
# 发版说明
金蝶 Apusic 分布式消息队列(Apusic Distributed Message Queue,简称ADMQ)是一款金融级分布式消息中间件, 具有多租户、跨集群数据复制、强一致性、高可靠、 高并发等特性。 ADMQ 支持原生 Java 、 C++、 Python、GO 多种 API, 支持以 Kafka、RocketMQ、RabbitMQ 客户端和 MQTT、JMS 等协议接入,从而简化不同业务系统的接入难度。
ADMQ采用了计算和存储分离的架构,客户端接入层是无状态的计算节点,底层是存储节点集群,计算节点和存储节点可以独立扩展。这种架构可以有效避免扩容限制,相对于其他消息中间件能更好的适配云原生环境。
# 关于此版本
ADMQ V2.0.3版本增加了对Kafka插件、RabbitMQ插件的管控功能,用户可直接在管控台上创建Kafka相关资源和RabbitMQ相关资源,并对Kafka客户端和RabbitMQ客户端消息收发情况进行不同维度的监控。对于Kafka插件,又提供了重置消费、不同维度的权限控制等功能。
ADMQ V2.0.3优化了集群管理模块、系统配置模块的功能。
ADMQ V2.0.3集成AMP和AUC,提升运维监控能力。
# 新功能及特性增强
# Kafka管控功能
# 租户管理
支持消息队列对租户进行管理,支持创建、编辑、删除、查询租户,创建租户时可以设置主题个数上限和订阅组个数上限。
# 命名空间管理
支持在租户下管理命名空间资源,支持创建、编辑、删除、查询命名空间, 创建命名空间时可以设置消息保留时间。
# 主题管理
支持在命名空间下管理主题资源,支持创建、编辑、删除、查询主题,创建主题时可以设置主题分区数。同时采集主题上消息生产信息,查看消息生产消费进度。
# 订阅组管理
支持在租户下管理订阅组,支持创建、编辑、删除、查询主订阅组,操作查看每个订阅组订阅的主题,以及每个主题的生产消费进度。
# 生产消费统计
支持在租户、主题和订阅的维度统计消息生产和消费情况,通过图标方式进行展示。
# 重置消费
支持通过管控设置topic下某个订阅的消费位点,可从指定时间或指定位置进行消费或者从最新位点或最旧位点开始进行消费消息。
# 权限控制
支持控制用户对主题和订阅组的读写权限。
# RabbitMQ管控功能
# 租户管理
支持消息队列对租户进行管理,支持创建、编辑、删除、查询租户,创建租户时可以设置虚拟主机上限、交换机上限及队列上限。
# 虚拟主机管理
支持在租户下管理虚拟主机资源,支持创建、编辑、删除、查询虚拟主机, 创建虚拟主机时可以设置消息保留时间。
# 交换机管理
支持在虚拟主机下管理交换机资源,支持创建、编辑、删除、查询交换机,创建主题时可以设置路由类型:direct、fanout、topic。同时采集交换机上消息信息,查看交换机基本信息、生产者客户端信息及消息生产情况和转发情况。
# 队列管理
支持在虚拟主机下管理队列资源,支持创建、编辑、删除、查询队列,支持清空队列消息功能。
# 路由管理
支持创建、编辑、删除、查询路由功能,新增路由时可选择是否指定key。支持路由重新绑定。支持查看路由详情。
# 生产消费统计
支持在租户、交换机和队列的维度统计消息生产或消费情况,并通过图标方式进行展示。
# 集群管理模块功能添加
# RocketMQ、MQTT、RabbitMQ、Kafka插件管理
通过管控台实现KOP、MOP、ROP、AOP等插件管理(启用、停用):安装包和创建集群时初始化插件信息,插件加载和卸载,插件替换和下发,插件加载后在集群中添加插件服务地址。
# 黑白名单
通过添加客户端黑、白名单地址,来限制客户端使用情况,该功能可选择开启或不开启。
# 集群节点
支持新增、编辑、删除admq集群节点或者rocketmq集群节点,实现扩缩容。支持在节点列表实现多个节点的一键启动、停止功能。
# 集群配置
支持在集群配置参数列表实现一键启用、一键停止功能。
# 证书管理
支持rocketmq证书管理。
# 依赖管理
支持rocketmq依赖管理。
# 系统配置模块功能
新增导入主机采集器软件包,ADMQ、RocetMQ安装包上传时可识别支持的芯片架构类型。
规范安装包:所有通过管控台部署的安装包都统一格式:类型-版本-芯片架构.tar.gz,例如ADMQ-V2.2.1-X86.tar.gz。
服务器批量导入导出
# 监控运维功能提升
集成AMP和AUC:对接AUC,实现登录功能。集群节点可跳转到AMP实例监控页面。
采集器部署:可对新添加的服务器进行部署采集器,提供HTTP服务。
# 管控台功能优化
提供不同数据库的SQL生成程序。
记录集群删除和资源删除信息,定时清理已删除集群的相关资源数据。
支持没有license也能启动管控台。
Kafka和RabbitMQ主题同步。