From 8021669f4c3ab68d5d49de50fbecee6690789785 Mon Sep 17 00:00:00 2001 From: wangh <9483> Date: Thu, 14 Dec 2023 13:25:11 +0800 Subject: [PATCH] =?UTF-8?q?rockermq=E8=AE=B0=E5=BD=95=E8=A1=A8=E7=9A=84?= =?UTF-8?q?=E5=A2=9E=E5=88=A0=E6=94=B9=E6=9F=A5+rocket=E5=BC=95=E5=85=A5+r?= =?UTF-8?q?edis=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/RocketmqRecordController.java | 0 .../record/entity/RocketmqRecord.java | 0 .../record/mapper/RocketmqRecordMapper.java | 0 .../mapper/xml/RocketmqRecordMapper.xml | 0 .../record/service/RocketmqRecordService.java | 0 .../impl/RocketmqRecordServiceImpl.java | 0 .../config/MQConsumerConfiguration.java | 2 ++ .../config/MQProducerConfiguration.java | 2 ++ .../fuint/common/config/RedissonConfig.java | 2 ++ .../common/util/DistributedLockUtil.java | 2 ++ .../java/com/fuint/common/util/RedisLock.java | 2 ++ .../util/RocketSendCallbackListener.java | 29 +++++++++++++++++++ .../com/fuint/common/util/RocketUtil.java | 2 ++ .../fuint-application/src/test/java/aes.java | 2 ++ 14 files changed, 43 insertions(+) create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/business/record/controller/RocketmqRecordController.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/business/record/entity/RocketmqRecord.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/RocketmqRecordMapper.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/xml/RocketmqRecordMapper.xml create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/RocketmqRecordService.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/impl/RocketmqRecordServiceImpl.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java create mode 100644 fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java create mode 100644 fuintBackend/fuint-application/src/test/java/aes.java diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/controller/RocketmqRecordController.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/controller/RocketmqRecordController.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/entity/RocketmqRecord.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/entity/RocketmqRecord.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/RocketmqRecordMapper.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/RocketmqRecordMapper.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/xml/RocketmqRecordMapper.xml b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/mapper/xml/RocketmqRecordMapper.xml new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/RocketmqRecordService.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/RocketmqRecordService.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/impl/RocketmqRecordServiceImpl.java b/fuintBackend/fuint-application/src/main/java/com/fuint/business/record/service/impl/RocketmqRecordServiceImpl.java new file mode 100644 index 000000000..e69de29bb diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java new file mode 100644 index 000000000..a0fbf99eb --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQConsumerConfiguration.java @@ -0,0 +1,2 @@ +package com.fuint.common.config;public class MQConsumerConfiguration { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java new file mode 100644 index 000000000..d94e3eaed --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/MQProducerConfiguration.java @@ -0,0 +1,2 @@ +package com.fuint.common.config;public class MQProducerConfiguration { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java new file mode 100644 index 000000000..4b8964338 --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/config/RedissonConfig.java @@ -0,0 +1,2 @@ +package com.fuint.common.config;public class RedissonConfig { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java new file mode 100644 index 000000000..37de0baac --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/DistributedLockUtil.java @@ -0,0 +1,2 @@ +package com.fuint.common.util;public class DistributedLockUtil { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java new file mode 100644 index 000000000..c49e465d9 --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RedisLock.java @@ -0,0 +1,2 @@ +package com.fuint.common.util;public class RedisLock { +} diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketSendCallbackListener.java new file mode 100644 index 000000000..54439479b --- /dev/null +++ b/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); + } +} \ No newline at end of file diff --git a/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java new file mode 100644 index 000000000..880c10233 --- /dev/null +++ b/fuintBackend/fuint-application/src/main/java/com/fuint/common/util/RocketUtil.java @@ -0,0 +1,2 @@ +package com.fuint.common.util;public class RocketUtil { +} diff --git a/fuintBackend/fuint-application/src/test/java/aes.java b/fuintBackend/fuint-application/src/test/java/aes.java new file mode 100644 index 000000000..fadccbf89 --- /dev/null +++ b/fuintBackend/fuint-application/src/test/java/aes.java @@ -0,0 +1,2 @@ +package PACKAGE_NAME;public class aes { +}