啥也不说了，这次直接上代码

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

package com.alibaba.dubbo.demo;public interface CacheService {    String findCache(String id);}

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

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、服务提供端配置文件

4、客户端配置文件

5、客户端主类

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("han@qq.com");        //        // try {        // String result = validationService.intsert(parameter);        //        // System.out.println(result);        // } catch (RpcException e) { // 抛出的是RpcException        // ConstraintViolationException ve = (ConstraintViolationException)        // e.getCause(); // 里面嵌了一个ConstraintViolationException        // Set
    
     > 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、客户端控制台，返回值

i=0 OK: request: 0, response: 0i=1 OK: request: 0, response: 0i=2 OK: request: 0, response: 0i=3 OK: request: 0, response: 0i=4 OK: request: 0, response: 0OK: request: 0, response: 1001