桂林市临桂区城乡建设局网站,县级部门和乡镇不能建网站建设,网站建设管理工作的总结,百度统计数据分析文章目录 Redis的Java客户端-JedisJedis快速入门创建工程#xff1a;引入依赖#xff1a;建立连接测试#xff1a;释放资源Jedis连接池创建Jedis的连接池改造原始代码 Redis的Java客户端-SpringDataRedis快速入门导入pom坐标配置文件测试代码 数据序列化器StringRedisTempla… 文章目录 Redis的Java客户端-JedisJedis快速入门创建工程引入依赖建立连接测试释放资源Jedis连接池创建Jedis的连接池改造原始代码 Redis的Java客户端-SpringDataRedis快速入门导入pom坐标配置文件测试代码 数据序列化器StringRedisTemplateHash结构操作 项目仓库 Redis的Java客户端-Jedis
在Redis官网中提供了各种语言的客户端地址https://redis.io/docs/clients/
其中Java客户端也包含很多但在开发中用的最多的还是Jedis接下来就让我们以Jedis开始我们的快速实战。
Jedis快速入门
入门案例详细步骤
案例分析
创建工程
创建一个maven管理的java项目
引入依赖
在pom.xml文件下添加以下依赖 dependencies!--jedis--dependencygroupIdredis.clients/groupIdartifactIdjedis/artifactIdversion4.4.3/version/dependencydependencygroupIdorg.junit.jupiter/groupIdartifactIdjunit-jupiter/artifactIdversionRELEASE/versionscopetest/scope/dependency
/dependencies建立连接
新建一个单元测试类内容如下
private Jedis jedis;BeforeEach
void setUp() {// 1.建立连接jedis new Jedis(192.168.218.134, 6379);// jedis JedisConnectionFactory.getJedis();// 2.设置密码jedis.auth(123456);// 3.选择库jedis.select(0);
}测试
Test
void testString() {// 存入数据String result jedis.set(name, onenewcode);System.out.println(result result);// 获取数据String name jedis.get(name);System.out.println(name name);
}Test
void testHash() {// 插入hash数据jedis.hset(user:1, name, Jack);jedis.hset(user:1, age, 21);// 获取MapString, String map jedis.hgetAll(user:1);System.out.println(map);
}释放资源
AfterEach
void tearDown() {if (jedis ! null) {jedis.close();}
}Jedis连接池
Jedis本身是线程不安全的并且频繁的创建和销毁连接会有性能损耗因此我们推荐大家使用Jedis连接池代替Jedis的直连方式
有关池化思想并不仅仅是这里会使用很多地方都有比如说我们的数据库连接池比如我们tomcat中的线程池这些都是池化思想的体现。
创建Jedis的连接池
public class JedisConnectionFacotry {private static final JedisPool jedisPool;static {//配置连接池JedisPoolConfig poolConfig new JedisPoolConfig();poolConfig.setMaxTotal(8);poolConfig.setMaxIdle(8);poolConfig.setMinIdle(0);poolConfig.setMaxWaitMillis(1000);//创建连接池对象jedisPool new JedisPool(poolConfig,192.168.218.134,6379,1000,123456);}public static Jedis getJedis(){return jedisPool.getResource();}
}代码说明 1 JedisConnectionFacotry工厂设计模式是实际开发中非常常用的一种设计模式我们可以使用工厂去降低代的耦合比如Spring中的Bean的创建就用到了工厂设计模式 2静态代码块随着类的加载而加载确保只能执行一次我们在加载当前工厂类的时候就可以执行static的操作完成对 连接池的初始化 3最后提供返回连接池中连接的方法.
改造原始代码
代码说明:
1.在我们完成了使用工厂设计模式来完成代码的编写之后我们在获得连接时就可以通过工厂来获得。
而不用直接去new对象降低耦合并且使用的还是连接池对象。
2.当我们使用了连接池后当我们关闭连接其实并不是关闭而是将Jedis还回连接池的。 BeforeEachvoid setUp(){//建立连接/*jedis new Jedis(127.0.0.1,6379);*/jedis JedisConnectionFacotry.getJedis();//选择库jedis.select(0);}AfterEachvoid tearDown() {if (jedis ! null) {jedis.close();}}Redis的Java客户端-SpringDataRedis
SpringData是Spring中数据操作的模块包含对各种数据库的集成其中对Redis的集成模块就叫做SpringDataRedis官网地址https://spring.io/projects/spring-data-redis
提供了对不同Redis客户端的整合Lettuce和Jedis提供了RedisTemplate统一API来操作Redis支持Redis的发布订阅模型支持Redis哨兵和Redis集群支持基于Lettuce的响应式编程支持基于JDK.JSON.字符串.Spring对象的数据序列化及反序列化支持基于Redis的JDKCollection实现
SpringDataRedis中提供了RedisTemplate工具类其中封装了各种对Redis的操作。并且将不同数据类型的操作API封装到了不同的类型中 快速入门
SpringBoot已经提供了对SpringDataRedis的支持使用非常简首先创建一个spring boot项目
导入pom坐标
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.onenewcode/groupIdartifactIdMyRedis/artifactIdversion0.0.1-SNAPSHOT/versionnameMyRedis/namedescriptionMyRedis/descriptionpropertiesjava.version17/java.versionproject.build.sourceEncodingUTF-8/project.build.sourceEncodingproject.reporting.outputEncodingUTF-8/project.reporting.outputEncodingspring-boot.version3.0.2/spring-boot.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependency!--redis依赖--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis/artifactId/dependency!--common-pool--dependencygroupIdorg.apache.commons/groupIdartifactIdcommons-pool2/artifactId/dependency!--Jackson依赖--dependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactId/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.30/version/dependency/dependenciesdependencyManagementdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-dependencies/artifactIdversion${spring-boot.version}/versiontypepom/typescopeimport/scope/dependency/dependencies/dependencyManagementbuildpluginsplugingroupIdorg.apache.maven.plugins/groupIdartifactIdmaven-compiler-plugin/artifactIdversion3.8.1/versionconfigurationsource17/sourcetarget17/targetencodingUTF-8/encoding/configuration/pluginplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactIdversion${spring-boot.version}/versionconfigurationmainClasscom.onenewcode.myredis.MyRedisApplication/mainClassskiptrue/skip/configurationexecutionsexecutionidrepackage/idgoalsgoalrepackage/goal/goals/execution/executions/plugin/plugins/build/project
配置文件
在application.yml文件下添加以下内容
spring:data:redis:host: 192.168.218.134port: 6379password: 123456lettuce:pool:max-active: 8 #最大连接max-idle: 8 #最大空闲连接min-idle: 0 #最小空闲连接max-wait: 100ms #连接等待时间
测试代码
SpringBootTest
class MyRedisApplicationTests {Resourceprivate RedisTemplateString, Object redisTemplate;Testvoid testString() {// 写入一条String数据redisTemplate.opsForValue().set(name, onenewcode);// 获取string数据Object name redisTemplate.opsForValue().get(name);System.out.println(name name);}
}
贴心小提示SpringDataJpa使用起来非常简单记住如下几个步骤即可
SpringDataRedis的使用步骤
引入spring-boot-starter-data-redis依赖在application.yml配置Redis信息注入RedisTemplate
目录结构 数据序列化器
RedisTemplate可以接收任意Object作为值写入Redis只不过写入前会把Object序列化为字节形式默认是采用JDK序列化得到的结果是这样的 缺点
可读性差内存占用较大
我们可以自定义RedisTemplate的序列化方式代码如下
Configuration
public class RedisConfig {Beanpublic RedisTemplateString, Object redisTemplate(RedisConnectionFactory connectionFactory){// 创建RedisTemplate对象RedisTemplateString, Object template new RedisTemplate();// 设置连接工厂template.setConnectionFactory(connectionFactory);// 创建JSON序列化工具GenericJackson2JsonRedisSerializer jsonRedisSerializer new GenericJackson2JsonRedisSerializer();// 设置Key的序列化template.setKeySerializer(RedisSerializer.string());template.setHashKeySerializer(RedisSerializer.string());// 设置Value的序列化template.setValueSerializer(jsonRedisSerializer);template.setHashValueSerializer(jsonRedisSerializer);// 返回return template;}
}这里采用了JSON序列化来代替默认的JDK序列化方式。最终结果如图 整体可读性有了很大提升并且能将Java对象自动的序列化为JSON字符串并且查询时能自动把JSON反序列化为Java对象。不过其中记录了序列化时对应的class名称目的是为了查询时实现自动反序列化。这会带来额外的内存开销。
StringRedisTemplate
尽管JSON的序列化方式可以满足我们的需求但依然存在一些问题自动进行序列化时会负载多余的信息。
为了在反序列化时知道对象的类型JSON序列化器会将类的class类型写入json结果中存入Redis会带来额外的内存开销。
为了减少内存的消耗我们可以采用手动序列化的方式换句话说就是不借助默认的序列化器而是我们自己来控制序列化的动作同时我们只采用String的序列化器这样在存储value时我们就不需要在内存中就不用多存储数据从而节约我们的内存空间
这种用法比较普遍因此SpringDataRedis就提供了RedisTemplate的子类StringRedisTemplate它的key和value的序列化方式默认就是String方式。
省去了我们自定义RedisTemplate的序列化方式的步骤而是直接使用
SpringBootTest
class MyRedisApplicationTests {Resourceprivate RedisTemplateString, Object redisTemplate;Autowiredprivate StringRedisTemplate stringRedisTemplate;// JSON工具private static final ObjectMapper mapper new ObjectMapper();Testvoid testString() {// 写入一条String数据redisTemplate.opsForValue().set(1, onenewcode);// 获取string数据Object name redisTemplate.opsForValue().get(name);System.out.println(name name);}Testvoid testSaveUser() throws JsonProcessingException {// 创建对象User user new User(onenewcode, 21);// 手动序列化String json mapper.writeValueAsString(user);// 写入数据stringRedisTemplate.opsForValue().set(user:200, json);// 获取数据String jsonUser stringRedisTemplate.opsForValue().get(user:200);// 手动反序列化User user1 mapper.readValue(jsonUser, User.class);System.out.println(user1 user1);}
}
此时我们再来看一看存储的数据小伙伴们就会发现那个class数据已经不在了节约了我们的空间~ 最后小总结
RedisTemplate的两种序列化实践方案 方案一 自定义RedisTemplate修改RedisTemplate的序列化器为GenericJackson2JsonRedisSerializer 方案二 使用StringRedisTemplate写入Redis时手动把对象序列化为JSON读取Redis时手动把读取到的JSON反序列化为对象
Hash结构操作
在基础篇的最后咱们对Hash结构操作一下收一个小尾巴这个代码咱们就不再解释啦
马上就开始新的篇章~~~进入到我们的Redis实战篇
SpringBootTest
class RedisStringTests {···Testvoid testHash() {stringRedisTemplate.opsForHash().put(user:400, name, onenewcode);stringRedisTemplate.opsForHash().put(user:400, age, 21);MapObject, Object entries stringRedisTemplate.opsForHash().entries(user:400);System.out.println(entries entries);}
}项目仓库
https://github.com/onenewcode/MyRedis.git
