SpringBoot+ActiveMq+MQTT实现消息的发送和接收

好的，我可以为您简单介绍一下SpringBoot集成ActiveMQ和MQTT实现消息的发送和接收。

首先，您需要在SpringBoot项目中添加ActiveMQ和MQTT的依赖，可以在pom.xml文件中添加如下代码：

<!-- ActiveMQ -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

<!-- MQTT -->
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
    <version>5.5.0</version>
</dependency>

接下来，您需要在application.properties中配置ActiveMQ和MQTT的连接信息，例如：

# ActiveMQ
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

# MQTT
spring.mqtt.username=admin
spring.mqtt.password=admin
spring.mqtt.url=tcp://localhost:1883

然后，您可以通过注入JmsTemplate和MqttPahoMessageHandler来实现消息的发送和接收。例如：

// ActiveMQ
@Autowired
private JmsTemplate jmsTemplate;

public void sendMessage(String destination, String message) {
    jmsTemplate.convertAndSend(destination, message);
}

@JmsListener(destination = "testQueue")
public void receiveMessage(String message) {
    System.out.println("Received message: " + message);
}

// MQTT
@Autowired
private MqttPahoMessageHandler mqttHandler;

public void sendMessage(String topic, String message) {
    mqttHandler.setDefaultTopic(topic);
    mqttHandler.handleMessage(MessageBuilder.withPayload(message).build());
}

@MessageEndpoint
public class MqttMessageReceiver {
    @ServiceActivator(inputChannel = "mqttInputChannel")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

以上代码中，sendMessage方法用于发送消息，receiveMessage方法用于接收消息。使用JmsTemplate可以很方便地发送和接收ActiveMQ消息，使用MqttPahoMessageHandler和MqttMessageReceiver可以很方便地发送和接收MQTT消息。

这就是SpringBoot集成ActiveMQ和MQTT实现消息发送和接收的基本流程，希望对您有所帮助。