Springboot整合AOP和redis的示例詳解

更新時間：2024年11月05日 11:24:46 作者：小熊哦嗚

本文主要介紹了Springboot整合AOP和Redis的詳細(xì)過程,包括AOP的依賴引入和默認(rèn)配置屬性,日志切面格式以及Redis的自動配置和連接池使用,總結(jié)了在多線程環(huán)境下,選擇合適的連接方式和客戶端是非常重要,感興趣的朋友一起看看吧

aop

pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

開啟自動代理

注意：在完成了引入AOP依賴包后，一般來說并不需要去做其他配置。使用過Spring注解配置方式的人會問是否需要在程序主類中增加@EnableAspectJAutoProxy來啟用，實(shí)際并不需要。

因?yàn)樵贏OP的默認(rèn)配置屬性中，spring.aop.auto屬性默認(rèn)是開啟的，也就是說只要引入了AOP依賴后，默認(rèn)已經(jīng)增加了@EnableAspectJAutoProxy。

日志切面

@Component
@Aspect
@Slf4j
public class WebLogAspect {
    @Pointcut("(execution(public * com.zking.ssm.web..*.*(..))) || (execution(public * com.zking.ssm.controller..*.*(..)))")
    public void pointcut(){
?
    }
    @Before("pointcut()")
    public void before(JoinPoint joinPoint){
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        if(attributes!=null){
            HttpServletRequest request = attributes.getRequest();
            log.info("請求地址URL:"+request.getRequestURL().toString());
            log.info("請求方式HTTP_METHOD:"+request.getMethod());
            log.info("客戶端地址IP:"+request.getRemoteAddr());
            log.info("訪問方法CLASS_METHOD:"+joinPoint.getSignature().getDeclaringTypeName());
            log.info("訪問方法中的參數(shù)ARGS:"+ Arrays.toString(joinPoint.getArgs()));
        }
    }
}

格式：

execution(modifiers-pattern? ret-type-pattern declaring-type-pattern? name-pattern(param-pattern)throws-pattern?)
修飾符匹配（modifier-pattern?）
返回值匹配（ret-type-pattern）可以為*表示任何返回值,全路徑的類名等
類路徑匹配（declaring-type-pattern?）
方法名匹配（name-pattern）可以指定方法名或者代表所有, set 代表以set開頭的所有方法
參數(shù)匹配（(param-pattern)）可以指定具體的參數(shù)類型，多個參數(shù)間用“,”隔開，各個參數(shù)也可以用“”來表示匹配任意類型的參數(shù)，如(String)表示匹配一個String參數(shù)的方法；(,String) 表示匹配有兩個參數(shù)的方法，第一個參數(shù)可以是任意類型，而第二個參數(shù)是String類型；可以用(..)表示零個或多個任意參數(shù)
異常類型匹配（throws-pattern?）
其中后面跟著“?”的是可選項(xiàng)

druid數(shù)據(jù)庫連接池

參考springboot03-mybatis.md

redis springboot整合redis pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--lettuce依賴commons-pool2-->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
    <version>2.8.0</version>
</dependency>

yaml

 spring:
     redis:
        host: 127.0.0.1
        port: 6379
        password:
        lettuce:
          pool:
            max-active: 8 #連接池最大連接數(shù)(使用負(fù)值表示沒有限制)默認(rèn)為8
            max-wait: -1ms #連接池最大阻塞等待時間(使用負(fù)值表示沒有限制)默認(rèn)為-1
            max-idle: 8 #連接池中的最大空閑連接 默認(rèn)為8
            min-idle: 5 # 連接池中的最小空閑連接 默認(rèn)為0

自動配置，參考：org.springframework.boot.autoconfigure.data.redis.RedisProperties

RedisConfig

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        // 配置redisTemplate
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        RedisSerializer stringSerializer = new StringRedisSerializer();
        redisTemplate.setKeySerializer(stringSerializer); // key序列化
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // value序列化
        redisTemplate.setHashKeySerializer(stringSerializer); // Hash key序列化
        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); // Hash value序列化
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
?
}

RedisService

