目錄

• 騰訊云上的配置
• redis連接單機(jī)和集群
  • 依賴 pom.xml
  • redis參數(shù)的配置文件
  • 遺留問題

騰訊云上的配置

在安全組上打開相關(guān)的端口即可

"來源" 就是你的目標(biāo)服務(wù)器的ip(也可以是0.0.0.0/0) 協(xié)議端口可以用范圍的寫法 TCP:6379-6389

然后需將redis運(yùn)行使用的配置文件redis.conf默認(rèn)bind 127.0.0.1（只允許本地訪問）注釋掉(或者改為0.0.0.0)

# bind 127.0.0.1 protected-mode no 從yes改為no

redis連接單機(jī)和集群

依賴 pom.xml

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId> </dependency><!-- redis依賴commons-pool 這個(gè)依賴一定要添加 --> <dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId> </dependency> <dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version> </dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.2</version> </dependency>

redis參數(shù)的配置文件

redis.properties

#啟動(dòng)集群 #redis.cluster=true########################### reids單機(jī)配置 ############################## #Matser的ip地址 redis.host=49.235.196.22 #端口號 redis.port=6380 #如果有密碼 #redis.password= #客戶端超時(shí)時(shí)間單位是毫秒 默認(rèn)是2000 redis.timeout=5000########################### jedis單機(jī)與集群的公共配置 ############################## #最大空閑數(shù) redis.maxIdle=300 #連接池的最大數(shù)據(jù)庫連接數(shù)。設(shè)為0表示無限制,如果是jedis 2.4以后用redis.maxTotal #redis.maxActive=600 #控制一個(gè)pool可分配多少個(gè)jedis實(shí)例,用來替換上面的redis.maxActive,如果是jedis 2.4以后用該屬性 redis.maxTotal=1000 #最大建立連接等待時(shí)間。如果超過此時(shí)間將接到異常。設(shè)為-1表示無限制。 redis.maxWaitMillis=1000 #連接的最小空閑時(shí)間 默認(rèn)1800000毫秒(30分鐘) redis.minEvictableIdleTimeMillis=300000 #每次釋放連接的最大數(shù)目,默認(rèn)3 redis.numTestsPerEvictionRun=1024 #逐出掃描的時(shí)間間隔(毫秒) 如果為負(fù)數(shù),則不運(yùn)行逐出線程, 默認(rèn)-1 redis.timeBetweenEvictionRunsMillis=30000 #是否在從池中取出連接前進(jìn)行檢驗(yàn),如果檢驗(yàn)失敗,則從池中去除連接并嘗試取出另一個(gè) redis.testOnBorrow=true #在空閑時(shí)檢查有效性, 默認(rèn)false redis.testWhileIdle=true########################### redis集群配置 ############################## redis.clusterNodes=49.235.196.22:7001,49.235.196.22:7002,49.235.196.22:7003,49.235.196.22:7004,49.235.196.22:7005,49.235.196.22:7006 redis.maxRedirects=3#哨兵模式 #redis.sentinel.host1=192.168.177.128 #redis.sentinel.port1=26379#redis.sentinel.host2=172.20.1.231 #redis.sentinel.port2=26379

application.yml

redis:cluster:true

三個(gè)Redis的配置類，RedisConfig：集群和單機(jī)的公共部分，SinglenRedisConfig單機(jī)特有的配置，ClusterRedisConfig集群特有的配置

