文档章节

windows搭建ActiveMQ伪集群

聆风阁主
 聆风阁主
发布于 03/26 22:38
字数 820
阅读 4
收藏 0

注:本次搭建 ActiveMQ 伪集群依赖 zookeeper 集群,请先搭建好 zookeeper 集群

一、规划 ActiveMQ 伪集群端口

主机IP:127.0.0.1

控制台端口:8161;8162;8163

集群通信端口:5151;5152;5153

消息端口:6161;6162;6163

zookeeper消息端口:2181;2182;2183

二、解压 apache-activemq-5.15.5-bin.zip 到指定目录

三、分别修改 conf 目录下的 jetty.xml 配置文件

D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8161-5151-6161\conf\jetty.xml

...省略代码...
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
    <!-- the default port number for the web console -->
    <property name="host" value="0.0.0.0"/>
    <property name="port" value="8161"/>
</bean>
...省略代码...

D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8162-5152-6162\conf\jetty.xml

...省略代码...
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
    <!-- the default port number for the web console -->
    <property name="host" value="0.0.0.0"/>
    <property name="port" value="8162"/>
</bean>
...省略代码...

D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8163-5153-6163\conf\jetty.xml

...省略代码...
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
    <!-- the default port number for the web console -->
    <property name="host" value="0.0.0.0"/>
    <property name="port" value="8163"/>
</bean>
...省略代码...

四、分别修改 conf 目录下的 activemq.xml 配置文件

D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8161-5151-6161\conf\activemq.xml

...省略代码...
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="activemq-cluster" dataDirectory="${activemq.data}">
...省略代码...
<persistenceAdapter>
    <!--<kahaDB directory="${activemq.data}/kahadb"/>-->
    <replicatedLevelDB
        directory="${activemq.data}/leveldb"
        replicas="3"
        bind="tcp://0.0.0.0:5151"
        zkAddress="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"
        hostname="127.0.0.1"
        zkPath="/activemq/leveldb-stores"/>
</persistenceAdapter>
...省略代码...
<transportConnectors>
    <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    <transportConnector name="openwire" uri="tcp://0.0.0.0:6161?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
...省略代码...
</broker>
...省略代码...

D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8162-5152-6162\conf\activemq.xml

...省略代码...
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="activemq-cluster" dataDirectory="${activemq.data}">
...省略代码...
<persistenceAdapter>
    <!--<kahaDB directory="${activemq.data}/kahadb"/>-->
    <replicatedLevelDB
        directory="${activemq.data}/leveldb"
        replicas="3"
        bind="tcp://0.0.0.0:5152"
        zkAddress="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"
        hostname="127.0.0.1"
        zkPath="/activemq/leveldb-stores"/>
</persistenceAdapter>
...省略代码...
<transportConnectors>
    <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    <transportConnector name="openwire" uri="tcp://0.0.0.0:6162?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
...省略代码...
</broker>
...省略代码...

D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8163-5153-6163\conf\activemq.xml

...省略代码...
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="activemq-cluster" dataDirectory="${activemq.data}">
...省略代码...
<persistenceAdapter>
    <!--<kahaDB directory="${activemq.data}/kahadb"/>-->
    <replicatedLevelDB
        directory="${activemq.data}/leveldb"
        replicas="3"
        bind="tcp://0.0.0.0:5153"
        zkAddress="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"
        hostname="127.0.0.1"
        zkPath="/activemq/leveldb-stores"/>
</persistenceAdapter>
...省略代码...
<transportConnectors>
    <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    <transportConnector name="openwire" uri="tcp://0.0.0.0:6163?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
...省略代码...
</broker>
...省略代码...

五、启动脚本

activemq1.bat

title apache-activemq-5.15.5-8161-5151-6161
D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8161-5151-6161\bin\activemq start

activemq2.bat

title apache-activemq-5.15.5-8162-5152-6162
D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8162-5152-6162\bin\activemq start

