SpringBoot整合Redis管道的示例代码
更新时间：2021年07月06日 15:03:19 作者：syrdbt
本文将结合实例代码，介绍SpringBoot整合Redis管道，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
1. Redis 之管道（pipeline)
执行一个Redis命令，Redis客户端和Redis服务器就需要执行以下步骤：
- 客户端发送命令到服务器；
- 服务器接受命令请求，执行命令，产生相应的结果；
- 服务器返回结果给客户端；
- 客户端接受命令的执行结果，并向用户展示。
Redis命令所消耗的大部分时间都用在了发送命令请求和接收命令结果上面，把任意多条Redis命令请求打包在一起，然后一次性地将它们全部发送给服务器，而服务器则会把所有命令请求都处理完毕之后，一次性地将它们的执行结果全部返回给客户端。
注意事项：
Redis服务器并不会限制客户端在管道中包含的命令数量，但是却会为客户端的输入缓冲区设置默认值为1GB的体积上限：当客户端发送的数据量超过这一限制时，Redis服务器将强制关闭该客户端。因此最好不要一下把大量命令或者一些体积非常庞大的命令放到同一个管道中执行。
除此之外，很多客户端本身也带有隐含的缓冲区大小限制，如果你在使用流水线特性的过程中，发现某些流水线命令没有被执行，或者流水线返回的结果不完整，那么很可能就是你的程序触碰到了客户端内置的缓冲区大小限制。
2. SpringBoot 整合 Redis 管道实例
使用单个的 increment 命令，处理 200w个key：
public class RedisPipelineStudy extends BaseTest {
@Autowired
private StringRedisTemplate stringRedisTemplate;
private static final String PREFIX = "test0:";
@Test
public void test() {
StopWatch stopWatch = new StopWatch();
stopWatch.start("test0");
for (int times = 0; times < 2; times++) {
for (int i = 0; i < 1000000; i++) {
stringRedisTemplate.opsForValue().increment(PREFIX + i, 1L);
}
}
stopWatch.stop();
System.out.println(stopWatch.prettyPrint());
}
}
耗时如下所示：是 12 位 ，单位ns
使用管道 incrBy 处理 200w个key，每次打包300条命令发送给服务器，如下所示：
public class RedisPipelineStudy extends BaseTest {
@Autowired
private StringRedisTemplate stringRedisTemplate;
private static final String PREFIX = "test1:";
@Test
public void test() {
StopWatch stopWatch = new StopWatch();
stopWatch.start("test1");
List<Integer> recordList = new ArrayList<>();
for (int times = 0; times < 2; times++) {
for (int i = 0; i < 1000000; i++) {
try {
recordList.add(i);
if (recordList.size() > 300) {
incrByPipeline(recordList);
recordList = new ArrayList<>();
}
} catch (Exception e) {
System.out.println(e);
}
}
if (!CollectionUtils.isEmpty(recordList)) {
incrByPipeline(recordList);
recordList = new ArrayList<>();
}
}
stopWatch.stop();
System.out.println(stopWatch.prettyPrint());
}
private void incrByPipeline(List<Integer> recordList) {
stringRedisTemplate.executePipelined(new RedisCallback<Object>() {
@Override
public Object doInRedis(RedisConnection connection) throws DataAccessException {
try {
for (Integer record : recordList) {
byte[] key = (PREFIX + record).getBytes();
connection.incrBy(key, 1);
}
} catch (Exception e) {
System.out.println(e);
}
return null;
}
});
}
}
耗用时间： 11 位 ，单位 ：ns，是单个命令耗时的 1/6。
到此这篇关于SpringBoot整合Redis管道的示例代码的文章就介绍到这了,更多相关SpringBoot整合Redis管道内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了java中的fork join框架的使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-03-03
这篇文章主要介绍了五分钟带你了解Java的接口数据校验，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-12-12
这篇文章主要介绍了Go反射底层原理及数据结构解析，反射的实现和interface的组成很相似，都是由“类型”和“数据值”构成，下面小编分享更多相关内容需要的小伙伴可以参考一下2022-06-06
今天突然想Java如何计算集合的交差并集，主要是看Python语言的时候想起来的。下面这篇文章主要给大家介绍了关于java中计算集合的交差并集的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考借鉴，下面来一起看看吧。2017-08-08
Spring中ImportBeanDefinitionRegistrar源码和使用方式
Spring容器扩展流程总结：1. 定义Mapper层,2. 通过FactoryBean创建代理对象,3. 使用ImportBeanDefinitionRegistrar修改Bean定义,4. 应用自定义注解@LuoyanImportBeanDefinitionRegistrar,5. 配置类中执行后置处理器,6. 启动类中查看源码,希望对大家有所帮助2024-11-11
这篇文章主要介绍了浅谈SpringCloud之zuul源码解析，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-02-02
这篇文章主要介绍了 Mybatis基于注解形式的sql语句生成实例代码,需要的朋友可以参考下2017-09-09
在我们平常开发操作数据库时,查询、插入数据等操作行为,有时会报数据类型不匹配异常,就可以得知数据的类型是不唯一的必然是多种不同的数据类型,本文给大家介绍了MyBatis中TypeHandler的使用教程,需要的朋友可以参考下2024-12-12
当服务器向客户端响应数据时，SpringMVC框架会使用“转换器”（Converter）将方法的返回值进行转换，SpringMVC框架还会自动使用不同的转换器，因此这篇文章就给大家详细介绍一下Spring MVC如何处理响应并附上案例,需要的朋友可以参考下2023-06-06
IoC全称Inversion of Control (控制反转) ,这里的控制其实是控制权的意思,可以理解为对象的获取权力和方式发生了发转,DI依赖注⼊是⼀个过程,是指IoC容器在创建Bean时, 去提供运⾏时所依赖的资源,⽽资源指的就是对象,本文介绍了Spring实现IoC和DI的方法2024-08-08
最新评论