Redis的使用和常遇问题

╰半橙微兮° 2022-03-25 01:06 178阅读 0赞

### 文章目录 ###

*  一、Redis的安装
 *  二、Redis的使用
 *  三、Redis做分布式锁
 *  四、Redis与数据库数据一致性问题
 *  五、解决表单重复提交问题

# 一、Redis的安装 #

1、安装C语言编译环境：`yum install -y gcc-c++`

2、解压`reids`：`tar -zxvf redis-4.0.2.tar.gz -C /opt`

3、修改`redis`编译后的路径(修改解压目录`src/Makefile`):  
`PREFIX?=/usr/local/redis`

4、编译：进去`redis`的解压目录:`make install`

5、定制配置项启动

复制`redis.conf`：`cp /opt/redis-4.0.2/redis.conf /usr/local/redis/`;

修改配置项：

<table> 
 <thead> 
  <tr> 
   <th>配置项名称</th> 
   <th>作用</th> 
   <th>取值</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td><code>daemonize</code></td> 
   <td>控制是否以守护进程形式运行<code>redis</code>服务器</td> 
   <td><code>yes</code></td> 
  </tr> 
  <tr> 
   <td><code>logfile</code></td> 
   <td>指定日志文件位置</td> 
   <td><code>"/var/logs/redis.log"</code></td> 
  </tr> 
  <tr> 
   <td><code>dir</code></td> 
   <td><code>redis</code>工作目录</td> 
   <td><code>/usr/local/redis</code></td> 
  </tr> 
  <tr> 
   <td><code>protected-mode</code></td> 
   <td>关闭保护,这样才能远程访问</td> 
   <td><code>no</code></td> 
  </tr> 
 </tbody> 
</table>

注释掉`#bind 127.0.0.1`

# 二、Redis的使用 #

1、启动`redis`服务

`./redis-server ../redis-conf`

2、引入`reids`客户端

<dependency>
    	<groupId>redis.clients</groupId>
    	<artifactId>jedis</artifactId>
    </dependency>

**3、在`application.properties`配置`redis`**

spring.redis.host=192.168.163.211
    spring.redis.port=6379
    spring.redis.database=0

**3、编写`ReidsUtil`工具类**

public class RedisUtil { 
    
        private JedisPool jedisPool;
    
        public void initPool(String host,int port ,int database){ 
            JedisPoolConfig poolConfig = new JedisPoolConfig();
            poolConfig.setMaxTotal(200);
            poolConfig.setMaxIdle(30);
            poolConfig.setBlockWhenExhausted(true);
            poolConfig.setMaxWaitMillis(10*1000);
            poolConfig.setTestOnBorrow(true);
            jedisPool=new JedisPool(poolConfig,host,port,20*1000);
        }
    
        public Jedis getJedis(){ 
            Jedis jedis = jedisPool.getResource();
            return jedis;
        }
    }

**4、编写`RedisConfig`配置类同时将`RedisUtil`注入到容器中**

@Configuration
    public class RedisConfig { 
    
        //读取配置文件中的redis的ip地址
        @Value("${spring.redis.host:disabled}")
        private String host;
    
        @Value("${spring.redis.port:0}")
        private int port;
    
        @Value("${spring.redis.database:0}")
        private int database;
    
        @Bean
        public RedisUtil getRedisUtil(){ 
            if(host.equals("disabled")){ 
                return null;
            }
            RedisUtil redisUtil=new RedisUtil();
            redisUtil.initPool(host,port,database);
            return redisUtil;
        }
    }

**5、`redis`的使用**

@Override
    public SkuInfo item(String skuId) { 
        SkuInfo skuInfo = null;
        //从缓存中取出sku的数据
        Jedis jedis = redisUtil.getJedis();
        String skuInfoStr = jedis.get("sku:" + skuId + ":info");
    
        skuInfo = JSON.parseObject(skuInfoStr, SkuInfo.class);
        //如果缓存中没有数据时，则去访问数据库
        if (skuInfo == null) { 
    
            //设置分布式锁(在Redis缓存在高并发下宕机后，为了防止多请求访问数据库导致数据库宕机，则设置分布式锁)
            String OK = jedis.set("sku:" + skuId + ":lock", "1", "nx");
            //如果返回的OK为null的话则存在分布式锁，如果不为null，则设置分布式锁成功
            if (StringUtils.isBlank(OK)){ 
                //分布式锁被占用，设置一定时间线程睡眠时间，等时间过后再次请求
                try { 
                    Thread.sleep(3000);
                } catch (InterruptedException e) { 
                    e.printStackTrace();
                }
                //自旋(递归的访问过程，不会开启新的线程)
                return item(skuId);
            }else { 
                //拿到分布式锁，可以访问数据库
                skuInfo = itemFromDB(skuId);
            }
            jedis.del("sku:" + skuId + ":lock");
            //同步缓存到Redis
            jedis.set("sku:" + skuId + ":info", JSON.toJSONString(skuInfo));
        }
        jedis.close();
        return skuInfo;
    }

**6、`redis`中`Key`的命名规范**

由于`redis`不像数据库那样有结构，其所以的数据全靠`key`进行索引，所以`redis`数据的可读性全依靠`key`.  
企业中最常用的方式就是：`object:id:field`  
比如：`sku:1314:info`; `user:1092:password`;

# 三、Redis做分布式锁 #

通过`UUID`生成一个唯一值，然后通过`setnx`将该值存入到`redis`中(可以设置过期时间)，这样就设置了分布式锁。如何解锁呢？通过`UUID`的值和`redis`中的值进行比较，如果相同，则删除`redis`中的该值，就释放了锁。

public String func(Integer id,String str){
    	//px为毫秒 ex为秒
        String OK = jedis.set("item:" + id + ":lock", UUID.randomUUID(), "nx", "px", 10000);
        if(StringUtils.isBlank(OK)){
            //自旋
            TimeUnit.SECONDS.sleep(10);
            //执行一次
            return func(id,str);
        }else{
            //执行业务操作
            ......
        }
        jedis.del("item:" + id + ":lock")
    }

# 四、Redis与数据库数据一致性问题 #

`redis`和`mysql`数据同步是先删`redis`后写`mysql`还是先写`mysql`后删`redis`?

这两种方式均会出现数据不一致问题。因为写和读是并发的，没法保证顺序，如果删了缓存，还没来得及写库，另一个线程就来读取，发现缓存为空，则去数据库汇总读取数据写入缓存，此时缓存中为脏数据；如果先写库后删缓存，如果删缓存的线程宕机没有删除掉缓存，此时也会出现数据不一致的问题。如果是`redis`集群，主从复制模式在复制的过程中存在一定的时间延迟，也会导致数据不一致问题。

**【解决方案】**：优先考虑先写入数据库，在一定的情况下可以允许数据缓存有误差，但是比如在结算等重要步骤时不允许数据不一致，此时应该进行数据一致性校验，校验成功后才能进行操作。

# 五、解决表单重复提交问题 #

在第一次跳转都页面时，生成一个唯一的标识符（`uuid`），将它存入session，同时将它写入表单的隐藏字段中，然后将表单页面发送给浏览器，用户录入信息后点击提交，在服务器端，获取表单中隐藏字段的值，与session中的唯一标识符比较，相等说明是首次提交，就处理本次请求，然后将session中的唯一标识符移除。不相等说明是重复提交，就不再处理。