From ac2873bd37eeb496b0e9dd62d66e9fc4b38ef39b Mon Sep 17 00:00:00 2001
From: qirong <2032486488@qq.com>
Date: 星期五, 22 十二月 2023 13:38:26 +0800
Subject: [PATCH] ftp摆渡
---
ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/PriorityQueueController.java | 178 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 89 insertions(+), 89 deletions(-)
diff --git a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/PriorityQueueController.java b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/PriorityQueueController.java
index 02c7396..fd637ff 100644
--- a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/PriorityQueueController.java
+++ b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/PriorityQueueController.java
@@ -1,89 +1,89 @@
-package org.dromara.demo.controller.queue;
-
-import cn.hutool.core.util.RandomUtil;
-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.RestController;
-
-/**
- * 浼樺厛闃熷垪 婕旂ず妗堜緥
- * <p>
- * 杞婚噺绾ч槦鍒� 閲嶉噺绾ф暟鎹噺 璇蜂娇鐢� MQ
- * <p>
- * 闆嗙兢娴嬭瘯閫氳繃 鍚屼竴涓秷鎭彧浼氳娑堣垂涓�娆� 鍋氬ソ浜嬪姟琛ュ伩
- * 闆嗙兢娴嬭瘯娴佺▼ 鍦ㄥ叾涓竴鍙板彂閫佹暟鎹� 涓ょ鍒嗗埆璋冪敤鑾峰彇鎺ュ彛 涓�娆¤幏鍙栦竴鏉�
- *
- * @author Lion Li
- * @version 3.6.0
- */
-@Slf4j
-@RequiredArgsConstructor
-@RestController
-@RequestMapping("/demo/queue/priority")
-public class PriorityQueueController {
-
- /**
- * 娣诲姞闃熷垪鏁版嵁
- *
- * @param queueName 闃熷垪鍚�
- */
- @GetMapping("/add")
- public R<Void> add(String queueName) {
- // 鐢ㄥ畬浜嗕竴瀹氳閿�姣� 鍚﹀垯浼氫竴鐩村瓨鍦�
- boolean b = QueueUtils.destroyPriorityQueue(queueName);
- log.info("閫氶亾: {} , 鍒犻櫎: {}", queueName, b);
-
- for (int i = 0; i < 10; i++) {
- int randomNum = RandomUtil.randomInt(10);
- PriorityDemo data = new PriorityDemo();
- data.setName("data-" + i);
- data.setOrderNum(randomNum);
- if (QueueUtils.addPriorityQueueObject(queueName, data)) {
- log.info("閫氶亾: {} , 鍙戦�佹暟鎹�: {}", queueName, data);
- } else {
- log.info("閫氶亾: {} , 鍙戦�佹暟鎹�: {}, 鍙戦�佸け璐�", queueName, data);
- }
- }
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
- /**
- * 鍒犻櫎闃熷垪鏁版嵁
- *
- * @param queueName 闃熷垪鍚�
- * @param name 瀵硅薄鍚�
- * @param orderNum 鎺掑簭鍙�
- */
- @GetMapping("/remove")
- public R<Void> remove(String queueName, String name, Integer orderNum) {
- PriorityDemo data = new PriorityDemo();
- data.setName(name);
- data.setOrderNum(orderNum);
- if (QueueUtils.removePriorityQueueObject(queueName, data)) {
- log.info("閫氶亾: {} , 鍒犻櫎鏁版嵁: {}", queueName, data);
- } else {
- return R.fail("鎿嶄綔澶辫触");
- }
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
- /**
- * 鑾峰彇闃熷垪鏁版嵁
- *
- * @param queueName 闃熷垪鍚�
- */
- @GetMapping("/get")
- public R<Void> get(String queueName) {
- PriorityDemo data;
- do {
- data = QueueUtils.getPriorityQueueObject(queueName);
- log.info("閫氶亾: {} , 鑾峰彇鏁版嵁: {}", queueName, data);
- } while (data != null);
- return R.ok("鎿嶄綔鎴愬姛");
- }
-
-}
+//package org.dromara.demo.controller.queue;
+//
+//import cn.hutool.core.util.RandomUtil;
+//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.RestController;
+//
+///**
+// * 浼樺厛闃熷垪 婕旂ず妗堜緥
+// * <p>
+// * 杞婚噺绾ч槦鍒� 閲嶉噺绾ф暟鎹噺 璇蜂娇鐢� MQ
+// * <p>
+// * 闆嗙兢娴嬭瘯閫氳繃 鍚屼竴涓秷鎭彧浼氳娑堣垂涓�娆� 鍋氬ソ浜嬪姟琛ュ伩
+// * 闆嗙兢娴嬭瘯娴佺▼ 鍦ㄥ叾涓竴鍙板彂閫佹暟鎹� 涓ょ鍒嗗埆璋冪敤鑾峰彇鎺ュ彛 涓�娆¤幏鍙栦竴鏉�
+// *
+// * @author Lion Li
+// * @version 3.6.0
+// */
+//@Slf4j
+//@RequiredArgsConstructor
+//@RestController
+//@RequestMapping("/demo/queue/priority")
+//public class PriorityQueueController {
+//
+// /**
+// * 娣诲姞闃熷垪鏁版嵁
+// *
+// * @param queueName 闃熷垪鍚�
+// */
+// @GetMapping("/add")
+// public R<Void> add(String queueName) {
+// // 鐢ㄥ畬浜嗕竴瀹氳閿�姣� 鍚﹀垯浼氫竴鐩村瓨鍦�
+// boolean b = QueueUtils.destroyPriorityQueue(queueName);
+// log.info("閫氶亾: {} , 鍒犻櫎: {}", queueName, b);
+//
+// for (int i = 0; i < 10; i++) {
+// int randomNum = RandomUtil.randomInt(10);
+// PriorityDemo data = new PriorityDemo();
+// data.setName("data-" + i);
+// data.setOrderNum(randomNum);
+// if (QueueUtils.addPriorityQueueObject(queueName, data)) {
+// log.info("閫氶亾: {} , 鍙戦�佹暟鎹�: {}", queueName, data);
+// } else {
+// log.info("閫氶亾: {} , 鍙戦�佹暟鎹�: {}, 鍙戦�佸け璐�", queueName, data);
+// }
+// }
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+// /**
+// * 鍒犻櫎闃熷垪鏁版嵁
+// *
+// * @param queueName 闃熷垪鍚�
+// * @param name 瀵硅薄鍚�
+// * @param orderNum 鎺掑簭鍙�
+// */
+// @GetMapping("/remove")
+// public R<Void> remove(String queueName, String name, Integer orderNum) {
+// PriorityDemo data = new PriorityDemo();
+// data.setName(name);
+// data.setOrderNum(orderNum);
+// if (QueueUtils.removePriorityQueueObject(queueName, data)) {
+// log.info("閫氶亾: {} , 鍒犻櫎鏁版嵁: {}", queueName, data);
+// } else {
+// return R.fail("鎿嶄綔澶辫触");
+// }
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+// /**
+// * 鑾峰彇闃熷垪鏁版嵁
+// *
+// * @param queueName 闃熷垪鍚�
+// */
+// @GetMapping("/get")
+// public R<Void> get(String queueName) {
+// PriorityDemo data;
+// do {
+// data = QueueUtils.getPriorityQueueObject(queueName);
+// log.info("閫氶亾: {} , 鑾峰彇鏁版嵁: {}", queueName, data);
+// } while (data != null);
+// return R.ok("鎿嶄綔鎴愬姛");
+// }
+//
+//}
--
Gitblit v1.8.0