美文网首页
无标题文章

无标题文章

作者: 我只是旁白 | 来源:发表于2017-11-08 20:00 被阅读0次

    redis
    高性能
    可扩展
    内存存储
    key/value数据存储方式

    1 nosql概念
    NoSQL(not only sql)泛指非关系型的数据库。 由于传统的关系数据库在应付web2.0网站,特别是超大规模和高并发的网站,例如搜索引擎,微博,电商等等,暴露了很多难以克服的问题,例如,查询速度慢,扩展性差,不支持高并发等等。 NoSQL数据库是为了解决高并发、高可扩展、高可用、大数据存储问题而产生的解决方案。

    NoSQL特点
    数据保存在内存
    弹性扩展
    集群分片

    使用场景
    数据模型比较简单
    需要灵活性更强的IT系统
    对数据库性能要求较高
    不需要高度的数据一致性

    2 redis简介
    高性能
    可扩展
    内存存储
    key/value数据存储方式

    3 redis入门
    string(字符串)

    Some_Text

    hash(哈希)相对于HashMap

    Some_Text

    list(列表)相当于LinkedList

    Some_Text

    set(集合)相当于HashSet

    Some_Text

    zset( 有序集合 ) 相当于TreeSet

    Some_Text

    key操作

    Some_Text

    4 持久化简介
    为应对拉闸限电,系统当机等事故,redis使用持久化技术来避免灾难性后果。
    redis有两种持久化方法:RDB、AOF

    rdb方式
    rdb:在指定的时间间隔对数据进行快照存储
    数据保存在硬盘上的一个dump.rdb文件中,如果删除将失去备份
    rdb方式的配置参数在redis.conf中,具体请查看官方文档

    优点:速度快,并且异步执行,不影响正常功能
    缺点:间隔期间,若服务器异常,将有数据丢失

    aof方式
    aof:记录每次写操作,当服务器重启的时候会重新执行这些命令来恢复原始的数据
    优点:不会有数据丢失
    缺点:若备份指令很多,恢复数据很慢

    5 事务

    redis事务的3个指令
    multi开启事务
    exec提交事务
    watch监视某个键是否被修改,若在事务提交前有被其他客户端所改动,事务将失败

    java操作redis事务
    Jedis jedis=new Jedis("127.0.0.1", 6379); //开启事务 Transaction tx = jedis.multi(); //执行语句 tx.set("goodname", "裤子"); tx.set("goodprice", "100"); tx.get("goodname"); //提交事务,并且返回结果 List<Object> exec = tx.exec(); System.out.println(exec); jedis.close();

    6 订阅与发布


    Some_Text

    应用场景
    1、微博的关注与取消关注
    2、向主服务器获取任务,然后执行任务
    3、web聊天程序,例如webQQ

    7 redis主从
    一台主服务器,配置一台或者多台从服务器
    作用:数据备份、故障转移、读写分离


    Some_Text

    8 redis集群
    集群:多台服务器一起工作
    作用:提高存储容量,分布式计算,主从同步,故障转移


    Some_Text

    9 整合redis

    整合的原则
    redis服务在整个架构中充当缓存
    先从缓存获取数据,获取失败再从关系型数据库获取
    更新关系型数据库时,缓存也要更新或者删除
    redis不能影响正常的SSM工作

    步骤
    1、编写redis接口
    2、编写单机版RedisPool和集群版RedisCluster
    具体请看RedisPool和RedisCluster工具类
    3、在service层调用对应的方法
    public List<AppInfo> selectAppInfoList(){ //先查询缓存 String string = redisPool.hget(Const.APP_INFO_LIST, "appinfolist:"+userId); if(!StringUtils.isEmpty(string)){ System.out.println("-----------redis 获取缓存数据----------"); return JsonUtils.readValue(string, new TypeReference<List<AppInfo>>() {}); } //查询mysql数据库 AppInfoExample example=new AppInfoExample(); example.createCriteria().andUserIdEqualTo(userId); List<AppInfo> list = appInfoMapper.selectByExample(example); //将数据放入缓存 redisPool.hset(Const.APP_INFO_LIST, "appinfolist:"+userId,JsonUtils.toJSon(list)); System.out.println("-----------redis 存储缓存数据----------"); return list; }

    public int updateAppInfo(AppInfo appInfo){ int i = appInfoMapper.updateByPrimaryKeySelective(appInfo); if(i!=0){ //删除缓存中对应的数据 redisPool.hdel(Const.APP_INFO_LIST, "appinfolist:"+appInfo.getUserId()); } return i; }

    4、在配置文件中,注入JedisPool或者JedisCluster
    <bean class="redis.clients.jedis.JedisPool"> <constructor-arg name="host" value="127.0.0.1"/> <constructor-arg name="port" value="6379"/> </bean> <bean class="redis.clients.jedis.JedisCluster"> <constructor-arg name="nodes"> <set> <bean class="redis.clients.jedis.HostAndPort.HostAndPort"> <property name="host" value="172.16.32.49"/> <property name="port" value="7001"></property> </bean> <bean class="redis.clients.jedis.HostAndPort.HostAndPort"> <property name="host" value="172.16.32.49"/> <property name="port" value="7002"></property> </bean> </set> </constructor-arg> </bean>

    注意
    1、对象的存储,使用Jackson工具类将对象转成json,然后使用hash保存
    2、使用Jackson工具类将json转成对象
    3、具体使用情况请看JsonUtils工具类

    相关文章

      网友评论

          本文标题:无标题文章

          本文链接:https://www.haomeiwen.com/subject/ofmbpxtx.html