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/RedisPubSubController.java | 94 +++++++++++++++++++++++----------------------- 1 files changed, 47 insertions(+), 47 deletions(-) diff --git a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisPubSubController.java b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisPubSubController.java index bdbf033..af6af50 100644 --- a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisPubSubController.java +++ b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisPubSubController.java @@ -1,47 +1,47 @@ -package org.dromara.demo.controller; - -import org.dromara.common.core.domain.R; -import org.dromara.common.redis.utils.RedisUtils; -import lombok.RequiredArgsConstructor; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -/** - * Redis 鍙戝竷璁㈤槄 婕旂ず妗堜緥 - * - * @author Lion Li - */ -@RequiredArgsConstructor -@RestController -@RequestMapping("/demo/redis/pubsub") -public class RedisPubSubController { - - /** - * 鍙戝竷娑堟伅 - * - * @param key 閫氶亾Key - * @param value 鍙戦�佸唴瀹� - */ - @GetMapping("/pub") - public R<Void> pub(String key, String value) { - RedisUtils.publish(key, value, consumer -> { - System.out.println("鍙戝竷閫氶亾 => " + key + ", 鍙戦�佸�� => " + value); - }); - return R.ok("鎿嶄綔鎴愬姛"); - } - - /** - * 璁㈤槄娑堟伅 - * - * @param key 閫氶亾Key - */ - @GetMapping("/sub") - public R<Void> sub(String key) { - RedisUtils.subscribe(key, String.class, msg -> { - System.out.println("璁㈤槄閫氶亾 => " + key + ", 鎺ユ敹鍊� => " + msg); - }); - return R.ok("鎿嶄綔鎴愬姛"); - } - -} +//package org.dromara.demo.controller; +// +//import org.dromara.common.core.domain.R; +//import org.dromara.common.redis.utils.RedisUtils; +//import lombok.RequiredArgsConstructor; +//import org.springframework.web.bind.annotation.GetMapping; +//import org.springframework.web.bind.annotation.RequestMapping; +//import org.springframework.web.bind.annotation.RestController; +// +///** +// * Redis 鍙戝竷璁㈤槄 婕旂ず妗堜緥 +// * +// * @author Lion Li +// */ +//@RequiredArgsConstructor +//@RestController +//@RequestMapping("/demo/redis/pubsub") +//public class RedisPubSubController { +// +// /** +// * 鍙戝竷娑堟伅 +// * +// * @param key 閫氶亾Key +// * @param value 鍙戦�佸唴瀹� +// */ +// @GetMapping("/pub") +// public R<Void> pub(String key, String value) { +// RedisUtils.publish(key, value, consumer -> { +// System.out.println("鍙戝竷閫氶亾 => " + key + ", 鍙戦�佸�� => " + value); +// }); +// return R.ok("鎿嶄綔鎴愬姛"); +// } +// +// /** +// * 璁㈤槄娑堟伅 +// * +// * @param key 閫氶亾Key +// */ +// @GetMapping("/sub") +// public R<Void> sub(String key) { +// RedisUtils.subscribe(key, String.class, msg -> { +// System.out.println("璁㈤槄閫氶亾 => " + key + ", 鎺ユ敹鍊� => " + msg); +// }); +// return R.ok("鎿嶄綔鎴愬姛"); +// } +// +//} -- Gitblit v1.8.0