From 5ac4d85e8e6a80ada870b5c92eb45897c7815b51 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 13 七月 2023 10:41:08 +0800
Subject: [PATCH] rgv
---
src/main/java/com/zy/core/cache/SlaveConnection.java | 36 ++++++++++++++++++++++--------------
1 files changed, 22 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/zy/core/cache/SlaveConnection.java b/src/main/java/com/zy/core/cache/SlaveConnection.java
index a3dbdea..0b57169 100644
--- a/src/main/java/com/zy/core/cache/SlaveConnection.java
+++ b/src/main/java/com/zy/core/cache/SlaveConnection.java
@@ -1,39 +1,41 @@
package com.zy.core.cache;
import com.zy.core.ThreadHandler;
+import com.zy.core.enums.SlaveType;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
+ * 绾跨▼缂撳瓨瀹瑰櫒
* Created by vincent on 2020/8/4
*/
public class SlaveConnection {
- public static final String CRN_PREFIX = "CRN_";
+ private static final String _LINK = "_";
- public static final String DEVP_PREFIX = "DEVP_";
+ private static final Map<String, ThreadHandler> conContain = new ConcurrentHashMap<>();
- private static Map<String, ThreadHandler> conContain = new ConcurrentHashMap<>();
-
- public static void put(String key, ThreadHandler threadHandler) {
-
+ public static void put(SlaveType type, Integer id, ThreadHandler threadHandler) {
+ String key = toKey(type, id);
+ remove(type, id);
+ conContain.put(key, threadHandler);
}
- public static ThreadHandler get(String key) {
- return conContain.get(key);
+ public static ThreadHandler get(SlaveType type, Integer id) {
+ return conContain.get(toKey(type, id));
}
- public static void remove(String key) {
- ThreadHandler threadHandler = get(key);
+ public static void remove(SlaveType type, Integer id) {
+ ThreadHandler threadHandler = get(type, id);
if (null == threadHandler) {
return;
}
- conContain.remove(key);
+ conContain.remove(toKey(type, id));
threadHandler.close();
}
- public static String remove(ThreadHandler threadHandler) {
+ public static Integer remove(ThreadHandler threadHandler) {
if (null == threadHandler) {
return null;
}
@@ -45,11 +47,17 @@
}
}
if (null != key) {
- remove(key);
- return key;
+ SlaveType type = SlaveType.findInstance(key);
+ Integer id = Integer.parseInt(key.split(_LINK)[1]);
+ remove(type, id);
+ return id;
} else {
return null;
}
}
+ private static String toKey(SlaveType type, Integer id){
+ return type.toString()+_LINK+id;
+ }
+
}
--
Gitblit v1.9.1