commons-lang3-3.1.jar
spring-data-commons-1.11.0.jar
spring-data-redis-1.6.1.jar
jedis-2.6.0.jar
spring-XX-4.0.6.jar
在spring的beans.xml中添加:
<!-- 对象池 --> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <property name="maxIdle" value="${redis.maxIdle}" /> <!-- <property name="maxActive" value="${redis.maxActive}" /> --> <!-- <property name="maxWait" value="${redis.maxWait}" /> --> <property name="testOnBorrow" value="${redis.testOnBorrow}" /> </bean> <!-- 工厂实现 --> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"> <property name="hostName" value="${redis.host}" /> <property name="port" value="${redis.port}" /> <!-- <property name="password" value="${redis.pass}" /> --> <property name="poolConfig" ref="jedisPoolConfig" /> </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"></bean> </property> <property name="valueSerializer"> <!-- default:JdkSerializationRedisSerializer --> <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"></bean> </property> </bean>
service实现层:
package com.edus.service.impl.demo; import java.io.Serializable; import java.util.HashSet; import java.util.Map; import java.util.Set; import javax.annotation.Resource; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import com.edus.entity.Book; import com.edus.service.demo.IRedisDemoService; @Service("redisDemoService") public class RedisDemoServiceImpl implements IRedisDemoService { @Resource private RedisTemplate<Serializable, Serializable> redisTemplate; private static String PREFIX_USER = "book:"; @Override public void delBookInRedis(Integer id) { redisTemplate.opsForHash().delete(PREFIX_USER+id, id); } @Override public Book getBookFromRedis(final Integer id) { // redisTemplate.multi(); // redisTemplate.opsForHash().put(PREFIX_USER+id, "id", id); Book book = (Book)redisTemplate.opsForHash().get(PREFIX_USER+id, id); // System.out.println(book); // redisTemplate.exec(); return book; } @Override public void saveOrUpdateBookInRedis(final Book book) { // System.out.println("1xxxx="+redisTemplate.getConnectionFactory().getClass().getName()); // System.out.println("1default="+redisTemplate.getDefaultSerializer().getClass().getName()); // System.out.println("1key="+redisTemplate.getKeySerializer().getClass().getName()); // System.out.println("1value="+redisTemplate.getValueSerializer().getClass().getName()); //开启事务 // redisTemplate.multi(); redisTemplate.opsForHash().put(PREFIX_USER+book.getId(), book.getId(), book); // redisTemplate.exec(); } @Override public Set<Book> findBookListInRedis(Map<String, Object> args) { Set<Serializable> keySet = redisTemplate.keys(PREFIX_USER+"*"); Set<Book> resultSet = new HashSet<Book>(); for(Object key : keySet) { Integer id = Integer.parseInt(key.toString().split(":")[1]); Book book = getBookFromRedis(id); resultSet.add(book); System.out.println(book); } return resultSet; } }
或:
package com.edus.service.impl.demo; import java.io.Serializable; import javax.annotation.Resource; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.RedisSerializer; import org.springframework.stereotype.Service; import com.edus.entity.Book; import com.edus.service.demo.IRedisDemoService; @Service("redisDemoService") public class RedisDemoServiceImpl implements IRedisDemoService { @Resource protected RedisTemplate<Serializable, Serializable> redisTemplate; @Override public void delBookInRedis(final Integer id) { redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection connection) { connection.del(redisTemplate.getStringSerializer().serialize("book.id." + id)); connection.del(redisTemplate.getStringSerializer().serialize("book.price." + id)); connection.del(redisTemplate.getStringSerializer().serialize("book.name." + id)); return null; } }); } @Override public Book findOneBookInRedis(final Integer id) { return redisTemplate.execute(new RedisCallback<Book>() { @Override public Book doInRedis(RedisConnection connection) throws DataAccessException { byte[] bid = redisTemplate.getStringSerializer().serialize( "book.id." + id); if (connection.exists(bid)) { byte[] nameByte = redisTemplate.getStringSerializer().serialize( "book.name." + id); byte[] nameVal = connection.get(nameByte); String name = redisTemplate.getStringSerializer().deserialize(nameVal); byte[] priceByte = redisTemplate.getStringSerializer().serialize( "book.price." + id); byte[] priceVal = connection.get(priceByte); String price = redisTemplate.getStringSerializer().deserialize(priceVal); Book book = new Book(); book.setId(id); book.setName(name); book.setPrice(Double.parseDouble(price)); return book; } return null; } }); } @Override public boolean saveBookInRedis(final Book book) { return redisTemplate.execute(new RedisCallback<Boolean>() { @Override public Boolean doInRedis(RedisConnection connection) throws DataAccessException { //connection.hSet(arg0, arg1, arg2) connection.set( redisTemplate.getStringSerializer().serialize( "book.id." + book.getId()), redisTemplate.getStringSerializer().serialize( String.valueOf(book.getId()))); connection.set( redisTemplate.getStringSerializer().serialize( "book.name." + book.getId()), redisTemplate.getStringSerializer().serialize( book.getName())); connection.set( redisTemplate.getStringSerializer().serialize( "book.price." + book.getId()), redisTemplate.getStringSerializer().serialize( String.valueOf(book.getPrice()))); return true; } }); } @Override public boolean updateBookInRedis(final Book book) { Integer key = book.getId(); if (this.findOneBookInRedis(key) == null) { throw new NullPointerException("数据行不存在, book.id = " + key); } return redisTemplate.execute(new RedisCallback<Boolean>() { public Boolean doInRedis(RedisConnection connection) throws DataAccessException { // if(book.getName() != null && book.getName().length() > 0) { byte[] key = redisTemplate.getStringSerializer().serialize("book.name."+String.valueOf(book.getId())); byte[] name = redisTemplate.getStringSerializer().serialize(book.getName()); connection.set(key, name); // } if(book.getPrice() != null) { byte[] key = redisTemplate.getStringSerializer().serialize("book.name."+String.valueOf(book.getId())); byte[] name = redisTemplate.getStringSerializer().serialize(book.getName()); connection.set(key, name); } return true; } }); } }
相关推荐
只是理解一下redis与spring整合的大概步骤,包括String,list,set,map格式的值
利用了spring+redis整合实现了简单的登录,将session交由redis管理,并且可测试nginx负载均衡,一台服务器宕机,勿需重新登陆,可继续操作!
spring+redis的整合实例,博客可见http://blog.csdn.net/smilefyx/article/details/71057059
Redis+spring-data-redis jar包Redis+spring-data-redis jar包Redis+spring-data-redis jar包
Spring mvc整合redis实例(redis连接池) 将所有jedis 增删改进行事务的封装、查询单独做为有返回参数的封装。简化了很多代码
Spring+redis整合demo,有助于学习spring和redis
SpringCloud整合Redis缓存;版本:SpringCloud :Dalston.SR4;SpringBoot:1.5.14.RELEASE;Redis:3.2.0;Maven :3.5.3.代码下载下来即可用
spring整合redis项目 spring redis 下载导入eclipse即可测试
Spring+redis整合的demo,可以进行学习
Spring+Redis集成,实现缓存存储。
spring整合redis 简单实例搭建------------供新手学习。
注解redis缓存数据,Spring-session和redis实现分布式session同步(建议按功能模块划分系统)。 6、日志 =========== logback打印日志,业务日志和调试日志分开打印。同时基于时间和文件大小分割日志文件。 9、...
spring-redis-mysql整合,前台为jquery,后台spring-mybatis
本资源的功能是利用spring整合redis,进行了基本的操作,具体见博客地址 https://blog.csdn.net/u012150590/article/details/79862294
整合了spring和redis相关jar,具体使用方法和代码请查看我的博客。
spring和redis集成有很多方式,看到网上很多都是使用redistemplate自己去做redis 的一些操作,但是对于我们开发来说,肯定是使用越方便越好,于是乎就有了spring的对redis或者memcahe这些换成框架的封装,只需要引入...
spring boot、 mybaits、 spring security、 redis整合
Spring整合Redis完整实例代码,下载经简单的修改配置文件,即可运行,代码中有详细的注释,关于代码的详情可参见博文:http://blog.csdn.net/l1028386804/article/details/52108758
spring整合redis哨兵模式,内含redis连接池,哨兵模式,json序列化,redis crud封装
spring boot,mybaits,spring security,redis整合