import org.apache.commons.lang.math.RandomUtils; import redis.clients.jedis.Jedis; import redis.clients.jedis.Pipeline; public class RedisEasyTest { private static Jedis jedis = new Jedis("xx.xx.xx.xx"); private static Pipeline p = jedis.pipelined(); private static int KEY_COUNT = 10000; private static int FIELD_COUNT = 10; public void single() { for (int i = 0; i < KEY_COUNT; i++) { String key = RandomUtils.nextInt(5) + ""; for (int j = 0; j < FIELD_COUNT; j++) { jedis.hset(key, j + "", i + j + ""); jedis.expire(key, 3600); } } } public void batch() { int index = 0; for (int i = 0; i < KEY_COUNT; i++) { String key = RandomUtils.nextInt(5) + ""; for (int j = 0; j < FIELD_COUNT; j++) { p.hset(key, j + "", i + j + ""); p.expire(key, 3600); } if (++index % 1000 == 0) { p.sync(); } } p.sync(); } public static void main(String[] args) { long start = System.currentTimeMillis(); RedisEasyTest r = new RedisEasyTest(); r.single(); System.out.printf("single use %d sec \n", (System.currentTimeMillis() - start) / 1000); start = System.currentTimeMillis(); r.batch(); System.out.printf("batch use %d sec \n", (System.currentTimeMillis() - start) / 1000); } }
输出结果:
single use 30 sec
batch use 0 sec
可以看到通过pipeline批量插入数据性能是非常不错的。
--end
相关推荐
Redis-PipeLine批量导入.docx
java连接redis集群批量String类型插入
由于项目中需要使用批量插入功能, 所以在网上查找到了Redis 批量插入可以使用pipeline来高效的插入, 示例代码如下: String key = "key"; Jedis jedis = new Jedis("xx.xx.xx.xx"); Pipeline p = jedis.pipelined();...
本篇文章主要介绍了如何高效地向Redis插入大量的数据,现在分享给大家,感兴趣的小伙伴们可以参考一下。
主要给大家介绍了关于Redis利用Pipeline加速查询速度的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用Redis具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
简单介绍 redis pipeline 的机制,结合一段实例说明pipeline 在提升吞吐量方面发生的效用。 案例背景 应用系统在数据推送或事件处理过程中,往往出现数据流经过多个网元; 然而在某些服务中,数据操作对redis 是强...
今天小编就为大家分享一篇python使用pipeline批量读写redis的方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
本篇文章主要介绍了Java使用Pipeline对Redis批量读写(hmset&hgetall),具有一定的参考价值,有兴趣的可以了解一下。
Redis笔记整理-五中数据类型之String和Hash,这两种数据类型是我们常用语做缓存,从而减轻数据库的压力,缓存我们一般放到服务成,被多个表现成调用达到公用性
java客户端不是很好支持redis cluster,spring-date-redis和jedis批量提交还不支持,单个提交都是可以的。 为了批量解决批量提交 网上有几个方案,本示例使用了其中一种,demo里的JedisClusterPipeline类是网上找的...
kettle如何3秒内写入100万条数据到Redis https://blog.csdn.net/huryer/article/details/106889792
redis pipleLine
redis增删改数据 redis增删改数据 redis增删改数据redis增删改数据 redis增删改数据
例如: ./redis_to_json.py | gzip > redis_backup.json.gz这对于您正在使用但又不想丢失数据的应用程序也很不错,因为Redis RDB文件并不总是那么方便。注意事项和注意事项u()中的Unicode支持仅适用于Python2.x。...
阿里巴巴28条Redis使用规范
Java实现redis,linux安装redis,一分钟学会使用redis,就是这么简单