建立redis的连接池

1、在配置文件中添加参数（application-dev.yml）

redis:
  # *** 邮件发送服务器地址
  host: 127.0.0.1
  # *** 邮件发送服务器端口
  port: 6379
  # *** 提醒邮件发件人邮箱
  timeout: 10000

2、建一个获取redis连接的工具类

@Component
public class JTRedisUtils {
    protected static final Logger logger = Logger.getLogger(JTRedisUtils.class);

    private JedisPool jedisPool;

    @Autowired
    private JTRedisConfig redisConfig;

    @Value("${redis.host}")
    private String host;

    @Value("${redis.port}")
    private int port;

    @Value("${redis.timeout}")
    private int timeout;

    public JedisPool redisPoolFactory() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        JedisPool jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout, null);
        logger.info("JedisPool注入成功！！");
        logger.info("redis地址：" + host + ":" + port);
        return jedisPool;
    }

    public Jedis getResource() {
        if(jedisPool == null){
            jedisPool = redisPoolFactory();
        }
        return jedisPool.getResource();
    }
}

3、测试获取redis连接

@Autowired
    private JTRedisUtils redisUtils;
    @Autowired
    private JTNoteClassificationMapper noteClassificationMapper;
    
    @Test
    public void testImportData() {
        Jedis jedis = redisUtils.getResource();
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("userId","e92d0309e0df4ef798a3d3f8e75eff6d");
        List<JTNoteClassificationEntity> noteClassificationEntityList =  noteClassificationMapper.getJTNoteClassificationEntityListByUserId("e92d0309e0df4ef798a3d3f8e75eff6d");
        for(JTNoteClassificationEntity noteClassificationEntity : noteClassificationEntityList){
            jedis.lpush("item_id_list",noteClassificationEntity.getId());

            jedis.hset("itemlist"+noteClassificationEntity.getId(),"id",noteClassificationEntity.getId()+"");
            jedis.hset("itemlist"+noteClassificationEntity.getId(),"title",noteClassificationEntity.getTitle());

        }
        System.out.println("操作完成");
        jedis.close();
    }