Redis 一二事 - 在spring中使用jedis 连接调试单机redis以及集群redis

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: Redis真是好,其中的键值用起来真心强大啊有木有, 之前的文章讲过搭建了redis集群 那么咋们该如何调用单机版的redis以及集群版的redis来使用缓存服务呢? 先讲讲单机版的,单机版redis安装非常简单,不多说了,直接使用命令:  1 [root@nginx bin]# .

Redis真是好,其中的键值用起来真心强大啊有木有,

之前的文章讲过搭建了redis集群

那么咋们该如何调用单机版的redis以及集群版的redis来使用缓存服务呢?

先讲讲单机版的,单机版redis安装非常简单,不多说了,直接使用命令:

 1 [root@nginx bin]# ./redis-server redis.conf 

启动就行

在sprig文件中配置如下

 1 <!-- 
 2         TODO:
 3         开发环境使用单机版
 4         生产环境务必切换成集群
 5      -->
 6     <!-- 配置redis客户端单机版 -->
 7     <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
 8         <constructor-arg name="host" value="${redis.single.client.host}"></constructor-arg>
 9         <constructor-arg name="port" value="${redis.single.client.port}"></constructor-arg>
10     </bean>
11     <!-- 配置redis客户端实现类 -->
12     <bean id="jedisClientSingle" class="com.lee.rest.component.impl.JedisClientSingle"/>
13     
14     <!-- 配置redis客户端集群版 单机版和集群版的jedis只能存在一个 -->
15     <!-- <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
16         <constructor-arg>
17             <set>
18                 <bean class="redis.clients.jedis.HostAndPort">
19                     <constructor-arg name="host" value="${redis01.real.cluster.client.host}"/>
20                     <constructor-arg name="port" value="${redis01.real.cluster.client.port}"/>
21                 </bean>
22                 <bean class="redis.clients.jedis.HostAndPort">
23                     <constructor-arg name="host" value="${redis02.real.cluster.client.host}"/>
24                     <constructor-arg name="port" value="${redis02.real.cluster.client.port}"/>
25                 </bean>
26                 <bean class="redis.clients.jedis.HostAndPort">
27                     <constructor-arg name="host" value="${redis03.real.cluster.client.host}"/>
28                     <constructor-arg name="port" value="${redis03.real.cluster.client.port}"/>
29                 </bean>
30                 <bean class="redis.clients.jedis.HostAndPort">
31                     <constructor-arg name="host" value="${redis04.real.cluster.client.host}"/>
32                     <constructor-arg name="port" value="${redis04.real.cluster.client.port}"/>
33                 </bean>
34                 <bean class="redis.clients.jedis.HostAndPort">
35                     <constructor-arg name="host" value="${redis05.real.cluster.client.host}"/>
36                     <constructor-arg name="port" value="${redis05.real.cluster.client.port}"/>
37                 </bean>
38                 <bean class="redis.clients.jedis.HostAndPort">
39                     <constructor-arg name="host" value="${redis06.real.cluster.client.host}"/>
40                     <constructor-arg name="port" value="${redis06.real.cluster.client.port}"/>
41                 </bean>
42             </set>
43         </constructor-arg>
44     </bean>
45     <bean id="jedisClientCluster" class="com.lee.rest.component.impl.JedisClientCluster"/> -->

这是配置的redis-cli的连接池

然后定义一个接口,这个接口供两个类实现

一个是单机版,一个是集群版

有人会问为啥要2个类实现,因为redis的单机和集群都是不同的实现方法

一般在开发环境会使用单机版来做测试,生产环境直接上集群

 1 #fake cluster
 2 redis.single.client.host=192.168.1.191
 3 redis.single.client.port=6379
 4 
 5 redis01.cluster.client.host=192.168.1.192
 6 redis01.cluster.client.port=7001
 7 
 8 redis02.cluster.client.host=192.168.1.192
 9 redis02.cluster.client.port=7002
10 
11 redis03.cluster.client.host=192.168.1.192
12 redis03.cluster.client.port=7003
13 
14 redis04.cluster.client.host=192.168.1.192
15 redis04.cluster.client.port=7004
16 
17 redis05.cluster.client.host=192.168.1.192
18 redis05.cluster.client.port=7005
19 
20 redis06.cluster.client.host=192.168.1.192
21 redis06.cluster.client.port=7006

在你的资源文件中配好如上信息,供spring调用

说个题外话,资源文件*.properties,在spring的父子容器中不是公用的

也就是说,在service的spring容器中,只能配service层调用

在springMVC容器中只能被springmvc自己调用,因为资源文件不是夸容器的

而spring容器中的对象是可以被springMVC来访问的

但是springMVC的对象以及资源文件绝对不能被spring来访问,

举个栗子:你有见过service访问controller的吗?没有吧,哈哈

咱们先来建一个通用jedis客户端

