安装
参考：http://www.redis.cn/download.html
安装
下载，解压，编译:
$ wget http://download.redis.io/releases/redis-4.0.8.tar.gz
$ tar -zcvf redis-4.0.8.tar.gz
$ cd redis-4.0.8
$ make
启动src/redis-server
内置的命令行工具command line interfacesrc/redis-cli
参考：http://www.cnblogs.com/liuling/p/2014-4-19-04.html
依赖
jedis:
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
连接池:
<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-pool2 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>2.4.2</version>
</dependency>
jedis操作redis
package impl.service.redis;
import face.service.RedisService;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
/**
* @author futao
* Created on 18-2-28-下午5:15.
*/
public class RedisServiceImpl implements RedisService {
private Jedis jedis;
@Before
public void setup() {
/*连接redis服务器*/
jedis = new Jedis("127.0.0.1", 6379);
/*权限，密码*/
//jedis.auth("");
}
/**
* jedis存储字符串
*/
@Test
public void testString() {
/*向redis中存String键值对 set*/
jedis.set("name", "futao");
/*从redis中读取String get*/
System.out.println(jedis.get("name"));
/*拼接*/
jedis.append("name", " is 666");
System.out.println(jedis.get("name"));
/*删除某个键值对*/
jedis.del("name");
System.out.println("del===" + jedis.get("name"));
/*一次性添加多个键值对*/
jedis.mset("k1", "v1", "k2", "v2", "age", "16");
System.out.println(jedis.get("k1"));
System.out.println(jedis.get("k2"));
System.out.println(jedis.get("age"));
/*age加一*/
jedis.incr("age");
System.out.println(jedis.get("age"));
/*String类型的数据设置过期时间*/
jedis.setex("name", 5, "Nicai");
System.out.println(jedis.get("name"));
}
/**
* jedis操作map
*/
@Test
public void testMap() {
Map<String, String> map = new HashMap<>();
map.put("user", "futao");
map.put("age", "18");
map.put("sex", "男");
/*存hashMap数据，hmset()*/
jedis.hmset("futaoInfo", map);
/*设置过期时间*/
jedis.expire("futaoInfo", 5);
/*读取hashMap数据结构的数据。返回的是一个List*/
System.out.println(jedis.hmget("futaoInfo", "sex", "user"));
List<String> list = jedis.hmget("futaoInfo", "sex", "sex", "age");
list.forEach(System.out::println);
/*删除map中的某个键值对*/
jedis.hdel("futaoInfo", "age");
/*返回key为futaoInfo的键中存放的值的个数*/
System.out.println("hlen===" + jedis.hlen("futaoInfo"));
/*是否存在该key*/
System.out.println("exist===" + jedis.exists("futaoInfo"));
/*返回map对象中的所有key */
System.out.println("map-all-keys" + jedis.hkeys("futaoInfo"));
/*返回map对象中的所有value */
System.out.println("map-all-value" + jedis.hvals("futaoInfo"));
Iterator<String> iterator = jedis.hkeys("futaoInfo").iterator();
/*遍历map中存储的key-value*/
while (iterator.hasNext()) {
String key = iterator.next();
System.out.println(key + "::" + jedis.hget("futaoInfo", key));
}
for (String key : jedis.hkeys("futaoInfo")) {
System.out.println(key + "::" + jedis.hget("futaoInfo", key));
}
}
/**
* jedis操作list
*/
@Test
public void testList() {
/*添加list数据*/
jedis.lpush("javaFramework", "Spring", "SpringMVC", "Hibernate");
/*获取list中的数据.-1表示获取所有数据*/
List<String> javaFramework = jedis.lrange("javaFramework", 0, -1);
for (String a : javaFramework) {
System.out.println(a);
}
}
/**
* jedis操作set
* **********************
* * jedis支持有序set集合 *
* **********************
*/
@Test
public void testSet() {
/*存*/
jedis.sadd("username", "futao");
jedis.sadd("username", "futao1");
jedis.sadd("username", "futao2");
jedis.sadd("username", "futao3", "futao4", "futao5");
/*读取set的所有value*/
System.out.println(jedis.smembers("username"));
/*判断futao是否是username的value*/
System.out.println(jedis.sismember("username", "futao"));
/*从key为username的set中随机读取一个值*/
System.out.println(jedis.srandmember("username"));
/*返回集合元素的个数*/
System.out.println(jedis.scard("username"));
}
@Test
public void test() {
jedis.del("b");
jedis.rpush("b", "7");
jedis.lpush("b", "-5");
jedis.lpush("b", "3");
jedis.lpush("b", "99");
jedis.lpush("b", "-666");
System.out.print("before sort" + jedis.lrange("b", 0, -1));
List<String> b = jedis.sort("b");
System.out.println("B" + b);
/*并不会改变原来的数据*/
System.out.print("\nafter sort" + jedis.lrange("b", 0, -1));
}
}
redis连接池
package impl.service.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* @author futao
* Created on 18-2-28-下午7:13.
*/
public class RedisUtil {
/*服务器地址*/
private static final String HOST = "127.0.0.1";
/*端口*/
private static final int PORT = 6379;
/*权限密码*/
private static final String PASSWORD = null;
//可用连接实例的最大数目，默认值为8；
//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
private static final int MAX_TOTAL = 1024;
//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。
private static final int MAX_IDLE = 200;
//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；
private static final int MAX_WAIT = 10000;
private static final int TIMEOUT = 10000;
//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
private static final boolean TEST_ON_BORROW = true;
private static JedisPool jedisPool = null;
static {
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(MAX_TOTAL);
jedisPoolConfig.setMaxIdle(MAX_IDLE);
jedisPoolConfig.setMaxWaitMillis(MAX_WAIT);
jedisPoolConfig.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(jedisPoolConfig, HOST, PORT, TIMEOUT, PASSWORD);
}
/**
* 获取jedis
*
* @return jedis实例
*/
public synchronized static Jedis getJedis() {
if (jedisPool != null) {
Jedis resource = jedisPool.getResource();
return resource;
} else {
return null;
}
}
/**
* 释放jedis资源
*
* @param jedis
*/
public static void releaseResource(final Jedis jedis) {
if (jedis != null) {
jedisPool.returnResource(jedis);
}
}
}
@Test
public void testRedisPool() {
Jedis jedis = RedisUtil.getJedis();
jedis.del("a");
jedis.lpush("a", "111", "222", "333");
List<String> a = jedis.lrange("a", 0, -1);
for (String i : a) {
System.out.println(i);
}
/*记得要释放资源*/
RedisUtil.releaseResource(jedis);
}
