博客系统案例练习2-用户注册-redis

前言

用户注册

[请求]/user/register[参数]contentType: application/json{"userName":"wangwu","password":"456789","githubUrl": "https://gitee.com/bubble-fish666/spring-cloud","email": "bite666@126.com"}[响应]{"code": 200,"errMsg": null,"data": 3   //⽤⼾ID 
}

⽤⼾注册增加邮箱字段(数据设计阶段,提供的SQL已包含该部分内容)

我们先定义返回的类，然后是非空定义，长度校验

然后是定义接口，实现接口



那个类的转换部分非常的繁琐，我们可以优化一下
直接抽出来

这样直接调用就可以了

还要改的一个地方就是密码，要加密存储

这样写就可以了，因为我们有全局异常处理类的

邮箱校验和测试

用正则表达式
我们把正则表达式的校验都放在blog-comon里面的工具包里面

public class RegexUtil {/*** 匹配 邮箱：xxx@xx.xxx(形如：abc@qq.com)* ^ 表示匹配字符串的开始。* [a-z0-9]+ 表示匹配一个或多个小写字母或数字。* ([._\\-]*[a-z0-9])* 表示匹配零次或多次下述模式：一个点、下划线、反斜杠或短横线，后面跟着一个或多个小写字母或数字。这部分是可选的，并且可以重复出现。* @ 字符字面量，表示电子邮件地址中必须包含的"@"符号。* ([a-z0-9]+[-a-z0-9]*[a-z0-9]+.) 表示匹配一个或多个小写字母或数字，后面可以跟着零个或多个短横线或小写字母和数字，然后是一个小写字母或数字，最后是一个点。这是匹配域名的一部分。* {1,63} 表示前面的模式重复1到63次，这是对顶级域名长度的限制。* [a-z0-9]+ 表示匹配一个或多个小写字母或数字，这是顶级域名的开始部分。* $ 表示匹配字符串的结束。*/private static final String emailRegex = "^[a-z0-9]+([._\\\\-]*[a-z0-9])*@([a-z0-9]+[-a-z0-9]*[a-z0-9]+.){1,63}[a-z0-9]+$";/*** 进行简单校验, 为URL即可* https://gitee.com/bubble-fish666/* ^：匹配字符串的开始。* (https?)：匹配http或https。* :\/\/：匹配://。* ([a-zA-Z0-9.-]+)：匹配域名，可以包含字母、数字、点和破折号。* (:\d+)?：可选部分，匹配冒号和端口号。* (\/[^\s]*)?：可选部分，匹配斜杠和路径，路径中不包含空白字符。* (\?[^\s]*)?：可选部分，匹配查询参数，参数中不包含空白字符。* $：匹配字符串的结束。*/private static final String urlRegex = "^(https?):\\/\\/([a-zA-Z0-9.-]+)(:\\d+)?(\\/[^\\s]*)?(\\?[^\\s]*)?$";/*** 邮箱：xxx@xx.xxx(形如：abc@qq.com)** @param content* @return*/public static boolean checkMail(String content) {if (!StringUtils.hasText(content)) {return false;}return Pattern.matches(emailRegex, content);}public static boolean checkURL(String content) {if (!StringUtils.hasText(content)) {return false;}return Pattern.matches(urlRegex, content);}public static void main(String[] args) {System.out.println(checkMail("bite@126.com"));}
}

?表示前面元素0-1次
*表示前面元素0-n次
+表示前面元素1-n次
直接复制就可以这个代码就可以了
然后就是使用了

这样就OK了
可以测试了

我们这里对NotBlank这种注解抛出的异常，统一的处理都是参数校验失败，统一被MethodArgumentNotValidException捕获，如何打印出具体的内容呢
这个是可以实现的

这样就可以了

length的话，就不校验了
我们不为空就校验好了
然后开始校验用户名不能重复

url可以为空
这个也校验好了
这个的异常是blogExcetion，状态码是200，刚刚的参数校验不为空的状态码是400
这个都是可以自己设置的

