Java使用Redis--jedis

Posted 2021-02-17 木心

参考：菜鸟教程 http://www.runoob.com/redis/redis-java.html

1、Java 使用 Redis

开始在 Java 中使用 Redis 前， 我们需要确保已经安装了 redis 服务及 Java redis 驱动（jedis-2.9.0.jar），且你的机器上能正常使用 Java。

　　1.1、Redis Java String(字符串) 实例

public class RedisStringJava {
    public static void main(String[] args) {
        //连接本地的 Redis 服务
        Jedis jedis = new Jedis("localhost");
        System.out.println("连接成功");
        //设置 redis 字符串数据
        jedis.set("runoobkey", "www.runoob.com");
        // 获取存储的数据并输出
        System.out.println("redis 存储的字符串为: "+ jedis.get("runoobkey"));
    }
}

　　

　　1.2、Redis Java List(列表) 实例

public class RedisListJava {
    public static void main(String[] args) {
        //连接本地的 Redis 服务
        Jedis jedis = new Jedis("localhost");
        System.out.println("连接成功");
        //存储数据到列表中
        jedis.lpush("site-list", "Runoob");
        jedis.lpush("site-list", "Google");
        jedis.lpush("site-list", "Taobao");
        // 获取存储的数据并输出
        List<String> list = jedis.lrange("site-list", 0 ,2);
        for(int i=0; i<list.size(); i++) {
            System.out.println("列表项为: "+list.get(i));
        }
    }
}

　　

　　1.3、Redis Java Keys 实例

public class RedisKeyJava {
    public static void main(String[] args) {
        //连接本地的 Redis 服务
        Jedis jedis = new Jedis("localhost");
        System.out.println("连接成功");
 
        // 获取数据并输出
        Set<String> keys = jedis.keys("*"); 
        Iterator<String> it=keys.iterator() ;   
        while(it.hasNext()){   
            String key = it.next();   
            System.out.println(key);   
        }
    }
}

 

2、Java 使用 Redis

　　jedis-2.7.2.jar  和  commons-pool2-2.3.jar

package com.oy.test;

import java.util.HashSet;
import java.util.Set;
import org.junit.Test;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPool;

public class Demo1 {
    // 单机版测试
    @Test
    public void fun1() throws Exception {
        // 创建一个Jedis对象
        Jedis jedis = new Jedis("192.168.25.128", 6379);
        jedis.set("test", "hello jedis");
        String string = jedis.get("test");
        System.out.println(string);
        jedis.close();
    }

    // 使用连接池
    @Test
    public void testJedisPool() throws Exception {
        // 创建一个连接池对象
        // 系统中应该是单例的。
        JedisPool jedisPool = new JedisPool("192.168.25.128", 6379);
        // 从连接池中获得一个连接
        Jedis jedis = jedisPool.getResource();
        String result = jedis.get("test");
        System.out.println(result);
        // jedis必须关闭
        jedis.close();

        // 系统关闭时关闭连接池
        jedisPool.close();
    }

    // 连接redis集群
    @Test
    public void testJedisCluster() throws Exception {
        // 创建一个JedisCluster对象
        Set<HostAndPort> nodes = new HashSet<>();
        nodes.add(new HostAndPort("192.168.25.128", 7001));
        nodes.add(new HostAndPort("192.168.25.128", 7002));
        nodes.add(new HostAndPort("192.168.25.128", 7003));
        nodes.add(new HostAndPort("192.168.25.128", 7004));
        nodes.add(new HostAndPort("192.168.25.128", 7005));
        nodes.add(new HostAndPort("192.168.25.128", 7006));
        // 在nodes中指定每个节点的地址
        // jedisCluster在系统中是单例的。
        JedisCluster jedisCluster = new JedisCluster(nodes);
        jedisCluster.set("name", "zhangsan");
        jedisCluster.set("value", "100");
        String name = jedisCluster.get("name");
        String value = jedisCluster.get("value");
        System.out.println(name);
        System.out.println(value);

        // 系统关闭时关闭jedisCluster
        jedisCluster.close();
    }
}