java连接redis的一个Demo

115 阅读 0 评论 76 点赞

我是靠谱客的博主可耐奇异果，最近开发中收集的这篇文章主要介绍java连接redis的一个Demo，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

首先使用的这个maven

<dependency>
      <groupId>redis.clients</groupId>
      <artifactId>jedis</artifactId>
      <version>3.6.0</version>
</dependency>

设置链接属性 jedis.properties

host=192.168.xx.xxx
port=6379
max=50
maxidle=10

设置连接类

package redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

public class JedisPoolUtils {
    private static JedisPool pool;

    static {
        //读取链接redis的配置文件
        InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");
        Properties p = new Properties();
        try {
            p.load(is);
        } catch (IOException e) {
            e.printStackTrace();
        }
//        创建redis配置
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxIdle(Integer.parseInt(p.getProperty("maxidle")));
        jedisPoolConfig.setMaxTotal(Integer.parseInt(p.getProperty("max")));

        pool=new JedisPool(jedisPoolConfig,p.getProperty("host"),Integer.parseInt(p.getProperty("port")));
    }
    //获取Jedis对象
    public static Jedis getJedis(){
        return pool.getResource();
    }
}

调用

package redis;

import redis.clients.jedis.Jedis;

import java.util.Iterator;
import java.util.Set;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args )
    {
//        Jedis jedis = new Jedis("192.168.xx.xxx", 6379); 最直接的
        Jedis jedis = JedisPoolUtils.getJedis();
        App app = new App();
        app.KeyOperate(jedis);
        jedis.close();
    }
    public void KeyOperate(Jedis jedis){
        System.out.println("======key=======");
        jedis.select(1);   //使用数据库1
        jedis.set("aaa", "1");  //添加 aaa->1
        jedis.set("bbb", "2");  //添加 bbb->2
        Set<String> keys = jedis.keys("*");   //keys *
        for (String a : keys){
            System.out.println(a);
        }
        System.out.println("==================");
        Boolean bbb = jedis.exists("bbb");      //exists bbb 查看bbb是否存在
        System.out.println(kb12);

//        Long bbb = jedis.del("bbb");               // 删除
//        Long aaa = jedis.expire("aaa", 10L);        //expire aaa "aaa" 倒计时10s后消失
//                                                       ttl  aaa     查看aaa倒计时
//                                                       persist aaa  取消aaa倒计时
//        for (int i = 0; i < 3; i++) {
//            System.out.println("循环 "+i+" 次");
//            try {
//                Thread.sleep(3000);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//            Long aaa= jedis.ttl("aaa");
//            System.out.println(aaa);
//        }

        String bbb = jedis.type("bbb");
        System.out.println(bbb);
    }

}