抽取cacheclient到公共依赖模块common中

beacon-api/src/main/java/com/mashibing/api/feignclient/CacheClient.java

@@ -1,5 +1,6 @@
 package com.mashibing.api.feignclient;
 
+import com.mashibing.common.clients.BeaconCacheClient;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.*;
 
@@ -14,30 +15,6 @@ import java.util.Set;
  */
 
 @FeignClient("beacon-cache")
-//@RequestMapping("cache")
-public interface CacheClient {
-	@GetMapping("/cache/get/{key}")
-	String get(@PathVariable String key);
+public interface CacheClient extends BeaconCacheClient {
 
-	@GetMapping("/cache/set/{key}/{value}")
-	void set(@PathVariable String key, @PathVariable String value);
-
-	@GetMapping("/cache/hget/{key}")
-	Map hget(@PathVariable String key);
-
-	@GetMapping("/cache/hget/{key}/{field}")
-	Object hget(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
-
-	// 这是弄成了两个接口先处理了一下是吧。
-	@GetMapping("/cache/hget/{key}/{field}")
-	String hgetString(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
-
-	@PostMapping("/cache/hset/{key}")
-	void hset(@PathVariable String key, @RequestBody Map hash);
-
-	@PostMapping("/cache/sadd/{key}")
-	void sadd(@PathVariable(value = "key") String key, @RequestBody Map<String, Object>... maps);
-
-	@PostMapping("/cache/smember/{key}")
-	Set<Map> smember(@PathVariable(value = "key") String key);
 }

beacon-common/src/main/java/com/mashibing/common/clients/BeaconCacheClient.java

@@ -0,0 +1,53 @@
+package com.mashibing.common.clients;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * @author heqijun
+ * @ClassName: BeaconCacheClient
+ * @Description: 公共依赖中缓存接口父接口
+ * @date 2025/6/8 16:08
+ */
+
+public interface BeaconCacheClient {
+
+	@GetMapping("cache/get/{key}")
+	String get(@PathVariable String key);
+
+	@GetMapping("cache/set/{key}/{value}")
+	void set(@PathVariable String key, @PathVariable String value);
+
+	@GetMapping("cache/hget/{key}")
+	Map hget(@PathVariable String key);
+
+	@GetMapping("cache/hget/{key}/{field}")
+	Object hget(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
+
+	@GetMapping("cache/hgetString/{key}/{field}")
+	String hgetString(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
+
+	@PostMapping("cache/hset/{key}")
+	void hset(@PathVariable String key, @RequestBody Map hash);
+
+	@PostMapping("cache/sadd/{key}")
+	void sadd(@PathVariable(value = "key") String key, @RequestBody Map<String, Object>... value);
+
+	@PostMapping("cache/smember/{key}")
+	Set smember(@PathVariable(value = "key") String key);
+
+	/**
+	 * 大批量写入String数据
+	 *
+	 * @param map key是key，value是value
+	 */
+	@PostMapping("cache/pipeline/string")
+	void pipelineString(@RequestBody Map<String, String> map);
+
+}

beacon-strategy/src/main/java/com/mashibing/strategy/feignclient/CacheClient.java

@@ -1,5 +1,6 @@
 package com.mashibing.strategy.feignclient;
 
+import com.mashibing.common.clients.BeaconCacheClient;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -17,28 +18,6 @@ import java.util.Set;
  */
 
 @FeignClient("beacon-cache")
-public interface CacheClient {
-	@GetMapping("/cache/get/{key}")
-	String get(@PathVariable String key);
+public interface CacheClient extends BeaconCacheClient {
 
-	@GetMapping("/cache/set/{key}/{value}")
-	void set(@PathVariable String key, @PathVariable String value);
-
-	@GetMapping("/cache/hget/{key}")
-	Map hget(@PathVariable String key);
-
-	@GetMapping("/cache/hget/{key}/{field}")
-	Object hget(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
-
-	@GetMapping("/cache/hget/{key}/{field}")
-	String hgetString(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
-
-	@PostMapping("/cache/hset/{key}")
-	void hset(@PathVariable String key, @RequestBody Map hash);
-
-	@PostMapping("/cache/sadd/{key}")
-	void sadd(@PathVariable(value = "key") String key, @RequestBody Map<String, Object>... maps);
-
-	@PostMapping("/cache/smember/{key}")
-	Set<Map> smember(@PathVariable(value = "key") String key);
 }