这里改一下写错了，然后是校验email和url

这样就成功了

注意我们这里没有setId，但是却可以获得id，这个的原因主要就是

我们在这里设置了注解，这个注解就可以在插入成功以后自动填充这个类里面的主键，自动返回主键，type是为了让主键不要太乱

Redis介绍

介绍

在对于性能要求⽐较⾼的模块中,Redis作为⼀个缓存层,经常存储⼀些热点数据,减少数据库的读取压
⼒,提⾼数据访问速度

Redis 是⼀种基于键值对（key-value）的NoSQL数据库，与很多键值对数据库不同的是，Redis中的
值可以是由string（字符串）、hash（哈希）、list（列表）、set（集合）、zset（有序集合）、
Bitmaps（位图）、HyperLogLog、GEO（地理信息定位）等多种数据结构和算法组成，因此Redis
可以满⾜很多的应⽤场景.因为Redis会将所有数据都存放再内存中，所以它的读写性能⾮常惊⼈。不
仅如此，Redis还可以将内存的数据利⽤快照和⽇志的形式保存到硬盘上，这样在发⽣类似断电或者机
器故障的时候，内存中的数据不会“丢失”。除了上述功能以外，Redis还提供了键过期、发布订阅、
事务、流⽔线、Lua脚本等附加功能。总之，如果在合适的场景使⽤号Redis，它就会像⼀把瑞⼠军⼑
⼀样所向披靡。

2. Redis 的使⽤场景

2.1 缓存（Cache）
缓存机制⼏乎在所有⼤型⽹站都有使⽤，合理地使⽤缓存不仅可以加速数据的访问速度，⽽且能
够有效地降低后端数据源的压⼒。Redis提供了键值过期时间设置，并且也提供了灵活控制最⼤内存和
内存溢出后的淘汰策略。可以这么说，⼀个合理的缓存设计能够为⼀个⽹站的稳定保驾护航。
2.2 排⾏榜系统
排⾏榜系统⼏乎存在于所有的⽹站，例如按照热度排名的排⾏榜，按照发布时间的排⾏榜，按照
各种复杂维度计算出的排⾏榜，Redis提供了列表和有序集合的结构，合理地使⽤这些数据结构可以很
⽅便地构建各种排⾏榜系统。
2.3 计数器应⽤
计数器在⽹站中的作⽤⾄关重要，例如视频⽹站有播放数、电商⽹站有浏览数，为了保证数据的
实时性，每⼀次播放和浏览都要做加1的操作，如果并发量很⼤对于传统关系型数据的性能是⼀种挑
战。Redis天然⽀持计数功能⽽且计数的性能也⾮常好，可以说是计数器系统的重要选择。
2.4 社交⽹络
赞/踩、粉丝、共同好友/喜好、推送、下拉刷新等是社交⽹站的必备功能，由于社交⽹站访问量
通常⽐较⼤，⽽且传统的关系型数据不太合适保存这种类型的数据，Redis提供的数据结构可以相对⽐
较容易地实现这些功能。
2.5 消息队列系统
消息队列系统可以说是⼀个⼤型⽹站的必备基础组件，因为其具有业务解耦、⾮实时业务削峰等
特性。Redis提供了发布订阅功能和阻塞队列的功能，虽然和专业的消息队列⽐还不够⾜够强⼤，但是
对于⼀般的消息队列功能基本可以满⾜

redis命令操作

安装

#使⽤apt安装Redis 
apt install redis -y

命令

#查看Redis状态
systemctl status redis-server
#再按ctrl+c结束显示#启动redisservice redis-server start#停⽌redis服务
service redis-server stop#重启redis服务
service redis-server restart

# 使⽤以下命令启动redis客⼾端
redis-cli

6379就是redis的默认端口号
常⻅命令介绍:
SET key value
GET key
DEL key [key…]
EXISTS key [key…]
EXPIRE key seconds
KEYS pattern

