淘宝SOA框架dubbo学习（5）--结果缓存

1、客户端和服务提供端共用接口类

?


1

2

3

4

5

package com.alibaba.dubbo.demo;

public interface CacheService {

    String findCache(String id);

}

2、服务提供端接口实现类

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

package com.alibaba.dubbo.demo.provider;

import java.util.concurrent.atomic.AtomicInteger;

import com.alibaba.dubbo.demo.CacheService;

public class CacheServiceImpl implements CacheService {

    private final AtomicInteger i = new AtomicInteger();

    @Override

    public String findCache(String id) {

        String result = "request: " + id + ", response: " + i.getAndIncrement();

        System.out.println(result);

        return result;

    }

}

3、服务提供端配置文件

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

    xsi:schemaLocation="http://www.springframework.org/schema/beans 

    http://www.springframework.org/schema/beans/spring-beans.xsd 

    http://code.alibabatech.com/schema/dubbo

    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

 

    <!-- 提供方应用信息，用于计算依赖关系 -->

    <dubbo:application name="hello-world"  />

 

    <!-- 使用zookeeper注册中心暴露发现服务地址 -->

    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

 

    <!-- 用dubbo协议在20880端口暴露服务 -->

    <dubbo:protocol name="dubbo" port="20880" />

 

    <!-- 声明需要暴露的服务接口 -->

    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />

 

    <!-- 和本地bean一样实现服务 -->

    <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />

 

    <!-- 声明需要暴露的服务接口 -->

    <dubbo:service interface="com.alibaba.dubbo.demo.ValidationService" ref="validationService" />

 

    <!-- 和本地bean一样实现服务 -->

    <bean id="validationService" class="com.alibaba.dubbo.demo.provider.ValidationServiceImpl" />

    

    <bean id="cacheService" class="com.alibaba.dubbo.demo.provider.CacheServiceImpl" />

    

    <dubbo:service interface="com.alibaba.dubbo.demo.CacheService" ref="cacheService" />

 

</beans>

4、客户端配置文件

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

    xsi:schemaLocation="http://www.springframework.org/schema/beans        

    http://www.springframework.org/schema/beans/spring-beans.xsd        

    http://code.alibabatech.com/schema/dubbo        

    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

 

    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->

    <dubbo:application name="consumer-of-helloworld-app"  />

 

    <!-- 使用zookeeper注册中心暴露发现服务地址 -->

    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

 

    <!-- 生成远程服务代理 -->

    <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService"

         retries="2"

          />

 

    <!-- 生成远程服务代理 -->

    <dubbo:reference id="validationService" interface="com.alibaba.dubbo.demo.ValidationService"

         retries="2" validation="true"

          />

    

    <!-- 生成远程服务代理 -->

    <dubbo:reference id="cacheService" interface="com.alibaba.dubbo.demo.CacheService" cache="true" />

 

</beans>

5、客户端主类

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.alibaba.dubbo.demo.CacheService;

public class Consumer {

    /**

     * @param args

     * @throws Exception

     */

    public static void main(String[] args) throws Exception {

        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(

                new String[] { "classpath:consumer.xml" });

        context.start();

        // DemoService demoService = (DemoService)

        // context.getBean("demoService");

        // while (true) {

        // String hello = demoService.sayHello("world");

        // System.out.println(hello);

        //

        // Thread.sleep(100);

        // }

        // 参数校验示例

        // ValidationService validationService = (ValidationService)

        // context.getBean("validationService");

        // while (true) {

        // ValidationParameter parameter = new ValidationParameter();

        // parameter.setAge(23);

        // parameter.setEmail("[email protected]");

        //

        // try {

        // String result = validationService.intsert(parameter);

        //

        // System.out.println(result);

        // } catch (RpcException e) { // 抛出的是RpcException

        // ConstraintViolationException ve = (ConstraintViolationException)

        // e.getCause(); // 里面嵌了一个ConstraintViolationException

        // Set<ConstraintViolation<?>> violations =

        // ve.getConstraintViolations(); // 可以拿到一个验证错误详细信息的集合

        // System.out.println(violations);

        // }

        // }

        CacheService cacheService = (CacheService) context.getBean("cacheService");

        // 测试缓存生效，多次调用返回同样的结果。(服务器端自增长返回值)

        String fix = null;

        for (int i = 0; i < 5; i++) {

            String result = cacheService.findCache("0");

            if (fix == null || fix.equals(result)) {

                System.out.println("i=" + i + " OK: " + result);

            } else {

                System.err.println("i=" + i + " ERROR: " + result);

            }

            fix = result;

            Thread.sleep(500);

        }

        // LRU的缺省cache.size为1000，执行1001次，应有溢出

        for (int n = 0; n < 1001; n++) {

            String pre = null;

            for (int i = 0; i < 10; i++) {

                String result = cacheService.findCache(String.valueOf(n));

                if (pre != null && !pre.equals(result)) {

                    System.err.println("n=" + n + " ERROR: " + result);

                }

                pre = result;

            }

        }

        // 测试LRU有移除最开始的一个缓存项

        String result = cacheService.findCache("0");

        if (fix != null && !fix.equals(result)) {

            System.out.println("OK: " + result);

        } else {

            System.err.println("ERROR: " + result);

        }

    }

}

