windows 환경 에서 Redis+Spring 캐 시 인 스 턴 스 설명

16909 단어 RedisSpring캐 시
1.Redis 이해
1.1,Redis 소개:
redis 는 key-value 저장 시스템 입 니 다.Memcached 와 유사 합 니 다.저 장 된 value 형식 이 상대 적 으로 많 습 니 다.string(문자열),list(링크),set(집합),zset(sorted set C 질서 있 는 집합)과 hash(해시 형식)를 포함 합 니 다.이러한 데이터 형식 은 push/pop,add/remove 및 교차 집합 과 차 집합 및 더욱 풍부 한 조작 을 지원 하 며,이러한 조작 은 모두 원자 적 이다.이 를 바탕 으로 redis 는 다양한 방식 의 정렬 을 지원 합 니 다.memcached 와 마찬가지 로 효율 을 확보 하기 위해 데 이 터 는 모두 메모리 에 캐 시 되 어 있 습 니 다.다른 것 은 redis 가 주기 적 으로 업 데 이 트 된 데 이 터 를 디스크 에 기록 하거나 수정 작업 을 추가 기록 파일 에 기록 하 며 이 를 바탕 으로 master-slave(주종)동기 화 를 실현 하 는 것 이다.
Redis 데이터 베 이 스 는 완전히 메모리 에 있 습 니 다.디스크 를 사용 하면 지속 성에 만 사 용 됩 니 다.많은 키 데이터 저장 소 에 비해 Redis 는 비교적 풍부 한 데이터 형식 을 가지 고 있다.Redis 는 서버 에서 임의의 수량의 데 이 터 를 복사 할 수 있 습 니 다.
1.2、Redis 의 장점:
(1)매우 빠르다:Redis 의 속도 가 매우 빨 라 서 초당 약 11 만 집합 을 실행 할 수 있 고 초당 약 81000+개의 기록 을 실행 할 수 있다.
(2)풍부 한 데이터 형식 을 지원 합 니 다.Redis 는 대부분의 개발 자 들 이 목록,집합,질서 있 는 집합,해시 데이터 형식 을 알 고 있 습 니 다.이것 은 그것 으로 하여 금 여러 가지 문 제 를 쉽게 해결 하 게 한다.왜냐하면 우 리 는 어떤 문제 가 그것 을 통 해 데이터 형식 을 처리 하 는 것 이 더 좋 은 지 알 고 있 기 때문이다.
(3)작업 은 모두 원자 성 입 니 다.모든 Redis 작업 은 원자 입 니 다.이 는 두 클 라 이언 트 가 동시에 방문 하 는 Redis 서버 가 업 데 이 트 된 값 을 얻 을 수 있 도록 보장 합 니 다.
(4)다기 능 유 틸 리 티:Redis 는 여러 가지 유 틸 리 티 도구 입 니 다.예 를 들 어 캐 시,메시지,대기 열 에서 사용 할 수 있 습 니 다(Redis 원생 지원 게시/구독).짧 은 데이터,응용 프로그램,예 를 들 어 웹 응용 프로그램 세 션,웹 명중 계수 등 입 니 다.
1.3、Redis 단점:
(1)단일 스 레 드
(2)메모리 소모
2,64 비트 windows 에서 Redis 설치
Redis 공식 은 windows 를 지원 하지 않 지만 Microsoft Open Tech group 은 GitHub 에서 Win 64 버 전 을 개발 하여 다운로드 주소:https://github.com/MSOpenTech/redis/releases.64 분만 지원 하 세 요.
아기 비 둘 기 는 레 디 스 x64-3.0.500 msi 를 내 려 받 아 설치 했다.설치 과정 에서 모두 기본 값 을 사용 하면 됩 니 다.
설치 가 완료 되면 Redis 에 대응 하 는 서 비 스 를 열 어 주 었 을 수도 있 습 니 다.블 로 거 는 그렇습니다.자원 관 리 를 보면 다음 과 같 습 니 다.열 렸 음 을 설명 합 니 다.

대응 하 는 서 비 스 를 시 작 했 습 니 다.저 희 는 이 서 비 스 를 유지 하도록 하 겠 습 니 다.다음 예 를 들 어 사용 해 야 합 니 다.열 리 지 않 으 면 레 디 스 의 설치 디 렉 터 리 에 들 어가 라 고 명령 합 니 다(블 로 거들 은 C:\Program Files\레 디 스).그리고 다음 명령 으로 시작 합 니 다.
redis-server  redis.windows.conf

