绘画逻辑新增

framework-starter/mrxu-starter-rocketmq/src/main/java/com/mrxu/framework/starter/rocketmq/RocketMQSender.java

@@ -1,6 +1,9 @@
 package com.mrxu.framework.starter.rocketmq;
 
 import com.mrxu.framework.starter.rocketmq.bean.MessageBody;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.client.producer.SendCallback;
+import org.apache.rocketmq.client.producer.SendResult;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -10,6 +13,7 @@ import org.springframework.stereotype.Service;
  * 功能概要：[] <br>
  * @date 2021/11/17
  */
+@Slf4j
 @Service
 public class RocketMQSender {
 
@@ -41,6 +45,24 @@ public class RocketMQSender {
         rocketMQTemplate.syncSend(topic+":"+body.getTag(),body,messageTimeOut);
     }
 
+    /**
+     * 发送消息（异步）
+     */
+    public void sendMsgAsync(String topic,String tag,Object body){
+        rocketMQTemplate.asyncSend(topic+":"+tag,body,new SendCallback(){
+            @Override
+            public void onSuccess(SendResult sendResult) {
+                log.debug("发送消息成功");
+            }
+
+            @Override
+            public void onException(Throwable throwable) {
+                log.warn("发送消息失败");
+            }
+        },messageTimeOut);
+    }
+
+
 /*    *//**
      * 发送普通消息
      * @param destination 发送队列