6、客户端控制台，返回值

?


1

2

3

4

5

6

i=0 OK: request: 0, response: 0

i=1 OK: request: 0, response: 0

i=2 OK: request: 0, response: 0

i=3 OK: request: 0, response: 0

i=4 OK: request: 0, response: 0

OK: request: 0, response: 1001
时间： 2024-10-01 22:27:31

淘宝SOA框架dubbo学习（5）--结果缓存的相关文章

淘宝SOA框架dubbo学习（2）--搭建Zookeeper注册中心服务

淘宝SOA框架dubbo学习(1) http://my.oschina.net/hanshubo/blog/374974 1.下载 Zookeeper 下载页面地址: http://www.apache.org/dist/zookeeper/zookeeper-3.4.6/ 注:下面步骤,windows和linux下几乎没什么太大区别 2.解压缩后进入 C:\zookeeper-3.4.6 目录结构如下图 3.进入conf目录 备份zoo_sample.cfg文件,然后将zoo_sample.c

淘宝SOA框架dubbo学习（3）--搭建监控中心

紧接上一篇,继续我的dubbo的学习之旅 1.下载监控中心dubbo服务安装包 下载地址: http://code.alibabatech.com/mvn/releases/com/alibaba/dubbo-monitor-simple/2.4.1/dubbo-monitor-simple-2.4.1-assembly.tar.gz 注:此地址,可能下载不了,我是群共享文件里,下载的 2.解压缩后,编辑conf/dubbo.properties 内容如下: ? 1 2 3 4 5 6 7 8

淘宝SOA框架dubbo学习（7）--异步调用

直接上代码: 1.服务提供端及客户端共享代码 package com.alibaba.dubbo.demo; public interface DemoService2 {     Person getPersion(String name); } package com.alibaba.dubbo.demo; import java.io.Serializable; public class Person implements Serializable {     private static

淘宝SOA框架dubbo学习（1）--first demo

部署开发,需要三部分:服务提供者.服务容器.服务消费者 本人用 eclipse 开发 1.服务提供者jar生成 A.项目截图 B.源码: ? 1 2 3 4 5 package com.alibaba.dubbo.demo; public interface DemoService {     String sayHello(String name); } ? 1 2 3 4 5 6 7 8 9 package com.alibaba.dubbo.demo.provider; import co

淘宝SOA框架dubbo学习（4）--参数验证

1.由于没用maven,和对dubbo不是很了解的原因,这次,总因为jar包不对,而导致:dubbo客户端程序,启动不起来 所以决定:将原来用过的所有jar包全部去,将dubbo-demo-provider-2.5.4-SNAPSHOT/lib下的所有jar包全部导入项目中 一切就OK了 2.服务消费者代码 ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34

淘宝SOA框架dubbo学习（1）

部署开发,需要三部分:服务提供者.服务容器.服务消费者 本人用 eclipse 开发 1.服务提供者jar生成 A.项目截图 B.源码: package com.alibaba.dubbo.demo; public interface DemoService { String sayHello(String name); } package com.alibaba.dubbo.demo.provider; import com.alibaba.dubbo.demo.DemoService; pu

淘宝SOA框架dubbo学习（9）--事件通知

1.服务提供端及客户端共享代码 package com.alibaba.dubbo.demo; public interface DemoService {     String sayHello(String name);     Person get(int id); } package com.alibaba.dubbo.demo; import java.io.Serializable; public class Person implements Serializable {     

淘宝SOA框架dubbo学习（8）--参数回调

1.服务提供端及客户端共享代码 package com.alibaba.dubbo.demo; public interface CallbackService {     void addListener(String key, CallbackListener listener); } package com.alibaba.dubbo.demo; public interface CallbackListener {     void changed(String msg); } 2.客户

淘宝SOA框架dubbo学习（6）--回声测试

由于用例比较简单,直接上代码吧! import org.springframework.context.support.ClassPathXmlApplicationContext; import com.alibaba.dubbo.demo.DemoService; import com.alibaba.dubbo.rpc.service.EchoService; public class Consumer {     /**      * @param args      * @throws