ActiveMQ + MQTT 集群搭建（虚机版本） + Springboot使用配置

在虚拟机环境中搭建ActiveMQ + MQTT集群，并使用Spring Boot进行配置的步骤如下：

1. 安装ActiveMQ

   • 在每台虚拟机上下载并安装ActiveMQ。
   • 确保ActiveMQ的版本支持MQTT协议。

2. 配置ActiveMQ支持MQTT

   • 修改ActiveMQ配置文件activemq.xml，启用MQTT传输：

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

3. 配置ActiveMQ集群

   • 修改ActiveMQ配置文件activemq.xml，启用ZooKeeper Discovery Agent用于集群：

     
     
     
     <broker ...>
       ...
       <discoveryAgent>
         <zookeeper xmlns="http://activemq.apache.org/schema/core">
           <zookeeperHosts>${zookeeper.hosts}</zookeeperHosts>
           <hostName>${zookeeper.hostname}</hostName>
           <port>${zookeeper.port}</port>
           <sessionTimeout>${zookeeper.sessionTimeout}</sessionTimeout>
           <connectionTimeout>${zookeeper.connectionTimeout}</connectionTimeout>
         </zookeeper>
       </discoveryAgent>
       ...
     </broker>

   • 在所有虚拟机上配置ZooKeeper的地址、端口等信息。

4. 配置Spring Boot连接ActiveMQ MQTT集群

   • 在application.properties或application.yml中配置Spring Boot连接信息：

     
     
     
     # MQTT 配置
     spring.mqtt.username=
     spring.mqtt.password=
     spring.mqtt.url=tcp://active-mq-broker1:1883,active-mq-broker2:1883
     spring.mqtt.client.id=spring-mqtt-client
     spring.mqtt.default.topic=spring/mqtt/topic

   • 确保spring.mqtt.url包含了所有ActiveMQ MQTT传输的URL。

5. 编写Spring Boot应用代码

   • 使用Spring Integration MQTT支持发送接收MQTT消息。

以上步骤提供了在虚拟机环境中搭建ActiveMQ + MQTT集群的指南，并展示了如何在Spring Boot应用中配置连接。需要注意的是，这些步骤可能需要根据实际环境进行调整，例如配置ZooKeeper集群的具体地址和端口。