Jedis
Jedis is a blazingly small and sane redis java client.
功能
-
Sorting
-
Connection handling
-
Commands operating on any kind of values
-
Commands operating on string values
-
Commands operating on hashes
-
Commands operating on lists
-
Commands operating on sets
-
Commands operating on sorted sets
-
Transactions
-
Pipelining
-
Publish/Subscribe
-
Persistence control commands
-
Remote server control commands
-
Connection pooling
-
Sharding (MD5, MurmurHash)
-
Key-tags for sharding
-
Sharding with pipelining
-
Scripting with pipelining
-
Redis Cluster
Docker 安装 Redis
基础知识
删除原始的
一条命令实现停用并删除容器：
ps: 危险操作，切勿模仿。
docker stop $(docker ps -a -q) & docker rm $(docker ps -a -q)
实际安装
- 验证是否存在
$ docker images | grep redis
发现没有了，也许是刚更新了 Docker 的原因。
- 下载
$ docker pull redis
- 再次查看
$ docker images | grep redis
redis latest e1a73233e3be 40 hours ago 83.4MB
- 启动
docker run -p 6379:6379 --name out-redis -d redis
- 状态查看
$ docker ps
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
b8dfa9422adb redis "docker-entrypoint.s…" 14 seconds ago Up 13 seconds 0.0.0.0:6379->6379/tcp out-redis
Jedis
使用 java 语言测试，结合 maven 进行 jar 管理。
jdk8 + junit4
jar 引入
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.1</version>
</dependency>
测试代码
public class RedisTest {
private Jedis jedis;
@BeforeEach
public void setUp() {
jedis = new Jedis("127.0.0.1", 6379);
// jedis.auth("123456");
}
/**
* 初始化测试
*/
@Test
public void initTest() {
jedis.set("key", "test");
System.out.println(jedis.get("key"));
}
}
- 输出日志
test
常见例子
为了测试的自动化，使用断言。
- crud
@Test
public void testCrudString() {
jedis.set("name", "ryo");
assertEquals("ryo", jedis.get("name"));
jedis.append("name", " is whose name?");
assertEquals("ryo is whose name?", jedis.get("name"));
jedis.del("name");
assertNull(jedis.get("name"));
jedis.mset("name", "ryo", "age", "22");
assertEquals("ryo", jedis.get("name"));
jedis.incr("age");
assertEquals("23", jedis.get("age"));
}
- map
@Test
public void testMap() {
Map<String, String> map = new HashMap<>();
map.put("name", "ryo");
map.put("age", "22");
jedis.hmset("map", map);
assertEquals("[ryo, 22]", jedis.hmget("map", "name", "age").toString());
assertEquals("2", jedis.hlen("map").toString());
assertEquals("true", jedis.exists("map").toString());
assertEquals("[name, age]", jedis.hkeys("map").toString());
jedis.hdel("map", "name");
assertEquals("1", jedis.hlen("map").toString());
}
- list
@Test
public void testList() {
jedis.del("list");
jedis.lpush("list", "apple");
jedis.lpush("list", "eat");
jedis.lpush("list", "ryo");
assertEquals("apple", jedis.lindex("list", 2));
jedis.lset("list", 2, "orange");
assertEquals("[ryo, eat, orange]", jedis.lrange("list", 0, -1).toString());
}
- set
@Test
public void testSet() {
jedis.del("name");
jedis.sadd("name", "ryo");
jedis.sadd("name", "apple");
jedis.sadd("name", "orange");
assertEquals("[orange, apple, ryo]", jedis.smembers("name").toString()); //show all members.
assertEquals("3", jedis.scard("name").toString()); //get number
jedis.srem("name", "orange"); //remove
assertEquals("[apple, ryo]", jedis.smembers("name").toString());
assertEquals("false", jedis.sismember("name", "banana").toString());
assertEquals("[ryo, apple]", jedis.srandmember("name", 2).toString());
}
- sort
@Test
public void testSort() {
jedis.del("sort");
jedis.lpush("sort", "3");
jedis.lpush("sort", "5");
jedis.lpush("sort", "2");
jedis.lpush("sort", "7");
assertEquals("[7, 2, 5, 3]", jedis.lrange("sort", 0, -1).toString());
assertEquals("[2, 3, 5, 7]", jedis.sort("sort").toString());
assertEquals("[7, 2, 5, 3]", jedis.lrange("sort", 0, -1).toString());
}
Jedis
- pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ryo</groupId>
<artifactId>redis</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<plugin.tomcat.version>2.2</plugin.tomcat.version>
<maven-surefire-plugin.version>2.18.1</maven-surefire-plugin.version>
<maven-compiler-plugin.version>3.3</maven-compiler-plugin.version>
<maven-compiler-plugin.jdk.version>1.8</maven-compiler-plugin.jdk.version>
<log4j.version>2.6</log4j.version>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.9</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.1</version>
</dependency>
<dependency>
<groupId>commons-pool</groupId>
<artifactId>commons-pool</artifactId>
<version>1.6</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>${plugin.tomcat.version}</version>
<configuration>
<port>8080</port>
<path>/</path>
<uriEncoding>${project.build.sourceEncoding}</uriEncoding>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>${maven-surefire-plugin.version}</version>
<configuration>
<skipTests>true</skipTests>
<testFailureIgnore>true</testFailureIgnore>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>${maven-compiler-plugin.version}</version>
<configuration>
<source>${maven-compiler-plugin.jdk.version}</source>
<target>${maven-compiler-plugin.jdk.version}</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
- RedisTest.java
package com.ryo.redis;
import junit.framework.TestCase;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import java.util.HashMap;
import java.util.Map;
/**
* Created by houbinbin on 16/7/3.
*/
public class RedisTest extends TestCase {
private Jedis jedis;
@Before
public void setUp() {
jedis = new Jedis("127.0.0.1", 6379);
jedis.auth("redis");
}
/**
* save String
*/
@Test
public void testSaveString() {
jedis.set("name", "ryo");
assertEquals("ryo", jedis.get("name"));
jedis.append("name", " is whose name?");
assertEquals("ryo is whose name?", jedis.get("name"));
jedis.del("name");
assertEquals(null, jedis.get("name"));
jedis.mset("name", "ryo", "age", "22");
assertEquals("ryo", jedis.get("name"));
jedis.incr("age");
assertEquals("23", jedis.get("age"));
}
/**
* Map
*/
@Test
public void testMap() {
Map<String, String> map = new HashMap<>();
map.put("name", "ryo");
map.put("age", "22");
jedis.hmset("map", map);
assertEquals("[ryo, 22]", jedis.hmget("map", "name", "age").toString());
assertEquals("2", jedis.hlen("map").toString());
assertEquals("true", jedis.exists("map").toString());
assertEquals("[name, age]", jedis.hkeys("map").toString());
assertEquals("[ryo, 22]", jedis.hvals("map").toString());
jedis.hdel("map", "name");
assertEquals("1", jedis.hlen("map").toString());
}
/**
* List
*/
@Test
public void testList() {
jedis.del("list");
jedis.lpush("list", "apple");
jedis.lpush("list", "eat");
jedis.lpush("list", "ryo");
assertEquals("apple", jedis.lindex("list", 2));
jedis.lset("list", 2, "orange");
assertEquals("[ryo, eat, orange]", jedis.lrange("list", 0, -1).toString());
}
/**
* Set
*/
@Test
public void testSet() {
jedis.del("name");
jedis.sadd("name", "ryo");
jedis.sadd("name", "apple");
jedis.sadd("name", "orange");
assertEquals("[orange, apple, ryo]", jedis.smembers("name").toString()); //show all members.
assertEquals("3", jedis.scard("name").toString()); //get number
jedis.srem("name", "orange"); //remove
assertEquals("[apple, ryo]", jedis.smembers("name").toString());
assertEquals("false", jedis.sismember("name", "banana").toString());
//get the random result, so assert may be false.
assertEquals("apple", jedis.srandmember("name"));
assertEquals("[ryo, apple]", jedis.srandmember("name", 2).toString());
}
/**
* sort
*/
@Test
public void testSort() {
jedis.del("sort");
jedis.lpush("sort", "3");
jedis.lpush("sort", "5");
jedis.lpush("sort", "2");
jedis.lpush("sort", "7");
assertEquals("[7, 2, 5, 3]", jedis.lrange("sort", 0, -1).toString());
assertEquals("[2, 3, 5, 7]", jedis.sort("sort").toString());
assertEquals("[7, 2, 5, 3]", jedis.lrange("sort", 0, -1).toString());
}
}
Jedis pool
I try times, but always get an error.
package com.ryo.util;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* Created by houbinbin on 16/7/3.
*/
public class RedisUtil {
private RedisUtil() {
}
private static final String ADDRESS = "127.0.0.1";
private static final int PORT = 6397;
private static final String PASSWORD = "redis";
//可用连接实例的最大数目，默认值为8；
//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
private static final int MAX_TOTAL = 512;
//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。
private static final int MAX_IDLE = 100;
//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；
private static final int TIMEOUT = 10000;
//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
private static final boolean TEST_ON_BORROW = true;
private static JedisPool jedisPool = null;
/**
* 初始化Redis连接池
*/
static {
try {
if (jedisPool == null) {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(MAX_TOTAL);
config.setMaxWaitMillis(TIMEOUT);
config.setMaxIdle(MAX_IDLE);
config.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(config, ADDRESS, PORT, TIMEOUT, PASSWORD);
}
} catch (Exception e) {
e.printStackTrace();
System.out.println("init redis pool failed!");
}
}
/**
* 获取Jedis实例
*
* @return
*/
public synchronized static Jedis getJedis() {
try {
if (jedisPool != null) {
Jedis resource = jedisPool.getResource();
return resource;
} else {
return null;
}
} catch (Exception e) {
e.printStackTrace();
return null;
} finally {
}
}
/**
* 释放jedis资源
*
* @param jedis
*/
public static void returnResource(final Jedis jedis) {
if (jedis != null) {
jedisPool.returnResource(jedis);
}
}
}
Spring-Redis
No invasive spring and redis integration.
@Cacheable triggers cache population
@CacheEvict triggers cache eviction
@CachePut updates the cache without interfering with the method execution
@Caching regroups multiple cache operations to be applied on a method
@CacheConfig shares some common cache-related settings at class-level
简单说下@Cacheable和@CachePut区别:
(1) @Cacheable 如果缓存中有,直接去缓存,不执行方法。否则执行方法,并将结果放在缓存中。适用于如查询的情况。
(2) @CachePut 无论缓存有没有,方法会正常执行。并将返回的结果放在缓存之中。适用于更新情况,并将更新后的对象放在缓存中。
- File struct
You can get the project demo from here or git clone https://github.com/houbb/spring-redis
.
|____main
| |____java
| | |____com
| | | |____ryo
| | | | |____cache
| | | | | |____RedisCacheConfig.java
| | | | |____domain
| | | | | |____User.java
| | | | |____service
| | | | | |____impl
| | | | | | |____UserServiceImpl.java
| | | | | |____UserService.java
| |____resources
| | |____app.xml
| | |____applicationContext.xml
| | |____spring-redis.xml
|____test
| |____java
| | |____com
| | | |____ryo
| | | | |____service
| | | | | |____BaseTest.java
| | | | | |____UserServiceTest.java
|____pom.xml
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ryo</groupId>
<artifactId>spring-redis</artifactId>
<version>1.0-SNAPSHOT</version>
<description>spring integrate redis</description>
<properties>
<junit.version>4.9</junit.version>
<spring.version>4.2.6.RELEASE</spring.version>
<spring-data-redis.version>1.3.2.RELEASE</spring-data-redis.version>
<jedis.version>2.4.2</jedis.version>
<lombok.version>1.16.8</lombok.version>
<maven-surefire-plugin.version>2.18.1</maven-surefire-plugin.version>
</properties>
<dependencies>
<!--junit-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${junit.version}</version>
</dependency>
<!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- redis -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>${spring-data-redis.version}</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>${jedis.version}</version>
</dependency>
<!--lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lombok.version}</version>
<scope>provided</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>${maven-surefire-plugin.version}</version>
<configuration>
<skipTests>true</skipTests>
<testFailureIgnore>true</testFailureIgnore>
</configuration>
</plugin>
</plugins>
</build>
</project>
User.java
@Data
public class User implements Serializable {
private Long id;
private String name;
}
UserServiceImpl.java
@Service("userService")
public class UserServiceImpl implements UserService {
/**
* @Cacheable triggers cache population
*/
@Cacheable(value = "user", key = "'user_id_' + #id")
public User getUser(Long id) {
System.out.println("get user"+id);
User user = new User();
user.setId(id);
return user;
}
@CacheEvict(value = "user", key = "'user_id_'+#id")
public void deleteUser(Long id) {
System.out.println("delete user"+id);
}
/**
* updated without interfering with the method execution
* - 将返回的结果,放入缓存
*/
@CachePut(value = "user", key = "'user_id_'+#user.getId()")
public User updateUser(User user) {
System.out.println("update user"+user);
user.setName("cachePut update");
return user;
}
@CacheEvict(value = "user", allEntries = true)
public void clearCache() {
System.out.println("clear all user cache");
}
}
RedisCacheConfig.java
@Configuration
@EnableCaching
public class RedisCacheConfig {
private JedisConnectionFactory jedisConnectionFactory;
private RedisTemplate redisTemplate;
private RedisCacheManager redisCacheManager;
public RedisCacheConfig(JedisConnectionFactory jedisConnectionFactory, RedisTemplate redisTemplate, RedisCacheManager redisCacheManager) {
this.jedisConnectionFactory = jedisConnectionFactory;
this.redisTemplate = redisTemplate;
this.redisCacheManager = redisCacheManager;
}
}
app.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
<!--spring公共配置-->
<import resource="applicationContext.xml"/>
<!--redis缓存配置-->
<import resource="spring-redis.xml"/>
</beans>
applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd">
<!-- Activates annotation-based bean configuration -->
<context:annotation-config/>
<!-- Scans for application @Components to deploy -->
<context:component-scan base-package="com.ryo"/>
</beans>
spring-redis.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal" value="1000"/>
<property name="minIdle" value="50"/>
<property name="maxIdle" value="100"/>
<property name="testOnBorrow" value="true"/>
</bean>
<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
p:hostName="127.0.0.1" p:port="6379" p:password="123456" p:poolConfig-ref="poolConfig"/>
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory"/>
<!-- 如果不配置Serializer，那么存储的时候智能使用String，如果用User类型存储，那么会提示错误User can't cast to String！！！ -->
<property name="keySerializer">
<bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
</property>
<property name="valueSerializer">
<bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
</property>
</bean>
<bean id="redisCacheManager" class="org.springframework.data.redis.cache.RedisCacheManager">
<constructor-arg ref="redisTemplate" />
</bean>
<!--自定义缓存配置-->
<bean id="redisCacheConfig" class="com.ryo.cache.RedisCacheConfig">
<constructor-arg ref="jedisConnectionFactory" />
<constructor-arg ref="redisTemplate" />
<constructor-arg ref="redisCacheManager" />
</bean>
</beans>
分布式
参考资料
https://github.com/xetorthio/jedis
