上次写完了一个demo 之后想把redis技术用在项目中，结果是频频报错。后来才发现原来我把两种实现方法混为一谈了，这次我向大家介绍第二种，我结合项目写的redis-demo。希望大家哆嗦多多收益，在看代码之前，我觉得有必要跟讲解一下 jedis 的运行原理：

1.插入一条数据 ：

2.查询刚才插入的方法：

3.第二次查询：

4.修改刚才插入的数据：

5.查询修改过的数据：

好了，了解了运行机制，我们运行代码就会明白很多。

在pom.xml文件中：

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

4.0.0

com.basessm

basessm

war

0.0.1-SNAPSHOT

basessm Maven Webapp

http://maven.apache.org

4.0.2.RELEASE

3.2.6

1.7.7

1.2.17

org.mybatis

mybatis-ehcache

1.0.0

org.springframework.data

spring-data-redis

1.0.2.RELEASE

org.apache.commons

commons-lang3

3.5

redis.clients

jedis

2.1.0

junit

junit

4.11

test

org.springframework

spring-core

${spring.version}

org.springframework

spring-web

${spring.version}

org.springframework

spring-oxm

${spring.version}

org.springframework

spring-tx

${spring.version}

org.springframework

spring-jdbc

${spring.version}

org.springframework

spring-webmvc

${spring.version}

org.springframework

spring-aop

${spring.version}

org.springframework

spring-context-support

${spring.version}

org.springframework

spring-test

${spring.version}

org.mybatis

mybatis

${mybatis.version}

org.mybatis

mybatis-spring

1.2.2

javax

javaee-api

7.0

mysql

mysql-connector-java

5.1.30

commons-dbcp

commons-dbcp

1.2.2

jstl

jstl

1.2

log4j

log4j

${log4j.version}

com.alibaba

fastjson

1.1.41

org.slf4j

slf4j-api

${slf4j.version}

org.slf4j

slf4j-log4j12

${slf4j.version}

org.codehaus.jackson

jackson-mapper-asl

1.9.13

commons-fileupload

commons-fileupload

1.3.1

commons-io

commons-io

2.4

commons-codec

commons-codec

1.9

org.aspectj

aspectjrt

1.6.12

org.aspectj

aspectjweaver

1.6.12

cglib

cglib

2.2

basessm

在application.xml文件中： 重点看 红色标注的地方

在mybatis-conf.xml文件中。开启全局缓存：<?xml version="1.0" encoding="UTF-8" ?>

/p>

PUBLIC "-//mybatis.org//DTD Config 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-config.dtd">

在UserMapper.xml文件中：<?xml version="1.0" encoding="UTF-8"?>

/p>

"http://mybatis.org/dtd/mybatis-3-mapper.dtd">

