ActiveMQ学习总结------入门篇01

注：*这篇博文文章主要介绍ActiveMQ是什么原理性的内容和如何安装和简易操做

---

 

1、 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
由阿里巴巴定义开发的一套消息队列应用服务。

---

 

2、消息服务的应用场景

　　消息队列的主要特色是异步处理，主要目的是减小请求响应时间和解耦。因此主要的使
用场景就是将比较耗时并且不须要即时（同步）返回结果的操做做为消息放入消息队列。同
时因为使用了消息队列，只要保证消息格式不变，消息的发送方和接收方并不须要彼此联系，
也不须要受对方的影响，即解耦和。

 

 

 

 

5.1  异步处理

例如：用户注册

用户注册流程：
1）注册处理以及写数据库
2）发送注册成功的手机短信
3）发送注册成功的邮件信息
若是用消息中间件：则能够建立两个线程来作这些事情，直接发送消息给消息中间件，
而后让邮件服务和短信服务本身去消息中间件里面去取消息，而后取到消息后再本身作对应
的业务操做。就是这么方便

 

5.2 应用的解耦

例如：订单处理

 

生成订单流程：
1）在购物车中点击结算
2）完成支付
3）建立订单
4）调用库存系统
订单完成后，订单系统并不去直接调用库存系统，而是发送消息到消息中间件，写入一
个订单信息。库存系统本身去消息中间件上去获取，而后作发货处理，并更新库存，这样能
够实现互联网型应用追求的快这一个属性。而库存系统读取订单后库存应用这个操做也是非
常快的，因此有消息中间件对解耦来讲也是一个不错的方向。

 

5.3  流量的消峰

例如：秒杀功能

 

秒杀流程：
1）用户点击秒杀
2）发送请求到秒杀应用
3）在请求秒杀应用以前将请求放入到消息队列
4）秒杀应用从消息队列中获取请求并处理。
好比，系统举行秒杀活动，热门商品。流量蜂拥而至 100 件商品，10 万人挤进来怎么
办？10 万秒杀的操做，放入消息队列。秒杀应用处理消息队列中的 10 万个请求中的前 100
个，其余的打回，通知失败。流量峰值控制在消息队列处，秒杀应用不会瞬间被怼死

---

 

3、 JMS

1 什么是 JMS

JMS（Java Messaging Service）是 Java 平台上有关面向消息中间件的技术规范，它便于
消息系统中的 Java 应用程序进行消息交换,而且经过提供标准的产生、发送、接收消息的接
口，简化企业应用的开发，也就是Java帮咱们定义的一套规范

 

2 JMS模型

2.1  点对点模型(Point To Point)

生产者发送一条消息到 queue，只有一个消费者能收到。

例如：你给你的好友发送一条消息，那么只有他能知道你发了啥

 

 

 

2.2  发布订阅模型(Publish/Subscribe)

发布者发送到 topic 的消息，只有订阅了 topic 的订阅者才会收到消息。

例如：你在教室里面大喊“我不要当码农！”，那么在教室的全部人都会听见。  

 

 

*学到后面的时候，你将知道，我为何举得这两个例子命名能够都在一个条件下成立，为何还换到了另外一个不着边际的立场点上。

---

4、 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 解压安装文件

tar -zxf apache-activemq-5.9.0-bin.tar.gz

　　

4 检查权限（大部分都没事的，能够略过）

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

/usr/local/activemq/bin/activemq restart

9 关闭 ActiveMQ

/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：

*若是你感到枯燥的话，那就过会再来看看吧，原理性的东西，嗯，蛮重要的

 

原文出处：https://www.cnblogs.com/arebirth/p/activemq01.html