redistemplate 是线程安全的吗

redistemplate 是线程安全的吗,第1张

redis 是线程安全
Redis是一个开源,先进的key-value存储,并用于构建高性能,可扩展的Web应用程序的完美解决方案,是线程安全的。
Redis三个主要特点:
Redis数据库完全在内存中,使用磁盘仅用于持久性。
相比许多键值数据存储,Redis拥有一套较为丰富的数据类型。
Redis可以将数据复制到任意数量的从服务器

Spring Boot是目前非常流行的Java Web开发框架,Redis是非关系型数据库的一种,以键值对的形式存储。Spring对Redis的支持是通过Spring Data Redis来实现的,给我们提供了RedisTemplate和StringRedisTemplate两种模板来 *** 作数据。Spring Boot框架也提供了对Redis的支持,下面我们来讲一下Spring Boot框架整合Redis的步骤。

工具/材料

IntelliJ IDEA

Spring Boot整合Redis我们需要添加依赖的jar包,spring-boot-starter-data-redis中包含spring和redis相关的jar包,jedis作为redis的客户端也需要添加到工程中,Spring Boot的版本信息在父pom中已指定,子模块中的spring相关的jar包无需另外指定。

<dependency>
<groupId>orgspringframeworkboot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>redisclients</groupId>
<artifactId>jedis</artifactId>
<version>300-m1</version>
</dependency>

Spring Boot会根据applicationproperties中的配置对Redis的属性进行自动配置,并注入到RedisProperties类中。在applicationproperties配置文件中这些属性都是以springredis为前缀的,值得注意的是在Spring Boot 15x版本中默认的Redis客户端是jedis,因此在配置文件中无需指定,如下图所示。

Spring Boot 15x版本的整合配置网上可以搜索大量的文章,然而Spring Boot 2x版本的整合资料却非常少,甚至提供的配置不能正常使用,因此本文主要讲解Spring Boot 2x整合Redis以及Redis的使用情况。spring-boot 2x版本有jedis和lettuce两种客户端,因此我们必须要去指定使用哪一种客户端,两个客户端的配置如下图所示,本文使用的是Jedis客户端连接池,具体的配置如下。

# Redis数据库索引(默认为0)
springredisdatabase=0
# Redis服务器地址
springredishost=127001

# Redis服务器连接端口
springredisport=6379
# Redis服务器连接密码(默认为空)
springredispassword=xylx1t!@#
# 配置jedis连接池
# 连接池最大连接数(使用负值表示没有限制)
springredisjedispoolmax-active=8
# 连接池最大阻塞等待时间(使用负值表示没有限制)
springredisjedispoolmax-wait=-1ms
# 连接池中的最大空闲连接
springredisjedispoolmax-idle=8
# 连接池中的最小空闲连接
springredisjedispoolmin-idle=0
# 连接超时时间(毫秒)
springredistimeout=5000ms
由配置我们可以看到spring-boot 2x版本时间设置需要加单位ms,因为参数的类型为Duration。另外springredistimeout尽量不要配置0,否则可能会出现iolettucecoreRedisCommandTimeoutException: Command timed out超时错误。

配置文件编辑完成后,我们开始编写代码实现Redis数据的存储和读取。我们创建一个RedisUtil工具类,该类使用@Component注解表示交由Spring管理,StringRedisTemplate是Spring提供的,可以使用@Autowired注解直接注入,接下来便可以书写存和取的代码了。

