1.0-MQ入门及使用

it2025-04-06  18

1.目前接触到的有kafka、ActiveMQ、RabbitMQ、RocketMQ等消息中间件。

其中RabbitMQ是由erlang编写,其余由java编写(kafka包含其他语言)。

MQ的主要作用在于 削峰、异步、解耦,其具体介绍自行百度,外面教程很多,本节以实战为主。

本次学习以ActiveMQ为例:

 下载地址:http://activemq.apache.org/ 

官网上下载的apache-activemq-5.16.0-bin.tar.gz,上送到服务器中(个人没买服务器,直接是在虚拟机中装入了centOS7)。

通常放置目录 /opt下。

 

2.下载后进行安装

tar -zxvf apache-activemq-5.16.0-bin.tar.gz

根目录下新建目录activeMQ,将apache-activemq-5.16.0目录及内容拷贝过去(源文件最好删除,毕竟日积月累文件会越来越多,已知能清除的尽早清除)。

3.启动MQ

3.1 普通启动:找到mq下bin目录

启动指令:./activemq start

其默认进程端口是61616

如上图所示即启动成功!

 

下面是查看启动占用服务:

可以看到4092这个进程是activeMQ(grep -v grep用于屏蔽查找的grep自身信息)。

查看端口:netstat -anp|grep 61616

注:lsof -i:61616 可直接查看端口从而判断是否启动MQ

4.关闭MQ

停止指令:./activemq stop

 

5.带日志的MQ处理方式

启动时打印日志追加到文件中: ./activemq start > /activeMQ/myrunmq.log

 

以上为基本安装及使用过程~

最新回复(0)