지역 사회 배우다 도구 라이브러리 여가
찾다
한국어
집 > Java > java지도 시간 > Java에서 Redis와 SSM 통합에 대한 자세한 설명

Java에서 Redis와 SSM 통합에 대한 자세한 설명

黄舟
풀어 주다： 2017-09-30 10:31:55
원래의
3541명이 탐색했습니다.

Java에서 Redis와 SSM 통합에 대한 자세한 설명

Redis 설치 및 사용

첫 번째 단계는 물론 Redis를 설치하는 것입니다. 여기서는 Windows에 설치하는 경우를 예로 들어보겠습니다.

  • 먼저 Redis를 다운로드하면 msi 또는 zip 패키지 설치 방법을 선택할 수 있습니다.

  • zip 방법은 cmd 창을 열고 압축이 풀린 디렉터리에서 redis-server redis.windows.conf를 실행해야 합니다. Redis를 시작하려면redis-server redis.windows.conf启动Redis

  • 采用msi方式安装后Redis默认启动，不需要进行任何配置

  • 可以在redis.windows.conf文件中修改Redis端口号、密码等配置，修改完成后使用redis-server redis.windows.conf命令重新启动

  • 在Redis安装目录下执行redis-cli -h 127.0.0.1 -p 6379 -a 密码打开Redis操作界面

  • 如果报错(error) ERR operation not permitted，使用auth 密码进行验证

SSM整合Redis

这里直接在上一篇SSM之框架整合的基础上进行Redis整合，这里需要注意，存入Redis的pojo类必须实现Serializable接口。

配置pom.xml引入Redis依赖


<!--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>
로그인 후 복사

redis.properties

redis.host=127.0.0.1
redis.port=6379
redis.password=redis
redis.maxIdle=100
redis.maxWait=1000
redis.testOnBorrow=true
redis.timeout=100000
defaultCacheExpireTime=3600
로그인 후 복사

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:mvc="http://www.springframework.org/schema/mvc"       
xmlns:context="http://www.springframework.org/schema/context"       
xmlns:aop="http://www.springframework.org/schema/aop"       
xmlns:tx="http://www.springframework.org/schema/tx"       
xsi:schemaLocation="http://www.springframework.org/schema/beans        
http://www.springframework.org/schema/beans/spring-beans.xsd        
http://www.springframework.org/schema/mvc        
http://www.springframework.org/schema/mvc/spring-mvc.xsd        
http://www.springframework.org/schema/context        
http://www.springframework.org/schema/context/spring-context.xsd        
http://www.springframework.org/schema/aop        
http://www.springframework.org/schema/aop/spring-aop.xsd        
http://www.springframework.org/schema/tx        
http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!--引入Redis配置文件-->
    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <list>
                <value>classpath:redis.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>
    <!-- 缓存拦截器配置 -->
    <bean id="methodCacheInterceptor" class="com.zkh.interceptor.MethodCacheInterceptor">
        <property name="redisUtil" ref="redisUtil"/>
        <property name="defaultCacheExpireTime" value="${defaultCacheExpireTime}"/>
        <!-- 禁用缓存的类名列表 -->
        <property name="targetNamesList">
            <list>
                <value></value>
            </list>
        </property>
        <!-- 禁用缓存的方法名列表 -->
        <property name="methodNamesList">
            <list>
                <value></value>
            </list>
        </property>
    </bean>
    <bean id="redisUtil" class="com.zkh.util.RedisUtil">
        <property name="redisTemplate" ref="redisTemplate"/>
    </bean>
    <!--配置切面拦截方法 -->
    <aop:config proxy-target-class="true">
        <aop:pointcut id="controllerMethodPointcut" expression="        
        execution(* com.zkh.service.impl.*.select*(..))"/>
        <aop:advisor advice-ref="methodCacheInterceptor" pointcut-ref="controllerMethodPointcut"/>
    </aop:config></beans>
로그인 후 복사

MethodCacheInterceptor.java


