ActiveMQ 基于zookeeper的主从（levelDB Master/Slave）搭建以及Spring-boot下使用

0：说明

　　ActiveMQ 5.9.0新推出的主从实现，基于zookeeper来选举出一个master，其他节点自动作为slave实时同步消息。因为有实时同步数据的slave的存在，master不用担心数据丢失，所以leveldb会优先采用内存存储消息，异步同步到磁盘，所以该方式的activeMQ读写性能最好因为选举机制要超过半数，所以最少需要3台节点，才能实现高可用。如果集群是两台则master失效后slave会不起作用，所以集群至少三台。此种方式仅实现主备功能，避免单点故障，没有负载均衡功能。

1：环境准备

IP
192.168.3.10    server1
192.168.3.11    server2
192.168.3.12　server3

安装软件信息：

apache-activemq-5.13.0-bin.tar.gz

zookeeper-3.5.2-alpha.tar.gz

ZooInspector.zip

2：搭建Zookeeper集群

（1）将zookeeper-3.5.2-alpha.tar.gz文件解压到/home/wzh/zk目录；

（2）将zoo_sample.cfg复制一份为 zoo.cfg，并修改其配置信息

[email protected]:~/zk/zookeeper-3.5.2-alpha/conf$ cp zoo_sample.cfg zoo.cfg

[email protected]:~/zk/zookeeper-3.5.2-alpha/conf$vim zoo.cfg

tickTime=2000

initLimit=10

syncLimit=5

dataDir=/tmp/zookeeper

clientPort=2181

server.1=192.168.3.10:2888:3888

server.2=192.168.3.11:2888:3888

server.3=192.168.3.11:2888:3888

（3）创建/tmp/zookeeper目录

在该目录下创建名为myid的文件，内容为1（这个值随server而改变）

（4）将server1上的/home/wzh/zk/zookeeper-3.5.2-alpha文件夹复制到server2，server3,然后创建/tmp/zookeeper目录

在该目录下创建名为myid的文件，内容为2

（5）启动zookeeper

[192.168.3.10]

[email protected]:~/zk/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh start

ZooKeeper JMX enabled by default

Using config: /home/wzh/zk/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

[192.168.3.11]

[email protected]:~/zk/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh start

ZooKeeper JMX enabled by default

Using config: /home/wzh/zk/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

[192.168.3.12]

[email protected]:~/zk/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh start

ZooKeeper JMX enabled by default

Using config: /home/wzh/zk/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

3：搭建ActiveMQ集群

（1）将apache-activemq-5.13.0-bin.tar.gz解压到/home/wzh/amq

（2）修改activemq.xml配置文件

【1】将broker节点的brokerName设置为wzhamq

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="wzhamq" dataDirectory="${activemq.data}">

【2】将persistenceAdapter的持久化方式选用replicatedLevelDB，将kahaDB方式注释掉

 <persistenceAdapter>
         <!--
            <kahaDB directory="${activemq.data}/kahadb"/>
         -->
        <replicatedLevelDB
                directory="${activemq.data}/leveldb"
                replicas="3"
                bind="tcp://0.0.0.0:0"
                zkAddress="192.168.3.10:2181,192.168.3.11:2181"
                hostname="192.168.3.10"
                sync="local_disk"
                zkPath="/activemq/leveldb-stores"/>
        </persistenceAdapter>

将apache-activemq-5.13.复制到11，12机器

[email protected]:~/amq$ scp -r apache-activemq-5.13.0/ [email protected]:/tmp

修改配置文件中的hostname="192.168.3.11"

修改配置文件中的hostname="192.168.3.12"

（3）启动ActiveMQ

[email protected]:~/amq$ ./apache-activemq-5.13.0/bin/activemq status
INFO: Loading ‘/home/wzh/amq/apache-activemq-5.13.0//bin/env‘
INFO: Using java ‘/opt/java/jdk1.8.0_91/bin/java‘
ActiveMQ is running (pid ‘2031‘)
[email protected]-master:~/amq$

依次启动192.168.3.11，192.168.3.12机器

4：集群管理

（1）通过使用ZooInspector工具查看zookeeper集群情况

