From fb766b5ff9f913561f76aa747c76eae5c3678589 Mon Sep 17 00:00:00 2001
From: qirong <2032486488@qq.com>
Date: 星期五, 08 十二月 2023 14:08:54 +0800
Subject: [PATCH] 三方同步
---
ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/DelayedQueueController.java | 188 +++++++++++++++++++++++-----------------------
1 files changed, 94 insertions(+), 94 deletions(-)
diff --git a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/DelayedQueueController.java b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/DelayedQueueController.java
index edd10ff..34f9a02 100644
--- a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/DelayedQueueController.java
+++ b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/DelayedQueueController.java
@@ -1,94 +1,94 @@
-package org.dromara.demo.controller.queue;
-
-import cn.dev33.satoken.annotation.SaIgnore;
-import org.dromara.common.core.domain.R;
-import org.dromara.common.redis.utils.QueueUtils;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.concurrent.TimeUnit;
-
-/**
- * 寤惰繜闃熷垪 婕旂ず妗堜緥
- * <p>
- * 杞婚噺绾ч槦鍒� 閲嶉噺绾ф暟鎹噺 璇蜂娇鐢� MQ
- * 渚嬪: 鍒涘缓璁㈠崟30鍒嗛挓鍚庤繃鏈熷鐞�
- * <p>
- * 闆嗙兢娴嬭瘯閫氳繃 鍚屼竴涓暟鎹彧浼氳娑堣垂涓�娆� 鍋氬ソ浜嬪姟琛ュ伩
- * 闆嗙兢娴嬭瘯娴佺▼ 涓ゅ彴闆嗙兢鍒嗗埆寮�鍚闃� 鍦ㄥ叾涓竴鍙板彂閫佹暟鎹� 瑙傚療鎺ユ敹娑堟伅鐨勮寰�
- *
- * @author Lion Li
- * @version 3.6.0
- */
-@SaIgnore
-@Slf4j
-@RequiredArgsConstructor
-@RestController
-@RequestMapping("/demo/queue/delayed")
-public class DelayedQueueController {
-
- /**
- * 璁㈤槄闃熷垪
- *
- * @param queueName 闃熷垪鍚�
- */
- @GetMapping("/subscribe")
- public R<Void> subscribe(String queueName) {
- log.info("閫氶亾: {} 鐩戝惉涓�......", queueName);
- // 椤圭洰鍒濆鍖栬缃竴娆″嵆鍙�
- QueueUtils.subscribeBlockingQueue(queueName, (String orderNum) -> {
- // 瑙傚療鎺ユ敹鏃堕棿
- log.info("閫氶亾: {}, 鏀跺埌鏁版嵁: {}", queueName, orderNum);
-
- });
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
- /**
- * 娣诲姞闃熷垪鏁版嵁
- *
- * @param queueName 闃熷垪鍚�
- * @param orderNum 璁㈠崟鍙�
-// * @param time 寤惰繜鏃堕棿(绉�)
- */
- @GetMapping("/add")
- public R<Void> add(@RequestParam("queueName") String queueName, @RequestParam("orderNum")String orderNum) {
- QueueUtils.addDelayedQueueObject(queueName, orderNum, 5, TimeUnit.SECONDS);
- // 瑙傚療鍙戦�佹椂闂�
- log.info("閫氶亾: {} , 鍙戦�佹暟鎹�: {}", queueName, orderNum);
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
- /**
- * 鍒犻櫎闃熷垪鏁版嵁
- *
- * @param queueName 闃熷垪鍚�
- * @param orderNum 璁㈠崟鍙�
- */
- @GetMapping("/remove")
- public R<Void> remove(String queueName, String orderNum) {
- if (QueueUtils.removeDelayedQueueObject(queueName, orderNum)) {
- log.info("閫氶亾: {} , 鍒犻櫎鏁版嵁: {}", queueName, orderNum);
- } else {
- return R.fail("鎿嶄綔澶辫触");
- }
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
- /**
- * 閿�姣侀槦鍒�
- *
- * @param queueName 闃熷垪鍚�
- */
- @GetMapping("/destroy")
- public R<Void> destroy(String queueName) {
- // 鐢ㄥ畬浜嗕竴瀹氳閿�姣� 鍚﹀垯浼氫竴鐩村瓨鍦�
- QueueUtils.destroyDelayedQueue(queueName);
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
-}
+//package org.dromara.demo.controller.queue;
+//
+//import cn.dev33.satoken.annotation.SaIgnore;
+//import org.dromara.common.core.domain.R;
+//import org.dromara.common.redis.utils.QueueUtils;
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.web.bind.annotation.GetMapping;
+//import org.springframework.web.bind.annotation.RequestMapping;
+//import org.springframework.web.bind.annotation.RequestParam;
+//import org.springframework.web.bind.annotation.RestController;
+//
+//import java.util.concurrent.TimeUnit;
+//
+///**
+// * 寤惰繜闃熷垪 婕旂ず妗堜緥
+// * <p>
+// * 杞婚噺绾ч槦鍒� 閲嶉噺绾ф暟鎹噺 璇蜂娇鐢� MQ
+// * 渚嬪: 鍒涘缓璁㈠崟30鍒嗛挓鍚庤繃鏈熷鐞�
+// * <p>
+// * 闆嗙兢娴嬭瘯閫氳繃 鍚屼竴涓暟鎹彧浼氳娑堣垂涓�娆� 鍋氬ソ浜嬪姟琛ュ伩
+// * 闆嗙兢娴嬭瘯娴佺▼ 涓ゅ彴闆嗙兢鍒嗗埆寮�鍚闃� 鍦ㄥ叾涓竴鍙板彂閫佹暟鎹� 瑙傚療鎺ユ敹娑堟伅鐨勮寰�
+// *
+// * @author Lion Li
+// * @version 3.6.0
+// */
+//@SaIgnore
+//@Slf4j
+//@RequiredArgsConstructor
+//@RestController
+//@RequestMapping("/demo/queue/delayed")
+//public class DelayedQueueController {
+//
+// /**
+// * 璁㈤槄闃熷垪
+// *
+// * @param queueName 闃熷垪鍚�
+// */
+// @GetMapping("/subscribe")
+// public R<Void> subscribe(String queueName) {
+// log.info("閫氶亾: {} 鐩戝惉涓�......", queueName);
+// // 椤圭洰鍒濆鍖栬缃竴娆″嵆鍙�
+// QueueUtils.subscribeBlockingQueue(queueName, (String orderNum) -> {
+// // 瑙傚療鎺ユ敹鏃堕棿
+// log.info("閫氶亾: {}, 鏀跺埌鏁版嵁: {}", queueName, orderNum);
+//
+// });
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+// /**
+// * 娣诲姞闃熷垪鏁版嵁
+// *
+// * @param queueName 闃熷垪鍚�
+// * @param orderNum 璁㈠崟鍙�
+//// * @param time 寤惰繜鏃堕棿(绉�)
+// */
+// @GetMapping("/add")
+// public R<Void> add(@RequestParam("queueName") String queueName, @RequestParam("orderNum")String orderNum) {
+// QueueUtils.addDelayedQueueObject(queueName, orderNum, 5, TimeUnit.SECONDS);
+// // 瑙傚療鍙戦�佹椂闂�
+// log.info("閫氶亾: {} , 鍙戦�佹暟鎹�: {}", queueName, orderNum);
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+// /**
+// * 鍒犻櫎闃熷垪鏁版嵁
+// *
+// * @param queueName 闃熷垪鍚�
+// * @param orderNum 璁㈠崟鍙�
+// */
+// @GetMapping("/remove")
+// public R<Void> remove(String queueName, String orderNum) {
+// if (QueueUtils.removeDelayedQueueObject(queueName, orderNum)) {
+// log.info("閫氶亾: {} , 鍒犻櫎鏁版嵁: {}", queueName, orderNum);
+// } else {
+// return R.fail("鎿嶄綔澶辫触");
+// }
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+// /**
+// * 閿�姣侀槦鍒�
+// *
+// * @param queueName 闃熷垪鍚�
+// */
+// @GetMapping("/destroy")
+// public R<Void> destroy(String queueName) {
+// // 鐢ㄥ畬浜嗕竴瀹氳閿�姣� 鍚﹀垯浼氫竴鐩村瓨鍦�
+// QueueUtils.destroyDelayedQueue(queueName);
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+//}
--
Gitblit v1.8.0