文档章节

聊聊dubbo的DataStore

go4it
 go4it
发布于 06/19 23:41
字数 416
阅读 13
收藏 0

本文主要研究一下dubbo的DataStore

DataStore

dubbo-2.7.2/dubbo-common/src/main/java/org/apache/dubbo/common/store/DataStore.java

@SPI("simple")
public interface DataStore {

    /**
     * return a snapshot value of componentName
     */
    Map<String, Object> get(String componentName);

    Object get(String componentName, String key);

    void put(String componentName, String key, Object value);

    void remove(String componentName, String key);

}
  • DataStore定义了get、put、remove方法,它有一个实现类为SimpleDataStore

SimpleDataStore

dubbo-2.7.2/dubbo-common/src/main/java/org/apache/dubbo/common/store/support/SimpleDataStore.java

public class SimpleDataStore implements DataStore {

    // <component name or id, <data-name, data-value>>
    private ConcurrentMap<String, ConcurrentMap<String, Object>> data =
            new ConcurrentHashMap<String, ConcurrentMap<String, Object>>();

    @Override
    public Map<String, Object> get(String componentName) {
        ConcurrentMap<String, Object> value = data.get(componentName);
        if (value == null) {
            return new HashMap<String, Object>();
        }

        return new HashMap<String, Object>(value);
    }

    @Override
    public Object get(String componentName, String key) {
        if (!data.containsKey(componentName)) {
            return null;
        }
        return data.get(componentName).get(key);
    }

    @Override
    public void put(String componentName, String key, Object value) {
        Map<String, Object> componentData = data.get(componentName);
        if (null == componentData) {
            data.putIfAbsent(componentName, new ConcurrentHashMap<String, Object>());
            componentData = data.get(componentName);
        }
        componentData.put(key, value);
    }

    @Override
    public void remove(String componentName, String key) {
        if (!data.containsKey(componentName)) {
            return;
        }
        data.get(componentName).remove(key);
    }

}
  • SimpleDataStore使用ConcurrentHashMap来存储数据,每个key存储的是ConcurrentMap

实例

dubbo-2.7.2/dubbo-common/src/test/java/org/apache/dubbo/common/store/support/SimpleDataStoreTest.java

public class SimpleDataStoreTest {
    private SimpleDataStore dataStore = new SimpleDataStore();

    @Test
    public void testPutGet() throws Exception {
        assertNull(dataStore.get("xxx", "yyy"));

        dataStore.put("name", "key", "1");
        assertEquals("1", dataStore.get("name", "key"));

        assertNull(dataStore.get("xxx", "yyy"));
    }

    @Test
    public void testRemove() throws Exception {
        dataStore.remove("xxx", "yyy");

        dataStore.put("name", "key", "1");
        dataStore.remove("name", "key");
        assertNull(dataStore.get("name", "key"));
    }

    @Test
    public void testGetComponent() throws Exception {
        Map<String, Object> map = dataStore.get("component");
        assertTrue(map != null && map.isEmpty());
        dataStore.put("component", "key", "value");
        map = dataStore.get("component");
        assertTrue(map != null && map.size() == 1);
        dataStore.remove("component", "key");
        assertNotEquals(map, dataStore.get("component"));
    }
}
  • 这里使用testPutGet、testRemove、testGetComponent进行了验证

小结

DataStore定义了get、put、remove方法,它有一个实现类为SimpleDataStore;SimpleDataStore使用ConcurrentHashMap来存储数据,每个key存储的是ConcurrentMap

doc

© 著作权归作者所有

go4it
粉丝 85
博文 1034
码字总数 988857
作品 0
深圳
私信 提问
【南京站报名中!】微服务框架到生态,Apache Dubbo 开发者沙龙

Dubbo 诞生于 2008 年,是阿里巴巴开源的高性能分布式服务框架(A High Performance Java RPC Framework),使得应用可通过高性能的 RPC 实现服务的输出和输入功能,可以和 Spring 框架无缝集...

amber涂南
03/11
0
0
聊聊dubbo的TPSLimiter

序 本文主要研究一下dubbo的TPSLimiter TPSLimiter dubbo-2.7.2/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/tps/TPSLimiter.java TPSLimiter定义了isAllowable方法......

go4it
06/23
0
0
聊聊dubbo的StatusChecker

序 本文主要研究一下dubbo的StatusChecker Status dubbo-2.7.2/dubbo-common/src/main/java/org/apache/dubbo/common/status/Status.java Status定义了三个属性,分别是level、message、des......

go4it
06/22
0
0
聊聊dubbo的CommandExecutor

序 本文主要研究一下dubbo的CommandExecutor CommandExecutor dubbo-2.7.2/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/CommandExecutor.java CommandExecutor定义了......

go4it
07/05
0
0
聊聊dubbo的DubboSwaggerService

序 本文主要研究一下dubbo的DubboSwaggerService DubboSwaggerService dubbo-2.7.2/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/integration/swagger/Dubbo......

go4it
07/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Linux的基本命令

目录的操作命令(增删改查) 增: mkdir 目录名称; 查: ls 可以看到该目录下的所有的目录和文件 ls -a,可以看到该目录下的所有文件和目录,包括隐藏的 ls -l,可以看到该目录下的所有目录和...

凹凸凸
今天
2
0
在古老unix中增加新用户

Installing 4.3 BSD Quasijarus on SIMH 目标:要在4.3BSD中新增加用户dmr,指定目录/home/dmr,uid为10 gid=31(guest组,系统已建立) 4.3BSD还没有adduser或useradd 直接修改/etc/passwd...

wangxuwei
今天
2
0
Bootstrap(六)表单样式

基本样式 所有设置了 .form-control 类的 <input>、<textarea> 和 <select> 元素都将被默认设置宽度属性为 width: 100%;。 将 label 元素和前面提到的控件包裹在 .form-group 中可以获得最好...

ZeroBit
昨天
3
0
SSL 证书格式转换

SSL 证书格式转换 不同服务器情况下,需要不同的证书格式。 比如 pem 转 pfx。 pem在window 平台下可以导入,但是无法正常使用。 需要转换成pfx。 推荐在线转换工具,由中国数字证书网站提供...

DrChenXX
昨天
2
0
HAProxy

xx

Canaan_
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部