【金蝶天燕鲲鹏云最佳实践 二】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组的消息并打印
支持消息分组，以保证客户端消息一致性和完整性。
五、总结
消息中间件作为基础中间件的一部分是非常重要的，消息中间件的应用场景非常丰富，点对点传输、主题/订阅、消息路由、保证海量文件、大文件的断点续传、多节点监控等等。以上只是简单的介绍了消息中间件的节点管理和消息传输。消息中间件如何能将网络、存储、芯片的性能表现出来，是非常至关重要的。鲲鹏云已经为我们提供了坚实的基础环境，如何能把底层计算能力更好的表现出来，就需要在此基础环境需要更深度的、源码级的优化，我们会持续介绍金蝶天燕消息中间件在鲲鹏云中的服务能力。
- 点赞
- 收藏
- 关注作者
评论（0）