启动activemq_ActiveMQ入门学习篇01

注&＃xff1a;*这篇博文文章主要介绍ActiveMQ是什么原理性的内容和如何安装以及简易操作

一、 ActiveMQ 简介

1 ActiveMQ是什么呢&＃xff1f;看起来好碉堡的东西哇&＃xff01;

ActiveMQ 是 Apache 出品&＃xff0c;最流行的&＃xff0c;能力强劲的开源消息总线。ActiveMQ 是一个
完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现&＃xff0c;尽管 JMS 规范出台已经是很久
的事情了&＃xff0c;但是 JMS 在当今的 J2EE 应用中间仍然扮演着特殊的地位。

2 什么是消息呢&＃xff1f;

大家对消息的这个词肯定不会陌生&＃xff0c;那么在我们ActiveMQ里面指的是什么&＃xff0c;我想你应该有必要了解下
“消息”是在两台计算机间传送的数据单位。消息可以非常简单&＃xff0c;例如只包含文本字符串&＃xff1b;
也可以更复杂&＃xff0c;可能包含嵌入对象。

3 什么是队列&＃xff1f;

我觉的下面的这张图对大家而言&＃xff0c;相比已经很清楚了&＃xff08;能学到MQ都很了不起啦&＃xff01;&＃xff09;

4 什么是 消息队列&＃xff1f;

简单来说&＃xff1a;
“消息队列”是在消息的传输过程中保存消息的容器。
举个小例子&＃xff1a;比如你在qq上根你朋友俩天&＃xff0c;聊天肯定是双方的&＃xff0c;那么你发给你朋友的消息就是存储在这个腾讯的服务器中&＃xff08;理解为消息队列&＃xff09;的&＃xff0c;当你朋友上线&＃xff08;登录QQ&＃xff09;的时候&＃xff0c;就从服务器中收到了这条消息
是不是看起来很高大上&＃xff0c;起始很容易了解&＃xff0c;哈哈

5 常用消费服务应用

5.1 ActiveMQ
ActiveMQ 是 Apache 出品&＃xff0c;最流行的&＃xff0c;能力强劲的开源消息总线。ActiveMQ 是一个完
全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现。&＃xff08;也是我们本次用的喔&＃xff01;&＃xff09;5.2 RabbitMQ
RabbitMQ 是一个在 AMQP 基础上完成的&＃xff0c;可复用的企业消息系统。他遵循 Mozilla Public
License 开源协议。开发语言为 Erlang。5.3 RocketMQ
由阿里巴巴定义开发的一套消息队列应用服务。

二、消息服务的应用场景

消息队列的主要特点是异步处理&＃xff0c;主要目的是减少请求响应时间和解耦。所以主要的使
用场景就是将比较耗时而且不需要即时&＃xff08;同步&＃xff09;返回结果的操作作为消息放入消息队列。同
时由于使用了消息队列&＃xff0c;只要保证消息格式不变&＃xff0c;消息的发送方和接收方并不需要彼此联系&＃xff0c;
也不需要受对方的影响&＃xff0c;即解耦和。

5.1 异步处理

例如&＃xff1a;用户注册
用户注册流程&＃xff1a;
1&＃xff09;注册处理以及写数据库
2&＃xff09;发送注册成功的手机短信
3&＃xff09;发送注册成功的邮件信息
如果用消息中间件&＃xff1a;则可以创建两个线程来做这些事情&＃xff0c;直接发送消息给消息中间件&＃xff0c;
然后让邮件服务和短信服务自己去消息中间件里面去取消息&＃xff0c;然后取到消息后再自己做对应
的业务操作。就是这么方便

5.2 应用的解耦

例如&＃xff1a;订单处理
生成订单流程&＃xff1a;
1&＃xff09;在购物车中点击结算
2&＃xff09;完成支付
3&＃xff09;创建订单
4&＃xff09;调用库存系统
订单完成后&＃xff0c;订单系统并不去直接调用库存系统&＃xff0c;而是发送消息到消息中间件&＃xff0c;写入一
个订单信息。库存系统自己去消息中间件上去获取&＃xff0c;然后做发货处理&＃xff0c;并更新库存&＃xff0c;这样能
够实现互联网型应用追求的快这一个属性。而库存系统读取订单后库存应用这个操作也是非
常快的&＃xff0c;所以有消息中间件对解耦来说也是一个不错的方向。