OK,다음은 실례 를 들 어 보 겠 습 니 다.
3.상세 사례
이 프로젝트 의 환경:Eclipse+maven+spring+junit
3.1,관련 의존(spring+junit+redis 의존),pom.xml 추가:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <groupId>com.luo</groupId>
 <artifactId>redis_project</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 
 <properties>
  <!-- spring    -->
  <spring.version>3.2.8.RELEASE</spring.version>
  <!-- junit    -->
  <junit.version>4.10</junit.version>
 </properties>
 
 <dependencies>
  <!--   Spring   -->
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-core</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-webmvc</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-context</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-context-support</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-aop</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-aspects</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-tx</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-jdbc</artifactId>
   <version>${spring.version}</version>
  </dependency>
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-web</artifactId>
   <version>${spring.version}</version>
  </dependency>
 
  <!--       -->
  <dependency>
   <groupId>junit</groupId>
   <artifactId>junit</artifactId>
   <version>${junit.version}</version>
   <scope>test</scope>
  </dependency>
 
  <!--spring       -->
  <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-test</artifactId>
   <version>${spring.version}</version>
   <scope>test</scope>
  </dependency>
 
  <!-- Redis      -->
  <dependency>
   <groupId>org.springframework.data</groupId>
   <artifactId>spring-data-redis</artifactId>
   <version>1.6.1.RELEASE</version>
  </dependency>
  <dependency>
   <groupId>redis.clients</groupId>
   <artifactId>jedis</artifactId>
   <version>2.7.3</version>
  </dependency>
 
 </dependencies>
</project>
3.2,spring 프로필 application.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:aop="http://www.springframework.org/schema/aop"
 xsi:schemaLocation=" 
 
