rockermq记录表的增删改查+rocket引入+redis锁

fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java

@@ -0,0 +1,2 @@
+package com.fuint.common.config;public class MQConsumerConfiguration {
+}

fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java

@@ -0,0 +1,2 @@
+package com.fuint.common.config;public class MQProducerConfiguration {
+}

fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java

@@ -0,0 +1,2 @@
+package com.fuint.common.config;public class RedissonConfig {
+}

fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java

@@ -0,0 +1,2 @@
+package com.fuint.common.util;public class DistributedLockUtil {
+}

fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java

@@ -0,0 +1,2 @@
+package com.fuint.common.util;public class RedisLock {
+}

fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java

@@ -0,0 +1,29 @@
+package com.ruoyi.rocket.utils;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.client.producer.SendCallback;
+import org.apache.rocketmq.client.producer.SendResult;
+
+/**
+ * rocketmq异步回调监听
+ */
+@Slf4j
+public class SendCallbackListener implements SendCallback {
+
+    private int id;
+
+    public SendCallbackListener(int id) {
+        this.id = id;
+    }
+
+    @Override
+    public void onSuccess(SendResult sendResult) {
+        log.info("CallBackListener on success11111111 : " + JSONObject.toJSONString(sendResult));
+    }
+
+    @Override
+    public void onException(Throwable throwable) {
+        log.error("CallBackListener on exception : ", throwable);
+    }
+}

fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java

@@ -0,0 +1,2 @@
+package com.fuint.common.util;public class RocketUtil {
+}

fuintBackend/fuint-application/src/test/java/aes.java

@@ -0,0 +1,2 @@
+package PACKAGE_NAME;public class aes {
+}