springboot异步发送rocketmq,如何接收

如果你想要在 Spring Boot 应用中异步发送 RocketMQ 消息，你可以使用 RocketMQ 的异步发送方式。具体来说，你可以通过使用 `org.apache.rocketmq.client.producer.SendCallback` 接口中的 `onSuccess` 和 `onException` 方法异步发送消息，并在消息发送成功或发送失败时接收返回结果。

下面是一个简单的示例代码，演示了如何在 Spring Boot 应用中异步发送 RocketMQ 消息并接收返回结果：

@Component
public class RocketMQProducer {

    @Autowired
    private DefaultMQProducer producer;

    public void sendAsyncMessage(String topic, String message) throws Exception {
        Message msg = new Message(topic, message.getBytes(Charset.forName("UTF-8")));

        producer.send(msg, new SendCallback() {
            @Override
            public void onSuccess(SendResult sendResult) {
                System.out.printf("Message send success, result=%s%n", sendResult);
            }

            @Override
            public void onException(Throwable e) {
                System.out.printf("Message send failed, error=%s%n", e.getMessage());
            }
        });
    }
}

在上面的代码中，我们通过 `DefaultMQProducer` 发送了一条 RocketMQ 消息，并通过 `SendCallback` 接口中的 `onSuccess` 和 `onException` 方法异步接收返回结果。你可以在 `onSuccess` 方法中处理消息发送成功的逻辑，在 `onException` 方法中处理消息发送失败的逻辑。

在你需要接收 RocketMQ 消息的地方，你可以使用 RocketMQ 提供的消费者客户端接收消息。你可以使用 `org.apache.rocketmq.client.consumer.DefaultMQPushConsumer` 类来创建一个消费者实例，并通过 `registerMessageListener` 方法注册一个消息监听器来接收消息。

下面是一个简单的示例代码，演示了如何在 Spring Boot 应用中接收 RocketMQ 消息：

@Component
public class RocketMQConsumer {

    @Autowired
    private RocketMQProperties rocketMQProperties;

    @PostConstruct
    public void init() throws Exception {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(rocketMQProperties.getConsumerGroup());
        consumer.setNamesrvAddr(rocketMQProperties.getNameServer());

        consumer.subscribe(rocketMQProperties.getTopic(), "*");

        consumer.registerMessageListener(new MessageListenerConcurrently() {
            @Override
            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                for (MessageExt msg : msgs) {
                    System.out.printf("Received message: %s%n", new String(msg.getBody()));
                }

                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });

        consumer.start();
    }
}

在上面的代码中，我们通过 `DefaultMQPushConsumer` 创建了一个 RocketMQ 消费者实例，并通过 `subscribe` 方法订阅了一个主题。我们还注册了一个消息监听器，在消息到达时可以通过 `consumeMessage` 方法接收消息。在 `consumeMessage` 方法中，你可以处理接收到的消息，并返回一个 `ConsumeConcurrentlyStatus` 类型的状态码来告诉 RocketMQ 消费者是否成功消费了该消息。

希望这个简单的示例代码能够帮助你在 Spring Boot 应用中异步发送和接收 RocketMQ 消息。