INSERT INTO user (id,username,password) VALUES (#{id},#{username},#{password})

DELETE FROM user WHERE id=#{id}

update user

set id=#{id}

,username = #{username}

,password = #{password}

WHERE id=#{id}

SELECT id,username,password FROM user WHERE id=#{id}

SELECT id,username,password FROM user where username=#{username} and password=#{password}

SELECT id,username,password FROM user

创建RedisCache，实现Ｃａｃｈｅ接口：package com.basessm.redis.core1;

import java.io.Serializable;

import java.util.concurrent.locks.ReadWriteLock;

import java.util.concurrent.locks.ReentrantReadWriteLock;

import org.apache.commons.lang3.SerializationUtils;

import org.apache.ibatis.cache.Cache;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.connection.jedis.JedisConnection;

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;

import org.springframework.data.redis.serializer.RedisSerializer;

import com.basessm.redis.core.SerializeUtil;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

import redis.clients.jedis.exceptions.JedisConnectionException;

public class RedisCache implements Cache {

/**

* 日志

*/

private static final Logger LOGGER = LoggerFactory.getLogger(RedisCache.class);

private static final long serialVersionUID = -8198240627840132613L;

/**

* The {@code ReadWriteLock}.

*/

private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

/**

* Jedis客户端

*/

@Autowired

private Jedis redisClient = createClient();

private String id;

public RedisCache(final String id) {

if (id == null) {

throw new IllegalArgumentException("必须传入ID");

}

System.out.println("............MybatisRedisCache:id=" + id);

LOGGER.debug("MybatisRedisCache:id=" + id);

this.id = id;

}

@Override

public void clear() {

redisClient.flushDB();

}

@Override

public String getId() {

return this.id;

}

@Override

public Object getObject(Object key) {

byte[] ob = redisClient.get(SerializeUtil.serialize(key.toString()));

if (ob == null) {

return null;

}

Object value = SerializeUtil.unSerialize(ob);

LOGGER.debug("获取的键值对>>>>>>>>>>>>>>>>>>>>>>>>getObject:" + key + "=" + value);

return value;

}

@Override

public ReadWriteLock getReadWriteLock() {

return readWriteLock;

}

@Override

public int getSize() {

return Integer.valueOf(redisClient.dbSize().toString());

}

@Override

public void putObject(Object key, Object value) {

LOGGER.debug("存入的键值对>>>>>>>>>>>>>>>>>>>>>>>>putObject:" + key + "=" + value);

redisClient.set(SerializeUtil.serialize(key.toString()), SerializeUtil.serialize(value));

}

@Override

public Object removeObject(Object key) {

return redisClient.expire(SerializeUtil.serialize(key.toString()), 0);

}

protected static Jedis createClient() {

try {

JedisPool pool = new JedisPool(new JedisPoolConfig(), "127.0.0.1",6379,8000,"foobared");

return pool.getResource();

} catch (Exception e) {

e.printStackTrace();

}

throw new RuntimeException("初始化连接池错误");

}

}

在项目运行之前启动　redis服务，

JedisPool pool = new JedisPool(new JedisPoolConfig(), "127.0.0.1",6379,8000,"foobared");

分别是连接ＩＰ，端口，连接启动时长，密码。

创建序列化类SerializeUtil：package com.basessm.redis.core;

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

public class SerializeUtil {

/**

*

* 序列化

*/

public static byte[] serialize(Object obj) {

ObjectOutputStream oos = null;

ByteArrayOutputStream baos = null;

try {

// 序列化

baos = new ByteArrayOutputStream();

oos = new ObjectOutputStream(baos);

oos.writeObject(obj);

byte[] byteArray = baos.toByteArray();

return byteArray;

} catch (IOException e) {

e.printStackTrace();

}

return null;

}

/**

*

* 反序列化

*

* @param bytes

* @return

*/

public static Object unSerialize(byte[] bytes) {

ByteArrayInputStream bais = null;

try {

// 反序列化为对象

bais = new ByteArrayInputStream(bytes);

ObjectInputStream ois = new ObjectInputStream(bais);

return ois.readObject();

} catch (Exception e) {

e.printStackTrace();

}

return null;

}

}

创建控制类：package com.basessm.controller;

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.ResponseBody;

import com.basessm.model.User;

import com.basessm.service.UserServiceI;

@Controller

@RequestMapping("redisTest")

public class RedisTestCon {

@Autowired

private UserServiceI userService;

@RequestMapping("/addUser")

public void addUser(){

User user = new User();

user.setId(6);

user.setUsername("tom6");

user.setPassword("123456");

int a = userService.add(user);

System.out.println("添加用户测试：" + a);

}

@RequestMapping("/selUser")

@ResponseBody

public User selUser(){

User user = userService.selById(5);

System.out.println("第一次 ：" + user.getUsername());

User user2 = userService.selById(5);

System.out.println("第二次 ：" + user2.getUsername());

return user;

}

@RequestMapping("/sel")

@ResponseBody

public User sel(){

User user = userService.selById(4);

System.out.println("第一次 ：" + user.getUsername());

User user2 = userService.selById(4);

System.out.println("第二次 ：" + user2.getUsername());

return user;

}

/**

* 修改数据,

* @return

*/

@RequestMapping("/updUser")

@ResponseBody

public User updUser(){

User user = new User();

user.setId(5);

user.setUsername("tom5");

user.setPassword("alice");

int su = userService.updat(user);

System.out.println("su:" + su);

System.out.println("获取修改后的：" + user.getPassword());

User user2 = userService.selById(5);

System.out.println("获取修改后的查询 ：" + user2.getUsername());

return user;

}

}

在Ｃｏｎｔｒｏｌｌｅｒ　里面直接测试，注意看后台日志

关于后台日志的配置：ｌｏｇ４．ｐｒｏｐｅｒｔｉｅｓ：log4j.rootLogger=DEBUG, stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender

log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.stdout.layout.ConversionPattern=[service] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#log4j.appender.R=org.apache.log4j.DailyRollingFileAppender

#log4j.appender.R.File=../logs/service.log

#log4j.appender.R.layout=org.apache.log4j.PatternLayout

#log4j.appender.R.layout.ConversionPattern=[service] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#log4j.logger.com.ibatis = debug

#log4j.logger.com.ibatis.common.jdbc.SimpleDataSource = debug

#log4j.logger.com.ibatis.common.jdbc.ScriptRunner = debug

#log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate = debug

#log4j.logger.java.sql.Connection = debug

log4j.logger.java.sql.Statement = debug

log4j.logger.java.sql.PreparedStatement = debug

log4j.logger.java.sql.ResultSet =debug

如果看的不是太明白，推荐大家一个原文网址，里面有详细配置后台打印日志，个人觉得比较好，推荐给大家：

http://blog.csdn.net/win7system/article/details/52014413

日志配置好后，别忘记加入ｗｅｂ．ｘｍｌ文件里<?xml version="1.0" encoding="UTF-8"?>

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"

version="3.0">

Archetype Created Web Application

contextConfigLocation

classpath:spring-mybatis.xml,classpath:applicationContext.xml

encodingFilter

org.springframework.web.filter.CharacterEncodingFilter

true

encoding

UTF-8

encodingFilter

/*

log4jConfigLocation

classpath:log4.properties

org.springframework.web.util.Log4jConfigListener

org.springframework.web.context.ContextLoaderListener

org.springframework.web.util.IntrospectorCleanupListener

SpringMVC

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath:spring-mvc.xml

1

true

SpringMVC

/

/index.jsp

好了　启动一下项目看看。如有疑问欢迎询问，写的不好的地方，也请大家多多见谅，勿喷，我只是记录一下，怕自己以后忘记！能帮到最好，帮不到请忽略，谢谢