ActiveMQ 安装

linux 安装

• 安装很简单，ActiveMQ就是用Java写的。因此，只要linux环境下有java 1.8的环境，将activemq的包下下来，就能直接打开用了。
• 官网下载
• 或者在linux环境下，用wget操作

  wget https://mirrors.bfsu.edu.cn/apache//activemq/5.15.15/apache-activemq-5.15.15-bin.tar.gz
             

• 解压

  tar -xvzf apache-activemq-5.15.15-bin.tar.gz
             

• 进入bin文件夹，开启服务

  ./activemq start
             

• 也可以让它的输出保存在一个文件里面，当成一个日志文件

  ./activemq start > /myactivemq/run_activemq.log
             

• 也可以针对某个配置文件，开启服务

  ./activemq start xbean:file/myactivemq/apache-activemq-5.15.9/conf/activemq.xml
             

• 查看是否开启，也有三个命令。（默认占用端口是61616）

  ps -ef | grep activemq
  netstat -anp | grep 61616
  lsof -i:61616
             

• 至此，在linux上开启了服务
• ActiveMQ官方开发了一个网页版的运维管理页面，我们可以直接通过HTTP访问服务器，了解当前MQ的情况
• 首先，获取目前服务器的ip地址

  ifconfig
             

• 获取ip地址之后，我们可以通过浏览器打开管理页面。默认端口是

  8161

  ，帐号密码都是

  admin

  

2. 嵌入式的broker

• broker，可以简单理解为一个Active MQ服务器实例。一个broker对外就是一个Active MQ服务器实例，当然为了保险起见，它可以由多个主从服务器组成。
• 而为了方便起见，其实我们也可以直接在自己的Java工程中，嵌入一个broker，对外就是一个简单的Active MQ实例。

2.1 实现

• 引入依赖

  <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-databind</artifactId>
      <version>2.10.1</version>
  </dependency>
             

• 写一个broker的启动类

  public class EmbedBroker {
    public static void main(String[] args) throws Exception {
      BrokerService brokerService = new BrokerService();  // 创建一个broker服务
      brokerService.setPopulateJMSXUserID(true);
      brokerService.addConnector("tcp://127.0.0.1:61616"); // 设置ip和端口号
      brokerService.start();
    }
  }
             

• 就此，完成了一个简单的broker，只要修改一下平时代码的地址部分，就可以直接使用了。