国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

ActiveMQ基于zookeeper的主從（levelDB Master/Slave）搭建

更新時間：2017年08月04日 09:02:43 作者：YSHY

這篇文章主要介紹了ActiveMQ基于zookeeper的主從levelDB Master/Slave搭建，以及Spring-boot下的使用方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下

ActiveMQ 5.9.0新推出的主從實現，基于zookeeper來選舉出一個master，其他節(jié)點自動作為slave實時同步消息。因為有實時同步數據的slave的存在，master不用擔心數據丟失，所以leveldb會優(yōu)先采用內存存儲消息，異步同步到磁盤，所以該方式的activeMQ讀寫性能最好因為選舉機制要超過半數，所以最少需要3臺節(jié)點，才能實現高可用。如果集群是兩臺則master失效后slave會不起作用，所以集群至少三臺。此種方式僅實現主備功能，避免單點故障，沒有負載均衡功能。

1、環(huán)境準備

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，并修改其配置信息

wzh@hd-master:~/zk/zookeeper-3.5.2-alpha/conf$ cp zoo_sample.cfg zoo.cfg

wzh@hd-master:~/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）創(chuàng)建/tmp/zookeeper目錄

在該目錄下創(chuàng)建名為myid的文件，內容為1（這個值隨server而改變）

（4）將server1上的/home/wzh/zk/zookeeper-3.5.2-alpha文件夾復制到server2，server3,然后創(chuàng)建/tmp/zookeeper目錄

在該目錄下創(chuàng)建名為myid的文件，內容為2

（5）啟動zookeeper

[192.168.3.10]

wzh@hd-master:~/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]

wzh@hd-slave1:~/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]

wzh@hd-slave2:~/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節(jié)點的brokerName設置為wzhamq

復制代碼代碼如下:

<broker xmlns="

【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機器

wzh@hd-master:~/amq$ scp -r apache-activemq-5.13.0/ wzh@192.168.3.11:/tmp

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

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

（3）啟動ActiveMQ

wzh@hd-master:~/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')
wzh@hd-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消息發(fā)送

@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管理控制臺創(chuàng)建一個消息隊列

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）目前系統(tǒng)連接的是10，如果此時將10集群Down掉，系統(tǒng)會理解選擇一臺slave作為master提供服務，從而啟動案例主備的效果。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

數據庫基本操作語法歸納總結
本篇文章主要介紹了數據庫的一些常用方法及一些基本操作，需要的朋友可以參考下
2017-04-04
Java實現順序棧的示例代碼
線性表和棧都是我們常用的數據結構，棧可以看成一種特殊狀態(tài)的線性表。線性表分為順序表和鏈表，使用線性表中的順序表來實現棧時這種棧被稱為順序棧。這篇文章總結了如何使用順序表實現棧，需要的可以參考一下
2022-11-11
Maven學習教程之搭建多模塊企業(yè)級項目
本篇文章主要介紹了Maven學習教程之搭建多模塊企業(yè)級項目，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-10-10
深入理解Java中的HashMap的實現機制
這篇文章主要介紹了深入理解Java中的HashMap的實現機制,同時也有助于理解Java中對于哈希函數的相關處理方式,需要的朋友可以參考下
2015-07-07
java.lang.NullPointerException異常問題解決方案
這篇文章主要介紹了java.lang.NullPointerException異常問題解決方案,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下
2021-08-08
Idea中如何查看SpringSecurity各Filter信息
這篇文章主要介紹了Idea中如何查看SpringSecurity各Filter信息，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-01-01
Spring如何自定義加載配置文件(分層次加載)
這篇文章主要介紹了Spring如何自定義加載配置文件(分層次加載)問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-07-07
SpringBoot整合PageHelper實現分頁查詢功能詳解
PageHelper是mybatis框架的一個插件,用于支持在mybatis執(zhí)行分頁操作。本文將通過SpringBoot整合PageHelper實現分頁查詢功能，需要的可以參考一下
2022-03-03
Java中對list map根據map某個key值進行排序的方法
今天小編就為大家分享一篇Java中對list map根據map某個key值進行排序的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2018-07-07
SpringBoot時區(qū)問題解決以及徹底解決時差問題
這篇文章主要給大家介紹了關于SpringBoot時區(qū)問題解決以及徹底解決時差問題的相關資料,spring?boot作為微服務簡易架構,擁有其自身的特點,快速搭建架構,簡單快捷,需要的朋友可以參考下
2023-08-08