5.3 流量的消峰

例如&＃xff1a;秒杀功能
秒杀流程&＃xff1a;
1&＃xff09;用户点击秒杀
2&＃xff09;发送请求到秒杀应用
3&＃xff09;在请求秒杀应用之前将请求放入到消息队列
4&＃xff09;秒杀应用从消息队列中获取请求并处理。
比如&＃xff0c;系统举行秒杀活动&＃xff0c;热门商品。流量蜂拥而至 100 件商品&＃xff0c;10 万人挤进来怎么
办&＃xff1f;10 万秒杀的操作&＃xff0c;放入消息队列。秒杀应用处理消息队列中的 10 万个请求中的前 100
个&＃xff0c;其他的打回&＃xff0c;通知失败。流量峰值控制在消息队列处&＃xff0c;秒杀应用不会瞬间被怼死

三、 JMS

1 什么是 JMS

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

2 JMS模型

2.1 点对点模型(Point To Point)

生产者发送一条消息到 queue&＃xff0c;只有一个消费者能收到。
例如&＃xff1a;你给你的好友发送一条消息&＃xff0c;那么只有他能知道你发了啥

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

发布者发送到 topic 的消息&＃xff0c;只有订阅了 topic 的订阅者才会收到消息。
例如&＃xff1a;你在教室里面大喊“我不要当码农&＃xff01;”&＃xff0c;那么在教室的所有人都会听见。

*学到后面的时候&＃xff0c;你将知道&＃xff0c;我为什么举得这两个例子命名可以都在一个条件下成立&＃xff0c;为什么还换到了另一个不着边际的立场点上。

四、 ActiveMQ 安装

准备环境&＃xff1a;Linux

1 下载资源

ActiveMQ 官网&＃xff1a; http://activemq.apache.org#
版本说明
ActiveMQ5.10.x 以上版本必须使用 JDK1.8 才能正常使用。
ActiveMQ5.9.x 及以下版本使用 JDK1.7 即可正常使用。
根据自己的JDK版本酌情而定&＃xff0c;初学者不必太纠结版本问题,我这里采用的是ActiveMQ5.9.0版本

2 上传至 Linux 服务器

3 解压安装文件

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

4 检查权限&＃xff08;大部分都没事的&＃xff0c;可以略过&＃xff09;

1
2
3ls -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 修改访问端口&＃xff08;如果你想的话&＃xff09;

修改 ActiveMQ 配置文件: /usr/local/activemq/conf/jetty.xml

配置文件修改完毕&＃xff0c;保存并重新启动 ActiveMQ 服务

7.4 修改用户名和密码

修改 conf/users.properties 配置文件.内容为: 用户名&＃61;密码
保存并重启 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搜索下位置哈&＃xff08;虚拟机坏了&＃xff0c;按时不做截图了&＃xff09;
配置文件中,配置的是 ActiveMQ 的核心配置信息. 是提供服务时使用的配置. 可以修改
启动的访问端口. 即 java 编程中访问 ActiveMQ 的访问端口.
默认端口为 61616.
使用协议是: tcp 协议.
修改端口后, 保存并重启 ActiveMQ 服务即可.

11 ActiveMQ

从它的目录来说,还是很简单的:
* bin 存放的是脚本文件
* conf 存放的是基本配置文件
* data 存放的是日志文件
* docs 存放的是说明文档
* examples 存放的是简单的实例
* lib 存放的是 activemq 所需 jar 包
* webapps 用于存放项目的目录

ps&＃xff1a;

*如果你感到枯燥的话&＃xff0c;那就过会再来看看吧&＃xff0c;原理性的东西&＃xff0c;嗯&＃xff0c;蛮重要的