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

很抱歉，我之前理解有误，MQTT与RocketMQ并不是一样的东西，它们只是不同的消息传递协议。如果您想要在SpringBoot项目中实现RocketMQ和MQTT的消息发送和接收，需要分别集成RocketMQ和MQTT的客户端。

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

<!-- RocketMQ -->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.8.0</version>
</dependency>

<!-- MQTT -->
<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

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

# RocketMQ
rocketmq.name-server=127.0.0.1:9876

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

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

// RocketMQ
@Autowired
private DefaultMQProducer producer;

public void sendMessage(String topic, String message) throws Exception {
    Message msg = new Message(topic, message.getBytes(StandardCharsets.UTF_8));
    SendResult sendResult = producer.send(msg);
    System.out.printf("%s%n", sendResult);
}

@Autowired
private DefaultMQPushConsumer consumer;

public void receiveMessage(String topic) throws Exception {
    consumer.subscribe(topic, "*");
    consumer.registerMessageListener(new MessageListenerConcurrently() {
        @Override
        public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
            System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        }
    });
    consumer.start();
}

// MQTT
@Autowired
private MqttClient mqttClient;

public void sendMessage(String topic, String message) throws Exception {
    MqttMessage mqttMessage = new MqttMessage(message.getBytes());
    mqttMessage.setQos(2);
    mqttClient.publish(topic, mqttMessage);
}

@MessageEndpoint
public class MqttMessageReceiver {
    @Autowired
    private MyService myService;

    @ServiceActivator(inputChannel = "mqttInputChannel")
    public void receiveMessage(String message) {
        myService.handleMessage(message);
    }
}

以上代码中，sendMessage方法用于发送消息，receiveMessage方法用于接收消息。使用DefaultMQProducer和DefaultMQPushConsumer可以很方便地发送和接收RocketMQ消息，使用MqttClient和MqttMessageReceiver可以很方便地发送和接收MQTT消息。

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