set test aaa
get test
set test bbb
get test

重新设置就是更新值

del test

这个就是删除值

exists test

这个就是判断test是否存在

 set test2 ddd ex 20

这个表示有效时间为20s，ex是s的意思

ttl test2

表示这个key的有效时间为多少

变成-2表示就过期了

没有设置过期时间的话，就是永不过期，ttl=-1

set test3 eee
ttl test3
expire test3 30
ttl test3

expire 也是设置过期时间为30s

keys *

就是返回redis里面所有的key，一般不要用

官网

想了解什么命令，直接搜就可以了

springboot集成redis

在user-service中引入依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

然后是配置yml

spring:data:redis:host: 139.159.230.105port: 6379timeout: 60s #连接空闲超过N(s秒、ms毫秒)后关闭，0为禁用，这里配置值和tcp-keepalive值一致lettuce:pool:max-active: 8  #允许最大连接数max-idle: 8 #最大空闲连接数, 默认8min-idle: 0  #最小空闲连接数max-wait: 5s  #请求获取连接等待时间

test测试

我们对这个直接运行
然后就报错了

根本就没有链接上
因为端口号6379没有开放,或者是redis没有启动
我们不建议开放这个端口号
我们可以通过隧道的方式来链接
xshell中

点这个

点击属性
然后是隧道-》添加

这个监听端口是没有使用的端口号
就是监听一个端口号，映射到我们的6379端口号，这样就不用开放了

就是这个意思
配置隧道之后，要重新连接云服务器

这个的意思就是我访问本地的6379就是转移到云服务器上的6379

所以我们把配置改成本地的6379
重新运行

这样就成功了

redis客户端

我们不使用小黑框框了，我们用好看的应用软件来远程控制redis
官网下载

然后点这个

我们这个建立连接的方式是通过隧道的方式，所以写的是127.0.0.1

这样就是链接成功了

这个是redis控制台，可以输入命令

插件操控redis

在File->Settings->Plugins->搜索Redis Helper插件

这里就多了一个控制的
然后加号，添加链接

右键加载

redis默认有16个DB，默认会在DB0里面放数据

这里也可以选择DB

右键这个控制台

可以输入代码

然后是双击DB也可以得到数据

Redis工具类分装

就是用户登录的时候，要从数据库中获取信息，现在从redis中获取
在⽤⼾登录后,可以将⽤⼾的信息存储在Redis中,当需要获取⽤⼾信息时,可以直接从Redis中获取,⽽不需要每次都查询数据库,这样可以加快数据的读取速度,减少数据库的压⼒.

查询用户就看redis里面有没有，没有的话，就去数据库查
更新用户的时候，就更新数据库和redis
删除用户就是删除数据库和删除redis
数据库和redis要一致性，分布式事务–》以后再说

我们直接写一个工具包
先在blog-common里面引入依赖

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>

但是这个StringRedisTemplate必须要Autowired注入才可以使用，这个已经是bean了的
但是使用Autowired，又必须把Redis这个类注入bean中，所以就要加上Configuration，但是另外的user-service扫描不到啊，这个也不是那个feign
我们可以在user-service中传入我们已经Autowired好的StringRedisTemplate，这样就可以在blog-common里面使用StringRedisTemplate了，而且都是spring中的同一个StringRedisTemplate

这样就可以了，然后就可以分装工具了

这个工具包以后直接复制就可以了

注意我们的set方法可以自带过期时间的，这个是原码
默认是s，其次是毫秒

这样我们的工具类就写好了
然后开始使用
我们可以把Redis这个类交给spring进行管理，注入外部类的方法
就是在user-serivce里面注入外部类，而不是在外部类里面声明为bean，注入bean

在user-serivce里面注入外部类，把外部类注入为bean，就要使用Configuration，和bean注解了

