• 20：第三章：开发通行证服务：3：在程序中，打通redis服务器；（仅仅是打通redis服务器，不涉及具体的业务开发）

    说明：

    （1）本篇博客需要注意的点：

              ● 本篇博客仅仅是打通redis服务（也就是我们的程序，可以操作redis服务器），不涉及【redis服务，在项目中的具体应用】，也不涉及【具体业务的开发】；

              ● 其中遇到了一款不错的redis图形化工具：rdm（Redis Desktop Manager）工具，感觉不错；

              ● redis服务，作为一个第三方的“工具”，我们把其写在了【imooc-news-dev-common】通用工程中；

    （2）有关Redis的内容，如有需要可以参考【（13）Linux基础】、【（14）Redis】专栏中的内容；

    目录

    一：我们这个项目，为什么需要用到redis；

    二：安装redis、redis简介；

    三：在项目中，整合redis，打通redis服务器；

    1.在【imooc-news-dev-common】通用工程中，引入redis等相关依赖；

    2.在【imooc-news-dev-common】通用工程中，创建一个操作redis的工具类；

    3.在【imooc-news-dev-user】这个（实际需要使用到redis的）用户微服务中，在application*.yml配置文件中去配置redis服务的url、密码等信息；

    4.在【imooc-news-dev-user】这个（实际需要使用redis的）用户微服务中，在HelloController中，编写代码，以测试“我们的程序，是否可以连上redis”；

    5.测试；

    一：我们这个项目，为什么需要用到redis；

    （1）生成验证码后，验证码是需要发给用户的；；；用户把收到的验证码在前端输入，就会进入后端验证；；；即，在后端，我们要把这个原生的验证码进行存储；；；而，对于分布式微服务项目，我们一般会存放在redis中（而不会像单体应用中那样，存在session中）；

    二：安装redis、redis简介；

    如有需要可以参考【（13）Linux基础】、【（14）Redis】专栏中的内容；

    同时，在【Spring Boot电商项目31：商品分类模块十：利用Redis缓存加速响应；】这个Spring Boot项目中，也用到过redis；

    我们这儿，就使用在【Redis入门二：Linux系统下安装Redis；】中，创建的那台虚拟机中安装的redis了；

    （1）把下载的包，上传到Linux系统，似乎可以借助FileZill工具；（自己没用过，自己用的是Xftp）

    （2）命令行工具，也可以使用SecureCRT；（自己没用过，自己用的是Xshell）

    （3）可以使用【rdm（Redis Desktop Manager）工具】这款redis可视化工具，来辅助开发；

              ● rdm的下载安装，可以参考【Redis Desktop Manager(Redis可视化工具)安装及使用教程】；

    三：在项目中，整合redis，打通redis服务器；

    1.在【imooc-news-dev-common】通用工程中，引入redis等相关依赖；

    1.  <!-- 引入 redis 依赖 -->
    2.         <dependency>
    3.             <groupId>org.springframework.boot</groupId>
    4.             <artifactId>spring-boot-starter-data-redis</artifactId>
    5.             <!--<version>2.1.5.RELEASE</version>-->
    6.         </dependency>
    7.  
    8.         <!--okhttp依赖.作用是，服务与服务之间发送rest请求-->
    9.         <dependency>
    10.             <groupId>com.squareup.okhttp3</groupId>
    11.             <artifactId>okhttp</artifactId>
    12.         </dependency>
    13.  
    14.         <!-- jackson三件套 -->
    15.         <dependency>
    16.             <groupId>com.fasterxml.jackson.core</groupId>
    17.             <artifactId>jackson-core</artifactId>
    18.         </dependency>
    19.         <dependency>
    20.             <groupId>com.fasterxml.jackson.core</groupId>
    21.             <artifactId>jackson-annotations</artifactId>
    22.         </dependency>
    23.         <dependency>
    24.             <groupId>com.fasterxml.jackson.core</groupId>
    25.             <artifactId>jackson-databind</artifactId>
    26.         </dependency>
    27.  
    28.         <!-- apache 工具类
    29.         【commons-codec】是apache提供的数据的编码/解码组件，可以使用【Commons Codec】来实现MD5的；
    30.         【commons-lang3】是Apache提供的一个java.lang包的增强版本，Lang3为java.lang API提供了许多帮助程序实用程序，特别是字符串操作方法，基本数值方法，对象反射，并发，创建和序列化以及系统属性。
    31.         【commons-fileupload】是一款apache提供的文件上传组件；
    32.         -->
    33.         <dependency>
    34.             <groupId>commons-codec</groupId>
    35.             <artifactId>commons-codec</artifactId>
    36.         </dependency>
    37.         <dependency>
    38.             <groupId>org.apache.commons</groupId>
    39.             <artifactId>commons-lang3</artifactId>
    40.         </dependency>
    41.         <dependency>
    42.             <groupId>commons-fileupload</groupId>
    43.             <artifactId>commons-fileupload</artifactId>
    44.         </dependency>
    45.  
    46.         <!-- google 工具类 -->
    47.         <dependency>
    48.             <groupId>com.google.guava</groupId>
    49.             <artifactId>guava</artifactId>
    50.         </dependency>
    51.  
    52.         <!-- joda-time 时间工具，一个时间工具类 -->
    53.         <dependency>
    54.             <groupId>joda-time</groupId>
    55.             <artifactId>joda-time</artifactId>
    56.         </dependency>

    说明： 

    （1）对这些依赖，如果有不清楚的，可以参考【9：第二章：架构后端项目：5：【聚合工程】简介；创建顶级父工程；】；

    （2）还是那句话，根据我们的分布式微服务项目，各个module的分工和关系；；；edis服务，作为一个第三方的“工具”，我们把其写在了【imooc-news-dev-common】通用工程中；

    2.在【imooc-news-dev-common】通用工程中，创建一个操作redis的工具类；

    RedisOperator工具类：

    1. package com.imooc.utils;
    2.  
    3.  
    4. import org.springframework.beans.factory.annotation.Autowired;
    5. import org.springframework.dao.DataAccessException;
    6. import org.springframework.data.redis.connection.RedisConnection;
    7. import org.springframework.data.redis.connection.StringRedisConnection;
    8. import org.springframework.data.redis.core.RedisCallback;
    9. import org.springframework.data.redis.core.StringRedisTemplate;
    10. import org.springframework.stereotype.Component;
    11.  
    12. import java.util.List;
    13. import java.util.Map;
    14. import java.util.Set;
    15. import java.util.concurrent.TimeUnit;
    16.  
    17. /**
    18.  * @Title: Redis 工具类
    19.  * @author 风间影月
    20.  */
    21. @Component
    22. public class RedisOperator {
    23.  
    24.     @Autowired
    25.     private StringRedisTemplate redisTemplate;
    26.  
    27.     // Key（键），简单的key-value操作
    28.  
    29.     /**
    30.      * 判断key是否存在
    31.      * @param key
    32.      * @return
    33.      */
    34.     public boolean keyIsExist(String key) {
    35.         return redisTemplate.hasKey(key);
    36.     }
    37.  
    38.     /**
    39.      * 实现命令：TTL key，以秒为单位，返回给定 key的剩余生存时间(TTL, time to live)。
    40.      *
    41.      * @param key
    42.      * @return
    43.      */
    44.     public long ttl(String key) {
    45.         return redisTemplate.getExpire(key);
    46.     }
    47.  
    48.     /**
    49.      * 实现命令：expire 设置过期时间，单位秒
    50.      *
    51.      * @param key
    52.      * @return
    53.      */
    54.     public void expire(String key, long timeout) {
    55.         redisTemplate.expire(key, timeout, TimeUnit.SECONDS);
    56.     }
    57.  
    58.     /**
    59.      * 实现命令：increment key，增加key一次
    60.      *
    61.      * @param key
    62.      * @return
    63.      */
    64.     public long increment(String key, long delta) {
    65.         return redisTemplate.opsForValue().increment(key, delta);
    66.     }
    67.  
    68.     /**
    69.      * 实现命令：decrement key，减少key一次
    70.      *
    71.      * @param key
    72.      * @return
    73.      */
    74.     public long decrement(String key, long delta) {
    75.         return redisTemplate.opsForValue().decrement(key, delta);
    76.     }
    77.  
    78.     /**
    79.      * 实现命令：KEYS pattern，查找所有符合给定模式 pattern的 key
    80.      */
    81.     public Set<String> keys(String pattern) {
    82.         return redisTemplate.keys(pattern);
    83.     }
    84.  
    85.     /**
    86.      * 实现命令：DEL key，删除一个key
    87.      *
    88.      * @param key
    89.      */
    90.     public void del(String key) {
    91.         redisTemplate.delete(key);
    92.     }
    93.  
    94.     // String（字符串）
    95.  
    96.     /**
    97.      * 实现命令：SET key value，设置一个key-value（将字符串值 value关联到 key）
    98.      *
    99.      * @param key
    100.      * @param value
    101.      */
    102.     public void set(String key, String value) {
    103.         redisTemplate.opsForValue().set(key, value);
    104.     }
    105.  
    106.     /**
    107.      * 实现命令：SET key value EX seconds，设置key-value和超时时间（秒）
    108.      *
    109.      * @param key
    110.      * @param value
    111.      * @param timeout
    112.      *            （以秒为单位）
    113.      */
    114.     public void set(String key, String value, long timeout) {
    115.         redisTemplate.opsForValue().set(key, value, timeout, TimeUnit.SECONDS);
    116.     }
    117.  
    118.     /**
    119.      * 如果key不存在，则设置，如果存在，则报错
    120.      * @param key
    121.      * @param value
    122.      */
    123.     public void setnx60s(String key, String value) {
    124.         redisTemplate.opsForValue().setIfAbsent(key, value, 60, TimeUnit.SECONDS);
    125.     }
    126.  
    127.     /**
    128.      * 如果key不存在，则设置，如果存在，则报错
    129.      * @param key
    130.      * @param value
    131.      */
    132.     public void setnx(String key, String value) {
    133.         redisTemplate.opsForValue().setIfAbsent(key, value);
    134.     }
    135.  
    136.     /**
    137.      * 实现命令：GET key，返回 key所关联的字符串值。
    138.      *
    139.      * @param key
    140.      * @return value
    141.      */
    142.     public String get(String key) {
    143.         return (String)redisTemplate.opsForValue().get(key);
    144.     }
    145.  
    146.     /**
    147.      * 批量查询，对应mget
    148.      * @param keys
    149.      * @return
    150.      */
    151.     public List<String> mget(List<String> keys) {
    152.         return redisTemplate.opsForValue().multiGet(keys);
    153.     }
    154.  
    155.     /**
    156.      * 批量查询，管道pipeline
    157.      * @param keys
    158.      * @return
    159.      */
    160.     public List<Object> batchGet(List<String> keys) {
    161.  
    162. //		nginx -> keepalive
    163. //		redis -> pipeline
    164.  
    165.         List<Object> result = redisTemplate.executePipelined(new RedisCallback<String>() {
    166.             @Override
    167.             public String doInRedis(RedisConnection connection) throws DataAccessException {
    168.                 StringRedisConnection src = (StringRedisConnection)connection;
    169.  
    170.                 for (String k : keys) {
    171.                     src.get(k);
    172.                 }
    173.                 return null;
    174.             }
    175.         });
    176.  
    177.         return result;
    178.     }
    179.  
    180.  
    181.     // Hash（哈希表）
    182.  
    183.     /**
    184.      * 实现命令：HSET key field value，将哈希表 key中的域 field的值设为 value
    185.      *
    186.      * @param key
    187.      * @param field
    188.      * @param value
    189.      */
    190.     public void hset(String key, String field, Object value) {
    191.         redisTemplate.opsForHash().put(key, field, value);
    192.     }
    193.  
    194.     /**
    195.      * 实现命令：HGET key field，返回哈希表 key中给定域 field的值
    196.      *
    197.      * @param key
    198.      * @param field
    199.      * @return
    200.      */
    201.     public String hget(String key, String field) {
    202.         return (String) redisTemplate.opsForHash().get(key, field);
    203.     }
    204.  
    205.     /**
    206.      * 实现命令：HDEL key field [field ...]，删除哈希表 key 中的一个或多个指定域，不存在的域将被忽略。
    207.      *
    208.      * @param key
    209.      * @param fields
    210.      */
    211.     public void hdel(String key, Object... fields) {
    212.         redisTemplate.opsForHash().delete(key, fields);
    213.     }
    214.  
    215.     /**
    216.      * 实现命令：HGETALL key，返回哈希表 key中，所有的域和值。
    217.      *
    218.      * @param key
    219.      * @return
    220.      */
    221.     public Map<Object, Object> hgetall(String key) {
    222.         return redisTemplate.opsForHash().entries(key);
    223.     }
    224.  
    225.     // List（列表）
    226.  
    227.     /**
    228.      * 实现命令：LPUSH key value，将一个值 value插入到列表 key的表头
    229.      *
    230.      * @param key
    231.      * @param value
    232.      * @return 执行 LPUSH命令后，列表的长度。
    233.      */
    234.     public long lpush(String key, String value) {
    235.         return redisTemplate.opsForList().leftPush(key, value);
    236.     }
    237.  
    238.     /**
    239.      * 实现命令：LPOP key，移除并返回列表 key的头元素。
    240.      *
    241.      * @param key
    242.      * @return 列表key的头元素。
    243.      */
    244.     public String lpop(String key) {
    245.         return (String)redisTemplate.opsForList().leftPop(key);
    246.     }
    247.  
    248.     /**
    249.      * 实现命令：RPUSH key value，将一个值 value插入到列表 key的表尾(最右边)。
    250.      *
    251.      * @param key
    252.      * @param value
    253.      * @return 执行 LPUSH命令后，列表的长度。
    254.      */
    255.     public long rpush(String key, String value) {
    256.         return redisTemplate.opsForList().rightPush(key, value);
    257.     }
    258.  
    259. }

    说明：

    （1）这个工具类，不是我写的；；里面定义了很多操作redis的方法；可以大略的瞅一瞅；

    （2）有关java操作redis的内容，如有需要可以先参考下【（14）Redis】专栏中的内容；

    3.在【imooc-news-dev-user】这个（实际需要使用到redis的）用户微服务中，在application*.yml配置文件中去配置redis服务的url、密码等信息；

    4.在【imooc-news-dev-user】这个（实际需要使用redis的）用户微服务中，在HelloController中，编写代码，以测试“我们的程序，是否可以连上redis”；

    5.测试；

    （1）首先，整个项目全局install一下；

    （2）然后，启动【user】的主启动类；

    （3）然后，访问【user】的【"/redis"】接口；

    至此，我们的redis就好了，也就是我们的项目是可以连接到redis服务器了；

  • 相关阅读:
    C++进阶之继承详解
    十九 两周记(11.14-11.27)
    在X11图形环境下开启/关闭勿扰模式及其背后机制
    链表反转类算法题
    分割等和子集
    03-迭代器生成器
    微信公众号h5写一个全局调用微信分享功能
    Linux 查看日志
    Linux中的日志
    Google I/O 2023 - Dart 3 发布，快来看看有什么更新吧
  • 原文地址：https://blog.csdn.net/csucsgoat/article/details/125466931