Maven中Spring-Data-Redis存储对象(redisTemplate)
2017-11-16 20:04
507 查看
Redis是一种nosql数据库,在开发中常用做缓存。Jedis是Redis在java中的redis- client.在此之前,希望已经了解redis的基本使用和Maven的使用。建立Maven Project之后,在POM.xml中添加jedis和spring-data-redis的依赖如下:
[html] view plain copy print?<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.0.0</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
<!– spring-redis –>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.0.0.RELEASE</version>
</dependency>
Redis连接数据库参数如下:applicationContext-redis.properties
[plain] view plain copy print?#redis config redis.pool.maxActive=100 redis.pool.maxIdle=20 redis.pool.maxWait=1000 redis.pool.testOnBorrow=true redis.hostname=localhost redis.port=6379 redis.password=
在上下文配置中使用key-value读取方式读取properties中的值:
[html] view plain copy print?<!– Jedis 连接池配置–>
<bean id=“jedisPoolConfig” class=“redis.clients.jedis.JedisPoolConfig”>
<property name=“maxActive” value=“{redis.pool.maxActive}"</span><span> </span><span class="tag">/></span><span> </span></span></li><li class=""><span> <span class="tag"><</span><span class="tag-name">property</span><span> </span><span class="attribute">name</span><span>=</span><span class="attribute-value">"maxIdle"</span><span> </span><span class="attribute">value</span><span>=</span><span class="attribute-value">"{redis.pool.maxIdle}” />
<property name=“maxWait” value=“{redis.pool.maxWait}"</span><span> </span><span class="tag">/></span><span> </span></span></li><li class=""><span> <span class="tag"><</span><span class="tag-name">property</span><span> </span><span class="attribute">name</span><span>=</span><span class="attribute-value">"testOnBorrow"</span><span> </span><span class="attribute">value</span><span>=</span><span class="attribute-value">"{redis.pool.testOnBorrow}” />
</bean>
<!– Jedis ConnectionFactory 数据库连接配置–>
<bean id=“jedisConnectionFactory” class=“org.springframework.data.redis.connection.jedis.JedisConnectionFactory”>
<property name=“hostName” value=“{redis.hostname}"</span><span> </span><span class="tag">/></span><span> </span></span></li><li class="alt"><span> <span class="tag"><</span><span class="tag-name">property</span><span> </span><span class="attribute">name</span><span>=</span><span class="attribute-value">"port"</span><span> </span><span class="attribute">value</span><span>=</span><span class="attribute-value">"{redis.port}” />
<property name=“password” value=“${redis.password}” />
<property name=“poolConfig” ref=“jedisPoolConfig” />
</bean>
<!—- redisTemplate配置,redisTemplate是对Jedis的对redis操作的扩展,有更多的操作,封装使操作更便捷 –>
<bean id=“redisTemplate” class=“org.springframework.data.redis.core.RedisTemplate” p:connection-factory-ref=“jedisConnectionFactory” />
上面redisTemplate已经基本配置完成。
接下来创建User类,必须实现或者间接实现Serializable接口:
Redis存储对象是使用序列化,spring-data-redis已经将序列化的功能内置,不需要我们去管,我们只需要调用api就可以使用。SerialVersionUID字段对序列化扩展有用,为了以后扩展或者缩减字段时不会造成反序列化出错。
[java] view plain copy print?public class User implements Serializable {
private static final long serialVersionUID = -7898194272883238670L;
public static final String OBJECT_KEY = “USER”;
public User() {
}
public User(String id) {
}
public User(String id, String name) {
this.id = id;
this.name = name;
}
private String id;
private String name;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String toString() {
return “User [id=” + id + “, name=” + name + “]”;
}
public String getKey() {
return getId();
}
public String getObjectKey() {
return OBJECT_KEY;
}
}
创建userService类来操作redis增删查改缓存对象。
[java] view plain copy print?public class UserService { RedisTemplate<String, User> redisTemplate; public RedisTemplate<String, User> getRedisTemplate() { return redisTemplate; } public void setRedisTemplate(RedisTemplate<String, User> redisTemplate) { this.redisTemplate = redisTemplate; } public void put(User user) { redisTemplate.opsForHash().put(user.getObjectKey(), user.getKey(), user); } public void delete(User key) { redisTemplate.opsForHash().delete(key.getObjectKey(), key.getKey()); } public User get(User key) { return (User) redisTemplate.opsForHash().get(key.getObjectKey(), key.getKey()); } }
在上下文中配置redisTemplate注入,在使用bean方式来注入时,redisTemplate必须有setter/getter方法:
[html] view plain copy print?<bean id=“userService” class=“Service.UserService”>
<property name=“redisTemplate”>
<ref bean=“redisTemplate” />
</property>
</bean>
在UserService注解@Service(“userService”),也可以在Service里写名字,默认是第一字母小写。
[java] view plain copy print?@Service(“userService”)
public class UserService {
@Autowired
RedisTemplate<String, User> redisTemplate;
……
……
}
在上下文配置文件中,添加自动扫描包的context节点,Base-package的路径要覆盖包含注解的类文件:[html] view plain copy print?<context:component-scan base-package=“*” />
在main中来简单操作一下:
[java] view plain copy print?public class Main {
public static void main( String[] args )
{
ApplicationContext applicationContext = new ClassPathXmlApplicationContext(“classpath*:/conf/applicationContext.xml” );
UserService userService = (UserService) applicationContext.getBean(”userService”);
User user1 = new User(“user1ID”, “User 1”);
User user2 = new User(“user2ID”, “User 2”);
System.out.println(”==== getting objects from redis ====”);
System.out.println(”User is not in redis yet: ” + userService.get(user1));
System.out.println(”User is not in redis yet: ” + userService.get(user2));
System.out.println(”==== putting objects into redis ====”);
userService.put(user1);
userService.put(user2);
System.out.println(”==== getting objects from redis ====”);
System.out.println(”User should be in redis yet: ” + userService.get(user1));
System.out.println(”User should be in redis yet: ” + userService.get(user2));
System.out.println(”==== deleting objects from redis ====”);
userService.delete(user1);
userService.delete(user2);
System.out.println(”==== getting objects from redis ====”);
System.out.println(”User is not in redis yet: ” + userService.get(user1));
System.out.println(”User is not in redis yet: ” + userService.get(user2));
}
}
确保redis服务器是开启状态之后就可以运行程序。运行结果如下:
![](https://oscdn.geek-share.com/Uploads/Images/Content/201508/1fe138750ca32b463ef1c1f2f3b802a5)
非Maven项目需要导入spring-data-redis-1.6.2.RELEASE.jar
jedis-2.7.2.jar(依赖 commons-pool2-2.3.jar)
commons-pool2-2.3.jar
[html] view plain copy print?<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.0.0</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
<!– spring-redis –>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.0.0.RELEASE</version>
</dependency>
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.0.0</version> <type>jar</type> <scope>compile</scope> </dependency> <!-- spring-redis --> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>1.0.0.RELEASE</version> </dependency>
Redis连接数据库参数如下:applicationContext-redis.properties
[plain] view plain copy print?#redis config redis.pool.maxActive=100 redis.pool.maxIdle=20 redis.pool.maxWait=1000 redis.pool.testOnBorrow=true redis.hostname=localhost redis.port=6379 redis.password=
#redis config redis.pool.maxActive=100 redis.pool.maxIdle=20 redis.pool.maxWait=1000 redis.pool.testOnBorrow=true redis.hostname=localhost redis.port=6379 redis.password=
在上下文配置中使用key-value读取方式读取properties中的值:
[html] view plain copy print?<!– Jedis 连接池配置–>
<bean id=“jedisPoolConfig” class=“redis.clients.jedis.JedisPoolConfig”>
<property name=“maxActive” value=“{redis.pool.maxActive}"</span><span> </span><span class="tag">/></span><span> </span></span></li><li class=""><span> <span class="tag"><</span><span class="tag-name">property</span><span> </span><span class="attribute">name</span><span>=</span><span class="attribute-value">"maxIdle"</span><span> </span><span class="attribute">value</span><span>=</span><span class="attribute-value">"{redis.pool.maxIdle}” />
<property name=“maxWait” value=“{redis.pool.maxWait}"</span><span> </span><span class="tag">/></span><span> </span></span></li><li class=""><span> <span class="tag"><</span><span class="tag-name">property</span><span> </span><span class="attribute">name</span><span>=</span><span class="attribute-value">"testOnBorrow"</span><span> </span><span class="attribute">value</span><span>=</span><span class="attribute-value">"{redis.pool.testOnBorrow}” />
</bean>
<!– Jedis ConnectionFactory 数据库连接配置–>
<bean id=“jedisConnectionFactory” class=“org.springframework.data.redis.connection.jedis.JedisConnectionFactory”>
<property name=“hostName” value=“{redis.hostname}"</span><span> </span><span class="tag">/></span><span> </span></span></li><li class="alt"><span> <span class="tag"><</span><span class="tag-name">property</span><span> </span><span class="attribute">name</span><span>=</span><span class="attribute-value">"port"</span><span> </span><span class="attribute">value</span><span>=</span><span class="attribute-value">"{redis.port}” />
<property name=“password” value=“${redis.password}” />
<property name=“poolConfig” ref=“jedisPoolConfig” />
</bean>
<!—- redisTemplate配置,redisTemplate是对Jedis的对redis操作的扩展,有更多的操作,封装使操作更便捷 –>
<bean id=“redisTemplate” class=“org.springframework.data.redis.core.RedisTemplate” p:connection-factory-ref=“jedisConnectionFactory” />
<!-- Jedis 连接池配置--> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <property name="maxActive" value="${redis.pool.maxActive}" /> <property name="maxIdle" value="${redis.pool.maxIdle}" /> <property name="maxWait" value="${redis.pool.maxWait}" /> <property name="testOnBorrow" value="${redis.pool.testOnBorrow}" /> </bean> <!-- Jedis ConnectionFactory 数据库连接配置--> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"> <property name="hostName" value="${redis.hostname}" /> <property name="port" value="${redis.port}" /> <property name="password" value="${redis.password}" /> <property name="poolConfig" ref="jedisPoolConfig" /> </bean> <!—- redisTemplate配置,redisTemplate是对Jedis的对redis操作的扩展,有更多的操作,封装使操作更便捷 --> <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" p:connection-factory-ref="jedisConnectionFactory" />
上面redisTemplate已经基本配置完成。
接下来创建User类,必须实现或者间接实现Serializable接口:
Redis存储对象是使用序列化,spring-data-redis已经将序列化的功能内置,不需要我们去管,我们只需要调用api就可以使用。SerialVersionUID字段对序列化扩展有用,为了以后扩展或者缩减字段时不会造成反序列化出错。
[java] view plain copy print?public class User implements Serializable {
private static final long serialVersionUID = -7898194272883238670L;
public static final String OBJECT_KEY = “USER”;
public User() {
}
public User(String id) {
}
public User(String id, String name) {
this.id = id;
this.name = name;
}
private String id;
private String name;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String toString() {
return “User [id=” + id + “, name=” + name + “]”;
}
public String getKey() {
return getId();
}
public String getObjectKey() {
return OBJECT_KEY;
}
}
public class User implements Serializable { private static final long serialVersionUID = -7898194272883238670L; public static final String OBJECT_KEY = "USER"; public User() { } public User(String id) { } public User(String id, String name) { this.id = id; this.name = name; } private String id; private String name; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String toString() { return "User [id=" + id + ", name=" + name + "]"; } public String getKey() { return getId(); } public String getObjectKey() { return OBJECT_KEY; } }
创建userService类来操作redis增删查改缓存对象。
[java] view plain copy print?public class UserService { RedisTemplate<String, User> redisTemplate; public RedisTemplate<String, User> getRedisTemplate() { return redisTemplate; } public void setRedisTemplate(RedisTemplate<String, User> redisTemplate) { this.redisTemplate = redisTemplate; } public void put(User user) { redisTemplate.opsForHash().put(user.getObjectKey(), user.getKey(), user); } public void delete(User key) { redisTemplate.opsForHash().delete(key.getObjectKey(), key.getKey()); } public User get(User key) { return (User) redisTemplate.opsForHash().get(key.getObjectKey(), key.getKey()); } }
public class UserService { RedisTemplate<String, User> redisTemplate; public RedisTemplate<String, User> getRedisTemplate() { return redisTemplate; } public void setRedisTemplate(RedisTemplate<String, User> redisTemplate) { this.redisTemplate = redisTemplate; } public void put(User user) { redisTemplate.opsForHash().put(user.getObjectKey(), user.getKey(), user); } public void delete(User key) { redisTemplate.opsForHash().delete(key.getObjectKey(), key.getKey()); } public User get(User key) { return (User) redisTemplate.opsForHash().get(key.getObjectKey(), key.getKey()); } }
在上下文中配置redisTemplate注入,在使用bean方式来注入时,redisTemplate必须有setter/getter方法:
[html] view plain copy print?<bean id=“userService” class=“Service.UserService”>
<property name=“redisTemplate”>
<ref bean=“redisTemplate” />
</property>
</bean>
<bean id="userService" class="Service.UserService"> <property name="redisTemplate"> <ref bean="redisTemplate" /> </property> </bean>======如果使用注解方式自动注入,则可以注释掉上面的bean配置方式======
在UserService注解@Service(“userService”),也可以在Service里写名字,默认是第一字母小写。
[java] view plain copy print?@Service(“userService”)
public class UserService {
@Autowired
RedisTemplate<String, User> redisTemplate;
……
……
}
@Service("userService") public class UserService { @Autowired RedisTemplate<String, User> redisTemplate; …… …… }
在上下文配置文件中,添加自动扫描包的context节点,Base-package的路径要覆盖包含注解的类文件:[html] view plain copy print?<context:component-scan base-package=“*” />
<context:component-scan base-package="*" />
在main中来简单操作一下:
[java] view plain copy print?public class Main {
public static void main( String[] args )
{
ApplicationContext applicationContext = new ClassPathXmlApplicationContext(“classpath*:/conf/applicationContext.xml” );
UserService userService = (UserService) applicationContext.getBean(”userService”);
User user1 = new User(“user1ID”, “User 1”);
User user2 = new User(“user2ID”, “User 2”);
System.out.println(”==== getting objects from redis ====”);
System.out.println(”User is not in redis yet: ” + userService.get(user1));
System.out.println(”User is not in redis yet: ” + userService.get(user2));
System.out.println(”==== putting objects into redis ====”);
userService.put(user1);
userService.put(user2);
System.out.println(”==== getting objects from redis ====”);
System.out.println(”User should be in redis yet: ” + userService.get(user1));
System.out.println(”User should be in redis yet: ” + userService.get(user2));
System.out.println(”==== deleting objects from redis ====”);
userService.delete(user1);
userService.delete(user2);
System.out.println(”==== getting objects from redis ====”);
System.out.println(”User is not in redis yet: ” + userService.get(user1));
System.out.println(”User is not in redis yet: ” + userService.get(user2));
}
}
public class Main { public static void main( String[] args ) { ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath*:/conf/applicationContext.xml" ); UserService userService = (UserService) applicationContext.getBean("userService"); User user1 = new User("user1ID", "User 1"); User user2 = new User("user2ID", "User 2"); System.out.println("==== getting objects from redis ===="); System.out.println("User is not in redis yet: " + userService.get(user1)); System.out.println("User is not in redis yet: " + userService.get(user2)); System.out.println("==== putting objects into redis ===="); userService.put(user1); userService.put(user2); System.out.println("==== getting objects from redis ===="); System.out.println("User should be in redis yet: " + userService.get(user1)); System.out.println("User should be in redis yet: " + userService.get(user2)); System.out.println("==== deleting objects from redis ===="); userService.delete(user1); userService.delete(user2); System.out.println("==== getting objects from redis ===="); System.out.println("User is not in redis yet: " + userService.get(user1)); System.out.println("User is not in redis yet: " + userService.get(user2)); } }
确保redis服务器是开启状态之后就可以运行程序。运行结果如下:
非Maven项目需要导入spring-data-redis-1.6.2.RELEASE.jar
jedis-2.7.2.jar(依赖 commons-pool2-2.3.jar)
commons-pool2-2.3.jar
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd"> <!--[redis-JedisPoolConfig配置](http://blog.csdn.net/liang_love_java/article/details/50510753)--> <!-- jedis-2.7.2.jar 依赖jar包 commons-pool2-2.3.jar jedis基于 commons-pool2-2.3.jar 自己实现了一个资源池。 配置参数 详见 http://blog.csdn.net/liang_love_java/article/details/50510753 --> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <property name="maxIdle" value="1" /> <property name="maxTotal" value="5" /> <property name="blockWhenExhausted" value="true" /> <property name="maxWaitMillis" value="30000" /> <property name="testOnBorrow" value="true" /> </bean> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"> <property name="hostName" value="10.1.8.200" /> <property name="port" value="6379"/> <property name="poolConfig" ref="jedisPoolConfig" /> <property name="usePool" value="true"/> </bean> <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"> <property name="connectionFactory" ref="jedisConnectionFactory" /> <property name="keySerializer"> <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" /> </property> <property name="valueSerializer"> <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" /> </property> <property name="hashKeySerializer"> <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/> </property> <property name="hashValueSerializer"> <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/> </property> </bean> </beans>
相关文章推荐
- Maven中Spring-Data-Redis存储对象(redisTemplate) (转)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- Maven中Spring-Data-Redis存储对象(redisTemplate)
- 使用Spring-Data-Redis存储对象(redisTemplate)
- Spring-Data-Redis存储对象(redisTemplate)
- 使用Spring-Data-Redis存储对象(redisTemplate)
- 基于Spring-Data-Redis存储JavaBean对象
- Spring-data-redis;存储对象实例
- Spring Data Redis实战之提供RedisTemplate
- Spring Data Redis实战之提供RedisTemplate
- SpringData+Redis存储
- Spring Data Redis简介以及项目Demo,RedisTemplate和 Serializer详解
- 关于Spring Data redis几种对象序列化的比较
- redis实现 spring-redis-data初学习二 进阶,存取对象