命令行启动

1、下载解压 ActiveMQ 后，进入 bin 目录下，命令行启动：

1）activemq start：此时将默认使用 conf 目录下的 activemq.xml 配置文件进行启动

2）activemq start xbean:file:../conf/activemq.xml：使用指定的配置文件进行启动

2、ActiveMQ 默认采用 61616 端口提供 JMS 服务，使用 8161 端口提供管理控制台服务

3、ActiveMQ 的 web 管理页面：http://localhost:8161/admin；默认账号密码是 admin/admin

4、关闭 ActiveMQ：进入 %ActiveMQ_HOME%/bin目录下，执行：activemq stop

嵌入式启动

1、如同 Tomcat 可以内嵌在 Java 应用中一样，ActiveMQ 也可以内嵌在 Java 应用中使用，作为独立的消息服务器，无缝集成 Java 应用。

2、环境：Maven 3.6.1 + Java JDK 1.8 + ActiveMQ 5.15.9 + IDEA 2018 ，Mava 管理的 Java SE 应用，进行编码演示。使用非常简单：

1）导入 activemq-all 依赖。（json 数据转换需要依赖 jackjson)

2）使用 BrokerService 启动 ActiveMQ 服务。（内嵌启动默认是没有提供 8161 的 web 管理界面的）

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.wmx</groupId><artifactId>activeMQ1</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency><!--ActiveMQ 内嵌启动时，json 数据转换需要依赖 jackjson--><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.9.9</version></dependency></dependencies>
</project>

3、pom.xml 文件内容如上所示，BrokerService 启动 ActiveMQ 服务如下：