这样我们就把redis搞入bean了，这个参数StringRedisTemplate 是自动Autowired的了，所以我们不用再单独写注解Autowired去注入StringRedisTemplate 了，而且还是已经自动bean了的，自动注入的了，这个是自动注入bean的，我们弄为·参数，就是自动Autowired

测试一下发生了异常
我们打印一下异常的日志

在测试一下，发现错误就是不能连接上redis
原因就是隧道关闭了，隔一段时间就会关闭的，这个隧道
直接连上云服务器就可以了，开启客户端就可以看有没有连上了


或者左边有一个小圆圈圈的话，就是开启了隧道的

这样就成功了

spring自动装配redis

如果我们的blog-serice要想使用redis的话

也要加上这个代码
可以写在blog-comomn里面吗

我们挪到这里，把原来user-service里面的这个config删掉
但是这样不能运行的

因为autowired的时候找不到redis这个bean

因为spring装配扫描的时候，只会扫描启动类所在目录下的，如果想要扫描其他地方的，要加上注解了

加上注解ComponentScan
或者Import

我们讲一个新的方法

我们希望把Redis自动弄为bean，我们就不管了
先搞个文件夹
双击shift
搜索这个AutoConfigurationImportSelector

找到这个，然后创建对应文件

这个里面配置我们希望交给spring管理的对象

这样就可以交给spring管理了

这个的意思就是和StringRedisTemplate 一样的了
只要你在一个包user-servicec里面引入了blog-common的依赖，那么就会去扫描Redisconfig，然后把里面的Redis这个类自动加入bean
所以再也不用在自己配置手动把外面的Redis加入自己的bean了，只有你引入依赖，就会自动装入bean

这样就可以了

所以有很多的方法，在自己模块的spring里面把别人的类，加入成自己的bean
第一就是注解Configuration和注解Bean，当然这个也可以把自己的类注入为自己的bean
但是把自己的类注入为自己的bean，还可以注解service和controller那些，很多的
第二就是启动类那里加上注解加上注解ComponentScan或者Import
第三就是在外部的地方，按照这个AutoConfigurationImportSelector的处理方法，使引入外部依赖的时候，就自动把外部配置好的类，自动注入bean

文件路径是META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

但是第三个方法的缺点就是，我引入了blog-common的依赖，不管我们需不需要Redis这个类，都会注入为bean
我们的要求是要使用redis，注入进来，不使用的话，就不要注入进来，虽然我们引入了blog-common的依赖

怎么弄呢

@Conditional讲解

@Conditional
是Spring框架从4.0版本开始引⼊的⼀个注解，它允许开发者根据特定的条件来控制Bean的注册.⼀般与@Configuration 和@Bean 配合使⽤。简单说，Spring在解析@Configuration 配置类的时候，如果该配置类增加了@Conditional 注解，那么会根据该注解配置的条件来决定是否要实现Bean的装配.
注解Conditional就是满足一定条件的时候才会注入这个bean
我们直接用一个测试方法来理解这个注解
因为加上了SpringBootTest注解，所以这个测试类也是可以交给spring进行管理的

这样的话，JDK17和JDK21也注入到spring里面了
而且因为一定会注入bean，所以肯定也会打印信息，运行的时候

但是我们现在希望只要使用了才注入对应的bean
就要用Conditional了

记得选择这个

这样我们就写了JDk的两个判断条件

如果Jdk17Conditional.class 返回true，则创建JDK17对象,则注入bean
这样就可以了

我们看到运行结果只有17了
但是类似于这个的conditional的注解还有很多

@ConditionalOnBean
当容器中存在指定的Bean时,使⽤这个注解的配置类或Bean⽅法才会⽣效

@ConditionalOnMissingBean
与@ConditionalOnBean 相反，只有当容器中不存在指定的Bean时，才会注册使⽤这个注解的Bean如果 DependencyBean 不存在， MyBean 会被注册。

@ConditionalOnClass
当类路径上存在指定的类时，使⽤这个注解的配置类或Bean⽅法才会⽣效.如果 DependencyClass 存在于类路径上，MyBean 会被注册

