在《redis之——spring整合redis》一文中，向大家介绍了如何将spring与redis整合起来，但不是基于注解的形式，很多同学都希望能够通过注解的形式来简单的将spring与redis整合起来，这样，在使用的时候，只需要在相应的方法上加上注解，便可以使方法轻松的调用redis的缓存。那么今天就来向大家介绍如何用基于注解的形式来整合spring与redis。
一、项目搭建
今天，我们不使用hibernate来操作数据库了，我们今天选择的框架是： spring4(包括mvc、context、orm) + mybatis3，所以，我们今天的基础架构是：spring4(包括mvc、context、orm) + mybatis3+redis
1、构建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
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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
<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>lyz</groupid> <artifactid>lyz</artifactid> <version>1.0.0</version> <packaging>war</packaging> <name>lyz</name> <description>basic data platform</description> <properties> <project.build.sourceencoding>utf-8</project.build.sourceencoding> <spring.version>4.2.0.release</spring.version> </properties> <dependencies> <!-- spring mvc related.....start --> <!-- todo: replace jackson with fastjson --> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-context</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-webmvc</artifactid> <version>${spring.version}</version> </dependency> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-web</artifactid> <version>${spring.version}</version> </dependency> <dependency> <groupid>javax.servlet</groupid> <artifactid>jstl</artifactid> <version>1.2</version> </dependency> <dependency> <groupid>commons-logging</groupid> <artifactid>commons-logging</artifactid> <version>1.1.3</version> </dependency> <dependency> <groupid>org.codehaus.jackson</groupid> <artifactid>jackson-mapper-asl</artifactid> <version>1.9.13</version> </dependency> <dependency> <groupid>com.fasterxml.jackson.core</groupid> <artifactid>jackson-annotations</artifactid> <version>2.6.1</version> </dependency> <dependency> <groupid>com.fasterxml.jackson.core</groupid> <artifactid>jackson-core</artifactid> <version>2.6.1</version> </dependency> <dependency> <groupid>com.fasterxml.jackson.core</groupid> <artifactid>jackson-databind</artifactid> <version>2.6.1</version> </dependency> <!-- spring mvc related.....end --> <!-- mybatis orm related.....start --> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-orm</artifactid> <version>${spring.version}</version> </dependency> <dependency> <groupid>org.mybatis</groupid> <artifactid>mybatis-spring</artifactid> <version>1.2.3</version> </dependency> <dependency> <groupid>mysql</groupid> <artifactid>mysql-connector-java</artifactid> <version>5.1.36</version> </dependency> <dependency> <groupid>org.mybatis</groupid> <artifactid>mybatis</artifactid> <version>3.3.0</version> </dependency> <dependency> <groupid>c3p0</groupid> <artifactid>c3p0</artifactid> <version>0.9.1.2</version> </dependency> <dependency> <groupid>org.slf4j</groupid> <artifactid>slf4j-log4j12</artifactid> <version>1.7.12</version> </dependency> <!-- mybatis orm related.....end --> <!-- project log related.....start --> <dependency> <groupid>log4j</groupid> <artifactid>log4j</artifactid> <version>1.2.17</version> </dependency> <!-- project log related.....end --> <!-- redis cache related.....start --> <dependency> <groupid>org.springframework.data</groupid> <artifactid>spring-data-redis</artifactid> <version>1.6.0.release</version> </dependency> <dependency> <groupid>redis.clients</groupid> <artifactid>jedis</artifactid> <version>2.7.3</version> </dependency> <!-- redis cache related.....end --> </dependencies> <build> <plugins> <plugin> <artifactid>maven-compiler-plugin</artifactid> <version>3.1</version> <configuration> <source>1.7</source> <target>1.7</target> </configuration> </plugin> <plugin> <artifactid>maven-war-plugin</artifactid> <version>2.4</version> <configuration> <warsourcedirectory>webcontent</warsourcedirectory> <failonmissingwebxml>false</failonmissingwebxml> </configuration> </plugin> </plugins> </build> </project> |
2、创建测试数据库：lyz，测试数据表：user
|
1
2
3
4
5
6
7
8
9
10
|
drop database if exists `lyz`; create database `lyz`; drop table if exists `user`; create table `user` ( `id` int(10) unsigned not null auto_increment, `name` varchar(255) default null, `sex` varchar(255) default null, `age` int(11) default null, primary key (`id`) ) engine=innodb default charset=utf8; |
3、创建实体类user
|
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
88
89
90
91
92
93
94
|
package com.lyz.user.bean; import java.io.serializable; import org.codehaus.jackson.map.annotate.jsonserialize; import com.fasterxml.jackson.databind.propertynamingstrategy; import com.fasterxml.jackson.databind.annotation.jsonnaming; /** * 用户实体类 * @author liuyazhuang * */@jsonserialize@jsonnaming(propertynamingstrategy.lowercasewithunderscoresstrategy.class) public class user implements serializable{ private static final long serialversionuid = 1332643889208978231l; /** * id */ private integer id; /** * 姓名 */ private string name; /** * 性别 */ private string sex; /** * 年龄 */ private integer age; public user() { super(); } public user(integer id, string name) { super(); this.id = id; this.name = name; } public user(string name, string sex, integer age) { super(); this.name = name; this.sex = sex; this.age = age; } public integer getid() { return id; } public void setid(integer id) { this.id = id; } public string getname() { return name; } public void setname(string name) { this.name = name; } public string getsex() { return sex; } public void setsex(string sex) { this.sex = sex; } public integer getage() { return age; } public void setage(integer age) { this.age = age; } @override public string tostring() { return "user [id=" + id + ", name=" + name + ", sex=" + sex + ", age=" + age + "]"; } } |
4、创建usermapper接口
此接口定义了与mybatis交互的接口协议，通过此接口与mybatis框架通信，由mybatis框架实现对数据库的增删改查操作。
|
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
|
package com.lyz.user.mapper; import java.util.list; import com.lyz.user.bean.user; /** * usermapper接口 * @author liuyazhuang * */public interface usermapper { /** * 保存用户 * @param user */ void saveuser(user user); /** * 获取所有用户列表 * @return */ list<user> getalluser(); /** * 根据id查询用户信息 * @param id * @return */ user getuserbyid(integer id); /** * 更新用户的名称 * @param user */ void renameuser(user user); /** * 根据id删除指定的用户 * @param id */ void deleteuserbyid(integer id); } |
5、创建usermapper.xml
此文件中主要实现了usermapper接口定义的方法，即实现对数据库的增删改查操作。
|
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
|
<?xml version="1.0" encoding="utf-8" ?> <!doctype mapper public "-//mybatis.org//dtd mapper 3.0//en" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" > <mapper namespace="com.lyz.user.mapper.usermapper" > <!-- 插入一条城市记录 --> <insert id="saveuser" parametertype="com.lyz.user.bean.user"> insert into user (name, sex, age) values ( #{name}, #{sex}, #{age} ) </insert> <!-- 根据省份名称返回该省份下的所有城市列表 --> <select id="getalluser" resulttype="com.lyz.user.bean.user"> select u.id, u.name, u.sex, u.age from user u </select> <!-- 根据 city_code 查找城市信息 --> <select id="getuserbyid" resulttype="com.lyz.user.bean.user" parametertype="java.lang.integer"> select u.id, u.name, u.sex, u.age from user u where u.id = #{id} </select> <!-- 重命名城市 --> <update id="renameuser" parametertype="com.lyz.user.bean.user"> update user set name = #{name} where id = #{id} </update> <!-- 删除一个城市记录 --> <delete id="deleteuserbyid" parametertype="java.lang.integer"> delete from user where id = #{id} </delete> </mapper> |
6、创建userdao接口
|
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
|
package com.lyz.user.dao; import java.util.list; import com.lyz.user.bean.user; /** * 用户dao接口 * @author liuyazhuang * */public interface userdao { /** * 保存用户 * @param user */ void saveuser(user user); /** * 获取所有用户列表 * @return */ list<user> getalluser(); /** * 根据id查询用户信息 * @param id * @return */ user getbyid(integer id); /** * 更新用户的名称 * @param user */ void rename(user user); /** * 根据id删除指定的用户 * @param id */ void deletebyid(integer id); } |
7、创建userdao的实现类userdaoimpl
此类主要实现userdao中定义的接口，主要实现方法是注入usermapper接口的实例对象，调用usermapper接口实例的方法来实现相应的操作。
|
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
|
package com.lyz.user.dao.impl; import java.util.list; import javax.annotation.resource; import org.springframework.stereotype.repository; import com.lyz.user.bean.user; import com.lyz.user.dao.userdao; import com.lyz.user.mapper.usermapper; /** * dao实现类 * @author liuyazhuang * */@repositorypublic class userdaoimpl implements userdao { @resource private usermapper musermapper; @override public void saveuser(user user) { musermapper.saveuser(user); } @override public list<user> getalluser() { return musermapper.getalluser(); } @override public user getbyid(integer id) { return musermapper.getuserbyid(id); } @override public void rename(user user) { musermapper.renameuser(user); } @override public void deletebyid(integer id) { musermapper.deleteuserbyid(id); } } |
8、创建userservice接口
|
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
|
package com.lyz.user.service; import java.util.list; import com.lyz.user.bean.user; /** * 用户service接口 * @author liuyazhuang * */public interface userservice { /** * 保存用户 * @param user */ void saveuser(string name, string sex, integer age); /** * 获取所有用户列表 * @return */ list<user> getalluser(); /** * 根据id查询用户信息 * @param id * @return */ user getuserbyid(integer id); /** * 更新用户的名称 * @param user */ void renameuser(string name, integer id); /** * 根据id删除指定的用户 * @param id */ void deleteuserbyid(integer id); } |
9、创建userservice接口实现类userserviceimpl
|
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
|
package com.lyz.user.service.impl; import java.util.list; import javax.annotation.resource; import org.springframework.cache.annotation.cacheevict; import org.springframework.cache.annotation.cacheable; import org.springframework.stereotype.service; import org.springframework.transaction.annotation.propagation; import org.springframework.transaction.annotation.transactional; import com.lyz.user.bean.user; import com.lyz.user.dao.userdao; import com.lyz.user.service.userservice; /** * userservice实现类 * @author liuyazhuang * */@service@transactional(propagation=propagation.required, rollbackfor=exception.class) public class userserviceimpl implements userservice { @resource private userdao muserdao; @override @cacheevict(value = { "saveuser"}, allentries = true) public void saveuser(string name, string sex, integer age) { user user = new user(name, sex, age); muserdao.saveuser(user); } @override @cacheable("getalluser") public list<user> getalluser() { return muserdao.getalluser(); } @override @cacheable("getuserbyid") public user getuserbyid(integer id) { return muserdao.getbyid(id); } @override @cacheevict(value = { "getalluser", "getuserbyid" }, allentries = true) public void renameuser(string name, integer id) { muserdao.rename(new user(id, name)); } @override @cacheevict(value = { "getalluser", "getuserbyid" }, allentries = true) public void deleteuserbyid(integer id) { muserdao.deletebyid(id); } } |
10、创建usercontroller
|
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
88
89
|
package com.lyz.user.controller; import java.util.list; import org.apache.commons.logging.log; import org.apache.commons.logging.logfactory; import org.springframework.beans.factory.annotation.autowired; import org.springframework.stereotype.controller; import org.springframework.web.bind.annotation.requestmapping; import org.springframework.web.bind.annotation.requestparam; import org.springframework.web.bind.annotation.responsebody; import com.lyz.user.bean.user; import com.lyz.user.service.userservice; /** * usercontroller类 * @author liuyazhuang * */@controller@requestmapping("/user") public class usercontroller { private final log logger = logfactory.getlog(this.getclass()); @autowired private userservice muserservice; /** * 保存用户 * @param name * @param sex * @param age * @return */ @requestmapping("/save") @responsebody public integer save(@requestparam(value="name", defaultvalue="") string name, @requestparam(value="sex", defaultvalue="") string sex, @requestparam(value="age", defaultvalue="0") string age){ logger.debug(name); muserservice.saveuser(name, sex, integer.parseint(age)); return 1; } /** * 获取所有用户列表 * @return */ @requestmapping("/getall") @responsebody public object getalluser(){ list<user> users = muserservice.getalluser(); for(user u : users){ logger.debug(u.tostring()); } return users; } /** * 根据用户id获取用户信息 * @return */ @requestmapping("/getuserbyid") @responsebody public object getuserbyid(@requestparam(value="id", defaultvalue="0") string id){ user user = muserservice.getuserbyid(integer.parseint(id)); logger.debug(user.tostring()); return user; } /** * 根据用户id获取用户信息 * @return */ @requestmapping("/renameuser") @responsebody public integer renameuser(@requestparam(value="id", defaultvalue="0") string id, @requestparam(value="name", defaultvalue="") string name){ logger.debug(id + "=========" + name); muserservice.renameuser(name, integer.parseint(id)); return 1; } /** * 根据用户id获取用户信息 * @return */ @requestmapping("/delete") @responsebody public integer delete(@requestparam(value="id", defaultvalue="0") string id){ logger.debug(id); muserservice.deleteuserbyid(integer.parseint(id)); return 1; } } |
到此，只要再创建相应的配置文件，我们就可以实现spring+mybatis框架的整合了，下面我们创建一个整合redis的关键类rediscacheconfig，这个类继承cachingconfigurersupport。
11、创建rediscacheconfig类
|
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
|
package com.lyz.cache.redis; import java.lang.reflect.method; import org.springframework.cache.cachemanager; import org.springframework.cache.annotation.cachingconfigurersupport; import org.springframework.cache.annotation.enablecaching; import org.springframework.cache.interceptor.keygenerator; import org.springframework.context.annotation.bean; import org.springframework.context.annotation.configuration; import org.springframework.data.redis.cache.rediscachemanager; import org.springframework.data.redis.connection.redisconnectionfactory; import org.springframework.data.redis.connection.jedis.jedisconnectionfactory; import org.springframework.data.redis.core.redistemplate; /** * 以spring与配置文件来管理的redis缓存配置类 * @author liuyazhuang * */@configuration@enablecachingpublic class rediscacheconfig extends cachingconfigurersupport { private volatile jedisconnectionfactory mjedisconnectionfactory; private volatile redistemplate<string, string> mredistemplate; private volatile rediscachemanager mrediscachemanager; public rediscacheconfig() { super(); } public rediscacheconfig(jedisconnectionfactory mjedisconnectionfactory, redistemplate<string,string> mredistemplate, rediscachemanager mrediscachemanager) { super(); this.mjedisconnectionfactory = mjedisconnectionfactory; this.mredistemplate = mredistemplate; this.mrediscachemanager = mrediscachemanager; } public jedisconnectionfactory redisconnectionfactory() { return mjedisconnectionfactory; } public redistemplate<string, string> redistemplate(redisconnectionfactory cf) { return mredistemplate; } public cachemanager cachemanager(redistemplate<?, ?> redistemplate) { return mrediscachemanager; } @bean public keygenerator customkeygenerator() { return new keygenerator() { @override public object generate(object o, method method, object... objects) { stringbuilder sb = new stringbuilder(); sb.append(o.getclass().getname()); sb.append(method.getname()); for (object obj : objects) { sb.append(obj.tostring()); } return sb.tostring(); } }; } } |
这个类中的所有属性、字段都是在spring的配置文件lyz-applicationcontext.xml文件中注入的，稍后我们介绍如何注入这些属性字段。
下面介绍每个配置文件的内容，注：所有的配置文件(除了web.xml)，都是放在classpath路径下的。
12、创建数据库的配置文件jdbc.properties
|
1
2
3
4
5
|
jdbc.host=127.0.0.1jdbc.database=lyz jdbc.port=3306jdbc.username=root jdbc.password=root |
13、创建log4j日志配置文件log4j.properties
|
1
2
3
4
5
6
7
8
9
10
11
|
# global logging configuration log4j.rootlogger=warn,stdout # console output... log4j.appender.stdout=org.apache.log4j.consoleappender log4j.appender.stdout.layout=org.apache.log4j.patternlayout log4j.appender.stdout.layout.conversionpattern=%d{yyyy-mm-dd hh:mm:ss} %-5p %c:%l - %m%n # mybatis log log4j.logger.com.lyz.user.mapper.usermapper=debug # lyz log log4j.logger.com.lyz.user.controller=debug log4j.logger.com.lyz.user.service=debug |
14、创建redis配置文件redis.properties
|
1
2
3
4
5
6
7
8
9
10
|
# redis settings redis.host=192.168.157.130redis.port=6379redis.pass=liuyazhuang redis.dbindex=0redis.expiration=3000redis.maxidle=300redis.maxactive=600redis.maxwait=1000redis.testonborrow=true |
15、创建springmvc的配置文件lyzmvc-servlet.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
|
<?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:p="http://www.springframework.org/schema/p" 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"> <!-- class annotation related... start --> <context:component-scan base-package="com.lyz.*.controller" /> <!-- class annotation related... end --> <!-- jsp page related... start --> <bean id="viewresolver" class="org.springframework.web.servlet.view.urlbasedviewresolver"> <property name="viewclass" value="org.springframework.web.servlet.view.jstlview" /> <property name="prefix" value="/web-inf/jsp/" /> <property name="suffix" value=".jsp" /> </bean> <!-- jsp page related... end --> <!-- rest json related... start --> <bean id="mappingjacksonhttpmessageconverter" class="org.springframework.http.converter.json.mappingjackson2httpmessageconverter"> <property name="supportedmediatypes"> <list> <value>application/json;charset=utf-8</value> </list> </property> </bean> <bean class="org.springframework.web.servlet.mvc.annotation.annotationmethodhandleradapter"> <property name="messageconverters"> <list> <ref bean="mappingjacksonhttpmessageconverter"/> </list> </property> </bean> <!-- rest json related... end --> </beans> |
16、创建mybatis配置文件mybatis-config.xml
|
1
2
3
4
5
6
7
|
<?xml version="1.0" encoding="utf-8"?> <!doctype configuration public "-//mybatis.org//dtd config 3.0//en" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <settings> <setting name="mapunderscoretocamelcase" value="true"/> </settings> </configuration> |
17、创建spring核心配置文件lyz-applicationcontext.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
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
88
89
90
91
92
93
94
95
|
<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" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" 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 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd"> <!-- class annotation related... start --> <context:component-scan base-package="com.lyz"/> <context:component-scan base-package="com.lyz.*.service" /> <context:component-scan base-package="com.lyz.*.service.*" /> <context:component-scan base-package="com.lyz.cache.redis" /> <!-- class annotation related... end --> <context:annotation-config /> <!-- mybatis related... start --> <bean class="org.springframework.beans.factory.config.propertyplaceholderconfigurer"> <property name="locations"> <list> <!-- 这里支持多种寻址方式：classpath和file --> <value>classpath:jdbc.properties</value> <value>classpath:redis.properties</value> <!-- 推荐使用file的方式引入，这样可以将配置和代码分离 --> </list> </property> </bean> <bean id="datasource" class="com.mchange.v2.c3p0.combopooleddatasource " destroy-method="close"> <property name="driverclass" value="com.mysql.jdbc.driver" /> <property name="jdbcurl" value="jdbc:mysql://${jdbc.host}:${jdbc.port}/${jdbc.database}?useunicode=true&characterencoding=utf8" /> <property name="user" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> <property name="acquireincrement" value="1" /> <property name="initialpoolsize" value="5" /> <property name="maxpoolsize" value="20" /> <property name="minpoolsize" value="5" /> <property name="maxstatements" value="100" /> <property name="testconnectiononcheckout" value="true" /> </bean> <bean id="sqlsessionfactory" class="org.mybatis.spring.sqlsessionfactorybean"> <property name="datasource" ref="datasource" /> <property name="configlocation" value="/web-inf/classes/mybatis-config.xml" /> </bean> <bean class="org.mybatis.spring.mapper.mapperscannerconfigurer"> <property name="basepackage" value="com.lyz.*.mapper"/> </bean> <!-- mybatis related... end --> <!-- transaction config related... start --> <tx:annotation-driven transaction-manager="transactionmanager" /> <bean id="transactionmanager" class="org.springframework.jdbc.datasource.datasourcetransactionmanager"> <property name="datasource" ref="datasource" /> </bean> <!-- transaction config related... end --> <!-- redis config start --> <!-- 配置jedispoolconfig实例 --> <bean id="poolconfig" class="redis.clients.jedis.jedispoolconfig"> <property name="maxidle" value="${redis.maxidle}" /> <property name="maxtotal" value="${redis.maxactive}" /> <property name="maxwaitmillis" value="${redis.maxwait}" /> <property name="testonborrow" value="${redis.testonborrow}" /> </bean> <!-- 配置jedisconnectionfactory --> <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="database" value="${redis.dbindex}"/> <property name="poolconfig" ref="poolconfig"/> </bean> <!-- 配置redistemplate --> <bean id="redistemplate" class="org.springframework.data.redis.core.redistemplate"> <property name="connectionfactory" ref="jedisconnectionfactory"/> </bean> <!-- 配置rediscachemanager --> <bean id="rediscachemanager" class="org.springframework.data.redis.cache.rediscachemanager"> <constructor-arg name="redisoperations" ref="redistemplate" /> <property name="defaultexpiration" value="${redis.expiration}"/> </bean> <!-- 配置rediscacheconfig --> <bean id="rediscacheconfig" class="com.lyz.cache.redis.rediscacheconfig"> <constructor-arg ref="jedisconnectionfactory" /> <constructor-arg ref="redistemplate" /> <constructor-arg ref="rediscachemanager" /> </bean> <!-- redis config end --> </beans> |
注：在lyz-applicationcontext.xml配置文件中，配置了spring的注解、注入了rediscacheconfig中的属性字段。
18、完善web.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
47
48
49
50
51
52
|
<?xml version="1.0" encoding="utf-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemalocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="webapp_id" version="3.0"> <display-name>lyz</display-name> <!-- character encoding related.....start --><!-- todo : 将 encodingfilter、sysparamsfilter 两个过滤器交给 spring 管理 --> <filter> <filter-name>encodingfilter</filter-name> <filter-class> org.springframework.web.filter.characterencodingfilter </filter-class> <init-param> <param-name>encoding</param-name> <param-value>utf-8</param-value> </init-param> <init-param> <param-name>forceencoding</param-name> <param-value>true</param-value> </init-param> </filter> <filter-mapping> <filter-name>encodingfilter</filter-name> <url-pattern>/*</url-pattern> </filter-mapping> <!-- 除了加过滤器，由于tomcat默认编码iso-8859-1，还需要修改 %tomcat%/conf/server.xml connector 标签加属性 uriencoding="utf-8" --> <!-- character encoding related.....end --> <context-param> <param-name>contextconfiglocation</param-name> <param-value>/web-inf/classes/*-applicationcontext.xml</param-value> </context-param> <listener> <listener-class>org.springframework.web.context.contextloaderlistener</listener-class> </listener> <servlet> <servlet-name>lyzmvc</servlet-name> <servlet-class>org.springframework.web.servlet.dispatcherservlet</servlet-class> <init-param> <param-name>contextconfiglocation</param-name> <param-value>/web-inf/classes/*-servlet.xml</param-value> </init-param> <load-on-startup>1</load-on-startup> </servlet> <servlet-mapping> <servlet-name>lyzmvc</servlet-name> <url-pattern>*.json</url-pattern> <url-pattern>*.html</url-pattern> </servlet-mapping> </web-app> |
二、运行测试
这里我们使用apache jmeter来测试我们的程序，大家可以到下载apache jmeter。
1、启动程序，使用jmeter调用保存用户接口
首先按照图示配置jmeter,其中访问路径和端口按照实际需要配置：
点击启动按钮，也就是上方的
图标：
点击“查看结果树”并打开“响应数据”选项：
我们看到返回的结果是1，证明我们成功的调用了保存用户的接口。
下面我们来看看数据库表：
已经将数据保存到数据库了。
2、调用查询用户的接口
首先按照图示配置jmeter,其中访问路径和端口按照实际需要配置：
这些我们先看看redis服务器中是否存在相应的数据：
此时,redis服务器中并没有任何数据，下面我们点击启动，执行程序：
点击“查看结果数”并打开“响应数据”，如下：
返回了相应的数据。
我们再打开控制台看看输出的语句：
说明首次获取数据是从数据库中获取的。下面我们再看看redis缓存中是否存在数据了：
说明首次获取数据，从数据库中取出的数据已经放在了redis缓存服务器中。
我们再次点击jmeter的启动按钮，执行查询用户的操作：
查看jmeter的“查看结果数”中的“响应数据”选项：
返回了正确的结果，同时，我们再看看eclipse的控制台：
已经没有再从数据库中获取数据了，说明再次执行查询用户的操作，程序是直接从redis缓存中获取的数据。
至此，spring基于注解整合redis介绍完毕。
三、源码下载
完整示例代码：spring_redis.rar
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：http://blog.csdn.net/l1028386804/article/details/52141372
