Java API操作Redis

2529 ワード

Redis用のJavaクライアントにはさまざまな種類があります.具体的には、公式サイトの情報を参照してください.https://redis.io/clients#java 今回のテストではJedis APIを使用し、Jedisの使用が便利で、apiメソッド名はredisコマンド名と一致しています.redisコマンドに詳しくない場合は、「Redisクライアント基本コマンド」を参照してください.
一、依存

    redis.clients
    jedis
    2.8.0

二、コード
import java.io.IOException;
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;
import redis.clients.jedis.JedisPoolConfig;

public class RedisTest {

    private static final String URL = "192.168.2.11";

    private static final int PORT = 6379;

    /**
     * redis    
     */
    @Test
    public void testJedisPool() {
        //   
        JedisPool pool = new JedisPool(URL, PORT);
        Jedis jedis = pool.getResource();
        jedis.set("username", "admin");
        String value = jedis.get("username");
        System.out.println(value);
        jedis.close();
    }

    /**
     * redis config    
     */
    @Test
    public void testJedisPoolAndConfig() {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10);
        config.setMinIdle(5);

        JedisPool pool = new JedisPool(config, URL, PORT);
        Jedis jedis = pool.getResource();
        jedis.set("goods", "    ");
        String value = jedis.get("goods");
        System.out.println(value);
        jedis.close();
    }

    /**
     * redis    
     */
    @Test
    public void testJedisCluster() {
        Set nodes = new HashSet<>();
        nodes.add(new HostAndPort(URL, 6379));
        nodes.add(new HostAndPort(URL, 6380));
        nodes.add(new HostAndPort(URL, 6381));
        nodes.add(new HostAndPort(URL, 6382));
        nodes.add(new HostAndPort(URL, 6383));
        nodes.add(new HostAndPort(URL, 6384));
        //   
        JedisCluster cluster = new JedisCluster(nodes);
        cluster.set("cluster", "hello world");
        String value = cluster.get("cluster");
        System.out.println(value);
        try {
            //          
            cluster.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

転載先:https://www.cnblogs.com/moonlightL/p/7404576.html