启动ActiveMQ的代理(Broker),有多中方式
1、直接运行安装目录的bin\activemq.bat
2、可以通过在应用程序中以编码的方式启动broker,例如:
BrokerService broker =new BrokerService(); broker.setBrokerName("testName");//如果启动多个Broker时,必须为Broker设置一个名称 broker.addConnector("tcp://localhost:61616"); broker.start();
3、可以通过BrokerFactory来创建broker,例如:
BrokerService broker =BrokerFactory.createBroker(new URI("broker:tcp://localhost:61616")); broker.start();
4、测代码
import java.net.URI; import org.apache.activemq.broker.BrokerFactory; import org.apache.activemq.broker.BrokerService; /** * 启动ActiveMQ的代理Broker * * @author XX * @version [版本号, Apr 28, 2013 3:21:20 PM ] * @see [相关类/方法] * @since [产品/模块版本] */ public class RunningBroker { public static void main(String[] args){ try { codeByRunning() ; //启动Broker } catch (Exception e) { e.printStackTrace(); } } /** * 应用程序中以编码的方式启动 * 创 建 人: XX * 创建时间: May 23, 2013 3:26:22 PM * @throws Exception * @see [类、类#方法、类#成员] */ public static void codeByRunning() throws Exception{ BrokerService broker =new BrokerService(); broker.setBrokerName("testName");//如果启动多个Broker时,必须为Broker设置一个名称 broker.addConnector("tcp://localhost:61616"); broker.start(); } /** * 以BrokerFactory的方式启动 * 创 建 人: XX * 创建时间: May 23, 2013 3:26:53 PM * @throws Exception * @see [类、类#方法、类#成员] */ public static void factoryByRunning()throws Exception{ BrokerService broker =BrokerFactory.createBroker(new URI("broker:tcp://localhost:61616")); broker.start(); } }
相关推荐
activemqBroker插件:activemqBroker-2.14-SNAPSHOT.war
一: ActiveMQ简介 包括:是什么、能干什么、特点;...包括:监控和管理Broker、集成ActiveMQ和Tomcat、什么时候使用ActiveMQ等 n 十四: ActiveMQ优化 包括:影响ActiveMQ性能的因素、常见的优化方式和配置等
在上面的日志信息中,我们可以看到 ActiveMQ 服务无法正常启动的错误信息是 “Failed to start ActiveMQ JMS Message Broker (localhost, null). Reason: java.io.IOException: Transport Connector could not be ...
activemq-broker-5.9.1.jar,activemq-broker-5.9.1.jar,activemq-broker-5.9.1.jar
activemq/5.9.0/apache-activemq-5.9.0-bin.tar;activemq/5.9.0/apache-activemq-5.9.0-bin.tar
ActiveMQ阿耳s弥斯 该文件描述了一些最低的“需要了解的东西”,以开始在该项目中进行编码。 资源 有关修改代码,构建项目,运行测试,IDE集成等的详细信息,请参见《 。 建立状态 建立状态: 建立ASYNC IO库 ...
spring.activemq.broker-url=failover:(tcp://10.0.1.227:61616,tcp://10.0.1.228:61616,tcp://10.0.1.229:61616,mqtt://10.0.1.227:1883,mqtt://10.0.1.228:1883,mqtt://10.0.1.229:1883) #spring.activemq.broker-...
ActiveMQ 是 Apache 软件基金会提供的一个开源message broker,能够实现点对点(Point-to-Point)和发布/订阅(Publish/Subscribe)模式的消息传递。ActiveMQ 5.13 是 ActiveMQ 的一个稳定版本,本文将指导您如何...
static broker测试同步
官方版本,亲测可用
NULL 博文链接:https://sswh.iteye.com/blog/1974156
activemq_lock:跟kahadb的lock文件类似,确保数据库在某一时刻只有一个broker在访问 Memory 消息存储 他是基于内存的消息存储,就是消息存储在内存中。persistent=”false”,表示不设置持 久化存储,直接存储到...
vertx-activemq-client vertx版本的ActiveMq客户端 配置使用(how to use) 1.创建客户端(create a client) Vertx vertx = Vertx.vertx(); //配置active基础属性 ... .put(ActiveMQClientConfigKey.BROKER_URL
完全支持JMS客户端和Message Broker中的企业集成模式。 支持许多高级功能,如消息组,虚拟目标,通配符和复合目标。 完全支持JMS 1.1和J2EE 1.4,支持瞬态,持久,事务和XA消息。 Spring支持,以便ActiveMQ可以轻松...
官方版本,亲测可用
使用activeMQ时所需jar包:activemq-broker-5.9.0.jar,activemq-client-5.9.0.jar,geronimo-j2ee-management_1.1_spec-1.0.1.jar,geronimo-jms_1.1_spec-1.1.1.jar,slf4j-api-1.7.5.jar
amq-聚类Activemq 代理动态集群,基于 ZooKeeper。
其实activemq-web-console完全可以和activemq-broker分开来部署。 activemq-web-console包含3个apps, 1.一个是admin,用来显示和管理所有的queue、topic、connection等等。 2.一个是demo,有一些使用jms和activemq...
type="org.apache.activemq.command.ActiveMQQueue" description="My Message Queue" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="MyMessageQueue"/> 说明:...
构建高可用的ActiveMQ系统在生产环境中是非常重要的,单点的ActiveMQ作为企业应用无法满足高可用和集群的需求,所以ActiveMQ提供 了master-slave、broker cluster等多种部署方式,但通过分析多种部署方式之后我认为...