HRM项目Day02-课程类型菜单树、集成redis缓存
1. 课程类型的菜单树展示
domain
@TableName("t_course_type")
public class CourseType extends Model<CourseType> {
private static final long serialVersionUID = 1L;
@TableId(value = "id", type = IdType.AUTO)
private Long id;
private Long createTime;
private Long updateTime;
/**
* 存放子分类
*/
@TableField(exist = false) //数据库不存在的字段
private List<CourseType> children = new ArrayList<>();
/**
* 类型名
*/
private String name;
/**
* 父ID
*/
private Long pid;
/**
* 图标
*/
private String logo;
/**
* 描述
*/
private String description;
private Integer sortIndex;
/**
* 路径
*/
private String path;
/**
* 课程数量
*/
private Integer totalCount;
public List<CourseType> getChildren() {
return children;
}
...
}
@TableField(exist = false) mybatis-plus中的注解表示数据库中没有该字段,为临时属性。
service实现类中:
查询所有类型,手动封装成结构树,思路:先查询顶级节点(pid==0),在查询所有的子节点,通过每一个子节点去找到对应的父节点!
public List<CourseType> treeData() {
//1. 从数据库中查询出所有的数据
List<CourseType> allCourseTypes = baseMapper.selectList(null);
//2. pid==0的作为顶层节点
List<CourseType> topNode = new ArrayList<>();
for (CourseType everyCourseType : allCourseTypes) {
if(everyCourseType.getPid().longValue()==0){
topNode.add(everyCourseType);
}else{
//3. 不是顶层节点,每一个节点去寻找对应的父节点
CourseType currentParentNode = null;
for (CourseType tempNode : allCourseTypes) {
if(everyCourseType.getPid().longValue()==tempNode.getId().longValue()){
currentParentNode = tempNode;
break;
}
}
//4.把子节点添加到父节点中
if (currentParentNode!=null){
currentParentNode.getChilderen().add(everyCourseType);
}
}
}
return topNode;
}
2. 解决跨源请求
在zuul网关中配置
@Configuration
public class GlobalCorsConfig {
@Bean
public CorsFilter corsFilter() {
//1.添加CORS配置信息
CorsConfiguration config = new CorsConfiguration();
//1) 允许的域,不要写*,否则cookie就无法使用了
config.addAllowedOrigin("http://127.0.0.1:6001");
config.addAllowedOrigin("http://localhost:6001");
//2) 是否发送Cookie信息
config.setAllowCredentials(true);
//3) 允许的请求方式
config.addAllowedMethod("OPTIONS");
config.addAllowedMethod("HEAD");
config.addAllowedMethod("GET");
config.addAllowedMethod("PUT");
config.addAllowedMethod("POST");
config.addAllowedMethod("DELETE");
config.addAllowedMethod("PATCH");
// 4)允许的头信息
config.addAllowedHeader("*");
//2.添加映射路径,我们拦截一切请求
UrlBasedCorsConfigurationSource configSource = new
UrlBasedCorsConfigurationSource();
configSource.registerCorsConfiguration("/**", config);
//3.返回新的CorsFilter.
return new CorsFilter(configSource);
}
}
2. 课程类型集成Redis
1.为什么要做缓存?
因为查询的频率高,且数据不易改变,可以用redis做缓存,提高读的效率!
2.为什么要用redis做缓存
redis作为一个中央缓存,可以作为一个独立的服务,相较于mybatis的缓存,它不用集成到项目中,不会在项目中抢占资源,最重要的是,它不存在数据不同步的问题!如果用mybatis的缓存,他需要在每个项目中集成,当一个请求访问某一个服务,对数据进行操作,可能会造成缓存不同步的问题,且会浪费大量的网络开销,性能不好!
3.搭建思路
①:创建redis服务作为一个独立的服务
hrm-redis-parent
---hrm-redis-feign :放feign的客户端接口,所有需要集成redis的服务,只需要依赖此模块,建立于feign的通讯
---hrm-redis-server-2030:redis的服务模块,直接操作redis缓存中心!
②:注册到eureka注册中心
③:注册到配置中心,配置文件从云端拉取
④:集成jedis用来在java代码中操作redis
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
⑤:hrm-redis-server-2030中创建redis工具类
public enum RedisUtils {
INSTANCE;
static JedisPool jedisPool = null;
static {
//1 创建连接池配置对象
JedisPoolConfig config = new JedisPoolConfig();
//2 进行配置-四个配置
config.setMaxIdle(1);//最小连接数
config.setMaxTotal(11);//最大连接数
config.setMaxWaitMillis(10 * 1000L);//最长等待时间
config.setTestOnBorrow(true);//测试连接时是否畅通
//3 通过配置对象创建连接池对象
Properties properties = null;
try {
properties = new Properties();
properties.load(RedisUtils.class.getClassLoader().getResourceAsStream("redis.properties"));
} catch (IOException e) {
e.printStackTrace();
}
String host = properties.getProperty("redis.host");
String port = properties.getProperty("redis.port");
String password = properties.getProperty("redis.password");
String timeout = properties.getProperty("redis.timeout");
jedisPool = new JedisPool(config, host, Integer.valueOf(port),Integer.valueOf(timeout), password);
}
//获取连接
public Jedis getSource() {
return jedisPool.getResource();
}
//关闭资源
public void closeSource(Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}
/**
* 设置字符值
*
* @param key
* @param value
*/
public void set(String key, String value) {
Jedis jedis = getSource();
jedis.set(key, value);
closeSource(jedis);
}
/**
* 设置
* @param key
* @param value
*/
public void set(byte[] key, byte[] value) {
Jedis jedis = getSource();
jedis.set(key, value);
closeSource(jedis);
}
/**
*
* @param key
* @return
*/
public byte[] get(byte[] key) {
Jedis jedis = getSource();
try {
return jedis.get(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
closeSource(jedis);
}
return null;
}
/**
* 设置字符值
*
* @param key
*/
public String get(String key) {
Jedis jedis = getSource();
try {
return jedis.get(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
closeSource(jedis);
}
return null;
}
}
⑥:创建controller,连接redis
@RestController
@RequestMapping("/redis")
public class RedisController {
@PostMapping("/set")
public AjaxResult set(@RequestParam("key") String key, @RequestParam("value")String value){
RedisUtils.INSTANCE.set(key, value);
return AjaxResult.me();
}
@GetMapping("/get/{key}")
public AjaxResult get(@PathVariable("key") String key){
String result = RedisUtils.INSTANCE.get(key);
return AjaxResult.me().setResultObj(result);
}
}
⑦:启动服务,用postman进行测试
⑧:hrm-redis-feign模块中集成feign,所有服务需要集成redis,通过feign与redis建立通讯
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
⑨:创建feign的客户端接口 @FeignClient目标服务的服务名,和目标服务的服务方法
@FeignClient(value = "redis-server")
public interface RedisFeignClient {
@PostMapping("/redis/set")
AjaxResult set(@RequestParam("key") String key, @RequestParam("value")String value);
@GetMapping("/redis/get/{key}")
AjaxResult get(@PathVariable("key") String key);
}
⑩:在需要集成redis的服务中开启feign建立与feign的通讯 @EnableFeignClients 扫面feign接口的路径!
@SpringBootApplication
@MapperScan("com.hanfengyi.course.mapper")
@EnableTransactionManagement
@EnableFeignClients("com.hanfengyi.feign")
public class CourseService2020 {
public static void main(String[] args) {
SpringApplication.run(CourseService2020.class);
}
}
3.课程类型对redis的操作
思路:在访问课程中心时,发送请求,请求通过feign与redis建立通讯,对redis进行操作,在执行查询的时候,先查询redis,如果redis有数据,就直接返回,没有从数据库中查询,查询后,同步到redis缓存中,再返回结果!
①:导入fastjson包,因为redis是以string类型的<key,value>存储,如果要存储对象,必须转换为json格式字符串
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.47</version>
</dependency>
②:修改获得课程类型的方法,同时对添加、修改、删除的方法增强,每次操作完,都要重新查询数据库,同步到redis
@Service
public class CourseTypeServiceImpl extends ServiceImpl<CourseTypeMapper, CourseType> implements ICourseTypeService {
@Autowired
private RedisFeignClient redisFeignClient;
private List<CourseType> putDataIntoRedis(){
List<CourseType> allTypes = baseMapper.selectList(null);
redisFeignClient.set(RedisKeyConstants.COURSE_TYPE, JSONObject.toJSONString(allTypes));
return allTypes;
}
@Override
public List<CourseType> treeData() {
List<CourseType> allTypes = null;
//1. 从redis中获取数据
AjaxResult course_type = redisFeignClient.get(RedisKeyConstants.COURSE_TYPE);
//2. 有数据转换为List
if(course_type.isSuccess() && course_type.getResultObj()!=null){
String courseTypeForJson = course_type.getResultObj().toString();
allTypes = JSON.parseArray(courseTypeForJson,CourseType.class);
}else{
allTypes = putDataIntoRedis();
}
//1. 查询出所有的类型
// List<CourseType> allTypes = baseMapper.selectList(null);
//2. 创建list存放顶层节点
List<CourseType> topNode = new ArrayList<>();
//3.查询顶层节点
for (CourseType everyType : allTypes) {
if(everyType.getPid().longValue()==0){
topNode.add(everyType);
}else {
//4. 当前节点是父节点
CourseType currentParentNode = null;
for (CourseType tempType : allTypes) {
if(everyType.getPid().longValue()==tempType.getId().longValue()){
currentParentNode = tempType;
break;
}
}
if(currentParentNode!=null){
currentParentNode.getChildren().add(everyType);
}
}
}
return topNode;
}
@Override
public boolean insert(CourseType entity) {
boolean insertResult = super.insert(entity);
putDataIntoRedis();
return insertResult;
}
@Override
public boolean deleteById(Serializable id) {
boolean deleteResult = super.deleteById(id);
putDataIntoRedis();
return deleteResult;
}
@Override
public boolean updateById(CourseType entity) {
boolean updateResult = super.updateById(entity);
putDataIntoRedis();
return updateResult;
}
}