springboot 手动加载redis 配置文件

1
2
3
4
5
6
<!--工具类-->
		<dependency>
			<groupId>com.xiaoleilu</groupId>
			<artifactId>hutool-all</artifactId>
			<version>3.3.0</version>
		</dependency>

1
com.xiaoleilu.hutool.db.nosql.redis.RedisDS 加载的, 但是本项目是一个中小型项目,不想引入太多工具类型的jar包,所有本地采用自己编写的方法解析

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
spring:
  redis:
    host: localhost
    port: 6379
    password: cloud     # 密码
    timeout: 6000    # 连接超时时长（毫秒）

    jedis.pool:
      #jedis最大分配对象
      maxTotal: 1024
      #jedis最大保存idel状态对象数
      maxIdle: 200
      #jedis池没有对象返回时，最大等待时间
      maxWaitMillis: 10000
      testOnBorrow: true
      testOnReturn: true
      blockWhenExhausted: false
      #Idle时进行连接扫描
      testWhileIdle: true
      #表示idle object evitor两次扫描之间要sleep的毫秒数
      timeBetweenEvictionRunsMillis: 30000
      #表示idle object evitor每次扫描的最多的对象数
      numTestsPerEvictionRun: 10
      #表示一个对象至少停留在idle状态的最短时间，然后才能被idle object evitor扫描并驱逐；这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义
      minEvictableIdleTimeMillis: 60000

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105


import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.env.PropertySourcesLoader;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.PropertySource;
import org.springframework.core.io.ClassPathResource;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.io.IOException;
import java.util.LinkedHashMap;

/**
 * 
 *
 * 读取 redis 配置,或者可以添加其他bean 注入
 *
 */
@Configuration
public class Config {

    Logger logger = Logger.getLogger(this.getClass());

    /**
     * 确定激活的是哪个配置文件
     */
    @Value("${spring.profiles.active}")
    private String active;


    /**
     * @ConditionalOnMissingBean
     * 找不到声明类的情况下创建
     * @return
     */
    @ConditionalOnMissingBean
    @Bean
    public JedisPool jedisPool (JedisPoolConfig config,PropertySource<LinkedHashMap<String,Object>> source) {
        if(null != source) {
            LinkedHashMap<String, Object> sourceMap = source.getSource();

            JedisPool pool = new JedisPool(config, (String) sourceMap.get("spring.redis.host"),(Integer) sourceMap.get("spring.redis.port"),
                    (Integer) sourceMap.get("spring.redis.timeout"),(String) sourceMap.get("spring.redis.password"));
            return pool;
        }
        // 输出创建失败,为了使程序正常启动返回空对象
        logger.error("根据配置创建 JedisPool 失败,创建默认配置的 JedisPool");
        // 使用默认地址 localhost 和默认端口 6379
        return new JedisPool();
    }



    @Bean
    public JedisPoolConfig jedisConfig(PropertySource<LinkedHashMap<String,Object>> source){
        if(null != source ) {
            LinkedHashMap<String,Object> sourceMap = source.getSource();

            JedisPoolConfig config = new JedisPoolConfig();
            config.setMaxIdle((Integer) sourceMap.get("spring.redis.jedis.pool.maxIdle"));
            config.setMaxTotal((Integer)sourceMap.get("spring.redis.jedis.pool.maxTotal"));
            config.setMaxWaitMillis(Long.valueOf(sourceMap.get("spring.redis.jedis.pool.maxWaitMillis").toString()));
            config.setTestOnBorrow((Boolean)sourceMap.get("spring.redis.jedis.pool.testOnBorrow"));
            config.setTestOnReturn((Boolean)sourceMap.get("spring.redis.jedis.pool.testOnReturn"));
            config.setBlockWhenExhausted((Boolean)sourceMap.get("spring.redis.jedis.pool.blockWhenExhausted"));
            config.setTestWhileIdle((Boolean)sourceMap.get("spring.redis.jedis.pool.testWhileIdle"));
            config.setTimeBetweenEvictionRunsMillis(Long.valueOf(sourceMap.get("spring.redis.jedis.pool.timeBetweenEvictionRunsMillis").toString()));
            config.setNumTestsPerEvictionRun((Integer)sourceMap.get("spring.redis.jedis.pool.timeBetweenEvictionRunsMillis"));
            config.setMinEvictableIdleTimeMillis(Long.valueOf(sourceMap.get("spring.redis.jedis.pool.minEvictableIdleTimeMillis").toString()));
            return config;
        }
        // 输出创建失败
        logger.error("创建 JedisPoolConfig 失败");
        return new JedisPoolConfig();

    }


    /**
     * 读取配置文件
     */
    @Bean
    public PropertySource<LinkedHashMap<String,Object>> readProperties(){
        String yml = "application-" + active +".yml";
        ClassPathResource resource = new ClassPathResource(yml);
        PropertySourcesLoader loader = new PropertySourcesLoader();
        PropertySource<LinkedHashMap<String,Object>> load;
        try {
            load = (PropertySource<LinkedHashMap<String,Object>>) loader.load(resource);
            return load;
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }




}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
@Component("RedisService")
public class RedisService {

  

    /**
     * 单机版
     */
    @Autowired
    private static JedisPool jedisPool;

    /**
     * JedisPool 单机版
     */
    @Autowired
    public  void setJedisPool(JedisPool jedisPool) {
        RedisService.jedisPool = jedisPool;
    }

   

// ... 各种操作redis 的方法

}

1
YamlPropertySourceLoader 但是发现文档注释不全,不知道什么意思,调用不成功,后来又发现有公共的读取工具类

1
PropertySourcesLoader ,这样才读取成功,后续类型转换 和 取值 还是比较