RocketMQ-JAVA客户端不同版本接入方式

@RestControllerpublicclassDemoController {
@AutowiredprivateRocketMQTemplaterocketMQTemplate;
@GetMapping("/testDelay")
publicvoidtest() {
Message<String>msg=MessageBuilder.withPayload("Hello,RocketMQ").build();
// 发送延迟消息，注意topic要先创建好SendResultsendResult=rocketMQTemplate.syncSendDeliverTimeMills("topic1", msg, System.currentTimeMillis() +100000);
System.out.println(JSON.toJSONString(sendResult));
    }
@GetMapping("/testSend")
publicvoidtestSend() {
Message<String>msg=MessageBuilder.withPayload("Hello,RocketMQ").build();
// 发送普通消息，注意topic要先创建好   SendResultsendResult=rocketMQTemplate.send("simple-topic", msg);
System.out.println(JSON.toJSONString(sendResult));
    }
}

@Component// 需要注意注解中的消费方式consumeMode（并发、顺序）、消费类型messageModel（集群、广播），需要与控制台设置的保持一致，同时注意topic和group需提前创建好@RocketMQMessageListener(topic="simple-topic", selectorExpression="*", consumerGroup="simple-group",
messageModel=MessageModel.CLUSTERING, consumeMode=ConsumeMode.CONCURRENTLY)
publicclassSimpleConsumerimplementsRocketMQListener<MessageExt> {
@OverridepublicvoidonMessage(MessageExtmessage) {
log.info("simple msg:{}, body:{}", message.getMsgId(), message.getBody());
    }
}