datasource 一台机器启动多个activeMQ activeMQ主从和集群搭建

一台机器启动多个activeMQ

1、brokerName修改

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

2、修改activemq.xml文件

??<transportConnectors>

<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->

<transportConnector??

uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector

uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector

uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector

uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector

uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

所有涉及transportConnectors的端口，都要不一样??

3、jetty.xml文件

??<bean init-method="start">

?? ?? ?? ?? ??<!-- the default port number for the web console -->

?? ?? ?? ?? <property value="0.0.0.0"/>

?? ?? ?? ?? <property value="8161"/>

</bean>

Mq主从和集群搭建

主从配置：

1、修改activemq.xml的brokerName（唯一）

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

2、添加bean配置

<bean destroy-method="close"> ????

<property value="com.mysql.jdbc.Driver"/> ????

<property value="jdbc:mysql://localhost:3306/mq?relaxAutoCommit=true"/> ????

本文来自电脑杂谈，转载请注明本文网址：
https://www.pc-fly.com/a/jisuanjixue/article-66736-1.html