（2）http://192.168.3.10:8161/admin/ 默认用户名与口令为admin登录ActiveMQ管理端

5：通过Spring-boot操作ActiveMQ JMS

（1）通过gradle构建Spring-boot应用，在 gradle文件中增加

dependencies {
    compile(‘org.springframework.boot:spring-boot-starter-activemq‘)
    compile(‘org.springframework.boot:spring-boot-starter-web‘)
    testCompile(‘org.springframework.boot:spring-boot-starter-test‘)
}

（2）application中增加以下配置

spring.activemq.broker-url=failover:(tcp://192.168.3.10:61616,tcp://192.168.3.11:61616,tcp://192.168.3.12:61616)
spring.activemq.in-memory=true
spring.activemq.pool.enabled=false
spring.activemq.user=admin
spring.activemq.password=admin

（3）JMS消息发送

@Service
public class Producer {

    @Autowired
    private JmsMessagingTemplate jmsTemplate;

    public void sendMessage(Destination destination, final String message){
        jmsTemplate.convertAndSend(destination, message);
    }
}

（4）JMS消息接收

@Component
public class Consumer {
    @JmsListener(destination = "test.queue")
    public void receiveQueue(String text){

        System.out.println("Consumer收到的报文为:"+text);
    }
}

（5）测试

@RestController
@RequestMapping(
        value = "/test",
        headers = "Accept=application/json",
        produces = "application/json;charset=utf-8"
)
public class TestCtrl {
    @Autowired
    Producer producer;

    Destination destination = new ActiveMQQueue("test.queue");

    @RequestMapping(
            value = "/say/{msg}/to/{name}",
            method = RequestMethod.GET
    )
    public Map<String, Object> say(@PathVariable String msg, @PathVariable String name){
        Map<String, Object> map = new HashMap<>();
        map.put("msg", msg);
        map.put("name", name);

        producer.sendMessage(destination, msg);

        return map;
    }
}

（6）进入ActiveMQ管理控制台创建一个消息队列

test.queue

（7）通过POSTMAN进行测试

2017-08-03 08:10:44.928 INFO 12820 --- [ActiveMQ Task-3] o.a.a.t.failover.FailoverTransport : Successfully reconnected to tcp://192.168.3.10:61616
2017-08-03 08:11:08.854 INFO 12820 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport : Successfully connected to tcp://192.168.3.10:61616
Consumer收到的报文为:hello
2017-08-03 08:43:39.464 INFO 12820 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport : Successfully connected to tcp://192.168.3.10:61616
Consumer收到的报文为:hello

（8）目前系统连接的是10，如果此时将10集群Down掉，系统会理解选择一台slave作为master提供服务，从而启动案例主备的效果。

				


				
时间： 2024-10-09 10:48:25 

		


		


	

	
	

		


		
ActiveMQ 基于zookeeper的主从（levelDB Master/Slave）搭建以及Spring-boot下使用的相关文章


								

		

			

                MySQL5.6 数据库主从（Master/Slave）同步安装与配置详解
			

		

		

									

				安装环境 操作系统 :CentOS 6.5 数据库版本:MySQL 5.6.27 主机A:192.168.1.1 (Master) 主机B:192.168.1.2 (Slave) 这里强调的数据库的版本,是因为MySQL在5.6之前和之后的安装方式是不一样的. 本人在进行配置的时候,也遇到了这个坑,这里提前说明,希望大家不要采坑. 注:这里有一篇CentOS安装MySQL的文章,在这里引出,过程亲测,希望对大家有帮助:http://blog.csdn.net/xlgen157387/articl			

		

	

				

		

			

                适合初学者的一个分布式环境搭建过程(spring boot + zookeeper + dubbo + mybatis + mysql)
			

		

		

									

				本人也是才开始接触 阿里巴巴的开源分布式框架 dubbo,因为现在微服务框架 spring boot也非常的火,然后结合dubbo的官网搭建这个开发环境. 一.首先 zookeeper作为集群管理服务器,安装和配置在这里就不说了 划分为 4个项目 项目目录如下: 4个项目的依赖关系是:common里面暂时存放的只有user一个实体类,后面陆续会加上其他的公共类,分页,验证等,这个项目不依赖其他的项目,其他3个项目都需要依赖它,所有这个项目需要先打包(相信做个maven项目的人应该都会-----如			

		

	

				

		

			

                ActiveMQ基于文件共享的主从配置方案
			

		

		

									

				假设两台装有activeMq服务的服务器分别为: <span style="white-space:pre"> </span>192.160.102.90 192.168.102.91 并打算将91上activeMq目录的数据存储目录共享给90的activeMq服务. 91上配置: 1.安装NFS服务和rpcbind服务,服务器上一般都安装了这两个服务,可以使用命令"service nfs status"和"service rpcb			

		

	

				

		

			

                mongodb 在认证（auth）的情况下，配置主从（master &amp; slave）
			

		

		

									

				master配置 本机 :192.168.100.23:27017 /etc/mongodb/mongo.conf port = 27017  dbpath = /data/mongodb_t  logpath = /var/log/mongodb_t.log  logappend = true  journal = true  fork = true 1. 以上配置单机打开mongo,对admin数据库进行设置 据资料, 必须建立全局用户root,个人感觉是超级管理员: 必须对local数据库			

		

	

				

		

			

                mysql master slave搭建
			

		

		

									

				1. 2.配置master 修改/etc/my.cnf增加 [mysqld] log-bin = master-bin log-bin-index = master-bin.index server-id = 1 3.master创建一个复制用户 CREATE USER repl_user; GRANT REPLICATION SLAVE ON *.* TO repl_user IDENTIFIED BY '123456'; 重启master 4.配置slave 修改/etc/my.cnf增加			

		

	

				

		

			

                通过dubbo暴露接口调用方法，及基于zookeeper的dubbo涉及配置文件【转】
			

		

		

									

				现在很流行的Dubbo很多朋友都听说过吧,最近我也在看这方面的东西,分享先我的心得笔记. 先说说我们团队要做的项目框架,很简单重在实现基于zookeeper的dubbo注册. 框架:springmvc+spring+zookeeper+dubbo 项目分三层,model存放数据,view页面展示.controller下面具体逻辑实现.通过dubbo消费方和供应方注册,供应方给消费方暴露接口,供消费方调用. 工程部署需要配置文件有: applicationContext-dubbo.xml {--			

		

	

				

		

			

                基于levelDB可复制master/slave（zookeeper+levelDB）
			

		

		

									

				Leveldb是一个google实现的非常高效的kv数据库,是单进程的服务,能够处理十亿级别规模Key-Value型数据,占用内存小. 基于可复制LevelDB的集群方案,需要引入ZooKeeper.根据ZooKeeper的使用方式可以分为单节点的ZooKeeper和Zookeeper集群.这里我们只讲述ZooKeeper集群,单节点不是一个可靠的选择. 4.1 Zookeeper集群配置 ZooKeeper可以在网站http://zookeeper.apache.org/ 下载.我们使用的是z			

		

	

				

		

			

                基于zookeeper+leveldb搭建activemq集群--转载
			

		

		

									

				原地址:http://www.open-open.com/lib/view/open1410569018211.html 自从activemq5.9.0开始,activemq的集群实现方式取消了传统的 Master-Slave方式,增加了基于zookeeper+leveldb的实现方式,其他两种方式:目录共享和数据库共享依然存在.本文主要阐述基 于zookeeper和leveldb搭建activemq集群,这里需要特别提醒,本文实现的集群仅提供主备功能,避免单点故障,没有负载均衡功能. 下面开始			

		

	

				

		

			

                基于zookeeper+leveldb搭建activemq集群
			

		

		

									

				自从activemq5.9.0开始,activemq的集群实现方式取消了传统的Master-Slave方式,增加了基于zookeeper+leveldb的实现方式,其他两种方式:目录共享和数据库共享依然存在.本文主要阐述基于zookeeper和leveldb搭建activemq集群,这里需要特别提醒,本文实现的集群仅提供主备功能,避免单点故障,没有负载均衡功能. 下面开始我们的征途. 一.搭建zookeeper集群 关于搭建zookeeper集群的文章请参考:zookeeper的集群模式下的安装