package per.qiao.config;import lombok.Getter; import lombok.Setter; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.data.redis.connection.RedisClusterConfiguration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import redis.clients.jedis.JedisPoolConfig;import java.util.List;/*** Create by IntelliJ Idea 2018.2** @author: qyp* Date: 2019-09-29 17:15*/ @Getter @Setter public abstract class RedisConfig {/*** 最大空閑數(shù)*/public Integer maxIdle;/*** 控制一個(gè)pool可分配多少個(gè)jedis實(shí)例*/public Integer maxTotal;/*** 最大建立連接等待時(shí)間。如果超過此時(shí)間將接到異常。設(shè)為-1表示無限制。*/public Integer maxWaitMillis;/*** 連接的最小空閑時(shí)間 默認(rèn)1800000毫秒(30分鐘)*/public Integer minEvictableIdleTimeMillis;/*** 每次釋放連接的最大數(shù)目,默認(rèn)3*/public Integer numTestsPerEvictionRun;/*** 逐出掃描的時(shí)間間隔(毫秒) 如果為負(fù)數(shù),則不運(yùn)行逐出線程, 默認(rèn)-1*/public long timeBetweenEvictionRunsMillis;/*** 是否在從池中取出連接前進(jìn)行檢驗(yàn),如果檢驗(yàn)失敗,則從池中去除連接并嘗試取出另一個(gè)*/public boolean testOnBorrow;/*** 在空閑時(shí)檢查有效性, 默認(rèn)false*/public boolean testWhileIdle;/*** JedisPoolConfig 連接池** @return*/@Beanpublic JedisPoolConfig jedisPoolConfig() {JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();// 最大空閑數(shù)jedisPoolConfig.setMaxIdle(maxIdle);// 連接池的最大數(shù)據(jù)庫連接數(shù)jedisPoolConfig.setMaxTotal(maxTotal);// 最大建立連接等待時(shí)間jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);// 逐出連接的最小空閑時(shí)間 默認(rèn)1800000毫秒(30分鐘)jedisPoolConfig.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);// 每次逐出檢查時(shí) 逐出的最大數(shù)目 如果為負(fù)數(shù)就是 : 1/abs(n), 默認(rèn)3jedisPoolConfig.setNumTestsPerEvictionRun(numTestsPerEvictionRun);// 逐出掃描的時(shí)間間隔(毫秒) 如果為負(fù)數(shù),則不運(yùn)行逐出線程, 默認(rèn)-1jedisPoolConfig.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);// 是否在從池中取出連接前進(jìn)行檢驗(yàn),如果檢驗(yàn)失敗,則從池中去除連接并嘗試取出另一個(gè)jedisPoolConfig.setTestOnBorrow(testOnBorrow);// 在空閑時(shí)檢查有效性, 默認(rèn)falsejedisPoolConfig.setTestWhileIdle(testWhileIdle);return jedisPoolConfig;}/*** 單機(jī)構(gòu)建JedisConnectionFactory對象* @param jedisPoolConfig* @return*/public JedisConnectionFactory redisConnectionFactory(JedisPoolConfig jedisPoolConfig) {return null;}/*** 集群redis構(gòu)建JedisConnectionFactory對象* @param jedisPoolConfig* @param redisClusterConfiguration* @return*/public JedisConnectionFactory redisConnectionFactory(JedisPoolConfig jedisPoolConfig, RedisClusterConfiguration redisClusterConfiguration) {return null;}/*** 實(shí)例化 RedisTemplate 對象** @return*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();initDomainRedisTemplate(redisTemplate, redisConnectionFactory);return redisTemplate;}/*** 設(shè)置數(shù)據(jù)存入 redis 的序列化方式,并開啟事務(wù)** @param redisTemplate* @param factory*/public void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) {//如果不配置Serializer，那么存儲的時(shí)候缺省使用String，如果用User類型存儲，那么會提示錯(cuò)誤User can't cast to String！redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());// 開啟事務(wù)//redisTemplate.setEnableTransactionSupport(true);redisTemplate.setConnectionFactory(factory);} }

SinglenRedisConfig.java

package per.qiao.config;import lombok.Getter; import lombok.Setter; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import redis.clients.jedis.JedisPoolConfig;/*** PropertySource加載文件到當(dāng)前類上下文的 Environment 中*/ @Configuration @PropertySource("classpath:redis.properties") @ConfigurationProperties(prefix = "redis") @ConditionalOnMissingBean(ClusterRedisConfig.class) @Getter @Setter public class SinglenRedisConfig extends RedisConfig {/*** host，port，timeout* 這三個(gè)是單機(jī)屬性*/private String host;private Integer port;private Integer timeout;/*** 單機(jī)版配置** @param @param jedisPoolConfig* @param @return* @return JedisConnectionFactory* @throws* @Title: JedisConnectionFactory* @autor lpl* @date 2018年2月24日*/@Beanpublic JedisConnectionFactory redisConnectionFactory(JedisPoolConfig jedisPoolConfig) {JedisConnectionFactory redisConnectionFactory = new JedisConnectionFactory();//連接池 redisConnectionFactory.setPoolConfig(jedisPoolConfig);//IP地址 redisConnectionFactory.setHostName(host);//端口號 redisConnectionFactory.setPort(port);//如果Redis設(shè)置有密碼 //JedisConnectionFactory.setPassword(password);//客戶端超時(shí)時(shí)間單位是毫秒 redisConnectionFactory.setTimeout(timeout);return redisConnectionFactory;} }

ClusterRedisConfig.java

package per.qiao.config; import lombok.Getter; import lombok.Setter; import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.data.redis.connection.RedisClusterConfiguration; import org.springframework.data.redis.connection.RedisNode; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.stereotype.Component; import redis.clients.jedis.JedisPoolConfig;import java.util.List; import java.util.Set; import java.util.stream.Collectors;/*** @author qiao*/ @Configuration @PropertySource("classpath:redis.properties") //@EnableConfigurationProperties(ClusterRedisConfig.class) @ConfigurationProperties(prefix = "redis") //@ConditionalOnExpression("#{'true'.equals(environment['redis.cluster'])}") //@ConditionalOnExpression("'${redis.cluster}'=='true'") @ConditionalOnExpression("${redis.cluster}") @Getter @Setter public class ClusterRedisConfig extends RedisConfig {/*** clusterNodes，mmaxRedirectsac* 這兩個(gè)是集群屬性*/private List<String> clusterNodes;private Integer maxRedirects;/*** Redis集群的配置** @return RedisClusterConfiguration* @throws* @autor lpl* @date 2017年12月22日*/@Beanpublic RedisClusterConfiguration redisClusterConfiguration() {RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();Set<RedisNode> nodes = clusterNodes.stream().map(ipPort -> {String[] ipAndPort = ipPort.split(":");return new RedisNode(ipAndPort[0].trim(), Integer.valueOf(ipAndPort[1]));}).collect(Collectors.toSet());redisClusterConfiguration.setClusterNodes(nodes);redisClusterConfiguration.setMaxRedirects(maxRedirects);return redisClusterConfiguration;}/*** 配置工廠** @param @param jedisPoolConfig* @param @return* @return JedisConnectionFactory* @throws* @Title: JedisConnectionFactory* @autor lpl* @date 2017年12月22日*/@Beanpublic JedisConnectionFactory redisConnectionFactory(JedisPoolConfig jedisPoolConfig, RedisClusterConfiguration redisClusterConfiguration) {JedisConnectionFactory redisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration, jedisPoolConfig);return redisConnectionFactory;}}

測試

@SpringBootTest @RunWith(SpringRunner.class) public class RedisTest {@AutowiredRedisUtil redisUtil;@Testpublic void test() {//redisUtil.del("abc");redisUtil.set("abc", "1234567");System.out.println("================");Object myKey = redisUtil.get("abc");System.out.println(myKey);} }

遺留問題

問題1：在集群配置上出了個(gè)問題ClusterRedisConfig

問題一、使用@PropertySource("classpath:redis.properties")加載配置文件，然后使用@ConditionalOnExpression獲取不到配置文件中的值使用@PropertySource("classpath:redis.properties")加載指定的屬性文件,然后使用@ConfigurationProperties(prefix = "redis")指定前綴，最后使用@ConditionalOnExpression("${redis.cluster}")判斷是否加載當(dāng)前類但是這個(gè)判斷不能按照設(shè)想進(jìn)行控制。1. 當(dāng)我將屬性redis.cluster放到redis.properties中時(shí)，獲取不到值，拋there is still more data in the expression in 'lcurly({)'錯(cuò)誤 2. 當(dāng)我把屬性redis.cluster放到application.yml文件中時(shí)，是可以成功的。猜想：yml文件最先加載，@ConditionalOnExpression又比@PropertySource先加載，所以拿不到數(shù)據(jù)

問題2：在使用lettuce連接redis時(shí)，項(xiàng)目總是報(bào)集群的連接超時(shí)，但是項(xiàng)目可以正常使用

這是使用lettuce(生菜)連接的yml配置文件

spring:redis:database: 1# host:# port:# password:cluster:nodes:- 49.235.196.22:7001- 49.235.196.22:7002- 49.235.196.22:7003- 49.235.196.22:7004- 49.235.196.22:7005- 49.235.196.22:7006lettuce:pool:# 連接池最大連接數(shù) 默認(rèn)8 ，負(fù)數(shù)表示沒有限制max-active: 8# 連接池中的最大空閑連接 默認(rèn)8max-idle: 8# 連接池中的最小空閑連接 默認(rèn)0min-idle: 0# 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒有限制） 默認(rèn)-1max-wait: -1shost: 49.235.196.22port: 7001#timeout: 30000s

這是配置類

@Configuration @AutoConfigureAfter(RedisAutoConfiguration.class) public class RedisConfig2 {/*** springboot2.x 使用LettuceConnectionFactory 代替 RedisConnectionFactory* application.yml配置基本信息后,springboot2.x RedisAutoConfiguration能夠自動(dòng)裝配* LettuceConnectionFactory 和 RedisConnectionFactory 及其 RedisTemplate* @param redisConnectionFactory* @return*/@Beanpublic RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory){RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setConnectionFactory(redisConnectionFactory);return redisTemplate;} }

參考

轉(zhuǎn)載于:https://www.cnblogs.com/qiaozhuangshi/p/11611237.html

總結(jié)

以上是生活随笔為你收集整理的java连接腾讯云上的redis的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。