阿里云Redis与Tair压力测评

这里有具体介绍Tair的视频，里面详细介绍了阿里云Redis和自建Redis的对比分析

AlgoRain

601人浏览 · 2023-07-12 22:06:33

AlgoRain · 2023-07-12 22:06:33 发布

无意中发现阿里云开发社区的训练营活动，其中有一个7天玩转Redis、tair训练营计划，里面可以免费领取三个月的试用礼包，因为是参营任务，不领取都不行的那种，领取之后放着也是放着，不如跑跑数据看看Redis和Tair的性能有什么区别，简单的压力测试下，本次测试并不精确，也不具有太多参考意义，真的就是为了测试而测试。

活动地址链接见最下面的

什么是Tair

这里有具体介绍Tair的视频，里面详细介绍了阿里云Redis和自建Redis的对比分析

阿里云登录 - 欢迎登录阿里云，安全稳定的云计算服务平台

测试工作

本次没有使用Redis自带的Redis Benchmark工具，想着为了测试而测试，就为了测试而开发吧。

一：准备工作

领取Redis与Tair三个月免费额度
编写压力测试代码
准备测试数据。

二：测试方案设计

批量插入数据查看总体时延，与不同数据量下时延曲线表，记录总体耗时
批量数据查询，记录查询QPS，内存情况，网络流量等
将数据库内存空间打满后，查看相同淘汰策略下内容优化情况

三：进行压力测试

先进行功能测试,校验系统功能在高负载下是否正常。
加大并发用户数或请求流量,模拟峰值压力情况。
观察记录关键指标,分析系统瓶颈。

四：机器指标

为了去除本地机器、网络带来的干扰，这次的代码都会运行在ECS服务器中，但自己的ECS服务器都不是杭州区的，还是要通过外网域名的形式连接Redis、Tair，不过数据传输速率也是可靠的。

	Redis	Tair	ECS服务器1	ECS服务器1
规格	2 GB 增强版 (vCPU shared)	2 GB 增强版 (vCPU shared)	4C8G	4C8G
最大连接数	10,000	30,000
最大带宽	96 MB/s	96 MB/s
参考QPS	100,000	300,000
副本数	2副本	2副本
分片数量	1	1
Redis版本	Redis 5.0	版本兼容性：Redis 6.0
存储空间	10G	10G
架构类型	非集群	非集群
maxmemory-policy	volatile-lru （按照LRU算法逐出原有数据，但仅逐出设置了过期时间的数据）	volatile-lru （按照LRU算法逐出原有数据，但仅逐出设置了过期时间的数据）

五：运行代码：

package org.rain;

import redis.clients.jedis.*;

import java.io.BufferedReader;
import java.io.File;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;

public class Main {

    public static void readTxtFile(String filePath, JedisPool pool) {
        try {
            File file = new File(filePath);
            if (file.isFile() && file.exists()) {
                InputStreamReader isr = new InputStreamReader(Files.newInputStream(file.toPath()), StandardCharsets.UTF_8);
                BufferedReader br = new BufferedReader(isr);
                String lineTxt = null;
                AtomicInteger i = new AtomicInteger();
                ExecutorService executorService = new ThreadPoolExecutor(50, 50, 100L, TimeUnit.MILLISECONDS, new SynchronousQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy());

                while ((lineTxt = br.readLine()) != null) {
                    String[] textArr = lineTxt.split("\t");
                    if (textArr.length <= 6) {
                        continue;
                    }
                    executorService.submit(() -> {
                        try (Jedis jedis = pool.getResource()) {
                            jedis.setex(textArr[0] + "-" + i.getAndIncrement(), 14400, textArr[6]);
                            //                            System.out.println("已处理第" + i);
                        }
                    });
                    executorService.submit(() -> {
                        try (Jedis jedis = pool.getResource()) {
                            jedis.setex(textArr[1] + "-" + i.getAndIncrement(), 14400, textArr[6]);
                            //                            System.out.println("已处理第" + i);
                        }
                    });
                }
                System.out.println("处理完毕，共处理：" + i);
                executorService.shutdown();
                br.close();
            } else {
                System.out.println("文件不存在!");
            }
        } catch (Exception e) {
            System.out.println("文件读取错误!" + e);
        }
    }

    public static void main(String[] args) {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxIdle(200);
        config.setMaxTotal(300);
        config.setTestOnBorrow(false);
        config.setTestOnReturn(false);
        String redisHost = "r-.redis.rds.aliyuncs.com";
        String redisUser = "r-";
        String redisPassword = "";
        String tairHost = "r-.redis.rds.aliyuncs.com";
        String tairUser = "r-";
        String tairPassword = "";
        JedisPool pool;
        if ("redis".equals(args[0])) {
            System.out.println("redis");
            pool = new JedisPool(config, redisHost, 6379, redisUser, redisPassword);
        } else {
            System.out.println("tair");
            pool = new JedisPool(config, tairHost, 6379, tairUser, tairPassword);
        }
        String filePath = "local".equals(args[1]) ? "/Users/Downloads/weibo_train_data.txt" : "/home/weibo_train_data.txt";
            System.out.println(filePath);
            readTxtFile(filePath, pool);
            }
            }

六：模拟数据

1229619条微博用户发帖数据

写入性能截图

Redis

Tair

服务器负载

从图里看，在没有调整任何参数的情况下，插入250w条数据，Redis和Tair基本没有太大的区别，只是Tair的平均时延有些高，两者的QPS都能达到1000，还没有跑满官方的参考值。

读取测试截图

代码

public static void getTxtFile(String filePath, JedisPool pool) {
    try {
        File file = new File(filePath);
        if (file.isFile() && file.exists()) {
            InputStreamReader isr = new InputStreamReader(Files.newInputStream(file.toPath()), StandardCharsets.UTF_8);
            BufferedReader br = new BufferedReader(isr);
            String lineTxt = null;
            AtomicInteger i = new AtomicInteger();
            ExecutorService executorService = new ThreadPoolExecutor(50, 50, 100L, TimeUnit.MILLISECONDS, new SynchronousQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy());

            while ((lineTxt = br.readLine()) != null) {
                String[] textArr = lineTxt.split("\t");
                if (textArr.length <= 6) {
                    continue;
                }
                executorService.submit(() -> {
                    try (Jedis jedis = pool.getResource()) {
                        System.out.println(jedis.get(textArr[0] + "-" + i.getAndIncrement()));
                    }
                });
                executorService.submit(() -> {
                    try (Jedis jedis = pool.getResource()) {
                        System.out.println(jedis.get(textArr[1] + "-" + i.getAndIncrement()));
                    }
                });
            }
            System.out.println("处理完毕，共处理：" + i);
            executorService.shutdown();
            br.close();
        } else {
            System.out.println("文件不存在!");
        }
    } catch (Exception e) {
        System.out.println("文件读取错误!" + e);
    }
}