文档章节

动态构建J2Cache以及注意事项

傲娇字符
 傲娇字符
发布于 05/25 09:01
字数 824
阅读 60
收藏 0
点赞 0
评论 0

一直以来,我们都是将数据字典等信息放在Redis缓存中,避免使用的时候,穿透到数据库层面,同时提升性能。最近突然发现线上频繁出现Redis连接超时等异常,经过跟踪,发现新增了一个字典表,有三万多行记录,始料未及的事情终究还是发生了。于是需要增加应用内存级别的缓存,同时还要保持与redis一致。

最近红薯的J2Cache发版有点频繁(快成娱乐新闻了),成功的引起了我的注意,基本满足此需求,由于J2Cache底层基于Ehcache,每次启动,都要往内存加载缓存数据,导致本地调试每次重启变得很慢,所以后续会基于J2Cache进行扩展(ehcache的磁盘缓存策略,必须确保应用正常退出才行)。

注意事项1:配置参数名不能直接使用j2cache.properties中示例

由于项目本身使用了配置中心,只能基于动态构建J2Cache的方式进行集成。此时发现了J2Cache的两个BUG,第一个直接导致红薯连夜发版(说好无BUG,反手就是一巴掌,再次给红薯道歉);第二个问题,每次启动的时候,没有读取到配置信息,而代码转换出现空指针异常(我认为这种强转是会出事的,建议官方在后续版本改一下写法)经过红薯的指点,在使用Properties方式进行动态添加配置的时候,需要将redis.的前缀去掉,所以只能在J2CacheBuilder.init(config);之前通过代码去掉前缀,此坑必须绕开。

代码参见下面的removePrefix方法。

注意事项2:不想使用集群广播通知应该如何设置

另外如果不想使用Redis集群或者集群广播功能,需要config.setBroadcast("none");里面的参数,其实建议官方能改成枚举。

示例代码如下:

package com.chz.apps.common.j2cache;

import com.chz.apps.common.cache.LocalCache;
import com.chz.apps.common.redisson.RedissionTools;
import net.oschina.j2cache.CacheChannel;
import net.oschina.j2cache.J2CacheBuilder;
import net.oschina.j2cache.J2CacheConfig;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Iterator;
import java.util.Map;
import java.util.Properties;

/**
 * J2Cache工具类
 * @Author gongstring(gongstring@foxmail.com)
 */
public class J2CacheUtil {

    private static Logger logger = LoggerFactory.getLogger(J2CacheUtil.class);

    private static CacheChannel channel = null;

    /**
     * 初始化启动
     */
    public static void start(){
        Object server = LocalCache.getInstance().get(RedissionTools.REDIS_SERVER_IP);
        Object port = LocalCache.getInstance().get(RedissionTools.REDIS_SERVER_PORT);
        Object timeout = LocalCache.getInstance().get(RedissionTools.REDIS_TIMEOUT);
        Object auth = LocalCache.getInstance().get(RedissionTools.REDIS_AUTH);
        Object database = LocalCache.getInstance().get(RedissionTools.REDIS_DATABASE);
        if(server != null && StringUtils.isNotBlank(server.toString()) && port != null && Integer.parseInt(port.toString()) > 0){
            try {

                Properties l1cacheProperties = new Properties();
                l1cacheProperties.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("j2cache/caffeine.properties"));

                Properties l2cacheProperties = new Properties();
                l2cacheProperties.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("j2cache/j2cache.properties"));
                //自定义redis配置连接
                l2cacheProperties.put("redis.hosts",server+":"+port);
                l2cacheProperties.put("redis.timeout",timeout);
                if(auth != null){
                    l2cacheProperties.put("redis.password",auth);
                }

                if(database != null){
                    l2cacheProperties.put("redis.database",database);
                }

                J2CacheConfig config = new J2CacheConfig();
                //不使用集群通知
                config.setBroadcast("none");
                config.setL1CacheName("caffeine");
                config.setL1CacheProperties(l1cacheProperties);

                config.setL2CacheName("redis");
                config.setL2CacheProperties(removePrefix(l2cacheProperties,"redis."));
                J2CacheBuilder builder = J2CacheBuilder.init(config);
                channel = builder.getChannel();

                logger.info("J2Cache启动成功");
            }catch (Exception e){
                e.printStackTrace();
                logger.error("J2Cache启动失败:{}",e);
            }
        }else{

            logger.info("J2Cache启动失败,没有配置二级缓存Redis的参数信息");
        }


    }

    public static void close(){
        if(channel != null){
            channel.close();
        }
    }

    public static CacheChannel getChannel(){
        return channel;
    }

    private static Properties removePrefix(Properties properties,String prefix){
        if(properties == null)
            return null;

        Properties result = new Properties();
        Iterator<Map.Entry<Object, Object>> it = properties.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry<Object, Object> entry = it.next();
            if(entry.getKey().toString().startsWith(prefix)){
                result.put(entry.getKey().toString().substring(prefix.length()),entry.getValue());
            }else{
                result.put(entry.getKey(),entry.getValue());
            }
        }
        return result;
    }

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

        // 通用没有具体业务意义的代码,只是为了保证主线程不退出
        synchronized (J2CacheUtil.class) {
            J2CacheUtil.class.wait();
        }
    }

}


© 著作权归作者所有

共有 人打赏支持
傲娇字符
粉丝 4
博文 36
码字总数 13903
作品 0
武汉
架构师
J2Cache 新增 Mybatis 支持模块,代码少到没 Bug

花了点时间撸了个 MyBatis 的 J2Cache 支持模块,含注释共八十多行代码 (J2CacheAdapter.java),再有 Bug 我就真的要退役了。 使用方法很简单,请看 https://gitee.com/ld/J2Cache/tree/mast...

红薯 ⋅ 05/15 ⋅ 30

J2Cache 2.3.17 发布,有 Bug 吐槽,不更新也吐槽

用 J2Cache 的开发者太多了,以至于 Bug 都被第一时间给你挑出来,所以直接导致每次发布完新版本紧接着又要发一个补丁版本。这就是人气啊! J2Cache 最新 bugfix 版本又来了,咋地,你还能打...

红薯 ⋅ 05/18 ⋅ 6

关于J2cache ...

刚刚开始接触红薯大大的J2cache,在此感谢! 请教大家关于j2cache的一些问题: 1. j2cache的优缺点是什么呢? 2.它适用于什么场景,该怎样去用它? 在此拜谢诸位英雄好汉!谢谢!!...

磁爆步兵001 ⋅ 06/01 ⋅ 0

J2Cache 2.3.18 发布,这一次是 Spring Boot 的锅

嗯,我又发布新版本了,我不知道该版本解决的问题算是 Bug 还是一个 Feature ! 某些用户是在 Spring Boot 中使用 J2Cache 框架,当启用 devtool 的时候会导致从缓存读取数据的时候出现 Clas...

红薯 ⋅ 05/22 ⋅ 0

J2Cache 2.3.12 发布,支持二级缓存只读模式

J2Cache 推出至今,已有多人希望能提供二级缓存只读模式,相当于应用只能从 Redis 二级缓存读取数据,而不允许写入任何数据,包括当一级缓存失效时也不能去清除二级缓存的数据。这样的开发者...

红薯 ⋅ 04/27 ⋅ 0

J2Cache 2.3.16 悄悄发布第三个 Bug 修复版本

实在无颜见江东父老啊,只好选择在星期天大家都在陪着男朋友玩耍的时候再次发布第三个 Bug 修复版本。 J2Cache 2.3.16 版本修复了当一级缓存使用 ehcache 或者 ehcache3 的异常: 修复了 Eh...

红薯 ⋅ 05/06 ⋅ 0

码云 5 周年推出 JavaDoc 在线生成和托管服务

我没事的时候喜欢翻翻 Java 的 API ,翻翻用过的开源项目的 API 文档。不时会有惊喜,不经意会发现一些黑科技。 看项目文档,当然,你最多掌握 60% 该项目的技能(文档非常完善的前提下) 熟...

红薯 ⋅ 06/01 ⋅ 36

J2Cache 2.3.14 红薯欲哭无泪版发布,紧急修复 Bug

重要!!! 请不要使用 2.3.13 和 2.3.14 版本,2.3.15 版本已经提交到 Maven 中央库!!! 我检讨,我反省,我犯了一个愚蠢的错误!!! J2Cache 2.3.13 版本发布时,脑袋被驴踢了,删掉了 ...

