redisTemplate 操作

redisDao封裝類-其他dao內建他

package com.ffcs.wlan.dao.common;
import javax.annotation.Resource;
import org.springframework.data.redis.core.StringRedisTemplate;

/** 
 * AbstractBaseRedisDao
 * @author hugsh
 * @version <b>1.0</b> 
 */ 
public abstract class AbstractBaseRedisDao<K, V> {
	
	@Resource
	protected StringRedisTemplate redisTemplate;

	public void setRedisTemplate(StringRedisTemplate redisTemplate) {
		this.redisTemplate = redisTemplate;
	}
}
           

 批量插入（不關注傳回值）

@Repository
public  class RedisInitDao extends AbstractBaseRedisDao<String, Object> {
		
	Logger logger=Logger.getLogger(RedisInitDao.class);
	
		/**
		 * 批量向redis中插入H碼:key(tableName:hcode) value(pcode)
		 * 如果鍵已存在則傳回false,不更新,防止覆寫。使用pipeline批處理方式(不關注傳回值)
		 *	@param list  一個map代表一行記錄,2個key:hcode & pcode。
		 *	@param tableName redis中key的值為tableName:hcode  對應value值為pcode。
		 *	@return
		 */
		public boolean addHcode(final List<Map<String, Object>> list,final String tableName) {
			boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
				public Boolean doInRedis(RedisConnection connection)
						throws DataAccessException {
					RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
					for (Map<String, Object> map : list) {
						byte[] key  = serializer.serialize(tableName+":"+map.get("hcode").toString());
						byte[] name = serializer.serialize(map.get("pcode").toString());
						connection.setNX(key, name);
					}
					return true;
				}
			}, false, true);
			return result;
		}
	
           

批量擷取（有傳回值）

/**
	 * 從redis中擷取(擷取密碼日志) rPop從連結清單尾部彈出(最早的日志)
	 * 多線程并發讀取日志長度的時候，比如都得到結果是1000條。
	 * 當多線程每個都 循環1000次 pop彈出 日志的時候，
	 * 由于是多線程一起pop，是以每個線程獲得的數組中都會包含 null  甚至有的全是null
	 * @return
	 */
	public List<String> getLogFromRedis() {
		
		final RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
		//密碼日志的長度
		final Long pwdLogSize=redisTemplate.opsForList().size("getpwdList");
		
		List<Object> pwdLogList=redisTemplate.executePipelined(new RedisCallback<String>() {
			@Override
			public String doInRedis(RedisConnection conn)
					throws DataAccessException {
				for (int i=0 ;i<pwdLogSize ;i++) {
					byte[] listName  = serializer.serialize("getpwdList");
					conn.rPop(listName);
				}
				return null;
			}
		}, serializer);
		
		//	去除結果中的null
		ArrayList<String> newList=new ArrayList<String>();
		for (Object o : pwdLogList) {
			if(o!=null)
				newList.add(String.valueOf(o));
		}
		return newList;
	}
           

基礎資料類型工具類(opsForList)

/**
	 * 向redis中插入擷取密碼日志:leftPush 從連結清單頭部壓入
	 *	@param pwdLog 擷取密碼的日志
	 *	@return
	 */
	public void addLogIntoRedis(final String pwdLog) {
		log.info("insert getpwd log into redis:"+pwdLog);
		try {
			redisTemplate.opsForList().leftPush("getpwdList", pwdLog);
		} catch (Exception e) {
			log.error(e.getMessage());
		}
	}
           

配置檔案

<?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"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:aop="http://www.springframework.org/schema/aop"
	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">


	<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
		<property name="maxTotal" value="${redis.maxTotal}"></property>
		<property name="maxIdle" value="${redis.maxIdle}" /> 
		<property name="maxWaitMillis" value="${redis.maxWait}" />
		<property name="testOnBorrow" value="${redis.testOnBorrow}" />
	</bean>
	
	
	<bean id="connectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
		p:host-name="${redis.host}" p:port="${redis.port}" p:pool-config-ref="poolConfig"/>
	
	<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
		<property name="connectionFactory" 	ref="connectionFactory" />
	</bean>		
	
</beans>
           

<!-- 引入項目配置檔案 -->
 	<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
 		<property name="locations">
 			<list>
 				<value>classpath:redis.properties</value><!-- 引入redis配置檔案 -->
 				<value>classpath:jdbc.properties</value><!-- 定義spring-jdbc配置資訊路徑 -->
 			</list>
 		</property>
 	</bean>
	
	
	<!-- 自動掃描model,dao和service包(自動注入) -->
	<context:component-scan base-package="com.ffcs.wlan.model,com.ffcs.wlan.dao,com.ffcs.wlan.service" />
           

屬性檔案

# Redis settings

redis.host=192.168.11.100
redis.port=6379
#redis.pass=hugsh

redis.maxIdle=25
redis.maxTotal=250
#redis.maxActive=600 invalid in2.4
redis.maxWait=1000
redis.testOnBorrow=true