个人中心
gpt4 book ai didi

Spring集成Redis详解代码示例

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 27 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Spring集成Redis详解代码示例由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

本文章从头开始介绍spring集成redis的示例.

eclipse工程结构 。

如下图为我的示例工程的结构图，采用maven构建。其中需要集成spring，因此需要beans.xml文件配置spring的依赖注入，redis.properties配置连接服务器的配置信息.

Spring集成Redis详解代码示例

其中工程中beans.xml和redis.properties文件直接放在了根目录，有需要的读者可以放到resource目录中.

pom依赖 。

如下为示例pom依赖，spring集成redis需要依赖的包为：jedis包，spring-context模块及依赖的包，spring-data-redis模块包，spring-test包用于junit测试，pom.xml文件内容如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
<project xmlns= "https://maven.apache.org/pom/4.0.0" xmlns:xsi= "https://www.w3.org/2001/xmlschema-instance" xsi:schemalocation= "https://maven.apache.org/pom/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd" >
   <modelversion> 4.0 . 0 </modelversion>
 
   <groupid>com.test</groupid>
   javatest</artifactid>
   <version> 0.0 . 1 -snapshot</version>
   <packaging>jar</packaging>
 
   <name>javatest</name>
   <url>https: //maven.apache.org</url>
 
   <properties>
     <project.build.sourceencoding>utf- 8 </project.build.sourceencoding>
   </properties>
 
   <dependencies>
     <dependency>
       <groupid>junit</groupid>
       junit</artifactid>
       <version> 4.12 </version>
       <scope>test</scope>
     </dependency>
     <dependency>
       <groupid>redis.clients</groupid>
       jedis</artifactid>
       <version> 2.5 . 1 </version>
     </dependency>
     <dependency>
       <groupid>org.springframework</groupid>
       spring-context</artifactid>
       <version> 4.2 . 6 .release</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupid>org.springframework</groupid>
       spring-test</artifactid>
       <version> 4.2 . 6 .release</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupid>org.springframework.data</groupid>
       spring-data-redis</artifactid>
       <version> 1.7 . 2 .release</version>
     </dependency>
   </dependencies>
</project>

spring配置 。

spring配置文件beans.xml的配置如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
<!--?xml version= "1.0" encoding= "utf-8" ?-->
<beans xmlns= "https://www.springframework.org/schema/beans" xmlns:aop= "https://www.springframework.org/schema/aop" xmlns:context= "https://www.springframework.org/schema/context" xmlns:jee= "https://www.springframework.org/schema/jee" xmlns:p= "https://www.springframework.org/schema/p" xmlns:tx= "https://www.springframework.org/schema/tx" xmlns:xsi= "https://www.w3.org/2001/xmlschema-instance" xsi:schemalocation="
       https: //www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd
       https: //www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">
   <!-- 加载classpath下的redis配置文件 -->
   <context:property-placeholder location= "classpath:redis.properties" >
 
   <bean class = "redis.clients.jedis.jedispoolconfig" id= "poolconfig" >
     <property name= "maxidle" value= "${redis.maxidle}" >
     <property name= "testonborrow" value= "${redis.testonborrow}" >
   </property></property></bean>
 
   <bean class = "org.springframework.data.redis.connection.jedis.jedisconnectionfactory" id= "connectionfactory" p:host-name= "${redis.host}" p:password= "${redis.pass}" p:pool-config-ref= "poolconfig" p:port= "${redis.port}" >
 
   <!-- spring提供的模板类 -->
   <bean class = "org.springframework.data.redis.core.stringredistemplate" id= "redistemplate" >
     <property name= "connectionfactory" ref= "connectionfactory" >
   </property></bean>
 
   <bean class = "com.redis.test.userdao" id= "userdao" >
     <property name= "redistemplate" ref= "redistemplate" >
   </property></bean>
 
</bean></context:property-placeholder></beans>

在beans.xml配置文件中，需要先加载redis.properties文件.

redis配置信息 。

redis的配置信息在redis.properties文件中配置:

?
1
2
3
4
5
6
7
# redis地址和端口和连接密码
redis.host=localhost
redis.port= 6379
redis.pass=
 
redis.maxidle= 300
redis.testonborrow= true

此示例，连接redis服务器时没有设置连接密码，因此不用填值.

java代码 。

user.java 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package com.redis.test;
import java.io.serializable;
public class user implements serializable {
     private static final long serialversionuid = 3409768855488864675l;
     private string id;
     private string name;
     private string password;
     public user() {
     }
     public user(string id, string name, string password) {
         this .id = id;
         this .name = name;
         this .password = password;
     }
     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 getpassword() {
         return password;
     }
     public void setpassword(string password) {
         this .password = password;
     }
     public string tostring() {
         return "user [id=" + id + ", name=" + name + ", password=" + password + "]" ;
     }
}

abstractredisbasedao.java 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
package com.redis.test;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.data.redis.serializer.redisserializer;
public abstract class abstractredisbasedao<k, v= "" > {
   protected redistemplate<k, v= "" > redistemplate;
public redistemplate<k, v= "" > getredistemplate() {
     return redistemplate;
}
public void setredistemplate(redistemplate<k, v= "" > redistemplate) {
     this .redistemplate = redistemplate;
}
/**
    * 获取 redisserializer
    */
protected redisserializer<string> getredisserializer() {
     return redistemplate.getstringserializer();
}
}

iuserdao.java 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
package com.redis.test;
import java.util.list;
public interface iuserdao {
     /** 新增 */
     boolean add(user user);
     /** 批量新增，pipeline方式 */
     boolean add(list<user> list);
     /** 删除 */
     void delete(string key);
     /** 批量删除 */
     void delete(list<string> keys);
     /** 更新 */
     boolean update(user user);
     /** 读取 */
     user get(string keyid);
}

