【金蝶天燕鲲鹏云最佳实践 二】ApusicMQ v9消息中间件实践系列（一）安装、测试消息

一、软件介绍

金蝶天燕Apusic消息中间件（Apusic Message Queue，简称AMQ或Apusic MQ）的出现，为信息流动提供了更强有力的支撑和集成灵活度。Apusic MQ通过松耦合的消息机制，能够在分布的、复杂的网络环境中安全、可靠、高效的传输消息，以及在传递消息时能够跨越不同的平台、不同的语言。

金蝶天燕AMQ支持行业标准的安全加密算法，保证消息传输的安全性、普通主题和临时主题，分层次主题订阅、多主题订阅、支持消息压缩，消息加密，网络限流、支持多操作系统、支持多种语言的客户端编程接口、多种持久化存储方式、高可靠、高性能等产品优势。

二、环境准备

1. 安装openjdk

sudo   apt-get       install openjdk-8-jre

2. 检查版本：

java   -version

如可正常显示版本号，则安装完毕：

root@deepin:/etc/apt#     java   -version

openjdk version     "1.8.0_212"

三、产品安装

1.    上传并解压软件包，将zip格式的安装文件拷贝到磁盘的对应目录下，如/mnt/amqtest/Apusic-MQ-V9.0目录下。

2.    执行unzip Apusic-MQ-V9.0.zip解压缩。

3.    修改安装目录下bin目录下AMQ启动脚本中的JAVA_HOME环境变量：

本次测试环境中为JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk

修改启动参数文件。修改安装目录下conf/common.properties文件内容，设置AMQ服务启动的各项参数。其中amq.port为消息服务端口，amq.console.port为控制台界面端口。

#AMQ Port config

#Fri Jul 19 11:51:41   GMT+08:00 2019

amq.ip=0.0.0.0

amq.port=5888

amq.console.port=7888

amq.jmx.port=1099

amq.sftp.port=8027

amq.ftp.port=2111

amq.brokerName=amq_broker_dev

amq.persistent=true

amq.prettyName=test

amq.register.dataCenter.ip=192.168.2.196

amq.register.dataCenter.port=8500

4.    执行bin目录./apusicmq console 启动ApusicMQ.

通过浏览器访问web管控，地址为ip:port/console

四、测试

1.     管理节点

通过浏览器访问管理控制台ip:port/ui，登陆完成管理平台具有节点管理功能，可以添加、删除节点管理平台具有节点管理功能，可以远程启停节点。可以展示队列、主题等相关信息。

点击节点管理，可看到节点列表，可点击右侧的添加按钮添加节点

2.    发送接收消息

执行客户端发送消息代码，给testq队列发送消息输入

通过管控看到等待队列为写入的消息

执行客户端接收消息代码，testq队列中消息被消费成功

3.    消息优先级

修改Apusic-MQ-V9.0/conf/apusicmq.xml，开启队列优先级策略

发送客户端代码发送10条消息优先级依次增高。

可在管控中查看每条消息的优先级。

执行接收客户端代码，查看打印信息，先收到的是优先级高的消息。

4.    消息分组

发送客户端代码将消息进行group1和group2分组，接收客户端代码设置只接收group2组的消息并打印

支持消息分组，以保证客户端消息一致性和完整性。

五、总结

消息中间件作为基础中间件的一部分是非常重要的，消息中间件的应用场景非常丰富，点对点传输、主题/订阅、消息路由、保证海量文件、大文件的断点续传、多节点监控等等。以上只是简单的介绍了消息中间件的节点管理和消息传输。消息中间件如何能将网络、存储、芯片的性能表现出来，是非常至关重要的。鲲鹏云已经为我们提供了坚实的基础环境，如何能把底层计算能力更好的表现出来，就需要在此基础环境需要更深度的、源码级的优化，我们会持续介绍金蝶天燕消息中间件在鲲鹏云中的服务能力。

鲲鹏 分布式数据库中间件 DDM

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。