(有2个小家伙看不懂最后2个方法什么意思,就加了注释,其实规范点来讲,所有的接口方法都要加注释,而实现类就不需要,但是实现类中的私有方法必须加注释,这是规范)

 1 package com.lee.rest.component;
 2 
 3 /**
 4  * 
 5  * @Title: JedisClient.java
 6  * @Package com.lee.rest.component
 7  * @Description: redis客户端
 8  * Copyright: Copyright (c) 2016
 9  * Company:Nathan.Lee.Salvatore
10  * 
11  * @author leechenxiang
12  * @date 2016年4月27日 下午4:28:46
13  * @version V1.0
14  */
15 public interface JedisClient {
16 
17     public String set(String key, String value);
18     public String get(String key);
19     public Long hset(String key, String item, String value);
20     public String hget(String key, String item);
21     public Long hdel(String key, String item);
22     public Long incr(String key);
23     public Long decr(String key);
24     
25     /**
26      * 
27      * @Description: 设置存存活时间
28      * @param key
29      * @param second
30      * @return
31      * 
32      * @author leechenxiang
33      * @date 2016年4月27日 下午4:34:35
34      */
35     public Long expire(String key, int second);
36     
37     /**
38      * 
39      * @Description: 判断key多久过期
40      * @param key
41      * @return42      *             >= 0     剩余秒数
43      *             = -1    永久存活
44      *             = -2    已经消除
45      * 
46      * @author leechenxiang
47      * @date 2016年4月27日 下午4:34:22
48      */
49     public Long ttl(String key);
50 }
 1 /**
 2  * 
 3  * @Title: JedisClientSingle.java
 4  * @Package com.lee.rest.component.impl
 5  * @Description: 单机版的jedis客户端操作
 6  * Copyright: Copyright (c) 2016
 7  * Company:Nathan.Lee.Salvatore
 8  * 
 9  * @author leechenxiang
10  * @date 2016年4月27日 下午4:36:42
11  * @version V1.0
12  */
13 public class JedisClientSingle implements JedisClient {
14 
15     @Autowired
16     private JedisPool jedisPool;
17 
18     @Override
19     public String set(String key, String value) {
20         Jedis jedis = jedisPool.getResource();
21         String result = jedis.set(key, value);
22         jedis.close();
23         return result;
24     }
25 
26     @Override
27     public String get(String key) {
28         Jedis jedis = jedisPool.getResource();
29         String result = jedis.get(key);
30         jedis.close();
31         return result;
32     }
33 
34     @Override
35     public Long hset(String key, String item, String value) {
36         Jedis jedis = jedisPool.getResource();
37         Long result = jedis.hset(key, item, value);
38         jedis.close();
39         return result;
40     }
41 
42     @Override
43     public String hget(String key, String item) {
44         Jedis jedis = jedisPool.getResource();
45         String result = jedis.hget(key, item);
46         jedis.close();
47         return result;
48     }
49     
50     @Override
51     public Long hdel(String key, String item) {
52         Jedis jedis = jedisPool.getResource();
53         Long result = jedis.hdel(key, item);
54         jedis.close();
55         return result;
56     }
57 
58     @Override
59     public Long incr(String key) {
60         Jedis jedis = jedisPool.getResource();
61         Long result = jedis.incr(key);
62         jedis.close();
63         return result;
64     }
65 
66     @Override
67     public Long decr(String key) {
68         Jedis jedis = jedisPool.getResource();
69         Long result = jedis.decr(key);
70         jedis.close();
71         return result;
72     }
73 
74     @Override
75     public Long expire(String key, int second) {
76         Jedis jedis = jedisPool.getResource();
77         Long result = jedis.expire(key, second);
78         jedis.close();
79         return result;
80     }
81 
82     @Override
83     public Long ttl(String key) {
84         Jedis jedis = jedisPool.getResource();
85         Long result = jedis.ttl(key);
86         jedis.close();
87         return result;
88     }
89 
90 }
 1 /**
 2  * 
 3  * @Title: JedisClientCluster.java
 4  * @Package com.lee.rest.component.impl
 5  * @Description: 集群版的jedis客户端操作
 6  * Copyright: Copyright (c) 2016
 7  * Company:Nathan.Lee.Salvatore
 8  * 
 9  * @author leechenxiang
10  * @date 2016年4月27日 下午4:44:02
11  * @version V1.0
12  */
13 public class JedisClientCluster implements JedisClient {
14 
15     @Autowired
16     private JedisCluster jedisCluster;
17 
18     @Override
19     public String set(String key, String value) {
20         return jedisCluster.set(key, value);
21     }
22 
23     @Override
24     public String get(String key) {
25         return jedisCluster.get(key);
26     }
27 
28     @Override
29     public Long hset(String key, String item, String value) {
30         return jedisCluster.hset(key, item, value);
31     }
32 
33     @Override
34     public String hget(String key, String item) {
35         return jedisCluster.hget(key, item);
36     }
37 
38     @Override
39     public Long hdel(String key, String item) {
40         return jedisCluster.hdel(key, item);
41     }
42     
43     @Override
44     public Long incr(String key) {
45         return jedisCluster.incr(key);
46     }
47 
48     @Override
49     public Long decr(String key) {
50         return jedisCluster.decr(key);
51     }
52 
53     @Override
54     public Long expire(String key, int second) {
55         return jedisCluster.expire(key, second);
56     }
57 
58     @Override
59     public Long ttl(String key) {
60         return jedisCluster.ttl(key);
61     }
62 
63 }