@Component
public class RedisUtil {

@Autowired
private StringRedisTemplate redisTemplate;

/
存字符串
@param key 缓存键
@param value 缓存值
@param expireTime过期时间(s)
/
public void setString(String key, String value, int expireTime){
ValueOperations<String, String> ops = redisTemplateopsForValue();
if (expireTime != 0) {
opsset(key, value, expireTime, TimeUnitSECONDS);
} else {
opsset(key,value);
}
}

/
取字符串
@param key 缓存键
@return缓存值
/
public String getString(String key){
ValueOperations<String, String> ops = thisredisTemplateopsForValue();
return opsget(key);
}

接下来我们编写Controller层代码去调用RedisUtil工具类,实现数据的存储和读取,代码比较简单可以参考下图。若想验证Redis是否可用,还需要编写启动类,如下图所示。

由上图可看到我们编写了一个post请求用于存储字符串,get请求用于取出字符串。启动类通过main方法启动应用,接下来我们使用postman去模拟浏览器调用post和get请求,由下图可以看到Redis存储的数据成功被取出。

接下来我们介绍Jedis,这是一个封装了Redis的客户端,在Spring Boot整合Redis的基础上,可以提供更简单的API *** 作。因此我们需要配置JedisPool的Bean,代码如下,其中@Configuration注解表明这是一个配置类,我们在该类中注入RedisProperties,并且使用@Bean注解指定JedisPool。

@Configuration
public class RedisConfiguration {

@Autowired
private RedisProperties properties;

@Bean
public JedisPool getJedisPool(){
JedisPoolConfig config = new JedisPoolConfig();
configsetMaxIdle(propertiesgetJedis()getPool()getMaxIdle());
configsetMaxTotal(propertiesgetJedis()getPool()getMaxActive());
configsetMaxWaitMillis(propertiesgetJedis()getPool()getMaxWait()toMillis());
JedisPool pool = new JedisPool(config,propertiesgetHost(),
propertiesgetPort(),100,
propertiesgetPassword(), propertiesgetDatabase());
return pool;
}
}

接下来我们编辑JedisUtil工具类,通过SpringBoot容器的@Component注解来自动创建,并且注入JedisPool,使用jedisPoolgetResource()方法来获取Jedis,并最终实现 *** 作redis数据库,其代码如下。

@Component
public class JedisUtil {

@Autowired
JedisPool jedisPool;

//获取key的value值
public String get(String key) {
Jedis jedis = jedisPoolgetResource();
String str = "";
try {
str = jedisget(key);
} finally {
try {
jedisclose();
} catch (Exception e) {
eprintStackTrace();
}
}
return str;
}

public String set(String key, String value) {
Jedis jedis = jedisPoolgetResource();
String str = "";
try {
str = jedisset(key, value);
} finally {
try {
jedisclose();
} catch (Exception e) {
eprintStackTrace();
}
}
return str;
}

}

JedisUtil工具类编写完成后,我们修改之前的RedisController,并注入JedisUtil,代码如下图所示。然后再用postman分别调用post和get接口,我们可以看到成功取到了新的key的value值。

特别提示

在Spring Boot整合Redis前本机需安装Redis,另外可以使用RedisDesktopManager这个Redis这个桌面管理工具查看Redis中的数据。

一、Redis了解

11、Redis介绍:

redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、list(链表)、set(集合)、zset(sorted set –有序集合)和hash(哈希类型)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的 *** 作,而且这些 *** 作都是原子性的。在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改 *** 作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。

Redis数据库完全在内存中,使用磁盘仅用于持久性。相比许多键值数据存储,Redis拥有一套较为丰富的数据类型。Redis可以将数据复制到任意数量的从服务器。

12、Redis优点:

(1)异常快速:Redis的速度非常快,每秒能执行约11万集合,每秒约81000+条记录。

(2)支持丰富的数据类型:Redis支持最大多数开发人员已经知道像列表,集合,有序集合,散列数据类型。这使得它非常容易解决各种各样的问题,因为我们知道哪些问题是可以处理通过它的数据类型更好。

(3) *** 作都是原子性:所有Redis *** 作是原子的,这保证了如果两个客户端同时访问的Redis服务器将获得更新后的值。

(4)多功能实用工具:Redis是一个多实用的工具,可以在多个用例如缓存,消息,队列使用(Redis原生支持发布/订阅),任何短暂的数据,应用程序,如Web应用程序会话,网页命中计数等。

13、Redis缺点:

(1)单线程

(2)耗内存

二、64位windows下Redis安装

Redis官方是不支持windows的,但是Microsoft Open Tech group 在 GitHub上开发了一个Win64的版本,下载地址:>

主从切换技术的方法是:当主服务器宕机后,需要手动把一台从服务器切换为主服务器,这就需要人工干预,费事费力,还会造成一段时间内服务不可用。 这不是一种推荐的方式,更多时候,我们优先考虑 哨兵模式

哨兵模式是一种特殊的模式,首先Redis提供了哨兵的命令,哨兵是一个独立的进程,作为进程,它会独立运行。其原理是 哨兵通过发送命令,等待Redis服务器响应,从而监控运行的多个Redis实例。

这里的哨兵有两个作用

然而一个哨兵进程对Redis服务器进行监控,可能会出现问题,为此,我们可以使用多个哨兵进行监控。各个哨兵之间还会进行监控,这样就形成了多哨兵模式。

用文字描述一下 故障切换(failover) 的过程。假设主服务器宕机,哨兵1先检测到这个结果,系统并不会马上进行failover过程,仅仅是哨兵1主观的认为主服务器不可用,这个现象成为 主观下线 。当后面的哨兵也检测到主服务器不可用,并且数量达到一定值时,那么哨兵之间就会进行一次投票,投票的结果由一个哨兵发起,进行failover *** 作。切换成功后,就会通过发布订阅模式,让各个哨兵把自己监控的从服务器实现切换主机,这个过程称为 客观下线 。这样对于客户端而言,一切都是透明的。

配置3个哨兵和1主2从的Redis服务器来演示这个过程。

首先配置Redis的主从服务器,修改redisconf文件如下

上述内容主要是配置Redis服务器,从服务器比主服务器多一个slaveof的配置和密码。

配置3个哨兵,每个哨兵的配置都是一样的。在Redis安装目录下有一个sentinelconf文件,copy一份进行修改

上述关闭了保护模式,便于测试。

有了上述的修改,我们可以进入Redis的安装目录的src目录,通过下面的命令启动服务器和哨兵

注意启动的顺序。 首先是主机(19216811128)的Redis服务进程,然后启动从机的服务进程,最后启动3个哨兵的服务进程。

上面是通过Jedis进行使用的,同样也可以使用Spring进行配置RedisTemplate使用。

sentinel down-after-milliseconds配置项只是一个哨兵在超过规定时间依旧没有得到响应后,会自己认为主机不可用。对于其他哨兵而言,并不是这样认为。哨兵会记录这个消息,当拥有认为主观下线的哨兵达到sentinel monitor所配置的数量时,就会发起一次投票,进行failover,此时哨兵会重写Redis的哨兵配置文件,以适应新场景的需要。


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zz/10760050.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-11
下一篇 2023-05-11

发表评论

登录后才能评论

评论列表(0条)

保存