Spring整合Redis完整实例代码

2024-02-25 08:43:04 56

做过大型软件系统的同学都知道，随着系统数据越来越庞大，越来越复杂，随之带来的问题就是系统性能越来越差，尤其是频繁操作数据库带来的性能损耗更为严重。很多业绩大牛为此提出了众多的解决方案和开发了很多框架以优化这种频繁操作数据库所带来的性能损耗，其中，尤为突出的两个缓存服务器是Memcached和Redis。今天，我们不讲Memcached和Redis本身，这里主要为大家介绍如何使spring与Redis整合。

1、pom构建



4.0.0
com.x.redis
springredis
0.0.1-SNAPSHOT



org.springframework.data
spring-data-redis
1.0.2.RELEASE


org.springframework
spring-test
3.1.2.RELEASE
test



redis.clients
jedis
2.1.0



junit
junit
4.8.2
test

2、spring配置文件(applicationContext.xml)

3、redis.properties

#Redissettings
redis.host=192.168.157.130
redis.port=6379
redis.pass=liuyazhuang


redis.maxIdle=300
redis.maxActive=600
redis.maxWait=1000
redis.testOnBorrow=true

4、User实体类

packagecom.lyz.entity;
importjava.io.Serializable;

/**
*user实体类
*@authorliuyazhuang
*
*/
publicclassUserimplementsSerializable{

privatestaticfinallongserialVersionUID=-6011241820070393952L;

privateStringid;

privateStringname;

privateStringpassword;


publicUser(){

}


publicUser(Stringid,Stringname,Stringpassword){
super();
this.id=id;
this.name=name;
this.password=password;
}

/**
*获得id
*@returntheid
*/
publicStringgetId(){
returnid;
}

/**
*设置id
*@paramidtheidtoset
*/
publicvoidsetId(Stringid){
this.id=id;
}

/**
*获得name
*@returnthename
*/
publicStringgetName(){
returnname;
}

/**
*设置name
*@paramnamethenametoset
*/
publicvoidsetName(Stringname){
this.name=name;
}

/**
*获得password
*@returnthepassword
*/
publicStringgetPassword(){
returnpassword;
}

/**
*设置password
*@parampasswordthepasswordtoset
*/
publicvoidsetPassword(Stringpassword){
this.password=password;
}
}

5、User操作的接口IUserDao

packagecom.lyz.dao;
importjava.util.List;
importcom.lyz.entity.User;
/**
*user操作接口
*@authorliuyazhuang
*
*/
publicinterfaceIUserDao{

/**
*新增
*@paramuser
*@return
*/
booleanadd(Useruser);

/**
*批量新增使用pipeline方式
*@paramlist
*@return
*/
booleanadd(Listlist);

/**
*删除
*@paramkey
*/
voiddelete(Stringkey);

/**
*删除多个
*@paramkeys
*/
voiddelete(Listkeys);

/**
*修改
*@paramuser
*@return
*/
booleanupdate(Useruser);

/**
*通过key获取
*@paramkeyId
*@return
*/
Userget(StringkeyId);
}

6、基本的抽象类

packagecom.lyz.dao.impl;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.data.redis.core.RedisTemplate;
importorg.springframework.data.redis.serializer.RedisSerializer;


/**
*基本的抽象类
*@authorliuyazhuang
*
*@param
*@param
*/
publicabstractclassAbstractBaseRedisDao{

@Autowired
protectedRedisTemplateredisTemplate;

/**
*设置redisTemplate
*@paramredisTemplatetheredisTemplatetoset
*/
publicvoidsetRedisTemplate(RedisTemplateredisTemplate){
this.redisTemplate=redisTemplate;
}

/**
*获取RedisSerializer
*
------------------------------

*/
protectedRedisSerializergetRedisSerializer(){
returnredisTemplate.getStringSerializer();
}
}

7、IUserDao的实现类UserDaoImpl

