ActiveMQ入门

消息模型

Queue(点对点)

一个生产者向一个指定的队列发布消息,一个消费者从这个队列中依次读取消息。
特点:一条消息只能被一个消费者获取,且消费者无需提前订阅。

Topic(发布/订阅)

一个生产者向一个指定的队列发布消息,一组消费者同时从这个队列中读取消息。
特点:消费者需提前订阅,否则无法接受消息。

消息格式

有五种消息格式

MapMessage : key-value键值对
TextMessage : 字符串对象
ObjcetMessage : 一个序列化的Java对象
ByteMessage : 一个未解释字节的数据流
StreamMessage : Java原始值的数据流

安装

首先进入官方下载页面,选择版本后下载系统对应的版本。

Windows版

Windows为zip格式的压缩包,下载完成后解压。
cmd进入bin目录下运行start命令即可启动服务。

1
2
cd bin
activemq start

或者使用管理员权限运行bin目录下win32或win64文件夹内的InstallService.bat将ActiveMQ服务安装至Windows服务中,在服务面板启动或停止服务。

Linux版

跟Windows步骤差不多,但是官方的下载链接使用wget会报错,推荐使用这个网站下载:http://archive.apache.org/dist/activemq/

1
2
3
4
5
6
7
# 1.下载
wget http://archive.apache.org/dist/activemq/5.15.7/apache-activemq-5.15.7-bin.tar.gz
# 2.解压
tar -zxvf apache-activemq-5.15.7-bin.tar.gz
# 3.运行
cd apache-activemq-5.15.7/bin
./activemq start

当然了你也可以参考我的博客Linux服务自启动将activemq设置为系统服务。