如何将SSM项目加入redis支持?针对这个问题,今天小编总结了这篇文章,希望能帮助更多想解决这个问题的朋友找到更加简单易行的办法。
创新互联公司2013年成立,是专业互联网技术服务公司,拥有项目成都网站建设、成都网站制作网站策划,项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命,1280元公主岭做网站,已为上家服务,为公主岭各地企业和个人服务,联系电话:13518219792
需要先搭好SSM开发环境,并安装好Redis,下面是具体的实现步骤:
1、在项目中引入jedis架包:jedis-2.8.2.jar、spring-data-redis-1.6.2.RELEASE.jar和commons-pool-1.6.jar,注意引入的jar版本,过高或过低都有可能引发异常,上面提到这些版本组合亲测可用;
2、编写Redis需要用的2个工具类 RedisUtil.java和SerializeUtil.java
3、新增一个Cache类MybatisRedisCache,实现 org.apache.ibatis.cache.Cache 接口
4、开启mybatis对缓存的支持,在本项目中,是修改 mybatis-config.xml文件
5、在相关的 mapper.xml 添加自定义的缓存类MybatisRedisCache
RedisUtil工具类是用以跟Redis数据通信,SerializeUtil为序列化工具类,也是lang包下的工具,主要用于序列化操作,同时提供对象克隆接口。下面是具体代码:
import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class RedisUtil { private static String ADDR = "127.0.0.1"; private static int PORT = 6379; private static int MAX_ACTIVE = 1024; private static int MAX_IDLE = 200; private static int MAX_WAIT = 100000; private static int TIMEOUT = 10000; private static boolean TEST_ON_BORROW = true; private static JedisPool jedisPool = null; static { try{ JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT); config.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT); }catch (Exception e) { e.printStackTrace(); } } public synchronized static Jedis getJedis(){ try{ if(jedisPool != null){ Jedis jedis = jedisPool.getResource(); return jedis; }else{ return null; } }catch (Exception e) { e.printStackTrace(); return null; } } public static void returnResource(final Jedis jedis){ if(jedis != null){ jedisPool.returnResource(jedis); } } }
import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; public class SerializeUtil { public static byte[] serialize(Object object) { ObjectOutputStream oos = null; ByteArrayOutputStream baos = null; try { // 序列化 baos = new ByteArrayOutputStream(); oos = new ObjectOutputStream(baos); oos.writeObject(object); byte[] bytes = baos.toByteArray(); return bytes; } catch (Exception e) { e.printStackTrace(); } return null; } public static Object unserialize(byte[] bytes) { if (bytes == null) return null; ByteArrayInputStream bais = null; try { // 反序列化 bais = new ByteArrayInputStream(bytes); ObjectInputStream ois = new ObjectInputStream(bais); return ois.readObject(); } catch (Exception e) { e.printStackTrace(); } return null; } } import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.apache.ibatis.cache.Cache; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class MybatisRedisCache implements Cache { private static Logger logger = LoggerFactory.getLogger(MybatisRedisCache.class); /** The ReadWriteLock. */ private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock(); private String id; public MybatisRedisCache(final String id) { if (id == null) { throw new IllegalArgumentException("Cache instances require an ID"); } logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>MybatisRedisCache:id="+id); this.id = id; } public String getId() { return this.id; } public void putObject(Object key, Object value) { logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>putObject:"+key+"="+value); RedisUtil.getJedis().set(SerializeUtil.serialize(key.toString()), SerializeUtil.serialize(value)); } public Object getObject(Object key) { Object value = SerializeUtil.unserialize(RedisUtil.getJedis().get(SerializeUtil.serialize(key.toString()))); logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>getObject:"+key+"="+value); return value; } public Object removeObject(Object key) { return RedisUtil.getJedis().expire(SerializeUtil.serialize(key.toString()),0); } public void clear() { RedisUtil.getJedis().flushDB(); } public int getSize() { return Integer.valueOf(RedisUtil.getJedis().dbSize().toString()); } public ReadWriteLock getReadWriteLock() { return readWriteLock; } }
mybatis-config.xml文件,在spring-mybatis.xml文件中选择全局加载:
以下是mybatis-config.xml详细代码:
最后在需要缓存的映射文件mapper.xml的namespace加上引用的
服务器端,在Redis安装目录下找到redis-cli,双击打开,输入keys *回车,将会看到生成的key,Redis就是根据key去获取所需的value。 在实际操作的过程中要注意RedisUtil工具类,需要根据自己的情况设置port、ADDR 、如果安装的Redis设置有密码,还需加上AUTH,如果没有设置密码,这项不要添加在工具类中,哪怕赋空值也不行,
曾经试过这样: private static String AUTH = " ";
结果运行的时候报了这个异常: jedis.exceptions.JedisDataException: ERR Client sent AUTH, but no password is set
意思就是redis服务器没有设置密码,但客户端向其发送了AUTH请求。 此外,要缓存的类需要implements Serializable。 如果怀疑你安装的Redis有问题,可通过下面的方法进行测试:
@Test public void testRedis(){ //连接本地的 Redis 服务 Jedis jedis = new Jedis("localhost"); System.out.println("连接成功"); //查看服务是否运行 System.out.println("服务正在运行: "+jedis.ping()); //设置 redis 字符串数据 jedis.set("success", "oobom"); // 获取存储的数据并输出 System.out.println("redis 存储的字符串为: "+ jedis.get("success")); }上述就是小编为大家分享的将SSM项目加入Redis支持的方法了,如果您也有类似的疑惑,不妨参照上述方法进行尝试。如果想了解更多相关内容,请关注创新互联行业资讯。
新闻名称:如何将SSM项目加入Redis支持
文章地址:http://njwzjz.com/article/gpeshs.html