import org.apache.activemq.broker.BrokerService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/*** 嵌入式 ActiveMQ 启动*/
public class EmbedActiveMQStart {private static Logger logger = LoggerFactory.getLogger(EmbedActiveMQStart.class);/*** 嵌入式 ActiveMQ 启动方式1* java.lang.NoClassDefFoundError: com/fasterxml/jackson/databind/ObjectMapper*/public static void main(String[] args) {try {/**设置 ActiveMQ 消息服务器用于被客户端连接的 url 地址* 实际开发中，地址应该在配置文件中可配置，不要写死*/String serviceURL = "tcp://localhost:61616";/**BrokerService 表示 ActiveMQ 服务，每一个 BrokerService 表示一个消息服务器实例* 如果想启动多个，只需要 start 多个不同端口的 BrokerService 即可*/BrokerService brokerService = new BrokerService();brokerService.setUseJmx(true);//设置是否应将代理的服务公开到jmx中。默认是 truebrokerService.addConnector(serviceURL);//为指定地址添加新的传输连接器/**启动 ActiveMQ 服务，此时客户端便可以使用提供的地址进行连接，然后发送消息过来，或者从这里消费消息。* 注意：这里内嵌启动后，默认是没有提供 8161 端口的 web 管理界面的，照样能做消息中间件使用* */brokerService.start();logger.info(" ActiveMQ Broker Service Start Finish...");} catch (Exception e) {logger.error("启动 ActiveMQ BrokerService 失败，cause by:" + e.getMessage(), e);}}
}

4、应用启动之后，可以查看端口检查 ActiveMQ 服务是否已经运行，也可以通过发送与接收消息来检验，生产者与消费者代码如下：

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
import java.util.UUID;
/*** 消息发送者*/
@SuppressWarnings("all")
public class Producer {public static void main(String[] args) {Connection connection = null;Session session = null;try {String brokerURL = "tcp://127.0.0.1:61616";//ActiveMQ 中间件连接地址/*** 创建 javax.jms.ConnectionFactory 连接工厂* org.apache.activemq.ActiveMQConnectionFactory 中默认设置了大量的参数，还有几个重载的构造器可以选择*/ConnectionFactory mqConnectionFactory = new ActiveMQConnectionFactory(brokerURL);//如果 ActiveMQ 连不上，则抛异常：java.net.ConnectException: Connection refused: connectconnection = mqConnectionFactory.createConnection();//通过连接工厂获取连接 javax.jms.Connectionconnection.start();//启动连接，同理还有 stop、close/**Session createSession(boolean transacted, int acknowledgeMode) 创建会话*/session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);/*** createQueue(String queueName)：创建消息队列，指定队列名称，消费者可以根据队列名称获取消息* Destination 目的地，重点，interface Queue extends Destination*/Destination destination = session.createQueue("queue-app");//createProducer(Destination destination)：根据目的地创建消息生产者MessageProducer producer = session.createProducer(destination);int massageTotal = 5;for (int i = 0; i < massageTotal; i++) {//创建一个文本消息TextMessage textMessage = session.createTextMessage("密钥：" + UUID.randomUUID());producer.send(textMessage);//生产者发送消息session.commit();//会话提交}} catch (JMSException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();//关闭会话}if (connection != null) {connection.close();//关闭连接}} catch (JMSException e) {e.printStackTrace();}}}
}

import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.*;
/*** 消息消费者*/
@SuppressWarnings("all")
public class Consumer {private static Logger logger = LoggerFactory.getLogger(EmbedActiveMQStart.class);public static void main(String[] args) {Connection connection = null;Session session = null;try {String brokerURL = "tcp://127.0.0.1:61616";//ActiveMQ 中间件连接地址/*** 创建 javax.jms.ConnectionFactory 连接工厂* org.apache.activemq.ActiveMQConnectionFactory 中默认设置了大量的参数，还有几个重载的构造器可以选择*/ConnectionFactory mqConnectionFactory = new ActiveMQConnectionFactory(brokerURL);//如果 ActiveMQ 连不上，则抛异常：java.net.ConnectException: Connection refused: connectconnection = mqConnectionFactory.createConnection();//通过连接工厂获取连接 javax.jms.Connectionconnection.start();//启动连接，同理还有 stop、close/**Session createSession(boolean transacted, int acknowledgeMode) 创建会话*/session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);/*** createQueue(String queueName)：创建消息队列，指定队列名称，消费者可以根据队列名称获取消息* Destination 目的地，重点，interface Queue extends Destination*/Destination destination = session.createQueue("queue-app");logger.info("消费者客户启动完毕，开始接收消息...");//createProducer(Destination destination)：根据目的地创建消息消费者MessageConsumer consumer = session.createConsumer(destination);Message message = consumer.receive();while (message != null) {if (message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;System.out.println(textMessage.getText());}session.commit();message = consumer.receive();}} catch (JMSException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();//关闭会话}if (connection != null) {connection.close();//关闭连接}} catch (JMSException e) {e.printStackTrace();}}}
}

MessageListener 监听消息

1、consumer.receive() 是一个线程阻塞的方法，更加推荐使用异步的消息监听器 MessageListener ，使用非常简单，只需要consumer.receive() 改为 consumer.setMessageListener() 即可。

import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.*;
import java.io.IOException;
/*** 消息消费者    ·   使用非阻塞的监听器方式*/
@SuppressWarnings("all")
public class ListenerConsumer {private static Logger logger = LoggerFactory.getLogger(EmbedActiveMQStart.class);public static void main(String[] args) {Connection connection = null;Session session = null;try {String brokerURL = "tcp://127.0.0.1:61616";//ActiveMQ 中间件连接地址/*** 创建 javax.jms.ConnectionFactory 连接工厂* org.apache.activemq.ActiveMQConnectionFactory 中默认设置了大量的参数，还有几个重载的构造器可以选择*/ConnectionFactory mqConnectionFactory = new ActiveMQConnectionFactory(brokerURL);//如果 ActiveMQ 连不上，则抛异常：java.net.ConnectException: Connection refused: connectconnection = mqConnectionFactory.createConnection();//通过连接工厂获取连接 javax.jms.Connectionconnection.start();//启动连接，同理还有 stop、close/**Session createSession(boolean transacted, int acknowledgeMode) 创建会话*/session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);/*** createQueue(String queueName)：创建消息队列，指定队列名称，消费者可以根据队列名称获取消息* Destination 目的地，重点，interface Queue extends Destination* 无论是消息队列还是订阅主题 (Topic)，MessageListener 写法都是一样的。*/Destination destination = session.createQueue("queue-app");MessageConsumer consumer = session.createConsumer(destination);//创建消息消费者/** consumer.receive() 是一个线程阻塞的方法，更加推荐使用异步的消息监听器* 为了方便直接使用了匿名内部类，正式开发建议单独作为一个类* */logger.info("开始监听消息...");final Session finalSession = session;consumer.setMessageListener(new MessageListener() {public void onMessage(Message message) {try {if (message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;logger.info("接收到消息--> " + textMessage.getText());}finalSession.commit();//消息确认} catch (JMSException e) {e.printStackTrace();}}});/*** 特别提醒：正因为 consumer.setMessageListener 是线程非阻塞的，所以如果不加处理，则 mian 会直接运行结束* 这里故意使用 System.in.read() 让 mian 线程阻塞停下来，实际开发中如果是 web 应用，或者是其它的不会马上结束* 的 Java SE 应用，则是不需要这样处理的*/System.in.read();//控制台随便输入字符，回车后，程序运行结束} catch (JMSException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();//关闭会话}if (connection != null) {connection.close();//关闭连接}} catch (JMSException e) {e.printStackTrace();}}}
}

ActiveMQ 命令行启动与嵌入式启动、MessageListener 监听消息相关推荐

无法从命令行或调试器启动服务，必须首先安装Windows服务(使用installutil.exe),然后用ServerExplorer、Windows服务器管理工具或NET START命令启动它
无法从命令行或调试器启动服务,必须首先安装Windows服务(使用installutil.exe),然后用ServerExplorer.Windows服务器管理工具或NET START命令启动它 1. ...
无法从命令行或调试器启动服务，必须首先安装Windows服务....。在“安装”阶段发生异常。 System.Security.SecurityException:未找到源
此处一共两个问题,第一个问题完整描述是: 无法从命令行或调试器启动服务,必须首先安装Windows服务(使用installutil.exe),然后用ServerExplorer.Windows服务器管 ...
【C#】无法从命令行或调试器启动服务，必须首先安装Windows服务(使用installutil.exe)
基于C#项目创建服务,服务创建后,拷贝bin文件至服务器,点击安装时候出现以下错误: 无法从命令行或调试器启动服务,必须首先安装Windows服务(使用installutil.exe),然后用Serv ...
【转】使用命令行方式创建和启动android模拟器
原文网址:http://blog.csdn.net/tiandinilv/article/details/8953001 1.Android模拟器介绍 Android中提供了一个模拟器来模拟ARM核的 ...
linux redis退出命令行,linux的redis启动关闭命令
Linux下redis的启动和关闭通过命令来实现.下面由学习啦小编为大家整理了linux下redis启动关闭命令的相关知识,希望对大家有帮助! linux的redis启动关闭命令 linux的redi ...
无法从命令行或调试器启动服务.必须首先_十大Java面试问题-您必须知道的Java基础知识...
问:什么是JRE,为什么需要它? JRE代表" Java运行时环境",您通常可以将其下载为Java软件.JRE由Java虚拟机,Java平台类和支持库组成.JRE是Java软件的运 ...
activemq 命令行的使用
对于 activemq 本身的一些说明,请参考 http://www.gxitsky.com/type/31 activemq 配置文件见 https://activemq.apache.org/xm ...
默认开机启动；通过Broadcastreceiver广播监听开机启动，实现没有activity的自启服务或者自启应用程序。...
一.首先介绍一下如何开机启动: 第一种: 监控RECEIVE_BOOT_COMPLETED,即开机启动事件第二种: 监控sd卡mount事件开机总会扫描sd卡吧? 监控sd卡事件也有类似开机启 ...
oracle监听服务无法启动不了,关于ORACLE监听服务无法启动的问题
今天电脑拿回家,启动oracle数据库的监听服务时发现无法启动.给出的错误提示是说,这个服务启动了又停止了,不知道是为什么.因为在学校的时候用是没有问题的.我想应该是因为ip的是问题.在网上查了一下: ...
java微信模板消息发送功能。activeMq监听消息，返回模板并发送
微信接口文档地址:模板消息 | 微信开放文档发送模板消息接口: http请求方式: POST https://api.weixin.qq.com/cgi-bin/message/template/s ...

ActiveMQ 命令行启动与嵌入式启动、MessageListener 监听消息

命令行启动

嵌入式启动

MessageListener 监听消息

ActiveMQ 命令行启动与嵌入式启动、MessageListener 监听消息相关推荐

最新文章

热门文章

ActiveMQ 命令行启动 与 嵌入式启动、MessageListener 监听消息

命令行启动

嵌入式启动

MessageListener 监听消息

ActiveMQ 命令行启动 与 嵌入式启动、MessageListener 监听消息相关推荐

最新文章

热门文章

ActiveMQ 命令行启动与嵌入式启动、MessageListener 监听消息

ActiveMQ 命令行启动与嵌入式启动、MessageListener 监听消息相关推荐