public interface RedisService {
    void setObj(String key, Object obj, long timeout);
    void setObj(String key, Object obj);
    Object getObj(String key);
}
@Service("redisService")
public class RedisServiceImpl implements RedisService {
    @Resource
    private RedisTemplate redisTemplate;
    @Override
    public void setObj(final String key, Object obj, long timeout) {
        ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
        operations.set(key, obj, timeout, TimeUnit.SECONDS);
    }
?
    @Override
    public void setObj(String key, Object obj) {
        setObj(key,obj,60*60*15);
    }
?
    @Override
    public Object getObj(final String key) {
        Object o = redisTemplate.opsForValue().get(key);
        return o;
    }
?
}

使用

@Service
public class CustomerServiceImpl implements CustomerService {
    @Autowired
    private CustomerMapper customerMapper;
    @Autowired
    private RedisService redisService;
       @Override
    public Customer selectByPrimaryKey(Integer id) {
        Customer customer = (Customer)redisService.getObj("springboot:ssm:customer:"+id);
        if(customer==null){
            customer = customerMapper.selectByPrimaryKey(id);
            redisService.setObj("springboot:ssm:customer:"+id,customer);
        }
        return customer;
    }
}

客戶端工具

在后面 springboot 整合 redis 的時候會用到連接池，所以這里先來介紹下 Redis中的連接池:

客戶端連接 Redis 使用的是 TCP協(xié)議，直連的方式每次需要建立 TCP連接，而連接池的方式是可以預(yù)先初始化好客戶端連接，所以每次只需要從連接池借用即可，而借用和歸還操作是在本地進(jìn)行的，只有少量的并發(fā)同步開銷，遠(yuǎn)遠(yuǎn)小于新建TCP連接的開銷。另外，直連的方式無法限制 redis客戶端對象的個數(shù)，在極端情況下可能會造成連接泄漏，而連接池的形式可以有效的保護(hù)和控制資源的使用

下面以Jedis客戶端為例，再來總結(jié)下客戶端直連方式和連接池方式的對比

	優(yōu)點(diǎn)	缺點(diǎn)
直連	簡單方便，適用于少量長期連接的場景	1. 存在每次新建/關(guān)閉TCP連接開銷 2. 資源無法控制，極端情況下出現(xiàn)連接泄漏 3. Jedis對象線程不安全(Lettuce對象是線程安全的)
連接池	1. 無需每次連接生成Jedis對象，降低開銷 2. 使用連接池的形式保護(hù)和控制資源的使用	相對于直連，使用更加麻煩，尤其在資源的管理上需要很多參數(shù)來保證，一旦規(guī)劃不合理也會出現(xiàn)問題

Jedis vs Lettuce

Jedis 和 Lettuce 是 Java 操作 Redis 的客戶端。在 Spring Boot 1.x 版本默認(rèn)使用的是 jedis ，而在 Spring Boot 2.x 版本默認(rèn)使用的就是Lettuce。關(guān)于 Jedis 跟 Lettuce 的區(qū)別如下：

Jedis在實(shí)現(xiàn)上是直接連接的redis server，如果在多線程環(huán)境下是非線程安全的，這個時候只有使用連接池，為每個Jedis實(shí)例增加物理連接 Lettuce的連接是基于Netty的，連接實(shí)例（StatefulRedisConnection）可以在多個線程間并發(fā)訪問，應(yīng)為StatefulRedisConnection是線程安全的，所以一個連接實(shí)例（StatefulRedisConnection）就可以滿足多線程環(huán)境下的并發(fā)訪問，當(dāng)然這個也是可伸縮的設(shè)計(jì)，一個連接實(shí)例不夠的情況也可以按需增加連接實(shí)例。

Lettuce

同4.1

jedis pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
    <exclusions>
        <exclusion>
            <groupId>io.lettuce</groupId>
            <artifactId>lettuce-core</artifactId>
        </exclusion>
    </exclusions>
</dependency>
?
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
</dependency>

yml

spring:
     redis:
        host: 127.0.0.1
        port: 6379
        password:
        jedis:
          pool:
            max-active: 8 #連接池最大連接數(shù)(使用負(fù)值表示沒有限制)默認(rèn)為8
            max-wait: -1ms #連接池最大阻塞等待時間(使用負(fù)值表示沒有限制)默認(rèn)為-1
            max-idle: 8 #連接池中的最大空閑連接 默認(rèn)為8
            min-idle: 5 # 連接池中的最小空閑連接 默認(rèn)為0

到此這篇關(guān)于Springboot整合AOP和redis的文章就介紹到這了,更多相關(guān)Springboot整合AOP和redis內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: