ActiveMQ配置

1.连接BrokerURI

failover://(tcp://localhost:61613,tcp://localhost:61612)

2.Master-slave配置

ActiveMQ的主备有三种方式:纯Master/Slave、文件共享方式、数据库共享方式。

3.Load Balance

#activemq.xml

<networkConnectors>
            <networkConnector uri="static:(tcp://localhost:61616)" duplex="true"/>
</networkConnectors>

静态路由支持failover,如:static:failover://(tcp://host1:61616,tcp://host2:61616)

4.Message Persistence

在broker中设置属性persistent=”true”(默认是true),同时发送的消息也应该是persitent类型的。ActiveMQ消息持久化有三种方式:AMQ、KahaDB、JDBC。

目前使用的是KahaDB方式(AMQ默认)。

Broker默认是持久化的,要做到消息的持久化只需在发送的时候标记为持久化即可,以目前使用的stomp协议为例,只需添加”persistent”=>”true”(PHP语法)到头信息中即可。

5.Authentication And Authorization

#activemq.xml

<plugins>
<simpleAuthenticationPlugin>
<users>
<authenticationUser username="${activemq.username}" password="${activemq.password}" groups="admins"/>
<authenticationUser username="${test.username}" password="${test.password}" groups="test"/>
</users>
</simpleAuthenticationPlugin>
<authorizationPlugin>
<map>
<authorizationMap>
<authorizationEntries>
<authorizationEntry queue=">" read="admins" write="admins" admin="admins"/>
<authorizationEntry queue="TEST.>" read="test,admins" write="test" admin="test"/>
<authorizationEntry topic="ActiveMQ.Advisory.>" read="test,admins" write="test,admins" admin="test,admins"/>
</authorizationEntries>
</authorizationMap>
</map>
</authorizationPlugin>
</plugins>

#credentials.properties

activemq.username=system

activemq.password=manager

guest.password=password

test.username=test

test.password=pwd

PS:有关activemq.xml的配置都是作为broker元素的子元素的~

时间: 2024-07-31 02:20:30

ActiveMQ配置的相关文章

Spring集成ActiveMQ配置 --转

转自:http://suhuanzheng7784877.iteye.com/blog/969865 集成环境 Spring采用2.5.6版本,ActiveMQ使用的是5.4.2,从apache站点可以下载.本文是将Spring集成ActiveMQ来发送和接收JMS消息. 集成步骤 将下载的ActiveMQ解压缩后文件夹如下 activemq-all-5.4.2.jar是activemq的所有的类jar包.lib下面是模块分解后的jar包.将lib下面的 Java代码 /lib/activati

ActiveMQ 配置jdbc主从

使用 jdbc 方式配置主从模式,持久化消息存放在数据库中. 在同一时刻,只有一个 master broker,master 接受客户端的连接,slave 不接受连接.当 master 因为关机而下线后,其中一个 slave 会提升为 master,然后接受客户端连接.但原来 master 的非持久消息丢失了,而持久消息保存在数据库中. broker xml 配置:使用 MySQL 数据源 <!-- Licensed to the Apache Software Foundation (ASF)

ActiveMQ配置策略

1.消息发送 1.异步发送 消息生产者使用持久(persistent)传递模式发送消息的时候,Producer.send() 方法会被阻塞,直到 broker 发送一个确认消息给生产者,这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中.这个过程通常称为同步发送.但有一个例外,当发送方法在一个事物上下文中时,被阻塞的是 commit 方法而不是 send 方法.commit 方法成功返回意味着所有的持久消息都以被写到二级存储中. 同步发送持久消息能

记录activemq 配置mysql 持久化入得坑

首先重点说明一下,百度找解决问题方法的时候一定要好好先看看,结合自己的问题一点点的改正,切忌全盘接受,然后一定要备份自己的代码,做到可以及时撤销更改 首先第一个坑我是避开了,习惯于用最新版本,所有我用的activemq是515,jdk是1.8,避免了版本冲突问题, 若activemq用的是10以上则必须用jdk1.8,. 第二个问题,完美入坑,重点记录,以下是database配置 <persistenceAdapter> <jdbcPersistenceAdapter dataSourc

(转)关于ActiveMQ的配置

目前常用的消息队列组建无非就是MSMQ和ActiveMQ,至于他们的异同,这里不想做过多的比较.简单来说,MSMQ内置于微软操作系统之中,在部署上包含一个隐性条件:Server需要是微软操作系统.(对于这点我并去调研过MSMQ是否可以部署在非微软系统,比如:Linux,只是拍脑袋想了想,感觉上是不可以).对于ActiveMQ,微软系统和Linux都是可以部署的.从功能方面来说,一般最常用的就是:消息的收/发,感觉差异不大.从性能上来说,一般的说法是ActiveMQ略高.在稳定性上,个人感觉MSM

Linux CentOS 下apache activemq的安装与配置

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

ActiveMq+zookeeper+levelDB集群整合配置

ActiveMq+zookeeper+levelDB集群整合配置 环境:linux系统,jdk1.7  三台linux系统电脑.我这里使用一台window,分别远程3台linux电脑.三台电脑的ip分别为10.0.88.10 ,10.0.88.11 ,10.0.88.12 第一步:下载activemq 和zookeeper,levelDB会activemq自带有,所以不需要下载,把下载好的压缩包发送到所有的linux上,(我这里是把下载好的压缩包放在当前window下的tomcat,root目录

Spring整合ActiveMQ及多个Queue消息监听的配置

消息队列(MQ)越来越火,在java开发的项目也属于比较常见的技术,MQ的相关使用也成java开发人员必备的技能.笔者公司采用的MQ是ActiveMQ,且消息都是用的点对点的模式.本文记录了实现Spring整合ActivateMQ的全过程及如何使用MQ,便于后续查阅. 一.项目的搭建 采用maven构建项目,免去了copy jar包的麻烦.因此,我们创建了一个java类型的Maven Project (1)项目结构图 先把项目结构图看一下,便于对项目的理解. (2)pom.xml 我们需要加入以

在Spring下集成ActiveMQ

1.参考文献 Spring集成ActiveMQ配置 Spring JMS异步发收消息 ActiveMQ 2.环境 在前面的一篇ActiveMQ入门实例中我们实现了消息的异步传送,这篇博文将如何在spring环境下集成ActiveMQ.如果要在spring下集成ActiveMQ,那么就需要将如下jar包导入项目: 本文有两篇参考文献,因此有两个实例,项目结构如下图所示: 3.实例1 信息发送者:HelloSender.java package edu.sjtu.erplab.springactiv