使用地方,一般都是在service中调用,把需要加缓存的地方都实现接口

取之前查询有没有缓存,有直接返回,没有查数据库,然后再放入缓存

也有企业会这么做,所有的缓存都有一个团队来管理,做一个定时器,每天凌晨固定一个时间点来跑批,把数据放入缓存

这么做也是可以的

我们采取的是第一种

PS:@Autowired 这边是用的类型相同,有人喜欢用@resource,这样的话就得多写一个,区别点

 1 @Autowired
 2 private JedisClient jedisClient;
 3 
 4 @Value("${REDIS_CONTENT_KEY}")
 5 private String REDIS_CONTENT_KEY;
 6 
 7 @Override
 8 public List<Content> gettList(Long id) {
 9 // TODO 这个地方加缓存和不加缓存,单台或者集群的redis,都要进行压力测试
10 //添加缓存
11 //查询数据库之前先查询缓存,如果有直接返回
12 try {
13 //从redis中取缓存数据
14 String json = jedisClient.hget(REDIS_CONTENT_KEY, id + "");
15 if (!StringUtils.isBlank(json)) {
16 //把json转换成List
17 List<Content> list = JsonUtils.jsonToList(json, Content.class);
18 return list;
19 }
20 } catch (Exception e) {
21 e.printStackTrace();
22 }
23 
24 //执行查询
25 List<?> list = xxxMapper.select(id);
26 // 返回结果之前,向缓存中添加数据
27 try {
28 // 为了规范key可以使用hash
29 // 定义一个保存内容的key,hash中每个项就是cid
30 // value是list,需要把list转换成json数据。
31 jedisClient.hset(REDIS_CONTENT_KEY, id + "", JsonUtils.objectToJson(list));
32 } catch (Exception e) {
33 e.printStackTrace();
34 }
35 return list;
36 }

 

那么service就好了,集群版的也通用

那么集群的配置如何呢?

放开注释

使用资源文件的配置

 

好了,启动一下就可以运行了

配置好Test或者controller都可以调用

但是要做好缓存同步,也就是在增加,修改,删除数据后,要同步缓存,把原有的del,在放入新的

这样就可以了`~

 

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
3天前
|
监控 NoSQL 算法
手把手教你如何搭建redis集群(二)
手把手教你如何搭建redis集群(二)
19 1
|
3天前
|
存储 NoSQL 容灾
手把手教你如何搭建redis集群(一)
手把手教你如何搭建redis集群(一)
17 1
|
1天前
|
存储 运维 NoSQL
Redis Cluster集群模式部署
Redis Cluster集群模式部署
22 4
|
4天前
|
存储 NoSQL Redis
多次访问redis造成redis连接断开的解决方案
多次访问redis造成redis连接断开的解决方案
12 2
|
6天前
|
NoSQL 关系型数据库 Serverless
Serverless 应用引擎产品使用合集之连接RDS、Redis等数据库时,是否需要通过安全组来控制访问权限
阿里云Serverless 应用引擎(SAE)提供了完整的微服务应用生命周期管理能力,包括应用部署、服务治理、开发运维、资源管理等功能,并通过扩展功能支持多环境管理、API Gateway、事件驱动等高级应用场景,帮助企业快速构建、部署、运维和扩展微服务架构,实现Serverless化的应用部署与运维模式。以下是对SAE产品使用合集的概述,包括应用管理、服务治理、开发运维、资源管理等方面。
|
7天前
|
DataWorks NoSQL Java
DataWorks操作报错合集之数据集成使用公共数据集成资源组写入到redis数据源(使用的是VPC连接),提示以下错误:request action:[InnerVpcGrantVpcInstanceAccessToApp], message:[InvalidInstanceId.怎么解决
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
7天前
|
缓存 NoSQL Java
Java一分钟之-Spring Data Redis:使用Redis做缓存
【6月更文挑战第10天】Spring Data Redis是Spring框架的一部分,简化了Java应用与Redis的集成,支持多种数据结构操作。本文介绍了其基本使用,包括添加依赖、配置Redis连接及使用RedisTemplate。还讨论了常见问题,如序列化、缓存穿透和雪崩,并提供解决方案。通过实战示例展示了缓存与数据库读写分离的实现,强调了Spring Data Redis在提升系统性能中的作用。
33 0
|
8天前
|
分布式计算 NoSQL 大数据
MaxCompute产品使用合集之自定义udf连接云上vpc网络的redis获取数据的步骤是什么
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
10天前
|
NoSQL Redis
|
12天前
|
存储 NoSQL 算法
Redis集群,集群的概念 三种主流分片方式1.哈希求余 一致性哈希算法:方案三:哈希槽分区算法问题一Redis集群是最多有16384个分片吗问题二:为什么是16384个,集群扩容:1.新的主节点
Redis集群,集群的概念 三种主流分片方式1.哈希求余 一致性哈希算法:方案三:哈希槽分区算法问题一Redis集群是最多有16384个分片吗问题二:为什么是16384个,集群扩容:1.新的主节点