有个项目使用的缓存是EhCache,  这个客户的访问量单机抗不住, 就用了多部署, 发现有些梗, 是缓存导致的, 没有同步... 于是用上了Redis  . 业务代码尽量不能动... 就写了个插件, EhCache与Redis自由切换 , 下面分享一下

这个分享适合老项目微改造，不想太多改动的。集群项目推荐直接使用j2cache这个开源中国红薯大佬的工具。

Redis 安装 配置
菜鸟教程网:
http://www.runoob.com/redis/redis-install.html

http://blog.csdn.net/libaineu2004/article/details/49004195

JFinal 中配置

看手册: 第八 章 RedisPlugin

数据库ActiveRecordPlugin 默认使用的是
EhCache
com.jfinal.plugin.activerecord.cache;

在这里得自己模仿写一个 可切换的Cache工具了.

MyCache.java

public class MyCache implements ICache {

    private static String getCacheType() {
        return PropKit.get("cache_type", "ehcache");
    }

    public static boolean isEhCache() {
        return "ehcache".equals(getCacheType());
    }

    public static boolean isRedis() {
        return "redis".equals(getCacheType());
    }

    @Override
    public <T> T get(String cacheName, Object key) {
        if (isEhCache()) {
            return CacheKit.get(cacheName, key);

        } else if (isRedis()) {
            return Redis.use(cacheName).get(key);
        }
        return null;
    }

    @Override
    public void put(String cacheName, Object key, Object value) {
        if (isEhCache()) {
            CacheKit.put(cacheName, key, value);

        } else if (isRedis()) {
            Redis.use(cacheName).set(key, value);
        }
    }

    @Override
    public void remove(String cacheName, Object key) {
        if (isEhCache()) {
            CacheKit.remove(cacheName, key);

        } else if (isRedis()) {
            Redis.use(cacheName).del(key);
        }

    }

    @Override
    public void removeAll(String cacheName) {
        if (isEhCache()) {
            CacheKit.removeAll(cacheName);

        } else if (isRedis()) {
            Cache cache = Redis.use(cacheName);
            cache.del(cache.keys("*").toArray());
        }

    }

}

放进数据库连接插件  ActiveRecordPlugin中
JFinalConfig中

/**
     * 配置插件
     */
    public void configPlugin(Plugins me) {
        // 配置DruidPlugin数据库连接池插件
        DruidPlugin druidPlugin = createDruidPlugin();
        me.add(druidPlugin);
        
        // 配置ActiveRecord插件
        ActiveRecordPlugin arp = new ActiveRecordPlugin(DbKit.MAIN_CONFIG_NAME, druidPlugin);
        me.add(arp);
        arp.setContainerFactory(new CaseInsensitiveContainerFactory(true));// 大小写不敏感
        
        // 缓存可切换使用
        arp.setCache(new MyCache());
        
        // 所有主数据元 配置在 MappingKit 中
        _MappingKit.mapping(arp);
        
        // 缓存设置
        if(MyCache.isRedis()){
            //根据ehcache.xml 中来 栗子~ 
            String[] cacheName = {"cacheName_1","cacheName_2",
            "cacheName_3","cacheName_4","cacheName_5","cacheName_6",
            "cacheName_7","cacheName_8","cacheName_9"};
            for (int i = 0; i <= 9; i++) {
                RedisPlugin newsRedis = 
                  new RedisPlugin( cacheName[i],  "192.168.1.240",  6379,  0,  "JFinal2011",  i);
                me.add(newsRedis);
            }
        }else if (MyCache.isEhCache()) {
            me.add(new EhCachePlugin());
        }
        
    }

好了, 最后导包

写个测试类:

public class RedisTest {

    public static void main(String[] args) {


        for (int i = 0; i <= 9; i++) {
         testRedis("cacheName_" + i, "192.168.1.240", 6379, 0 , "JFinal2011", i);
         System.out.println("------------------------");
        }
    }

     public static void testRedis(final String cacheName, String host, int port) {
        System.out.println("cacheName="+ cacheName + "  host="+ host + " port="+ port);
        
        RedisPlugin rpMy = new RedisPlugin( cacheName,  host,  port,  timeout,  password,  database);
        rpMy.start();

        new Thread(){
            public void run() {
                
                for (int i = 0; i < 10000; i++) {
                    new Thread(){
                        public void run() {
                            String name = getName();
                            Cache use = Redis.use(cacheName);
                            use.set("k" + name, "value_key_" + cacheName + "_"+name);
                            
                            Object v = use.get("k" + name);
                            System.out.println(v);
                            use.del("k" + name);
                        }
                    }.start();
                }
            }
        }.start();
        
    }

}

@JFinal   非常感谢老大的指导!!! 已经做修改了~  爽!