前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >redis配置文件_redis怎么连接

redis配置文件_redis怎么连接

作者头像
全栈程序员站长
发布2022-09-30 12:48:01
2.2K0
发布2022-09-30 12:48:01
举报
文章被收录于专栏:全栈程序员必看

大家好,又见面了,我是你们的朋友全栈君。

文章目录


1. 引入依赖

代码语言:javascript
复制
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>

2. 参数配置

代码语言:javascript
复制
# Redis集群服务器地址
redis.host1=192.168.000.11
redis.host2=192.168.000.12
redis.host3=192.168.000.13
# Redis服务器连接端口
redis.master.port=6379
redis.slave.port=6380
# Redis服务器连接密码(默认为空)
redis.password=xxxx
# 连接超时时间
redis.connection-timeout=2000
# 读取数据超时时间
redis.so-timeout=2000
# 连接超时或读取超时进行重试的次数
redis.max-attempts=3
# 开启对象验证,保证可用
redis.testOnBorrow=true

3. 代码实现

代码语言:javascript
复制
import lombok.extern.slf4j.Slf4j;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;
import java.io.IOException;
import java.util.HashSet;
import java.util.Properties;
import java.util.Set;
/** * Redis Cluster 配置 * * @author wangbo * @date 2021/6/15 */
@Slf4j
public class JedisClusterManager { 

private JedisClusterManager() { 

}
private static final JedisCluster JEDIS_CLUSTER;
static { 

Properties props = new Properties();
try { 

props.load(JedisClusterManager.class.getResourceAsStream(PropertiesConstants.PROPERTIES_FILE_REDIS));
} catch (IOException e) { 

log.error("load redis config properties exception", e);
}
String redisHost1 = props.getProperty("redis.host1");
String redisHost2 = props.getProperty("redis.host2");
String redisHost3 = props.getProperty("redis.host3");
int masterPort = Integer.parseInt(props.getProperty("redis.master.port"));
int slavePort = Integer.parseInt(props.getProperty("redis.slave.port"));
Set<HostAndPort> nodes = new HashSet<>();
nodes.add(new HostAndPort(redisHost1, masterPort));
nodes.add(new HostAndPort(redisHost2, masterPort));
nodes.add(new HostAndPort(redisHost3, masterPort));
nodes.add(new HostAndPort(redisHost1, slavePort));
nodes.add(new HostAndPort(redisHost2, slavePort));
nodes.add(new HostAndPort(redisHost3, slavePort));
String password = props.getProperty("redis.password");
int connectionTimeout = Integer.parseInt(props.getProperty("redis.connection-timeout"));
int soTimeout = Integer.parseInt(props.getProperty("redis.so-timeout"));
int maxAttempts = Integer.parseInt(props.getProperty("redis.max-attempts"));
boolean testOnBorrow = Boolean.parseBoolean(props.getProperty("redis.testOnBorrow"));
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setTestOnBorrow(testOnBorrow);
JEDIS_CLUSTER = new JedisCluster(nodes, connectionTimeout, soTimeout, maxAttempts, password, jedisPoolConfig);
}
/** * 获取JedisCluster对象 */
public static JedisCluster getJedis() { 

return JEDIS_CLUSTER;
}
}

然后每次使用的时候直接在程序中使用如下代码获取 JedisCluster 对象即可使用 Jedis 提供的各种操作 Redis 的方法:

代码语言:javascript
复制
JedisCluster jedisCluster = JedisClusterManager.getJedis();

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022年9月10日 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 文章目录
  • 1. 引入依赖
  • 2. 参数配置
  • 3. 代码实现
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis(TencentDB for Redis)是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备,提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档