packagecom.lyz.dao.impl;
importjava.util.ArrayList;
importjava.util.List;
importorg.springframework.dao.DataAccessException;
importorg.springframework.data.redis.connection.RedisConnection;
importorg.springframework.data.redis.core.RedisCallback;
importorg.springframework.data.redis.serializer.RedisSerializer;
importorg.springframework.util.Assert;
importcom.lyz.dao.IUserDao;
importcom.lyz.entity.User;
/**
*接口的实现类
*@authorliuyazhuang
*
*/
publicclassUserDaoImplextendsAbstractBaseRedisDaoimplementsIUserDao{

/**
*新增
*@paramuser
*@return
*/
publicbooleanadd(finalUseruser){
booleanresult=redisTemplate.execute(newRedisCallback(){
publicBooleandoInRedis(RedisConnectionconnection)
throwsDataAccessException{
RedisSerializerserializer=getRedisSerializer();
byte[]key=serializer.serialize(user.getId());
byte[]name=serializer.serialize(user.getName());
returnconnection.setNX(key,name);
}
});
returnresult;
}

/**
*批量新增使用pipeline方式
*@paramlist
*@return
*/
publicbooleanadd(finalListlist){
Assert.notEmpty(list);
booleanresult=redisTemplate.execute(newRedisCallback(){
publicBooleandoInRedis(RedisConnectionconnection)
throwsDataAccessException{
RedisSerializerserializer=getRedisSerializer();
for(Useruser:list){
byte[]key=serializer.serialize(user.getId());
byte[]name=serializer.serialize(user.getName());
connection.setNX(key,name);
}
returntrue;
}
},false,true);
returnresult;
}

/**
*删除
*@paramkey
*/
publicvoiddelete(Stringkey){
Listlist=newArrayList();
list.add(key);
delete(list);
}

/**
*删除多个
*@paramkeys
*/
publicvoiddelete(Listkeys){
redisTemplate.delete(keys);
}

/**
*修改
*@paramuser
*@return
*/
publicbooleanupdate(finalUseruser){
Stringkey=user.getId();
if(get(key)==null){
thrownewNullPointerException("数据行不存在,key="+key);
}
booleanresult=redisTemplate.execute(newRedisCallback(){
publicBooleandoInRedis(RedisConnectionconnection)
throwsDataAccessException{
RedisSerializerserializer=getRedisSerializer();
byte[]key=serializer.serialize(user.getId());
byte[]name=serializer.serialize(user.getName());
connection.set(key,name);
returntrue;
}
});
returnresult;
}

/**
*通过key获取
*@paramkeyId
*@return
*/
publicUserget(finalStringkeyId){
Userresult=redisTemplate.execute(newRedisCallback(){
publicUserdoInRedis(RedisConnectionconnection)
throwsDataAccessException{
RedisSerializerserializer=getRedisSerializer();
byte[]key=serializer.serialize(keyId);
byte[]value=connection.get(key);
if(value==null){
returnnull;
}
Stringname=serializer.deserialize(value);
returnnewUser(keyId,name,null);
}
});
returnresult;
}
}

8、测试类RedisTest

packagecom.lyz.test;
importjava.util.ArrayList;
importjava.util.List;
importjunit.framework.Assert;
importorg.junit.Test;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.test.context.ContextConfiguration;
importorg.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
importcom.lyz.dao.IUserDao;
importcom.lyz.entity.User;
/**
*Redis测试类
*@authorliuyazhuang
*
*/
@ContextConfiguration(locations={"classpath*:applicationContext.xml"})
publicclassRedisTestextendsAbstractJUnit4SpringContextTests{

@Autowired
privateIUserDaouserDao;

/**
*新增
*/
@Test
publicvoidtestAddUser(){
Useruser=newUser();
user.setId("user1");
user.setName("liuyazhuang");
booleanresult=userDao.add(user);
Assert.assertTrue(result);
}

/**
*批量新增普通方式
*/
@Test
publicvoidtestAddUsers1(){
Listlist=newArrayList();
for(inti=10;i<50000;i++){
Useruser=newUser();
user.setId("user"+i);
user.setName("liuyazhuang"+i);
list.add(user);
}
longbegin=System.currentTimeMillis();
for(Useruser:list){
userDao.add(user);
}
System.out.println(System.currentTimeMillis()-begin);
}

/**
*批量新增pipeline方式
*/
@Test
publicvoidtestAddUsers2(){
Listlist=newArrayList();
for(inti=10;i<1500000;i++){
Useruser=newUser();
user.setId("user"+i);
user.setName("liuyazhuang"+i);
list.add(user);
}
longbegin=System.currentTimeMillis();
booleanresult=userDao.add(list);
System.out.println(System.currentTimeMillis()-begin);
Assert.assertTrue(result);
}

/**
*修改
*/
@Test
publicvoidtestUpdate(){
Useruser=newUser();
user.setId("user1");
user.setName("liuyazhuang");
booleanresult=userDao.update(user);
Assert.assertTrue(result);
}

/**
*通过key删除单个
*/
@Test
publicvoidtestDelete(){
Stringkey="user1";
userDao.delete(key);
}

/**
*批量删除
*/
@Test
publicvoidtestDeletes(){
Listlist=newArrayList();
for(inti=0;i<10;i++){
list.add("user"+i);
}
userDao.delete(list);
}

/**
*获取
*/
@Test
publicvoidtestGetUser(){
Stringid="user1";
Useruser=userDao.get(id);
Assert.assertNotNull(user);
Assert.assertEquals(user.getName(),"liuyazhuang");
}

/**
*设置userDao
*@paramuserDaotheuserDaotoset
*/
publicvoidsetUserDao(IUserDaouserDao){
this.userDao=userDao;
}
}

9、温馨提示

项目下载地址：Spring-Redis_jb51.rar

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

Spring整合Redis完整实例代码

热门推荐

随机推荐