主项目链接&＃xff1a;https://gitee.com/java_wxid/java_wxid
项目架构及博文总结&＃xff1a;
项目模块&＃xff1a;
前期规划&＃xff0c;实现部分
java_wxid
├── demo // 演示模块
│ └── 模块名称&＃xff1a;apache-mybatis-demo模块 //Apache Mybatis集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;apache-shardingsphere-demo模块 //Apache ShardingSphere集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;design-demo模块 //设计模式实战落地&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;elasticsearch-demo模块 //ElasticSearch集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;mongodb-demo模块 //MongoDB集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;redis-demo模块 //Redis集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-boot-demo模块 //Spring Boot快速构建应用&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-alibaba-nacos-demo模块 //Spring Cloud Alibaba Nacos集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-alibaba-seata-demo模块 //Spring Cloud Alibaba Seata集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-alibaba-sentinel-demo模块 //Spring Cloud Alibaba Sentinel集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-gateway-demo模块 //Spring Cloud Gateway集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-hystrix-demo模块 //Spring Cloud Hystrix集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-open-feign-demo模块 //Spring Cloud Open Feign集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-ribbon-demo模块 //Spring Cloud Ribbon集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-security-oauth2-demo模块 //Spring Cloud Security Oauth2集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-security-oauth2-sso-client-demo模块 //Spring Cloud Security Oauth2集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-skywalking-demo模块 //Spring Cloud Skywalking集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;spring-cloud-stream-demo模块 //Spring Cloud Stream集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;swagger-demo模块 //springfox-swagger2集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;xxl-job模块 //xxl-job集成&＃xff08;已实现并有博文总结&＃xff09;
│ └── 模块名称&＃xff1a;apache-spark-demo模块 //Apache Spark集成
│ └── 模块名称&＃xff1a;etl-hdfs-hive-hbase-demo模块 //ETL、HDFS、Hive、Hbase集成
│ └── 模块名称&＃xff1a;ddd-mode-demo模块 //DDD领域设计
│ └── 模块名称&＃xff1a;netty-demo模块 //Netty集成
│ └── 模块名称&＃xff1a;vue-demo模块 //前端vue集成
├── document // 文档
│ └── JavaKnowledgeDocument //java知识点
│ └── java基础知识点.md
│ └── mq知识点.md
│ └── mysql知识点.md
│ └── redis知识点.md
│ └── springcould知识点.md
│ └── spring知识点.md
│ └── FounderDocument //创始人
│ └── 创始人.md
系列文章&＃xff1a;快速集成各种微服务相关的技术&＃xff0c;帮助大家可以快速集成到自己的项目中&＃xff0c;节约开发时间。
提示&＃xff1a;系列文章还未全部完成&＃xff0c;后续的文章&＃xff0c;会慢慢补充进去的。
项目代码&＃xff1a;https://gitee.com/java_wxid/java_wxid/tree/master/demo/redis-demo
项目结构如下&＃xff08;示例&＃xff09;&＃xff1a;
代码如下&＃xff08;示例&＃xff09;&＃xff1a;
代码如下&＃xff08;示例&＃xff09;&＃xff1a;
server.port&＃61;8093
spring.redis.host&＃61;139.224.137.74
spring.redis.port&＃61;6379
spring.redis.password&＃61;ca0a997ee4770063
spring.redis.database&＃61;0
#由于我们使用的lettuce客户端&＃xff0c;所以配置的时候&＃xff0c;在spring.redis下加上lettuce再加上pool来配置.如果使用的是jedis,就把lettuce换成jedis
spring.redis.lettuce.pool.max-idle&＃61;16
spring.redis.lettuce.pool.max-active&＃61;32
spring.redis.lettuce.pool.min-idle&＃61;8
spring.devtools.restart.enable&＃61;true
代码如下&＃xff08;示例&＃xff09;&＃xff1a;
package com.example.redisdemo.config;/*** &＃64;author zhiweiLiao
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;&＃64;Configuration
public class RedisConfig {/*** Redis本身提供了多种种序列化的方式&＃xff1a;* GenericToStringSerializer: 可以将任何对象泛化为字符串并序列化* Jackson2JsonRedisSerializer: 跟JacksonJsonRedisSerializer实际上是一样的* JacksonJsonRedisSerializer: 序列化object对象为json字符串* JdkSerializationRedisSerializer: 序列化java对象* StringRedisSerializer: 简单的字符串序列化* 如果我们存储的是String类型&＃xff0c;默认使用的是StringRedisSerializer 这种序列化方式。* 如果我们存储的是对象&＃xff0c;默认使用的是 JdkSerializationRedisSerializer&＃xff0c;也就是Jdk的序列化方式* &＃xff08;通过ObjectOutputStream和ObjectInputStream实现&＃xff0c;缺点是我们无法直观看到存储的对象内容&＃xff0c;很不方便我们排查问题&＃xff09;。* 我们可以根据redis操作的不同数据类型&＃xff0c;设置对应的序列化方式。* 而一般我们最经常使用的对象序列化方式是&＃xff1a; Jackson2JsonRedisSerializer* 设置序列化方式的主要方法就是我们在配置类中&＃xff0c;自己来创建RedisTemplate对象&＃xff0c;并在创建的过程中指定对应的序列化方式* &＃64;param factory* &＃64;return*/&＃64;Bean(name &＃61; "redisTemplate")public RedisTemplate
// objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance ,ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); // value的序列化类型redisTemplate.setHashKeySerializer(stringRedisSerializer);redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}}
代码如下&＃xff08;示例&＃xff09;&＃xff1a;
package com.example.redisdemo.util;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;/*** &＃64;author zhiweiLiao
&＃64;Component
public class RedisUtil {&＃64;Autowiredprivate RedisTemplate redisTemplate;/*** 给一个指定的 key 值附加过期时间** &＃64;param key* &＃64;param time* &＃64;return*/public boolean expire(String key, long time) {return redisTemplate.expire(key, time, TimeUnit.SECONDS);}/*** 根据key 获取过期时间** &＃64;param key* &＃64;return*/public long getTime(String key) {return redisTemplate.getExpire(key, TimeUnit.SECONDS);}/*** 根据key 获取过期时间** &＃64;param key* &＃64;return*/public boolean hasKey(String key) {return redisTemplate.hasKey(key);}/*** 移除指定key 的过期时间** &＃64;param key* &＃64;return*/public boolean persist(String key) {return redisTemplate.boundValueOps(key).persist();}//- - - - - - - - - - - - - - - - - - - - - String类型 - - - - - - - - - - - - - - - - - - - -/*** 根据key获取值** &＃64;param key 键* &＃64;return 值*/public Object get(String key) {return key &＃61;&＃61; null ? null : redisTemplate.opsForValue().get(key);}/*** 将值放入缓存** &＃64;param key 键* &＃64;param value 值* &＃64;return true成功 false 失败*/public void set(String key, String value) {redisTemplate.opsForValue().set(key, value);}/*** 将值放入缓存并设置时间** &＃64;param key 键* &＃64;param value 值* &＃64;param time 时间(秒) -1为无期限* &＃64;return true成功 false 失败*/public void set(String key, String value, long time) {if (time > 0) {redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);} else {redisTemplate.opsForValue().set(key, value);}}/*** 批量添加 key (重复的键会覆盖)** &＃64;param keyAndValue*/public void batchSet(Map
// redisTemplate.opsForList().leftPushAll(key,"w","x","y");redisTemplate.opsForList().leftPushAll(key, values);}/*** 向集合最右边添加元素。** &＃64;param key* &＃64;param value* &＃64;return*/public void leftPushAll(String key, String value) {redisTemplate.opsForList().rightPush(key, value);}/*** 向左边批量添加参数元素。** &＃64;param key* &＃64;param values* &＃64;return*/public void rightPushAll(String key, String... values) {//redisTemplate.opsForList().leftPushAll(key,"w","x","y");redisTemplate.opsForList().rightPushAll(key, values);}/*** 向已存在的集合中添加元素。** &＃64;param key* &＃64;param value* &＃64;return*/public void rightPushIfPresent(String key, Object value) {redisTemplate.opsForList().rightPushIfPresent(key, value);}/*** 向已存在的集合中添加元素。** &＃64;param key* &＃64;return*/public long listLength(String key) {return redisTemplate.opsForList().size(key);}/*** 移除集合中的左边第一个元素。** &＃64;param key* &＃64;return*/public void leftPop(String key) {redisTemplate.opsForList().leftPop(key);}/*** 移除集合中左边的元素在等待的时间里&＃xff0c;如果超过等待的时间仍没有元素则退出。** &＃64;param key* &＃64;return*/public void leftPop(String key, long timeout, TimeUnit unit) {redisTemplate.opsForList().leftPop(key, timeout, unit);}/*** 移除集合中右边的元素。** &＃64;param key* &＃64;return*/public void rightPop(String key) {redisTemplate.opsForList().rightPop(key);}/*** 移除集合中右边的元素在等待的时间里&＃xff0c;如果超过等待的时间仍没有元素则退出。** &＃64;param key* &＃64;return*/public void rightPop(String key, long timeout, TimeUnit unit) {redisTemplate.opsForList().rightPop(key, timeout, unit);}
}
代码如下&＃xff08;示例&＃xff09;&＃xff1a;
package com.example.redisdemo.controller;/*** &＃64;author zhiweiLiao
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/*** &＃64;className: RedisController* &＃64;description:* &＃64;author: sh.Liu* &＃64;date: 2022-03-08 14:28*/
&＃64;RestController
&＃64;RequestMapping("/redis")
public class RedisController {private final RedisTemplate redisTemplate;public RedisController(RedisTemplate redisTemplate) {this.redisTemplate &＃61; redisTemplate;}&＃64;GetMapping("/setValueAndGetValue")public Object setValueAndGetValue(String key, String value){redisTemplate.opsForValue().set(key, value);return redisTemplate.opsForValue().get(key);}}
如下图&＃xff08;示例&＃xff09;&＃xff1a;
如下图&＃xff08;示例&＃xff09;&＃xff1a;
正常吐出数据&＃xff0c;说明redis已经可以正常工作了
京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有