"1、 maven 配置 redis.clients jedis 2.9.0 2、 Java 操作 Redis 数据接口 [链接] package com.coshaho.learn.redis; import java.util.HashMap; import java.util.Iterato ...."

someone1
AI专业者开发社区 1 号成员
AI开发者社区 • 0 回帖 • 1 浏览 • 5 个月前

Redis入门——Java接口

1、 maven 配置

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

2、 Java 操作 Redis 数据接口

package com.coshaho.learn.redis;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import redis.clients.jedis.Jedis;
/**
*


MyRedisLearn.java Create on 2017 年 11 月 4 日 下午 4:40:39



类功能说明:  Redis Java 接口测试



Copyright: Copyright(c) 2013


Company: COSHAHO


@Version 1.0


@Author coshaho
*/
public class MyRedisLearn
{
private Jedis jedis;
public static void main(String[] args)
{
MyRedisLearn redis = new MyRedisLearn();
redis.init();
redis.testString();
redis.testMap();
redis.testList();
redis.testSet();
}
public void init()
{
jedis = new Jedis("127.0.0.1", 6379);
jedis.auth("coshaho");
}
public void testString()
{
// 设置值
jedis.del("string1");
jedis.set("string1","coshaho");
System.out.println(jedis.get("string1"));
 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 字符串拼接</span>
 jedis.append("string1", " is my name"); <span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">拼接</span>
 System.out.println(jedis.get("string1"<span style="color: rgba(0, 0, 0, 1)">)); 

 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 删除字符串</span>
 jedis.del("string1"<span style="color: rgba(0, 0, 0, 1)">);
 System.out.println(jedis.get(</span>"string1"<span style="color: rgba(0, 0, 0, 1)">));

 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 设置多个键值对</span>
 jedis.del("name"<span style="color: rgba(0, 0, 0, 1)">);
 jedis.del(</span>"age"<span style="color: rgba(0, 0, 0, 1)">);
 jedis.mset(</span>"name","coshaho","age","28"<span style="color: rgba(0, 0, 0, 1)">);
 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 加1操作</span>
 jedis.incr("age"<span style="color: rgba(0, 0, 0, 1)">);
 System.out.println(jedis.get(</span>"name") + "-" + jedis.get("age"<span style="color: rgba(0, 0, 0, 1)">));

}
public void testMap()
{
jedis.del("user");
Map<String, String> map = new HashMap<String, String>();
map.put("name", "coshaho");
map.put("age", "28");
map.put("sex", "male");
jedis.hmset("user",map);
 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 参数1 key 参数2 filed 参数3 field</span>
 List&lt;String&gt; rsmap = jedis.hmget("user", "name", "age", "sex"<span style="color: rgba(0, 0, 0, 1)">);
 System.out.println(rsmap);  

 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 删除map中的某个键值  </span>
 jedis.hdel("user","age"<span style="color: rgba(0, 0, 0, 1)">);
 System.out.println(jedis.hmget(</span>"user", "age"<span style="color: rgba(0, 0, 0, 1)">));   
 System.out.println(jedis.hlen(</span>"user"<span style="color: rgba(0, 0, 0, 1)">));  
 System.out.println(jedis.exists(</span>"user"<span style="color: rgba(0, 0, 0, 1)">));
 System.out.println(jedis.hkeys(</span>"user"<span style="color: rgba(0, 0, 0, 1)">));
 System.out.println(jedis.hvals(</span>"user"<span style="color: rgba(0, 0, 0, 1)">));

 Iterator</span>&lt;String&gt; iter=jedis.hkeys("user"<span style="color: rgba(0, 0, 0, 1)">).iterator();  
 </span><span style="color: rgba(0, 0, 255, 1)">while</span><span style="color: rgba(0, 0, 0, 1)"> (iter.hasNext())
 {  
     String key </span>=<span style="color: rgba(0, 0, 0, 1)"> iter.next();  
     System.out.println(key</span>+":"+jedis.hmget("user"<span style="color: rgba(0, 0, 0, 1)">,key));  
 }  

}
public void testList()
{
// 删除 list
jedis.del("language");
System.out.println(jedis.lrange("language",0,-1));
 jedis.lpush(</span>"language","english"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.lpush(</span>"language","chinese"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.lpush(</span>"language","japanese"<span style="color: rgba(0, 0, 0, 1)">);  

 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 第一个是key，第二个是起始位置，第三个是结束位置，jedis.llen获取长度 -1表示取得所有  </span>
 System.out.println(jedis.lrange("language",0,-1<span style="color: rgba(0, 0, 0, 1)">));  

 jedis.del(</span>"language"<span style="color: rgba(0, 0, 0, 1)">);
 jedis.rpush(</span>"language","java"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.rpush(</span>"language","c"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.rpush(</span>"language","python"<span style="color: rgba(0, 0, 0, 1)">); 
 System.out.println(jedis.lrange(</span>"language",0,-1<span style="color: rgba(0, 0, 0, 1)">));

 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 双向列表，jedis 排序 </span>
 jedis.del("a"<span style="color: rgba(0, 0, 0, 1)">);
 jedis.rpush(</span>"a", "1"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.lpush(</span>"a","6"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.lpush(</span>"a","3"<span style="color: rgba(0, 0, 0, 1)">);  
 jedis.lpush(</span>"a","9"<span style="color: rgba(0, 0, 0, 1)">);  
 System.out.println(jedis.lrange(</span>"a",0,-1<span style="color: rgba(0, 0, 0, 1)">));
 System.out.println(jedis.sort(</span>"a"<span style="color: rgba(0, 0, 0, 1)">)); 
 System.out.println(jedis.lrange(</span>"a",0,-1<span style="color: rgba(0, 0, 0, 1)">));  

}
public void testSet()
{
jedis.del("b");
jedis.sadd("b","张三");
jedis.sadd("b","李四");
jedis.sadd("b","王五");
jedis.sadd("b","胜七");
jedis.sadd("b","段九");
 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 移除</span>
 jedis.srem("b","胜七"<span style="color: rgba(0, 0, 0, 1)">);  
 System.out.println(jedis.smembers(</span>"b"<span style="color: rgba(0, 0, 0, 1)">));  
 System.out.println(jedis.sismember(</span>"b", "胜七"<span style="color: rgba(0, 0, 0, 1)">));  
 System.out.println(jedis.srandmember(</span>"b"<span style="color: rgba(0, 0, 0, 1)">));  
 System.out.println(jedis.scard(</span>"b"<span style="color: rgba(0, 0, 0, 1)">));

}
}

3、 Java 创建 Redis 连接池

package com.coshaho.learn.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public final class RedisPool
{
//Redis 服务器 IP
private static String ADDR = "127.0.0.1";
</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">Redis的端口号</span>
<span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">int</span> PORT = 6379<span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">访问密码</span>
<span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> String AUTH = "coshaho"<span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">可用连接实例的最大数目，默认值为8；
</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">如果赋值为-1，则表示不限制；如果pool已经分配了MAX_TOTAL个jedis实例，则此时pool的状态为exhausted(耗尽)。</span>
<span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">int</span> MAX_TOTAL = 1024<span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。</span>
<span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">int</span> MAX_IDLE = 200<span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；</span>
<span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">int</span> MAX_WAIT = 10000<span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">int</span> TIMEOUT = 10000<span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；</span>
<span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">boolean</span> TEST_ON_BORROW = <span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> JedisPool jedisPool = <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">;

</span><span style="color: rgba(0, 128, 0, 1)">/**</span><span style="color: rgba(0, 128, 0, 1)">
 * 初始化Redis连接池
 </span><span style="color: rgba(0, 128, 0, 1)">*/</span>
<span style="color: rgba(0, 0, 255, 1)">static</span><span style="color: rgba(0, 0, 0, 1)"> 
{
    </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)"> 
    {
        JedisPoolConfig config </span>= <span style="color: rgba(0, 0, 255, 1)">new</span><span style="color: rgba(0, 0, 0, 1)"> JedisPoolConfig();
        config.setMaxIdle(MAX_IDLE);
        config.setTestOnBorrow(TEST_ON_BORROW);
        config.setMaxTotal(MAX_TOTAL);
        config.setMaxWaitMillis(MAX_WAIT);
        jedisPool </span>= <span style="color: rgba(0, 0, 255, 1)">new</span><span style="color: rgba(0, 0, 0, 1)"> JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);
    } 
    </span><span style="color: rgba(0, 0, 255, 1)">catch</span><span style="color: rgba(0, 0, 0, 1)"> (Exception e) 
    {
        e.printStackTrace();
    }
}

</span><span style="color: rgba(0, 128, 0, 1)">/**</span><span style="color: rgba(0, 128, 0, 1)">
 * 获取Jedis实例
 * </span><span style="color: rgba(128, 128, 128, 1)">@return</span>
 <span style="color: rgba(0, 128, 0, 1)">*/</span>
<span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">synchronized</span> <span style="color: rgba(0, 0, 255, 1)">static</span><span style="color: rgba(0, 0, 0, 1)"> Jedis getJedis() 
{
    </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)"> 
    {
        </span><span style="color: rgba(0, 0, 255, 1)">if</span> (jedisPool != <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">) 
        {
            Jedis resource </span>=<span style="color: rgba(0, 0, 0, 1)"> jedisPool.getResource();
            </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> resource;
        } 
        </span><span style="color: rgba(0, 0, 255, 1)">else</span><span style="color: rgba(0, 0, 0, 1)"> 
        {
            </span><span style="color: rgba(0, 0, 255, 1)">return</span> <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">;
        }
    } 
    </span><span style="color: rgba(0, 0, 255, 1)">catch</span><span style="color: rgba(0, 0, 0, 1)"> (Exception e) 
    {
        e.printStackTrace();
        </span><span style="color: rgba(0, 0, 255, 1)">return</span> <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">;
    }
}

</span><span style="color: rgba(0, 128, 0, 1)">/**</span><span style="color: rgba(0, 128, 0, 1)">
 * 释放jedis资源
 * </span><span style="color: rgba(128, 128, 128, 1)">@param</span><span style="color: rgba(0, 128, 0, 1)"> jedis
 </span><span style="color: rgba(0, 128, 0, 1)">*/</span>
<span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">void</span> close(<span style="color: rgba(0, 0, 255, 1)">final</span><span style="color: rgba(0, 0, 0, 1)"> Jedis jedis) 
{
    </span><span style="color: rgba(0, 0, 255, 1)">if</span> (jedis != <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">) {
        jedis.close();;
    }
}

</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">void</span><span style="color: rgba(0, 0, 0, 1)"> main(String[] args)
{
    RedisPool.getJedis().set(</span>"pool", "连接池"<span style="color: rgba(0, 0, 0, 1)">);
    System.out.println(RedisPool.getJedis().get(</span>"pool"<span style="color: rgba(0, 0, 0, 1)">));
}

}

Redis入门——Java接口

相关帖子

随便看看

Redis入门——Java接口