undefined
注：*这篇博文文章主要介绍ActiveMQ是什么原理性的内容和如何安装和简易操作#
一、 ActiveMQ 简介#
1 ActiveMQ是什么呢？看起来好碉堡的东西哇！#
ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个
完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现，尽管 JMS 规范出台已经是很久
的事情了，但是 JMS 在当今的 J2EE 应用中间仍然扮演着特殊的地位。
2 什么是消息呢？#
大家对消息的这个词肯定不会陌生，那么在我们ActiveMQ里面指的是什么，我想你应该有必要了解下
“消息”是在两台计算机间传送的数据单位。消息可以非常简单，例如只包含文本字符串；
也可以更复杂，可能包含嵌入对象。
3 什么是队列？#
我觉的下面的这张图对大家而言，相比已经很清楚了（能学到MQ都很了不起啦！）
4 什么是 消息队列？#
简单来说：
“消息队列”是在消息的传输过程中保存消息的容器。
举个小例子：比如你在qq上根你朋友俩天，聊天肯定是双方的，那么你发给你朋友的消息就是存储在这个腾讯的服务器中（理解为消息队列）的，当你朋友上线（登录QQ）的时候，就从服务器中收到了这条消息
是不是看起来很高大上，起始很容易了解，哈哈
5 常用消费服务应用#
5.1 ActiveMQ
ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完
全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现。（也是我们本次用的喔！）
5.2 RabbitMQ
RabbitMQ 是一个在 AMQP 基础上完成的，可复用的企业消息系统。他遵循 Mozilla Public
License 开源协议。开发语言为 Erlang。
5.3 RocketMQ
由阿里巴巴定义开发的一套消息队列应用服务。
二、消息服务的应用场景#
消息队列的主要特点是异步处理，主要目的是减少请求响应时间和解耦。所以主要的使
用场景就是将比较耗时而且不需要即时（同步）返回结果的操作作为消息放入消息队列。同
时由于使用了消息队列，只要保证消息格式不变，消息的发送方和接收方并不需要彼此联系，
也不需要受对方的影响，即解耦和。
5.1 异步处理#
例如：用户注册
用户注册流程：
1）注册处理以及写数据库
2）发送注册成功的手机短信
3）发送注册成功的邮件信息
如果用消息中间件：则可以创建两个线程来做这些事情，直接发送消息给消息中间件，
然后让邮件服务和短信服务自己去消息中间件里面去取消息，然后取到消息后再自己做对应
的业务操作。就是这么方便
5.2 应用的解耦#
例如：订单处理
生成订单流程：
1）在购物车中点击结算
2）完成支付
3）创建订单
4）调用库存系统
订单完成后，订单系统并不去直接调用库存系统，而是发送消息到消息中间件，写入一
个订单信息。库存系统自己去消息中间件上去获取，然后做发货处理，并更新库存，这样能
够实现互联网型应用追求的快这一个属性。而库存系统读取订单后库存应用这个操作也是非
常快的，所以有消息中间件对解耦来说也是一个不错的方向。
5.3 流量的消峰#
例如：秒杀功能
秒杀流程：
1）用户点击秒杀
2）发送请求到秒杀应用
3）在请求秒杀应用之前将请求放入到消息队列
4）秒杀应用从消息队列中获取请求并处理。
比如，系统举行秒杀活动，热门商品。流量蜂拥而至 100 件商品，10 万人挤进来怎么
办？10 万秒杀的操作，放入消息队列。秒杀应用处理消息队列中的 10 万个请求中的前 100
个，其他的打回，通知失败。流量峰值控制在消息队列处，秒杀应用不会瞬间被怼死
三、 JMS#
1 什么是 JMS#
JMS（Java Messaging Service）是 Java 平台上有关面向消息中间件的技术规范，它便于
消息系统中的 Java 应用程序进行消息交换,并且通过提供标准的产生、发送、接收消息的接
口，简化企业应用的开发，也就是Java帮我们定义的一套规范
2 JMS模型#
2.1 点对点模型(Point To Point)#
生产者发送一条消息到 queue，只有一个消费者能收到。
例如：你给你的好友发送一条消息，那么只有他能知道你发了啥
2.2 发布订阅模型(Publish/Subscribe)#
发布者发送到 topic 的消息，只有订阅了 topic 的订阅者才会收到消息。
例如：你在教室里面大喊“我不要当码农！”，那么在教室的所有人都会听见。
*学到后面的时候，你将知道，我为什么举得这两个例子命名可以都在一个条件下成立，为什么还换到了另一个不着边际的立场点上。
四、 ActiveMQ 安装#
准备环境：Linux
1 下载资源#
ActiveMQ 官网： http://activemq.apache.org#
版本说明
ActiveMQ5.10.x 以上版本必须使用 JDK1.8 才能正常使用。
ActiveMQ5.9.x 及以下版本使用 JDK1.7 即可正常使用。根据自己的JDK版本酌情而定，初学者不必太纠结版本问题,我这里采用的是ActiveMQ5.9.0版本
2 上传至 Linux 服务器#
3 解压安装文件#
|
1
|
tar -zxf apache-activemq-5.9.0-bin.tar.gz |
4 检查权限（大部分都没事的，可以略过）#
|
1
2
3
|
ls -al apache-activemq-5.9.0/bin如果权限不足,则无法执行,需要修改文件权限:chmod 755 activemq |
5 复制应用至本地目录#
cp -r apache-activemq-5.9.0 /usr/local/activemq
6 启动 ActiveMQ#
/usr/local/activemq/bin/activemq start
7 测试 ActiveMQ#
检查进程
ps aux | grep activemq
见到下述内容即代表启动成功
7.2 管理界面#
使用浏览器访问 ActiveMQ 管理应用, 地址如下:
http://ip:8161/admin/
用户名: admin
密码: admin
ActiveMQ 使用的是 jetty 提供 HTTP 服务.启动稍慢,建议短暂等待再访问测试.
见到如下界面代表服务启动成功
7.3 修改访问端口（如果你想的话）#
修改 ActiveMQ 配置文件: /usr/local/activemq/conf/jetty.xml
配置文件修改完毕，保存并重新启动 ActiveMQ 服务
7.4 修改用户名和密码#
修改 conf/users.properties 配置文件.内容为: 用户名=密码
保存并重启 ActiveMQ 服务即可
8 重启 ActiveMQ#
|
1
|
/usr/local/activemq/bin/activemq restart |
9 关闭 ActiveMQ#
|
1
|
/usr/local/activemq/bin/activemq stop |
10 配置文件 activemq.xm#
自行在vim里面输入ese /61616搜索下位置哈（虚拟机坏了，按时不做截图了）
配置文件中,配置的是 ActiveMQ 的核心配置信息. 是提供服务时使用的配置. 可以修改
启动的访问端口. 即 java 编程中访问 ActiveMQ 的访问端口.
默认端口为 61616.
使用协议是: tcp 协议.
修改端口后, 保存并重启 ActiveMQ 服务即可.
11 ActiveMQ #
从它的目录来说,还是很简单的:
* bin 存放的是脚本文件
* conf 存放的是基本配置文件
* data 存放的是日志文件
* docs 存放的是说明文档
* examples 存放的是简单的实例
* lib 存放的是 activemq 所需 jar 包
* webapps 用于存放项目的目录
ps：
*如果你感到枯燥的话，那就过会再来看看吧，原理性的东西，嗯，蛮重要的
作者： Arebirth
出处：https://www.cnblogs.com/arebirth/p/activemq01.html
本站使用「CC BY 4.0」创作共享协议，转载请在文章明显位置注明作者及出处。