Spring与Mybatis基于注解整合Redis

基于这段时间折腾redis遇到了各种问题，想着整理一下。本文主要介绍基于Spring+Mybatis以注解的形式整合Redis。废话少说，进入正题。首先准备Redis，我下的是Windows版，下载后直接启动redis-server就行了，见下图：一，先上jar包二，创建实体类 1 package com.sl.user.vo; 23 import java.io.Serializable; 45 import com.fasterxml.jackson.databind.PropertyNamingStrategy; 6 import com.fasterxml.jackson.databind.annotation.JsonNaming; 7 import com.fasterxml.jackson.databind.annotation.JsonSerialize; 89 @JsonSerialize10 @JsonNaming（PropertyNamingStrategy.LowerCaseWithUnderscoresStrategy.class）11 public class UserVO implements Serializable{12 13 private static final long serialVersionUID = 1L;14 15 private int id;16 private String username;17 private String password;18 private int age;19 20 public UserVO（）{21 super（）; 22 }23 24 public UserVO（int id, String username, String password, int age） {25 super（）;26 this.id = id;27 this.username = username;28 this.password = password;29 this.age = age;30 }31 32 public int getId（） {33 return id;34 }35 36 public void setId（int id） {37 this.id = id;38 }39 40 public String getUsername（） {41 return username;42 }43 44 public void setUsername（String username） {45 this.username = username;46 }47 48 public String getPassword（） {49 return password;50 }51 52 public void setPassword（String password） {53 this.password = password;54 }55 56 public int getAge（） {57 return age;58 }59 60 public void setAge（int age） {61 this.age = age;62 }63 64 @Override65 public String toString（） {66 return "UserVO [id=" + id + ", username=" + username + ", password="67 + password + ", age=" + age + "]";68 }69 70 }三，dao接口 1 package com.sl.user.dao; 23 import com.sl.user.vo.UserVO; 45 public interface UserDao { 67 public void addUser（UserVO user）; 89 public void deleteUser（UserVO user）;10 11 public void updateUser（UserVO user）;12 13 public UserVO getUserById（int id）;14 15 public UserVO getUser（int id）;16 17 }四，UserMapper 1 <？xml version="1.0" encoding="UTF-8" ？> 2 <！DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" > 3 <mapper namespace="com.sl.user.dao.UserDao" > 45 <resultMap id="userResult" type="User"> 6 <result column="id" property="id"/> 7 <result column="userame" property="userame"/> 8 <result column="password" property="password"/> 9 <result column="age" property="age"/>10 </resultMap>11 12 <insert id="addUser" parameterType="User">13 insert into t_user（username,password,age） values（#{username},#{password},#{age}）14 </insert>15 16 <update id="deleteUser" parameterType="User">17 delete * from t_user where id = #{id}18 </update>19 20 <update id="updateUser" parameterType="User">21 update t_user set22 <if test="username ！= null and username ！= """> username = #{username},</if>23 <if test="password ！= null and password ！= """> password = #{password},</if>24 <if test="age ！= null and age ！= """> age = #{age}</if>25 where 1=126 <if test="id ！= null and id ！= """>and id = #{id}</if>27 28 </update>29 30 <select id="getUser" parameterType="int" resultType="User" >31 select * from t_user where id = #{id}32 </select>33 34 <select id="getUserById" parameterType="int" resultType="java.lang.String" >35 select username from t_user where id = #{id}36 </select>37 38 </mapper>五，Service接口 1 package com.sl.user.service; 23 import com.sl.user.vo.UserVO; 45 public interface UserService { 67 public void addUser（UserVO user）; 89 public void deleteUser（UserVO user）;10 11 public void updateUser（UserVO user）;12 13 public UserVO getUserById（int id）;14 15 public UserVO getUser（int id）;16 17 }六，Service实现 1 package com.sl.user.service.impl; 23 import org.springframework.beans.factory.annotation.Autowired; 4 import org.springframework.cache.annotation.CacheEvict; 5 import org.springframework.cache.annotation.Cacheable; 6 import org.springframework.stereotype.Service; 7 import org.springframework.transaction.annotation.Propagation; 8 import org.springframework.transaction.annotation.Transactional; 9 10 import com.sl.user.dao.UserDao;11 import com.sl.user.service.UserService;12 import com.sl.user.vo.UserVO;13 14 @Service（"userService"）15 @Transactional（propagation=Propagation.REQUIRED, rollbackFor=Exception.class） 16 public class UserServiceImpl implements UserService{17 18 @Autowired19 private UserDao userDao;20 21 @Override22 @CacheEvict（value="User",key="addUser",allEntries=true） 23 public void addUser（UserVO user） {24 userDao.addUser（user）;25 }26 27 @Override28 @CacheEvict（value = {"getUser", "getUserById"}, allEntries = true）29 public void deleteUser（UserVO user） {30 userDao.deleteUser（user）;31 }32 33 @Override34 @CacheEvict（value = {"getUser", "getUserById"}, allEntries = true）35 public void updateUser（UserVO user） {36 userDao.updateUser（user）;37 }38 39 @Override40 @Cacheable（value="User",key="getUserById"）41 public UserVO getUserById（int id） {42 return userDao.getUserById（id）;43 }44 45 @Override46 @Cacheable（value="User",key=""getUser""）47 public UserVO getUser（int id） {48 return userDao.getUser（id）;49 }50 51 }七，Ctrl层 1 package com.sl.user.web; 23 import java.util.HashMap; 4 import java.util.Map; 56 import org.springframework.beans.factory.annotation.Autowired; 7 import org.springframework.stereotype.Controller; 8 import org.springframework.web.bind.annotation.RequestMapping; 9 import org.springframework.web.bind.annotation.ResponseBody;10 11 import com.sl.user.service.UserService;12 import com.sl.user.vo.UserVO;13 14 @Controller15 @RequestMapping（"/userCtrl"）16 public class UserCtrl {17 18 @Autowired19 private UserService userService;20 21 @RequestMapping（"/addUser"）22 public void addUser（UserVO user）{23 userService.addUser（user）;24 }25 26 @RequestMapping（"/deleteUser"）27 public void deleteUser（UserVO user）{28 userService.deleteUser（user）;29 }30 31 @RequestMapping（"/updateUser"）32 public void updateUser（UserVO user）{33 userService.updateUser（user）;34 }35 36 @ResponseBody37 @RequestMapping（"/getUserById"）38 public Map<String,Object> getUserById（UserVO user）{39 Map<String,Object> map = new HashMap<String,Object>（）;40 map.put（"msg",userService.getUserById（4））;41 return map;42 }43 44 @ResponseBody45 @RequestMapping（"/getUser"）46 public Map<String,Object> getUser（UserVO vo）{47 Map<String,Object> map = new HashMap<String,Object>（）;48 Object user = userService.getUser（4）;49 map.put（"msg",user.toString（））;50 return map;51 }52 53 }八，Redis关键类，用于CRUD操作1 package com.sl.user.redis;2 import java.io.ByteArrayInputStream;3 import java.io.ByteArrayOutputStream;4 import java.io.IOException;5 import java.io.ObjectInputStream;6 import java.io.ObjectOutputStream;7 8 import org.springframework.cache.Cache;9 import org.springframework.cache.support.SimpleValueWrapper; 10 import org.springframework.dao.DataAccessException; 11 import org.springframework.data.redis.connection.RedisConnection; 12 import org.springframework.data.redis.core.RedisCallback; 13 import org.springframework.data.redis.core.RedisTemplate; 1415 public class RedisUtil implements Cache{ 1617 private RedisTemplate<String, Object> redisTemplate; 18 private String name; 19 public RedisTemplate<String, Object> getRedisTemplate（） { 20 return redisTemplate; 21 } 22 23 public void setRedisTemplate（RedisTemplate<String, Object> redisTemplate） { 24 this.redisTemplate = redisTemplate; 25 } 26 27 public void setName（String name） { 28 this.name = name; 29 } 30 31 @Override 32 public String getName（） { 33 return this.name; 34 } 3536 @Override 37 public Object getNativeCache（） { 38 return this.redisTemplate; 39 } 4041 /** 42* 从缓存中获取key 43*/ 44 @Override 45 public ValueWrapper get（Object key） { 46 System.out.println（"get key"）; 47 final String keyf =key.toString（）; 48 Object object = null; 49 object = redisTemplate.execute（new RedisCallback<Object>（） { 50 public Object doInRedis（RedisConnection connection） 51 throws DataAccessException { 52 byte[] key = keyf.getBytes（）; 53 byte[] value = connection.get（key）; 54 if （value == null） { 55return null; 56 } 57 return toObject（value）; 58 } 59}）; 60 return （object ！= null ？ new SimpleValueWrapper（object） : null）; 61 } 6263/** 64 * 将一个新的key保存到缓存中 65 * 先拿到需要缓存key名称和对象，然后将其转成ByteArray 66 */ 67@Override 68public void put（Object key, Object value） { 69 System.out.println（"put key"）; 70final String keyf = key.toString（）; 71final Object valuef = value; 72final long liveTime = 86400; 73redisTemplate.execute（new RedisCallback<Long>（） { 74public Long doInRedis（RedisConnection connection） 75throws DataAccessException { 76 byte[] keyb = keyf.getBytes（）; 77 byte[] valueb = toByteArray（valuef）; 78 connection.set（keyb, valueb）; 79 if （liveTime > 0） { 80 connection.expire（keyb, liveTime）; 81} 82 return 1L; 83} 84}）; 85 } 8687 private byte[] toByteArray（Object obj） { 88byte[] bytes = null; 89ByteArrayOutputStream bos = new ByteArrayOutputStream（）; 90try { 91ObjectOutputStream oos = new ObjectOutputStream（bos）; 92oos.writeObject（obj）; 93oos.flush（）; 94bytes = bos.toByteArray（）; 95oos.close（）; 96bos.close（）; 97 }catch （IOException ex） { 98ex.printStackTrace（）; 99 }100 return bytes;101 }102 103private Object toObject（byte[] bytes） {104Object obj = null;105try {106ByteArrayInputStream bis = new ByteArrayInputStream（bytes）;107ObjectInputStream ois = new ObjectInputStream（bis）;108obj = ois.readObject（）;109ois.close（）;110bis.close（）;111} catch （IOException ex） {112ex.printStackTrace（）;113 } catch （ClassNotFoundException ex） {114ex.printStackTrace（）;115 }116 return obj;117 }118119/**120 * 删除key121 */122@Override123public void evict（Object key） {124 System.out.println（"del key"）;125final String keyf = key.toString（）;126redisTemplate.execute（new RedisCallback<Long>（） {127public Long doInRedis（RedisConnection connection）128throws DataAccessException {129return connection.del（keyf.getBytes（））;130 }131 }）;132 }133134 /**135* 清空key136*/137 @Override138 public void clear（） {139 System.out.println（"clear key"）;140redisTemplate.execute（new RedisCallback<String>（） {141 public String doInRedis（RedisConnection connection）142 throws DataAccessException {143 connection.flushDb（）;144 return "ok";145}146}）;147 }148 149 @Override150 public <T> T get（Object key, Class<T> type） {151 return null;152 }153 154 @Override155 public ValueWrapper putIfAbsent（Object key, Object value） {156 return null;157 }158 159 }九，Spring整合mybatis和redis配置文件 1 <？xml version="1.0" encoding="UTF-8"？> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"4 xmlns:p="http://www.springframework.org/schema/p" 5 xmlns:context="http://www.springframework.org/schema/context"6 xmlns:tx="http://www.springframework.org/schema/tx" 7 xmlns:mvc="http://www.springframework.org/schema/mvc" 8 xmlns:aop="http://www.springframework.org/schema/aop" 9 xmlns:cache="http://www.springframework.org/schema/cache"10 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd11http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd12http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd13http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd14http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd15http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd">16 17 <！-- 扫描dao,service -->18 <context:component-scan base-package="com.sl.user.service" />19 <context:component-scan base-package="com.sl.user.service.*" />20 <context:component-scan base-package="com.sl.user.redis" />21 <！-- 启用注解 -->22 <context:annotation-config/>23 <！-- 启动缓存注解 -->24 <cache:annotation-driven/>25 26 <！-- MyBatis start -->27 <！-- 配置dataSource DriverManagerDataSource-->28 <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">29 <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>30 <property name="url" value="jdbc:mysql://127.0.0.1:3306/test"></property>31 <property name="username" value="root"></property>32 <property name="password" value="root"></property>33 </bean>34 35 <！-- MyBatis配置 SqlSessionFactoryBean -->36 <bean id="sessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">37 <property name="dataSource" ref="dataSource"></property>38 <property name="configLocation" value="classpath:config/mybatis.xml"></property>39 <property name="mapperLocations" value="classpath:mapper/UserMapper.xml"></property>40 </bean>41 42 <！-- mybatis自动扫描加载Sql映射文件/接口 : MapperScannerConfigurer 43sqlSessionFactory44 basePackage:指定sql映射文件/接口所在的包（自动扫描） -->45 <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">46 <property name="sqlSessionFactory" ref="sessionFactory"></property>47 <property name="basePackage" value="com.sl.user.dao"></property>48 </bean>49 50<！-- 事务管理DataSourceTransactionManager-->51<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">52<property name="dataSource" ref="dataSource"></property>53</bean>5455<！-- 使用声明式事务 transaction-manager：引用上面定义的事务管理器-->56<tx:annotation-driven transaction-manager="txManager"></tx:annotation-driven>5758<！-- MyBatis end -->5960<！-- 配置redis部分 start -->6162<！-- 配置redis连接池JedisPoolConfig-->63<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">64<property name="maxIdle" value="300" />65 <property name="maxTotal" value="600" />66</bean> 6768<！-- 配置CoonnectionFactory JedisConnectionFactory-->69<bean id="connFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">70 <property name="hostName" value="127.0.0.1"></property>71 <property name="port" value="6379"></property>72 <property name="poolConfig" ref="poolConfig"></property>73</bean>74 75<！-- 配置redisTemplate StringRedisTemplate-->76<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">77 <property name="connectionFactory" ref="connFactory"/>78</bean>7980<bean id="cacheManager" class="org.springframework.cache.support.SimpleCacheManager">81<property name="caches">82 <set>83 <bean class="com.sl.user.redis.RedisUtil">84<property name="redisTemplate" ref="redisTemplate" />85<property name="name" value="User"/>86<！-- User名称要在类或方法的注解中使用 -->87 </bean>88 </set>89</property>90</bean>91 92 </beans>十，SpringMVC配置文件 1 <？xml version="1.0" encoding="UTF-8"？> 2 <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" 3 xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:mvc="http://www.springframework.org/schema/mvc" 4 xmlns:aop="http://www.springframework.org/schema/aop" 5 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 6http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 7http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd 8http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd 9http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">10 11 <mvc:annotation-driven/>12 <！-- 启用spring mvc 注解 -->13 <context:annotation-config/>14 <！-- 设置使用注解的类所在的jar包 -->15 <context:component-scan base-package="com.sl.user.*"></context:component-scan>16 17 <！-- 对模型视图名称的解析，即在模型视图名称添加前后缀 -->18 <bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">19 <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>20 <property name="prefix" value="/views/"/>21 <property name="suffix" value=".jsp"/>22 </bean>23 24 <bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter">25 <！-- JSON转换器 -->26 <property name="messageConverters">27 <list>28 <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">29 <property name="supportedMediaTypes">30 <list>31 <value>application/json;charset=utf-8</value>32 <value>text/json;charset=utf-8</value>33 </list>34 </property>35 </bean>36 </list>37 </property>38 </bean>39 40 </beans>十一，mybatis配置文件 1 <？xml version="1.0" encoding="UTF-8"？> 2 <！DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"3 "http://mybatis.org/dtd/mybatis-3-config.dtd"> 4 <configuration> 56 <！-- 实体类,简称 -设置别名 --> 7 <typeAliases> 8 <typeAlias alias="User" type="com.sl.user.vo.UserVO" /> 9 </typeAliases>10 11 </configuration>十二，log4j 1 # Set root category priority to INFO and its only appender to CONSOLE. 2 log4j.rootCategory=DEBUG, CONSOLE 3 #log4j.rootCategory=INFO, CONSOLE, LOGFILE 45 # CONSOLE is set to be a ConsoleAppender using a PatternLayout. 6 log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender 7 log4j.appender.CONSOLE.Threshold=DEBUG 8 log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout 9 log4j.appender.CONSOLE.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %p - %m%n10 11 log4j.logger.java.sql.Connection=DEBUG12 log4j.logger.java.sql.Statement=DEBUG13 log4j.logger.java.sql.PreparedStatement=DEBUG14 log4j.logger.java.sql.ResultSet=DEBUG十三，web.xml 1 <？xml version="1.0" encoding="UTF-8"？> 2 <web-app version="3.0"3 xmlns="http://java.sun.com/xml/ns/javaee"4 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"5 xsi:schemaLocation="http://java.sun.com/xml/ns/javaee6 http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"> 7 <display-name>TestRedis</display-name> 89 <context-param>10 <param-name>contextConfigLocation</param-name>11 <param-value>12 classpath:config/applicationContext.xml13 </param-value>14 </context-param>15 16 <context-param>17 <param-name>log4jConfigLocation</param-name>18 <param-value>classpath:config/log4j.properties</param-value>19 </context-param>20 <context-param>21 <param-name>log4jRefreshInterval</param-name>22 <param-value>60000</param-value>23 </context-param>24 25 <listener>26 <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>27 </listener>28 <！-- 日志 -->29 <listener>30 <listener-class>org.springframework.web.util.Log4jConfigListener</listener-class>31 </listener>32 33 <servlet>34 <servlet-name>spring</servlet-name>35 <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>36 <init-param>37 <param-name>contextConfigLocation</param-name>38 <param-value>classpath:config/SpringMVC.xml</param-value>39 </init-param>40 <load-on-startup>1</load-on-startup>41 </servlet>42 <servlet-mapping>43 <servlet-name>spring</servlet-name>44 <url-pattern>*.do</url-pattern>45 </servlet-mapping>46 47 <！-- 解决中文乱码问题 -->48 <filter>49 <filter-name>characterEncoding</filter-name>50 <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>51 <init-param>52 <param-name>encoding</param-name>53 <param-value>UTF-8</param-value>54 </init-param>55 <init-param>56 <param-name>forceEncoding</param-name>57 <param-value>true</param-value>58 </init-param>59 </filter>60 <filter-mapping>61 <filter-name>characterEncoding</filter-name>62 <url-pattern>*.do</url-pattern>63 </filter-mapping>64 65 66 <welcome-file-list>67 <welcome-file>index.jsp</welcome-file>68 </welcome-file-list>69 </web-app>十四，测试，已查询为例（getUser（）方法），jsp测试页面整的比较丑就不贴出来了，自己写一个吧。。。查询前：执行第一次查询：执行第二次查询操作：上图可见，没有再执行sql，直接从redis中获取数据。大功告成！！！！在下初学，文中多有不足之处，还望多多指教。不喜勿喷。本文永久更新链接地址：http://www.linuxidc.com/Linux/2016-09/134911.htm