http://www.springframework.org/schema/beans
 
 
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
 
 
http://www.springframework.org/schema/aop
 
 
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
 
 
http://www.springframework.org/schema/context
 
 
http://www.springframework.org/schema/context/spring-context-3.0.xsd">
 
 <!--        bean -->
 <context:component-scan base-package="com.luo.service" />
 
 <!--   properties     --> 
 <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  <property name="locations">
   <list>
    <value>classpath:properties/*.properties</value>
    <!--         ,            -->
   </list>
  </property>
 </bean>
 
 <!-- jedis    -->
 <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig" >
   <property name="maxIdle" value="${redis.maxIdle}" />
   <property name="maxWaitMillis" value="${redis.maxWait}" />
   <property name="testOnBorrow" value="${redis.testOnBorrow}" />
 </bean >
 
 <!-- redis      -->
 <bean id="connectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" >
   <property name="poolConfig" ref="poolConfig" />
   <property name="port" value="${redis.port}" />
   <property name="hostName" value="${redis.host}" />
   <!-- <property name="password" value="${redis.password}" /> -->
   <property name="timeout" value="${redis.timeout}" ></property>
 </bean >
 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" >
   <property name="connectionFactory" ref="connectionFactory" />
   <property name="keySerializer" >
    <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
   </property>
   <property name="valueSerializer" >
    <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
   </property>
 </bean >
 
 <!-- cache   -->
 <bean id="methodCacheInterceptor" class="com.luo.redis.cache.MethodCacheInterceptor" >
   <property name="redisTemplate" ref="redisTemplate" />
 </bean >
 
 <!-- aop        -->
 <bean id="methodCachePointCut" class="org.springframework.aop.support.RegexpMethodPointcutAdvisor">
  <property name="advice" ref="methodCacheInterceptor"/>
  <property name="pattern" value=".*ServiceImpl.*getTimestamp"/>
 </bean>
 <bean id="redisTestService" class="com.luo.service.impl.RedisTestServiceImpl">
 </bean>
 <bean class="org.springframework.aop.framework.autoproxy.DefaultAdvisorAutoProxyCreator"/>
 
</beans>
3.3,Redis 설정 매개 변수,redis.properties:

#redis  
#       
redis.host=127.0.0.1
#  Redis    ,     6379
redis.port=6379
#    (       )
redis.password=123456 
#     :       maxIdle ,     
redis.maxIdle=100 
#     :       “      ”
redis.maxActive=300 
#      :  ms
redis.maxWait=1000 
#     ,         
redis.testOnBorrow=true
#               ,     0,       
redis.timeout=10000
3.4,인터페이스 추가 및 대응 실현 RedisTestService.Java 와 RedisTestServiceImpl.java:

package com.luo.service;
 
public interface RedisTestService {
 public String getTimestamp(String param);
}

package com.luo.service.impl;
 
import org.springframework.stereotype.Service;
import com.luo.service.RedisTestService;
 
@Service
public class RedisTestServiceImpl implements RedisTestService {
 
 public String getTimestamp(String param) {
  Long timestamp = System.currentTimeMillis();
  return timestamp.toString();
 }
 
}
3.5.이 예 는 spring aop 절단면 방식 으로 캐 시 를 하고 위 spring 설정 파일 에 설정 되 어 있 으 며 MethodCache Interceptor.자바 로 대응 합 니 다.

package com.luo.redis.cache;
 
import java.io.Serializable;
import java.util.concurrent.TimeUnit;
import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
 
public class MethodCacheInterceptor implements MethodInterceptor {
 
 private RedisTemplate<Serializable, Object> redisTemplate;
 private Long defaultCacheExpireTime = 10l; //          ,     10 
 
 public Object invoke(MethodInvocation invocation) throws Throwable {
  Object value = null;
 
  String targetName = invocation.getThis().getClass().getName();
  String methodName = invocation.getMethod().getName();
 
  Object[] arguments = invocation.getArguments();
  String key = getCacheKey(targetName, methodName, arguments);
 
  try {
   //        
   if (exists(key)) {
    return getCache(key);
   }
   //     
   value = invocation.proceed();
   if (value != null) {
    final String tkey = key;
    final Object tvalue = value;
    new Thread(new Runnable() {
     public void run() {
      setCache(tkey, tvalue, defaultCacheExpireTime);
     }
    }).start();
   }
  } catch (Exception e) {
   e.printStackTrace();
   if (value == null) {
    return invocation.proceed();
   }
  }
  return value;
 }
 
 /**
  *     key
  *
  * @param targetName
  * @param methodName
  * @param arguments
  */
 private String getCacheKey(String targetName, String methodName,
   Object[] arguments) {
  StringBuffer sbu = new StringBuffer();
  sbu.append(targetName).append("_").append(methodName);
  if ((arguments != null) && (arguments.length != 0)) {
   for (int i = 0; i < arguments.length; i++) {
    sbu.append("_").append(arguments[i]);
   }
  }
  return sbu.toString();
 }
 
 /**
  *            value
  * 
  * @param key
  * @return
  */
 public boolean exists(final String key) {
  return redisTemplate.hasKey(key);
 }
 
 /**
  *     
  * 
  * @param key
  * @return
  */
 public Object getCache(final String key) {
  Object result = null;
  ValueOperations<Serializable, Object> operations = redisTemplate
    .opsForValue();
  result = operations.get(key);
  return result;
 }
 
 /**
  *     
  * 
  * @param key
  * @param value
  * @return
  */
 public boolean setCache(final String key, Object value, Long expireTime) {
  boolean result = false;
  try {
   ValueOperations<Serializable, Object> operations = redisTemplate
     .opsForValue();
   operations.set(key, value);
   redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);
   result = true;
  } catch (Exception e) {
   e.printStackTrace();
  }
  return result;
 }
 
 public void setRedisTemplate(
   RedisTemplate<Serializable, Object> redisTemplate) {
  this.redisTemplate = redisTemplate;
 }
}
3.6.유닛 테스트 관련 유형:

package com.luo.baseTest;
 
import org.junit.runner.RunWith; 
import org.springframework.test.context.ContextConfiguration; 
import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests; 
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; 
 
//  bean        
@ContextConfiguration(locations = { "classpath:application.xml" }) 
//     JUnit @RunWith     JUnit  Spring TestRunner 
@RunWith(SpringJUnit4ClassRunner.class) 
public class SpringTestCase extends AbstractJUnit4SpringContextTests {
 
}

package com.luo.service;
 
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
 
import com.luo.baseTest.SpringTestCase;
 
public class RedisTestServiceTest extends SpringTestCase {
 
 @Autowired 
 private RedisTestService redisTestService;
 
 @Test 
 public void getTimestampTest() throws InterruptedException{ 
  System.out.println("     :" + redisTestService.getTimestamp("param"));
  Thread.sleep(2000);
  System.out.println("2     :" + redisTestService.getTimestamp("param"));
  Thread.sleep(11000);
  System.out.println("  11     :" + redisTestService.getTimestamp("param"));
 } 
}
3.7.실행 결과:

4.소스 코드 다운로드:redis-project(jb51.net).rar
이상 은 본문의 전체 내용 이 므 로 여러분 의 학습 에 도움 이 되 기 를 바 랍 니 다.

좋은 웹페이지 즐겨찾기