使用原生jedis和spring的redisTemplate调用连接池,发现差别巨大:
redis配置:
redis:database: 0host: 127.0.0.1port: 6379password: 123456timeout: 5000lettuce:shutdown-timeout: 200pool:max-active: 500max-idle: 100min-idle: 50max-wait: 2000
jedis单元测试:
public void testJedis() throws IOException {GreExam greExam = new GreExam();greExam.setId(997);String greExamStr = JacksonUtil.bean2Json(greExam);long time = 0;for (int i = 0; i < 100; i++) {try (Jedis jedis = jedisPool.getResource()) {// 1、推送long time1 = System.currentTimeMillis();jedis.lpush("jedis-mq", greExamStr);// 2、接收String msg = jedis.brpoplpush("jedis-mq", "jedis-mq_bak", 0);jedis.lrem("jedis-mq_bak", 1, msg);long time2 = System.currentTimeMillis();time += time2 - time1;} catch (Exception e) {e.printStackTrace();}}System.out.println("总时间:" + time);}
redisTemplate单元测试:
public void testRedisTemplate() throws IOException {GreExam greExam = new GreExam();greExam.setId(997);String greExamStr = JacksonUtil.bean2Json(greExam);long time = 0;for (int i = 0; i < 100; i++) {// 1、推送long time1 = System.currentTimeMillis();redisTemplate.opsForList().leftPush("redisTemplate-mq", greExamStr);// 2、接收String msg = (String) redisTemplate.opsForList().rightPopAndLeftPush("redisTemplate-mq", "redisTemplate-mq_bak", 1, TimeUnit.SECONDS);redisTemplate.opsForList().remove("redisTemplate-mq_bak", 1, msg);long time2 = System.currentTimeMillis();time += time2 - time1;}System.out.println("总时间:" + time);}
时效对比:
结论:原生jedis效率优于redisTemplate。另外,测试种发现,使用了100次请求,每次不进行业务操作,执行速度很快,redis只保持了几个连接,但是若是加上自己的业务处理或者休眠几秒,会发现redis持续保持了连接池的配置50+连接,由于是单线程,上一个jedis执行完毕后,貌似没有关闭,而且下次调用也没有分派空闲连接,而是打开新连接,直到最小连接数饱和,才分配空空闲连接给下一个(按理说单线程应该保证新调用的时候,上一个已经完全空闲,所以不再开新连接),具体原因位置,保持疑问,可能和线程池的原理有关。
手动休眠,模拟业务过程:
添加休眠前:
添加休眠后: