mq-2-多broker配置

最新推荐文章于 2024-08-07 15:10:36 发布

Liberal_夜不黑

最新推荐文章于 2024-08-07 15:10:36 发布

阅读量539

点赞数

分类专栏： mq linux 文章标签： activemq broker

本文链接：https://blog.csdn.net/csdn_ygy/article/details/76222550

版权

linux 同时被 2 个专栏收录

6 篇文章

订阅专栏

3 篇文章

订阅专栏

本文详细介绍了如何配置多个Broker，以实现ActiveMQ的高可用性和扩展性。通过多Broker设置，可以提升消息队列系统的稳定性和处理能力。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

broker配置步骤

    1.cp  conf目录(新broker启动配置目录)
    2.修改activemq.xml
        a.brokerName 互相不能重复
        b.数据存放的文件名称不能重复
        c.所有涉及的transportConnector的端口，都需要不一样
    3.修改jetty.xml中的端口（互不相同）
    4、cp activemq目录
        a.修改程序的id，不能和原来的重复，
        b.修改配置文件路径(conf,env).
        c. 修改env中tcp端口。

1.cp  conf目录
[root@iz2ze38kyanwmst1qj2lojz activemq-5.12]# cp -r conf conf_back  //备份
[root@iz2ze38kyanwmst1qj2lojz activemq-5.12]# cp -r conf conf_2   //新broker目录

2.修改activemq.xml

        a.brokerName 互相不能重复
        <broker xmlns="http://activemq.apache.org/schema/core" brokerName="broker_2" dataDirectory="${activemq.data}">

        b.数据存放的文件名称不能重复（<kahaDB directory = "${activemq.data}/kahadb2"/>）
         <persistenceAdapter>
            <kahaDB directory="${activemq.data}/kahadb_2"/>
        </persistenceAdapter>

        c.所有涉及的transportConnector的端口，都需要不一样
        <transportConnectors>
            <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61716?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
            <transportConnector name="amqp" uri="amqp://0.0.0.0:5772?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
            <transportConnector name="stomp" uri="stomp://0.0.0.0:61713?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
            <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1783?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
            <transportConnector name="ws" uri="ws://0.0.0.0:61714?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
        </transportConnectors>

3.修改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="8171"/>
    </bean>

4、cp activemq
    [root@iz2ze38kyanwmst1qj2lojz bin]# cp -r activemq activemq_back  //备份
    [root@iz2ze38kyanwmst1qj2lojz bin]# cp -r activemq activemq_2   //broker2
    [root@iz2ze38kyanwmst1qj2lojz bin]# cp -r env env_back
    [root@iz2ze38kyanwmst1qj2lojz bin]# cp -r env env_2

        a.修改程序的id，不能和原来的重复.
        # Location of the pidfile
            if [ -z "$ACTIVEMQ_PIDFILE" ]; then
              ACTIVEMQ_PIDFILE="$ACTIVEMQ_DATA/activemq_2.pid"
            fi

        b.修改配置文件路径(conf,env).
        # For backwards compat with old variables we let ACTIVEMQ_CONFIG_DIR set ACTIVEMQ_CONF
                if [ -z "$ACTIVEMQ_CONFIG_DIR" ] ; then
                    ACTIVEMQ_CONF="$ACTIVEMQ_BASE/conf_2"
                else
                    ACTIVEMQ_CONF="$ACTIVEMQ_CONFIG_DIR"
                fi
        # CONFIGURATION
        # For using instances
        if ( basename $0 | grep "activemq-instance-" > /dev/null);then
          INST="`basename $0|sed 's/^activemq-instance-//;s/\.sh$//'`"
          ACTIVEMQ_CONFIGS="/etc/default/activemq-instance-${INST} $HOME/.activemqrc-instance-${INST}"
          echo "INFO: Using alternative activemq configuration files: $ACTIVEMQ_CONFIGS"
        else
          ACTIVEMQ_CONFIGS="/etc/default/activemq $HOME/.activemqrc $ACTIVEMQ_HOME/bin/env_2"
        fi

        c. 修改env中tcp端口。
        # Specify the queue manager URL for using "browse" option of sysv initscript
        if [ -z "$ACTIVEMQ_QUEUEMANAGERURL" ]; then
            ACTIVEMQ_QUEUEMANAGERURL="--amqurl tcp://localhost:61716"
        fi