基于JavaEE的SSM框架集成Redis

xiaoxiao2021-02-28  9

基于JavaEE的SSM框架集成redis,我的项目架构是SpringMVC+Spring+Mybatis 用maven管理 ,下面看代码.

我的项目结构:(项目下载链接:https://pan.baidu.com/s/1dZCV0u4qDLg5mjZHqHerHg)

1. 在pom.xml文件引入redis依赖包

<!-- redis集成spring --> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>1.4.2.RELEASE</version> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.6.2</version> </dependency> <dependency>     <groupId>org.json</groupId> <artifactId>json</artifactId> <version>20150729</version> </dependency> <!-- https://mvnrepository.com/artifact/com.google.code.gson/gson --> <dependency> <groupId>com.google.code.gson</groupId>     <artifactId>gson</artifactId>     <version>2.2.4</version> </dependency> <dependency>     <groupId>org.codehaus.jackson</groupId>     <artifactId>jackson-core-asl</artifactId>      <version>1.9.2</version> </dependency> <dependency>     <groupId>org.codehaus.jackson</groupId>     <artifactId>jackson-mapper-asl</artifactId>     <version>1.8.5</version> </dependency> <dependency>     <groupId>org.json</groupId>     <artifactId>org.json</artifactId>     <version>chargebee-1.0</version> </dependency>

2.web.xml中引入Redis的配置文件

<!-- 配置Redis环境 --> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:applicationContext-redis.xml</param-value> </context-param>

3.redis配置文件applicationContext-redis.xml

<?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:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd" default-autowire="byName" > <context:property-placeholder location="classpath*:/redis.properties" ignore-unresolvable="true"/> <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> <bean id="connectionFactory" 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="poolConfig" ref="poolConfig" /> </bean> <bean id="stringSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/> <!-- 开启事务,可以通过transcational注解控制 --> <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"> <property name="connectionFactory" ref="connectionFactory" /> <property name="keySerializer" ref="stringSerializer" /> <property name="enableTransactionSupport" value="true" /> </bean> </beans>

4.redis.properties配置文件 

redis.host=redis地址 redis.pass=密码 redis.port=6379 redis.maxIdle=300 redis.maxActive=300 redis.maxTotal=600 redis.maxWait=1000 redis.testOnBorrow=true

5. Spring配置文件applicationContext.xml中引入Redis的配置文件

在项目启动的时候会加载applicationContext-redis.xml文件,但是redis.properties需要配置,如下

<bean id="config" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <list> <value>classpath:/redis.properties</value> </list> </property> </bean>

6. 创建RedisService工具类,方便调用

package com.base.redis; import java.io.UnsupportedEncodingException; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.JacksonJsonRedisSerializer; import org.springframework.stereotype.Service; import com.base.utils.StringUtils; @Service public class RedisService { private Logger LOG = LoggerFactory.getLogger(RedisService.class); @Autowired private List<RedisTemplate<String, String>> redisTemplateList; @Autowired private RedisTemplate<String, String> redisTemplate; /** * 从缓存中删除指定的key * @param keys */ public void del(final String... keys) { for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { redisTemplate.execute(new RedisCallback<Long>() { public Long doInRedis(RedisConnection connection) throws DataAccessException { long result = 0; for (int i = 0; i < keys.length; i++) { result = connection.del(keys[i].getBytes()); } return result; } }); } catch (Exception e) { e.printStackTrace(); } } } /** * 重缓存中删除指定的key 模式匹配,效率低 * @param keys */ public void delByReg(final String... keys) { for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { redisTemplate.execute(new RedisCallback<Long>() { public Long doInRedis(RedisConnection connection) throws DataAccessException { long result = 0; for (int i = 0; i < keys.length; i++) { Set<byte[]> keyset = connection.keys((keys[i] + "*").getBytes()); for (byte[] key : keyset) { result = connection.del(key); } } return result; } }); } catch (Exception e) { e.printStackTrace(); } } } /** * 判断一个键是否存在于缓存中 * @param key * @return */ public boolean exists(final String key) { Boolean result = false; for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { result = (Boolean) redisTemplate.execute(new RedisCallback<Object>() { public Boolean doInRedis(RedisConnection connection) throws DataAccessException { return connection.exists(key.getBytes()); } }); if (result) { break; } } catch (Exception e) { e.printStackTrace(); } } return result; } /** * 向缓存中插入数据 * @param key * @param value * @param liveTime */ public void set(final byte[] key, final byte[] value, final long liveTime) { for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { redisTemplate.execute(new RedisCallback<Object>() { public Long doInRedis(final RedisConnection connection) throws DataAccessException { connection.set(key, value); if (liveTime > 0) { connection.expire(key, liveTime); } return 1L; } }); } catch (Exception e) { e.printStackTrace(); } } } public <T> void set(String key, T value, long liveTime, Class<T> type) { if (value == null) return; try { JacksonJsonRedisSerializer<T> serializer = new JacksonJsonRedisSerializer<T>(type); byte[] _value = serializer.serialize(value); this.set(key.getBytes(), _value, liveTime); } catch (Exception e) { e.printStackTrace(); } } public void set(String key, String value, long liveTime) { try { this.set(key.getBytes(), value.getBytes("UTF-8"), liveTime); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } } public <T> List<T> lRange(final String key, final Long begin, final Long end, final Class<T> type) { return redisTemplate.execute(new RedisCallback<List<T>>() { public List<T> doInRedis(RedisConnection connection) throws DataAccessException { JacksonJsonRedisSerializer<T> serializer = new JacksonJsonRedisSerializer<T>(type); List<T> list = new ArrayList<T>(); for (byte[] element : connection.lRange(key.getBytes(), begin, end)) { T bean = serializer.deserialize(element); list.add(bean); } return list; } }); } /** * 从缓存中获取数据 * @param key * @return */ public String get(final String key) { String cacheValue = ""; for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { cacheValue = redisTemplate.execute(new RedisCallback<String>() { public String doInRedis(RedisConnection connection) throws DataAccessException { try { byte[] cacheBytes = connection.get(key.getBytes()); if (cacheBytes != null) { String cacheStr = new String(cacheBytes, "utf-8"); return cacheStr; } } catch (Exception e) { LOG.info(e.getMessage()); } return ""; } }); if (!StringUtils.isEmpty(cacheValue)) break; } catch (Exception e) { e.printStackTrace(); } } return cacheValue; } public <T> T get(final String key, final Class<T> clazz) { T t = null; for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { t = redisTemplate.execute(new RedisCallback<T>() { public T doInRedis(RedisConnection connection) throws DataAccessException { byte[] data = connection.get(key.getBytes()); if (data != null) return new JacksonJsonRedisSerializer<T>(clazz).deserialize(data); return null; } }); if (t != null) break; } return t; } public <T> Long rPush(final String key, final List<T> list, final Class<T> type, final long expire) { if (list == null) { return 0L; } return redisTemplate.execute(new RedisCallback<Long>() { public Long doInRedis(RedisConnection connection) throws DataAccessException { JacksonJsonRedisSerializer<T> serializer = new JacksonJsonRedisSerializer<T>(type); connection.multi(); for (T value : list) { connection.rPush(key.getBytes(), serializer.serialize(value)); } if (expire > 0) { connection.expire(key.getBytes(), expire); } connection.exec(); return new Long(list.size()); } }); } /** * 清空缓存 */ public void flushDB() { for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { redisTemplate.execute(new RedisCallback<String>() { public String doInRedis(RedisConnection connection) throws DataAccessException { connection.flushDb(); return "ok"; } }); } catch (Exception e) { e.printStackTrace(); } } } /** * 添加至有序集合 * @param key * @param score * @param value */ public void zadd(final byte[] key, final double score, final byte[] value) { for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { redisTemplate.execute(new RedisCallback<String>() { public String doInRedis(RedisConnection connection) throws DataAccessException { connection.zAdd(key, score, value); return "ok"; } }); } catch (Exception e) { e.printStackTrace(); } } } /** * 按条件获取有序集合元素子集 * @param key * 有序集合key * @param min * 范围最小值 * @param max * 范围最大值 * @param offset * 从第0ffset+1个元素起 * @param count * 返回上限 * @return */ public Set<byte[]> zRangeByScore(final byte[] key, final double min, final double max, final long offset, final long count) { Set<byte[]> set = null; for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { set = redisTemplate.execute(new RedisCallback<Set<byte[]>>() { public Set<byte[]> doInRedis(RedisConnection connection) throws DataAccessException { return connection.zRangeByScore(key, min, max, offset, count); } }); if (set != null) { break; } } catch (Exception e) { e.printStackTrace(); } } return set; } /** * 添加指定map至缓存 * @param key map唯一标识 * @param hashes */ @SuppressWarnings({ "unchecked", "rawtypes" }) public void hMSet(final byte[] key, final Map<byte[], byte[]> hashes) { for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { redisTemplate.execute(new RedisCallback() { public Object doInRedis(RedisConnection connection) throws DataAccessException { connection.hMSet(key, hashes); return null; } }); } catch (Exception e) { e.printStackTrace(); } } } /** * 获取指定map中指定键对应的值列表 * @param key map的唯一标识 * @param fields 键数组 * @return 值数组 */ public List<byte[]> hMGet(final byte[] key, final byte[]... fields) { List<byte[]> cacheValue = null; for (RedisTemplate<String, String> redisTemplate : redisTemplateList) { try { cacheValue = redisTemplate.execute(new RedisCallback<List<byte[]>>() { public List<byte[]> doInRedis(RedisConnection connection) throws DataAccessException { return connection.hMGet(key, fields); } }); if (cacheValue != null) { break; } } catch (Exception e) { e.printStackTrace(); } } return cacheValue; } // getters and setters public List<RedisTemplate<String, String>> getRedisTemplateList() { return redisTemplateList; } public void setRedisTemplateList(List<RedisTemplate<String, String>> redisTemplateList) { this.redisTemplateList = redisTemplateList; } } 接下来就是调用了,跟普通的service的使用方法是一样的。

转载请注明原文地址: https://www.6miu.com/read-2400104.html

最新回复(0)