redis多实列java代码怎么实现

redis多实列java代码怎么实现,第1张

多实例的redis 主要通过 redis shard功能实现

可以看一下Java Redis线程池ShardedJedisPool 使用方法

主要的原理是根据key做hash散列算法存储查询到不同的实例分片上

redis是key-value存储系统。

key-value分布式存储系统查询速度快、存放数据量大、支持高并发,非常适合通过主键进行查询,但不能进行复杂的条件查询。

如果辅以Real-Time Search Engine(实时搜索引擎)进行复杂条件检索、全文检索,就可以替代并发性能较低的MySQL等关系型数据库,达到高并发、高性能,节省几十倍服务器数 量的目的。

以MemcacheDB、Tokyo Tyrant为代表的key-value分布式存储,在上万并发连接下,轻松地完成高速查询。而MySQL,在几百个并发连接下,就基本上崩溃了。

在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改 *** 作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。

扩展资料:

Jedis主存保护是存储保护的重要环节。主存保护一般有存储区域保护和访问方式保护。存储区域保护可采用界限寄存器方式,由系统软件经特权指令给定上、下界寄存器内容,从而划定每个用户程序的区域,禁止越界访问。

Jedis当两键符合时才允许执行存取 *** 作,从而保护别的程序区域不被侵犯,环状保护是把系统程序和用户程序按重要性分层,称为环,对每个环都规定访问它的级别,违反规定的存取 *** 作是非法的,以此实现对正在执行的程序的保护。

参考资料来源:百度百科-Key-Value

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多实列java代码怎么实现全部的内容,包括:redis多实列java代码怎么实现、Jedis干什么用的、Spring Boot如何整合Redis等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

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

原文地址:https://54852.com/web/9337032.html

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

发表评论

登录后才能评论

评论列表(0条)

    保存