activemq3.bat

title apache-activemq-5.15.5-8163-5153-6163
D:\clustering-space\apache-activemq-5.15.5\apache-activemq-5.15.5-8163-5153-6163\bin\activemq start

activemq-cluster.bat

@echo off
    color 0A

@echo on
    start activemq1.bat
    start activemq2.bat
    start activemq3.bat

@echo off
    echo.
    pause

@echo on

© 著作权归作者所有

聆风阁主
粉丝 0
博文 19
码字总数 16521
作品 0
福州
私信 提问
Linux环境下Apache ActiveMQ 基本安装

在linux上安装mq,并映射到外网。 1.Apache ActiveMQ安装基本条件请参考链接: 2.下载Apache ActiveMQ 3.解压安装 将下载好的apache-activemq-5.13.3-bin.tar解压至安装目录 命令:tar -zxvf...

zhuyuansj
2018/04/02
0
0
ActiveMQ+ZooKeeper 伪集群整合

原理简介: 一般在部署ActiveMQ集群的时候,更倾向于使用基于ZooKeeper的Replicated LevelDB Store方式,该方式是Master Slave部署方案的其中一种策略,也是在多台主机实现ActiveMQ集群的主流...

watermelon11
02/18
22
0
基于zookeeper+leveldb搭建activemq集群实现高可用

自从activemq5.9.0开始,activemq的集群实现方式取消了传统的Master-Slave方式,增加了基于zookeeper+leveldb的实现方式,其他两种方式:目录共享和数据库共享依然存在。本文主要阐述基于zoo...

chaun
2015/08/17
322
2
基于zookeeper+leveldb搭建activemq集群

自从activemq5.9.0开始,activemq的集群实现方式取消了传统的Master-Slave方式,增加了基于zookeeper+leveldb的实现方式,其他两种方式:目录共享和数据库共享依然存在。本文主要阐述基于zoo...

萧十一郎君
2014/09/12
15.4K
7
springboot整合kafka应用

1、kafka在消息传递的使用非常普遍,相对于activemq来说kafka的分布式管理和使用更加灵活。 2、activemq的搭建和使用可以参考:   activemq搭建和springmvc的整合:http://www.cnblogs.co...

小不点丶
2017/11/09
0
0

没有更多内容

加载失败,请刷新页面

加载更多

只需一步,在Spring Boot中统一Restful API返回值格式与统一处理异常

统一返回值 在前后端分离大行其道的今天,有一个统一的返回值格式不仅能使我们的接口看起来更漂亮,而且还可以使前端可以统一处理很多东西,避免很多问题的产生。 比较通用的返回值格式如下:...

晓月寒丶
昨天
59
0
区块链应用到供应链上的好处和实际案例

区块链可以解决供应链中的很多问题,例如记录以及追踪产品。那么使用区块链应用到各产品供应链上到底有什么好处?猎头悬赏平台解优人才网小编给大家做个简单的分享: 使用区块链的最突出的优...

猎头悬赏平台
昨天
28
0
全世界到底有多少软件开发人员?

埃文斯数据公司(Evans Data Corporation) 2019 最新的统计数据(原文)显示,2018 年全球共有 2300 万软件开发人员,预计到 2019 年底这个数字将达到 2640万,到 2023 年达到 2770万。 而来自...

红薯
昨天
65
0
Go 语言基础—— 通道(channel)

通过通信来共享内存(Java是通过共享内存来通信的) 定义 func service() string {time.Sleep(time.Millisecond * 50)return "Done"}func AsyncService() chan string {retCh := mak......

刘一草
昨天
58
0
Apache Flink 零基础入门(一):基础概念解析

Apache Flink 的定义、架构及原理 Apache Flink 是一个分布式大数据处理引擎,可对有限数据流和无限数据流进行有状态或无状态的计算,能够部署在各种集群环境,对各种规模大小的数据进行快速...

Vincent-Duan
昨天
60
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部