From 5f9704c02fc61da33ed4d3db0d1172976e461089 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 22 七月 2021 19:01:02 +0800
Subject: [PATCH] 推送服务完善
---
service-goldcorn/src/main/java/com/ks/goldcorn/config/RedisConfig.java | 32 +++++++++++++++++++++++++++++++-
1 files changed, 31 insertions(+), 1 deletions(-)
diff --git a/service-goldcorn/src/main/java/com/ks/goldcorn/config/RedisConfig.java b/service-goldcorn/src/main/java/com/ks/goldcorn/config/RedisConfig.java
index eee35e6..032159f 100644
--- a/service-goldcorn/src/main/java/com/ks/goldcorn/config/RedisConfig.java
+++ b/service-goldcorn/src/main/java/com/ks/goldcorn/config/RedisConfig.java
@@ -3,6 +3,7 @@
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@@ -11,10 +12,29 @@
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.JedisPoolConfig;
@Configuration
public class RedisConfig extends CachingConfigurerSupport {
+
+ @Value("${spring.redis.host}")
+ private String addr;
+ @Value("${spring.redis.port}")
+ private int port;
+ @Value("${spring.redis.timeout}")
+ private String timeout;
+ @Value("${spring.redis.password}")
+ private String auth;
+ @Value("${spring.redis.database}")
+ private int database;
+ @Value("${spring.redis.jedis.pool.max-total}")
+ private int maxTotal;
+ @Value("${spring.redis.jedis.pool.max-idle}")
+ private int maxIdle;
+ @Value("${spring.redis.jedis.pool.test_on_borrow}")
+ private boolean testOnBorrow;
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
@@ -31,10 +51,20 @@
// hash鐨刱ey涔熼噰鐢⊿tring鐨勫簭鍒楀寲鏂瑰紡
template.setHashKeySerializer(stringRedisSerializer);
// value搴忓垪鍖栨柟寮忛噰鐢╦ackson
- template.setValueSerializer(jackson2JsonRedisSerializer);
+ template.setValueSerializer(stringRedisSerializer);
// hash鐨剉alue搴忓垪鍖栨柟寮忛噰鐢╦ackson
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
+
+
+ @Bean
+ public JedisPool jedisPool() {
+ JedisPoolConfig poolConfig = new JedisPoolConfig();
+ poolConfig.setMaxTotal(maxTotal);
+ poolConfig.setMaxIdle(maxIdle);
+ poolConfig.setTestOnBorrow(testOnBorrow);
+ return new JedisPool(poolConfig, addr, port, Integer.parseInt(timeout.replace("ms", "").trim()), auth, database);
+ }
}
--
Gitblit v1.8.0