dubbo 使用学习七（结果缓存）

dubbo 我们提供给了结果缓存功能，只要进行简单的配置就能实现结果缓存功能！

一、服务提供者

1、服务提供者接口

[java]view plain copy print ?

packagecom.test.dubboser;

publicinterfaceCacheService {

String findCache(String id);

}

package com.test.dubboser;

public interface CacheService {

String findCache(String id);

}

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

[java]view plain copy print ?

packagecom.test.dubboser;

importjava.util.concurrent.atomic.AtomicInteger;

publicclassCacheServiceImpimplementsCacheService{

privatefinalAtomicInteger i =newAtomicInteger();

publicString findCache(String id) {

// TODO Auto-generated method stub

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

System.out.println(result);

returnresult;

}

package com.test.dubboser;

import java.util.concurrent.atomic.AtomicInteger;

public class CacheServiceImp implements CacheService{

private final AtomicInteger i = new AtomicInteger();

public String findCache(String id) {

// TODO Auto-generated method stub

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

System.out.println(result);

return result;

}

3、服务端配置文件

[html]view plain copy print ?

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

ref="demoService"/>

ref="demoService2"/>

ref="cacheService"/>

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

ref="demoService"/>

ref="demoService2"/>

ref="cacheService"/>

二、服务消费者

1、服务消费者配置文件

[html]view plain copy print ?

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

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配置结果缓存还是很简单的……

2、客户端代码

[java]view plain copy print ?

packagecom.test.dubbocli;

importorg.springframework.context.support.ClassPathXmlApplicationContext;

importcom.test.dubboser.CacheService;

importcom.test.dubboser.ServiceDemo;

importcom.test.dubboser.ServiceDemo2;

publicclassMain {

publicstaticvoidmain(String[] args)throwsInterruptedException {

run();

}

publicstaticvoidrun()throwsInterruptedException{

ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext(newString[] {"applicationConsumer.xml"});

context.start();

//ServiceDemo demoServer = (ServiceDemo) context.getBean("demoServicemy");

//ServiceDemo2 demoServer2 = (ServiceDemo2) context.getBean("demoServicemy2");

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

/*ServiceDemo demoServer3 = (ServiceDemo) context.getBean("demoServicemy3");*/

/*String str=demoServer.say("java ---->>>");

String str2=demoServer2.say("java ---->>>");*/

String test=null;

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

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

if(test==null||test.equals(caches)){

System.out.println("i="+i +" ok:"+caches);

}else{

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

}

test= caches;

Thread.sleep(500);

}

String caches=cacheService.findCache("1");

System.out.println("last:"+caches);

/*String str3=demoServer3.say("java ---->>>");*/

/*System.err.println("res: "+str);

System.err.println("res: "+str2);*/

//System.err.println("cache res"+caches);

//System.err.println("res: "+str3);

}

package com.test.dubbocli;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.test.dubboser.CacheService;

import com.test.dubboser.ServiceDemo;

import com.test.dubboser.ServiceDemo2;

public class Main {

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

run();

}

public static void run() throws InterruptedException{

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "applicationConsumer.xml" });

context.start();

//ServiceDemo demoServer = (ServiceDemo) context.getBean("demoServicemy");

//ServiceDemo2 demoServer2 = (ServiceDemo2) context.getBean("demoServicemy2");

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

/*ServiceDemo demoServer3 = (ServiceDemo) context.getBean("demoServicemy3");*/

/*String str=demoServer.say("java ---->>>");

String str2=demoServer2.say("java ---->>>");*/

String test=null;

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

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

if(test==null||test.equals(caches)){

System.out.println("i="+i +" ok:"+caches);

}else{

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

}

test= caches;

Thread.sleep(500);

}

String caches=cacheService.findCache("1");

System.out.println("last:"+caches);

/*String str3=demoServer3.say("java ---->>>");*/

/*System.err.println("res: "+str);

System.err.println("res: "+str2);*/

//System.err.println("cache res"+caches);

//System.err.println("res: "+str3);

}

3、服务端接口实现代码

[java]view plain copy print ?

packagecom.test.dubboser;

importjava.util.concurrent.atomic.AtomicInteger;

publicclassCacheServiceImpimplementsCacheService{

privatefinalAtomicInteger i =newAtomicInteger();

publicString findCache(String id) {

// TODO Auto-generated method stub

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

System.out.println(result);

returnresult;

}

package com.test.dubboser;

import java.util.concurrent.atomic.AtomicInteger;

public class CacheServiceImp implements CacheService{

private final AtomicInteger i = new AtomicInteger();

public String findCache(String id) {

// TODO Auto-generated method stub

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

System.out.println(result);

return result;

}

第一次启动服务提供者，消费端运行结果：

[plain]view plain copy print ?

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

i=5 ok:request: 0, response: 0

i=6 ok:request: 0, response: 0

i=7 ok:request: 0, response: 0

i=8 ok:request: 0, response: 0

i=9 ok:request: 0, response: 0

last:request: 1, response: 1

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

i=5 ok:request: 0, response: 0

i=6 ok:request: 0, response: 0

i=7 ok:request: 0, response: 0

i=8 ok:request: 0, response: 0

i=9 ok:request: 0, response: 0

last:request: 1, response: 1

服务端没有重新启动，而客户端再次访问结果：

[plain]view plain copy print ?

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

i=1 ok:request: 0, response: 2

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

i=3 ok:request: 0, response: 2

i=4 ok:request: 0, response: 2

i=5 ok:request: 0, response: 2

i=6 ok:request: 0, response: 2

i=7 ok:request: 0, response: 2

i=8 ok:request: 0, response: 2

i=9 ok:request: 0, response: 2

last:request: 1, response: 3

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

i=1 ok:request: 0, response: 2

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

i=3 ok:request: 0, response: 2

i=4 ok:request: 0, response: 2

i=5 ok:request: 0, response: 2

i=6 ok:request: 0, response: 2

i=7 ok:request: 0, response: 2

i=8 ok:request: 0, response: 2

i=9 ok:request: 0, response: 2

last:request: 1, response:

愿意了解或者源码的朋友直接求求交流分享技术：2042849237

更多详细源码参考来源：http://minglisoft.cn/technology

最后编辑于：2017.12.11 12:55:19

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 194,088评论 5赞 459
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 81,715评论 2赞 371
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 141,361评论 0赞 319
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 52,099评论 1赞 263
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 60,987评论 4赞 355
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 46,063评论 1赞 272
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 36,486评论 3赞 381
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 35,175评论 0赞 253
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 39,440评论 1赞 290
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 34,518评论 2赞 309
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 36,305评论 1赞 326
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 32,190评论 3赞 312
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 37,550评论 3赞 298
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 28,880评论 0赞 17
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,152评论 1赞 250
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 41,451评论 2赞 341
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 40,637评论 2赞 335

dubbo 使用学习七（结果缓存）

推荐阅读更多精彩内容