@ConditionalOnMissingClass
当类路径上存在指定的类时，使⽤这个注解的配置类或Bean⽅法才会⽣效.如果D ependencyClass 不存在于类路径上， MyBean 会被注册

@ConditionalOnProperty：
这个注解允许基于配置⽂件中的属性值来注册Bean.你可以指定属性的名称和期望的值,如果配置的属性存在且匹配指定的值,则相应的Bean会被注册如果m y.property 的值是 true ，则MyBean 会被注册

我们看redis对应bean的原码就知道了
我们现在再来解决问题

我们用注解ConditionalOnProperty，这样的话，就会去看配置文件，如果配置文件中有相关信息，就会引入依赖就配置这个bean

这个是原码，havingValue是值

@ConditionalOnProperty(prefix = “spring.data.redis”, name = “host”)
这样写的意思就是配置文件中要有spring.data.redis，中要有host

这样就可以了

fastjson讲解

现在就讲一下用户信息如何在redis中存储


Redis格式定义:
key设置为:user:zhangsan
为了避免键名冲突,通常会为key添加命名空间前缀,这个前缀通常反映了键的⽤途或归属,⽐如
user: session: product: 等
value设置为⽤⼾信息的Json字符串

就是这样的

JSON⼯具类
Jackson，Gson，Fastjson

Jackson 是⼀个开源的JSON处理库,⼴泛⽤于将Java对象与JSON数据进⾏互相转换,Jackson是
Spring 框架的默认JSON解析器,拥有活跃的社区⽀持和频繁的更新迭代，所以用这个，不用引入依赖

ObjectMapper mapper = new ObjectMapper();String jsonString = mapper.writeValueAsString(yourObject);YourClass obj = mapper.readValue(jsonString, YourClass.class);

Gson是Google开发的⼀个JSON库`

 Gson gson = new Gson();String json = gson.toJson(yourObject);YourClass obj = gson.fromJson(json, YourClass.class);

Fastjson 是阿⾥巴巴开源的JSON处理库,具有⾼性能的特点.

String jsonString = JSON.toJSONString(yourObject);YourClass obj = JSON.parseObject(jsonString, YourClass.class);

我们用Fastjson

先引入依赖

用这个的

<dependency><groupId>com.alibaba.fastjson2</groupId><artifactId>fastjson2</artifactId><version>2.0.53</version></dependency>

我们把Json的转换也搞到一个公共包里面

然后再blog-common添加依赖

这样就分装完成了

用户注册

注册用户，然后存储数据库，存储redis
原：

    @Autowiredprivate Redis redis;

直接注入redis

    private static final long EXPIRE_TIME = 141 * 24 * 60 * 60;private static final String USER_PREFIX = "user";

这个是过期时间和常量

然后书写buildKey方法
我们把这个方法写在blog-common中的redis中

然后调用就可以了

数据一致性方案介绍

查询用户的时候，第一用户登录的时候，用用户名查询用户信息
或者用户主页的时候，用用户id查询用户信息（自己扩展）

就是用户登录的逻辑要改变了

我们登录的时候，先从缓存中获取信息，缓存中没有的话，再从数据库中获取信息，在存入缓存

原：

现在：

因为redis有链接问题，所以要有很多的判断
然后是redis还有数据一致性问题，与mysql数据一致性

我们先测试一下

我们看到还多了一个文件夹user
然后是登录

这里还有日志

我们删掉redis对应信息


这样就成功了
所以要时刻打印日志，这样就不用调试了

数据一致性

在更新删除的时候存在这个问题

mysql中存储的数据和redis中存储数据不一样，这个就是一致性问题

万一删除失败呢

那就再次删除，两次都删除失败的概率就很低了

意思就是删除一次，后面一段时间再删除一次
方法二：就是异步更新，基于消息队列

方法三：mysql的binlog订阅同步功能（用得少）

总结