红薯 ⋅ 05/03 ⋅ 33

J2Cache 2.3.19 性能提升 30%,这不是 Bugfix 版本

这个版本你们没有槽点可喷了吧,因为没有 Bug 了!!! J2Cache 2.3.19 带来了部分性能的提升达 30% ,而且进一步降低对 Redis 请求的压力。 纳尼?你说我吹牛逼?下面说说详情! 假设有 10...

红薯 ⋅ 05/23 ⋅ 44

J2Cache 2.3.20 封箱版发布,要开始 3.x 跨语言支持了

我说你们咋那么讨厌呢,每次喷我都喷得那么准! 日前 J2Cache 已经修复了 2.x 的最后一个很小很小的 Bug(详情),发布了这个 2.3.20 版本。这将会是 2.x 的最后一个更新版本。 Maven: net....

红薯 ⋅ 05/24 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

浅谈springboot Web模式下的线程安全问题

我们在@RestController下,一般都是@AutoWired一些Service,由于这些Service都是单例,所以并不存在线程安全问题。 由于Controller本身是单例模式 (非线程安全的), 这意味着每个request过来,...

算法之名 ⋅ 58分钟前 ⋅ 0

知乎Java数据结构

作者:匿名用户 链接:https://www.zhihu.com/question/35947829/answer/66113038 来源:知乎 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。 感觉知乎上嘲讽题主简...

颖伙虫 ⋅ 今天 ⋅ 0

Confluence 6 恢复一个站点有关使用站点导出为备份的说明

推荐使用生产备份策略。我们推荐你针对你的生产环境中使用的 Confluence 参考 Production Backup Strategy 页面中的内容进行备份和恢复(这个需要你备份你的数据库和 home 目录)。XML 导出备...

honeymose ⋅ 今天 ⋅ 0

JavaScript零基础入门——(九)JavaScript的函数

JavaScript零基础入门——(九)JavaScript的函数 欢迎回到我们的JavaScript零基础入门,上一节课我们了解了有关JS中数组的相关知识点,不知道大家有没有自己去敲一敲,消化一下?这一节课,...

JandenMa ⋅ 今天 ⋅ 0

火狐浏览器各版本下载及插件httprequest

各版本下载地址:http://ftp.mozilla.org/pub/mozilla.org//firefox/releases/ httprequest插件截至57版本可用

xiaoge2016 ⋅ 今天 ⋅ 0

Docker系列教程28-实战:使用Docker Compose运行ELK

原文:http://www.itmuch.com/docker/28-docker-compose-in-action-elk/,转载请说明出处。 ElasticSearch【存储】 Logtash【日志聚合器】 Kibana【界面】 答案: version: '2'services: ...

周立_ITMuch ⋅ 今天 ⋅ 0

使用快嘉sdkg极速搭建接口模拟系统

在具体项目研发过程中,一旦前后端双方约定好接口,前端和app同事就会希望后台同事可以尽快提供可供对接的接口方便调试,而对后台同事来说定好接口还仅是个开始、设计流程,实现业务逻辑,编...

fastjrun ⋅ 今天 ⋅ 0

PXE/KickStart 无人值守安装

导言 作为中小公司的运维,经常会遇到一些机械式的重复工作,例如:有时公司同时上线几十甚至上百台服务器,而且需要我们在短时间内完成系统安装。 常规的办法有什么? 光盘安装系统 ===> 一...

kangvcar ⋅ 昨天 ⋅ 0

使用Puppeteer撸一个爬虫

Puppeteer是什么 puppeteer是谷歌chrome团队官方开发的一个无界面(Headless)chrome工具。Chrome Headless将成为web应用自动化测试的行业标杆。所以我们很有必要来了解一下它。所谓的无头浏...

小草先森 ⋅ 昨天 ⋅ 0

Java Done Right

* 表示难度较大或理论性较强。 ** 表示难度更大或理论性更强。 【Java语言本身】 基础语法,面向对象,顺序编程,并发编程,网络编程,泛型,注解,lambda(Java8),module(Java9),var(...

风华神使 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部