|
|
@@ -4,6 +4,7 @@
|
|
|
*/
|
|
|
package org.jetlinks.community.bridge.core;
|
|
|
|
|
|
+import java.util.List;
|
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
import java.util.concurrent.ConcurrentMap;
|
|
|
|
|
|
@@ -14,6 +15,8 @@ import com.aliyun.iot.as.bridge.core.model.DeviceIdentity;
|
|
|
import com.aliyun.openservices.iot.api.util.StringUtil;
|
|
|
import com.typesafe.config.Config;
|
|
|
import com.typesafe.config.ConfigFactory;
|
|
|
+import org.hswebframework.web.cache.supports.RedisReactiveCache;
|
|
|
+import org.jetlinks.supports.cluster.redis.RedisClusterCache;
|
|
|
|
|
|
/**
|
|
|
* Default implementation of {@link DeviceConfigManager device configuration manager}.
|
|
|
@@ -25,6 +28,7 @@ public class DefaultDeviceConfigManager implements DeviceConfigManager{
|
|
|
private static ConcurrentMap<String, DeviceIdentity> configCache = new ConcurrentHashMap<>(500000);
|
|
|
private static ConcurrentMap<String, String> revertCache = new ConcurrentHashMap<>(500000);
|
|
|
private DefaultDeviceConfigManager() {
|
|
|
+
|
|
|
}
|
|
|
|
|
|
public static DefaultDeviceConfigManager getInstance(){
|