package com.zkh.interceptor;
import com.zkh.util.RedisUtil;
import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import java.util.List;
/** 
* Redis缓存过滤器 
*/
public class MethodCacheInterceptor implements MethodInterceptor {    
private RedisUtil redisUtil;    
private List<String> targetNamesList; // 禁用缓存的类名列表
    private List<String> methodNamesList; // 禁用缓存的方法列表
    private String defaultCacheExpireTime; // 缓存默认的过期时间

    @Override
    public Object invoke(MethodInvocation invocation) throws Throwable {
        Object value = null;

        String targetName = invocation.getThis().getClass().getName();
        String methodName = invocation.getMethod().getName();        
        if (!isAddCache(targetName, methodName)) {            
        // 跳过缓存返回结果
            return invocation.proceed();
        }
        Object[] arguments = invocation.getArguments();
        String key = getCacheKey(targetName, methodName, arguments);        
        try {            // 判断是否有缓存
            if (redisUtil.exists(key)) {                
            return redisUtil.get(key);
            }            // 写入缓存
            value = invocation.proceed();            
            if (value != null) {                
            final String tkey = key;                
            final Object tvalue = value;                
            new Thread(new Runnable() {                    
            @Override
                    public void run() {
                        redisUtil.set(tkey, tvalue, Long.parseLong(defaultCacheExpireTime));
                    }
                }).start();
            }
        } catch (Exception e) {
            e.printStackTrace();            
            if (value == null) {                
            return invocation.proceed();
            }
        }        return value;
    }    
    /**     
    * 是否加入缓存     
    *     
    * @return     
    */
    private boolean isAddCache(String targetName, String methodName) {        
    boolean flag = true;        
    if (targetNamesList.contains(targetName)
                || methodNamesList.contains(methodName) || targetName.contains("$$EnhancerBySpringCGLIB$$")) {
            flag = false;
        }        return flag;
    }    
    /**     
    
    * 创建缓存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();
    }    public void setRedisUtil(RedisUtil redisUtil) {        
    this.redisUtil = redisUtil;
    }    public void setTargetNamesList(List<String> targetNamesList) {        
    this.targetNamesList = targetNamesList;
    }    public void setMethodNamesList(List<String> methodNamesList) {        
    this.methodNamesList = methodNamesList;
    }    public void setDefaultCacheExpireTime(String defaultCacheExpireTime) {        
    
    this.defaultCacheExpireTime = defaultCacheExpireTime;
    }
}
로그인 후 복사

RedisUtil.java 工具类

package com.zkh.util;import org.apache.log4j.Logger;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.ValueOperations;import java.io.Serializable;import java.util.Set;import java.util.concurrent.TimeUnit;/** * Redis工具类 */public class RedisUtil {    private RedisTemplate<Serializable, Object> redisTemplate;    /**     * 批量删除对应的value     *     * @param keys     */
    public void remove(final String... keys) {        for (String key : keys) {            remove(key);
        }
    }    /**     * 批量删除key     *     * @param pattern     */
    public void removePattern(final String pattern) {
        Set<Serializable> keys = redisTemplate.keys(pattern);        if (keys.size() > 0)
            redisTemplate.delete(keys);
    }    /**     * 删除对应的value     *     * @param key     */
    public void remove(final String key) {        if (exists(key)) {
            redisTemplate.delete(key);
        }
    }    /**     * 判断缓存中是否有对应的value     *     * @param key     * @return     */
    public boolean exists(final String key) {        return redisTemplate.hasKey(key);
    }    /**     * 读取缓存     *     * @param key     * @return     */
    public Object get(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 set(final String key, Object value) {        boolean result = false;        try {
            ValueOperations<Serializable, Object> operations = redisTemplate
                    .opsForValue();
            operations.set(key, value);
            result = true;
        } catch (Exception e) {
            e.printStackTrace();
        }        return result;
    }    /**     * 写入缓存     *     * @param key     * @param value     * @return     */
    public boolean set(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;
    }
}
로그인 후 복사


效果展示

Java에서 Redis와 SSM 통합에 대한 자세한 설명

刚开始Redis中没有任何记录，接下来访问一下第一页记录

Java에서 Redis와 SSM 통합에 대한 자세한 설명

再查看缓存，记录已经存如Redis，并且第一次访问会从Mysql中读取数据

Java에서 Redis와 SSM 통합에 대한 자세한 설명

Java에서 Redis와 SSM 통합에 대한 자세한 설명

按F5

Java에서 Redis와 SSM 통합에 대한 자세한 설명msi를 사용하여 설치한 후 Redis는 기본적으로 시작되며 구성이 필요하지 않습니다

Java에서 Redis와 SSM 통합에 대한 자세한 설명

이후 🎜redis.windows.conf🎜 파일에서 Redis 포트 번호, 비밀번호 및 기타 구성을 수정할 수 있습니다. 수정이 완료되면 redis-server redis.windows.conf 명령을 사용하여 Redis 설치 디렉터리에서 🎜🎜🎜🎜Execute를 다시 시작하세요. redis-cli -h 127.0.0.1 -p 6379 -a Redis 작업 인터페이스를 열려면 비밀번호를 사용하세요. 🎜🎜🎜🎜(오류) ERR 작업이 허용되지 않습니다 오류가 보고되면 인증 비밀번호를 사용하여 확인하세요🎜🎜🎜🎜SSM은 Redis를 통합합니다🎜🎜🎜여기서 직접 Redis 통합은 이전 글의 SSM 프레임워크 통합을 기반으로 수행됩니다. 🎜 여기서 주목해야 할 점은 Redis에 저장된 pojo 클래스는 Serialized를 구현해야 한다는 것입니다. 인터페이스 🎜. 🎜

🎜Redis 종속성을 도입하도록 pom.xml을 구성하세요🎜


🎜rrreee

🎜redis.properties🎜

rrreee

🎜applicationContext - redis.xml🎜


🎜rrreee

🎜MethodCacheInterceptor.java🎜


🎜rrreee🎜RedisUtil.java 도구 클래스🎜rrreee


🎜효과 표시🎜

🎜Java에서 Redis와 SSM 통합에 대한 자세한 설명🎜🎜처음에는 Redis에 레코드가 없습니다. 다음으로 레코드의 첫 번째 페이지를 방문하세요🎜🎜Java에서 Redis와 SSM 통합에 대한 자세한 설명🎜🎜캐시를 다시 확인하세요. 레코드는 Redis에 저장되었으며, 처음에는 Mysql에서 데이터를 읽습니다. 방문🎜🎜Java에서 Redis와 SSM 통합에 대한 자세한 설명🎜🎜Java에서 Redis와 SSM 통합에 대한 자세한 설명🎜🎜페이지를 새로 고치려면 F5를 누르세요. Tomcat 콘솔에서 SQL 쿼리가 없음을 확인할 수 있습니다. 수행되지만 Redis에서 직접 읽혀집니다. 데이터를 캐싱하면 데이터베이스 부담이 줄어듭니다🎜🎜🎜🎜🎜🎜🎜

위 내용은 Java에서 Redis와 SSM 통합에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨：
java redis 상해
원천：php.cn
이전 기사：Java가 리플렉션을 사용하여 지정된 주석을 사용하여 클래스를 찾는 방법에 대한 자세한 설명 다음 기사：Java 동시성에서 스레드의 사용 및 기본 개념
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
최신 이슈
Symfony Redis는 env 파일에 정의된 호스트(기본값은 localhost)에 연결할 수 없습니다. 캐싱 메커니즘으로 Redis를 사용하는 새로운 Symfony 설정이 있습니다. 기본 로컬 호스트가 아닌 특정 호스트에 연결하려고 합니다. 프로덕션에서는 ./bin...
에서 2024-04-06 10:53:02
0
1
375
관련 주제
더>
인기 추천
인기 튜토리얼
더>
관련 튜토리얼
인기 추천
최신 강좌
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