userdao.java 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
package com.redis.test;
import java.util.list;
import org.springframework.dao.dataaccessexception;
import org.springframework.data.redis.connection.redisconnection;
import org.springframework.data.redis.core.rediscallback;
import org.springframework.data.redis.serializer.redisserializer;
import org.springframework.util. assert ;
public class userdao extends abstractredisbasedao<string, user= "" > implements iuserdao {
   public boolean add( final user user) {
     boolean result = redistemplate.execute( new rediscallback< boolean >() {
         public boolean doinredis(redisconnection connection) throws dataaccessexception {
             redisserializer<string> serializer = getredisserializer();
             byte [] key = serializer.serialize(user.getid());
             // 将id序列化成key
             byte [] value = serializer.serialize(user.getname());
             return connection.setnx(key, value);
         }
     }
     );
     return result;
}
public boolean add( final list<user> list) {
     assert .notempty(list);
     boolean result = redistemplate.execute( new rediscallback< boolean >() {
         public boolean doinredis(redisconnection connection) throws dataaccessexception {
             redisserializer<string> serializer = getredisserializer();
             for ( int i = 0 ; i < list.size(); i++) {
                 user user = list.get(i);
                 byte [] key = serializer.serialize(user.getid());
                 // 将id序列化成key
                 byte [] value = serializer.serialize(user.getname());
                 connection.setnx(key, value);
             }
             return true ;
         }
     }
     , false , true );
     return result;
}
public void delete(string key) {
     redistemplate.delete(key);
}
public void delete(list<string> keys) {
     redistemplate.delete(keys);
}
public boolean update( final user user) {
     string key = user.getid();
     if (get(key) == null ) {
         throw new nullpointerexception( "数据行不存在,key = " + key);
     }
     boolean result = redistemplate.execute( new rediscallback< boolean >() {
         public boolean doinredis(redisconnection connection) throws dataaccessexception {
             redisserializer<string> serializer = getredisserializer();
             byte [] key = serializer.serialize(user.getid());
             // 将id序列化成key
             byte [] value = serializer.serialize(user.getname());
             connection.set(key, value);
             return true ;
         }
     }
     );
     return result;
}
public user get( final string keyid) {
     user user = redistemplate.execute( new rediscallback<user>() {
         public user doinredis(redisconnection connection) throws dataaccessexception {
             redisserializer<string> serializer = getredisserializer();
             byte [] key = serializer.serialize(keyid);
             byte [] value = connection.get(key);
             if (value == null ) {
                 return null ;
             }
             string name = serializer.deserialize(value);
             return new user(keyid, name, null );
         }
     }
     );
     return user;
}
}

redistest.java（junit测试类） 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package com.redis.test;
import java.util.arraylist;
import java.util.list;
import org.junit.test;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.test.context.contextconfiguration;
import org.springframework.test.context.junit4.abstractjunit4springcontexttests;
import org.springframework.util. assert ;
/**
  * junit在spring context环境下测试
  */
@contextconfiguration (locations={ "classpath*:beans.xml" })
public class redistest extends abstractjunit4springcontexttests {
     @autowired
       private iuserdao userdao;
     /** 增加单个用户 */
     @test
       public void testadduser() {
         user user = new user( "user1" , "password1" , null );
         boolean result = userdao.add(user);
         assert .istrue(result);
         system.out.println( "添加结果：" + result);
     }
     /** 批量新增普通方式,5286ms */
     @test
       public void testaddusers1() {
         list<user> list = new arraylist<user>();
         for ( int i = 10 ; i < 50000 ; i++) {
             user user = new user();
             user.setid( "user" + i);
             user.setname( "password" + i);
             list.add(user);
         }
         long begin = system.currenttimemillis();
         for (user user : list) {
             userdao.add(user);
         }
         system.out.println(system.currenttimemillis() - begin);
     }
     /** 批量新增pipeline方式,484ms */
     @test
       public void testaddusers2() {
         list<user> list = new arraylist<user>();
         for ( int i = 50000 ; i < 100000 ; i++) {
             user user = new user();
             user.setid( "user" + i);
             user.setname( "password" + i);
             list.add(user);
         }
         long begin = system.currenttimemillis();
         boolean result = userdao.add(list);
         assert .istrue(result);
         system.out.println(system.currenttimemillis() - begin);
     }
     /** 更新 */
     @test
       public void testupdate() {
         user user = new user();
         user.setid( "user1" );
         user.setname( "new_password" );
         boolean result = userdao.update(user);
         assert .istrue(result);
     }
     /** 删除 */
     @test
       public void testdelete() {
         string key = "user1" ;
         userdao.delete(key);
     }
     /** 批量删除 */
     @test
       public void testdeletes() {
         list<string> list = new arraylist<string>();
         for ( int i = 0 ; i < 10 ; i++) {
             list.add( "user" + i);
         }
         userdao.delete(list);
     }
     /** 读取 */
     @test
       public void testgetuser() {
         string id = "user1" ;
         user user = userdao.get(id);
         assert .notnull(user);
         system.out.println(user);
     }
}

总结 。

以上就是本文关于spring集成redis详解代码示例的全部内容，希望对大家有所帮助。如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！ 。

  。

原文链接：https://www.2cto.com/kf/201609/543944.html 。

最后此篇关于Spring集成Redis详解代码示例的文章就讲到这里了,如果你想了解更多关于Spring集成Redis详解代码示例的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

27 4 0
文章推荐： 百度新算法下友情链接是否真的能帮助网站推广?
文章推荐： python实现指定文件夹下的指定文件移动到指定位置
文章推荐： 关于网站内容如何快速被百度搜索收录的经验和技巧
文章推荐： python批量复制图片到另一个文件夹
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com