大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE稳定放心使用
JedisCluster
jedis客户端提供的一个操作集群的连接对象;
底层封装了单个节点电连接对象,
封装了连接池的对外使用的集群对象;
测试连接代码 •
收集节点信息(redis-cluster可以只提供若干个节点)
@Test
public void test(){
//收集若干个节点信息
Set<HostAndPort> set=new HashSet<HostAndPort>();
set.add(new HostAndPort("10.9.39.13", 8000));
set.add(new HostAndPort("10.9.39.13", 8001));
//jedisCluster对象的构造需要连接池的配置对象
JedisPoolConfig config=new JedisPoolConfig();
config.setMaxTotal(200);
config.setMaxIdle(8);
config.setMinIdle(2);
JedisCluster cluster
=new JedisCluster(set, config);
//调用方法,发送redis命令到集群执行;
//name对应的slot是5798
cluster.set("name", "王翠花");
System.out.println(cluster.get("gender"));}
• 框架使用jedisCluster
○ 配置集群的连接信息
#redis集群的配置
spring.redis.cluster.nodes=10.9.39.13:8000,10.9.39.13:8001,10.9.39.13:8002
spring.redis.cluster.maxTotal=200
spring.redis.cluster.maxIdle=8
spring.redis.cluster.minIdle=2
○ 配置类初始化构造一个JedisCluster对象
package com.jt.easymall.config;
import java.util.HashSet;
import java.util.Set;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 每个configuration的代码,都对应xml一部分配置
* @author admin
*/
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedisPool;
@Configuration
@ConfigurationProperties(prefix="spring.redis.cluster")
public class RedisClusterConfig {
private String nodes;
private Integer maxTotal;
private Integer maxIdle;
private Integer minIdle;
public String getNodes() {
return nodes;
}
public void setNodes(String nodes) {
this.nodes = nodes;
}
public Integer getMaxTotal() {
return maxTotal;
}
public void setMaxTotal(Integer maxTotal) {
this.maxTotal = maxTotal;
}
public Integer getMaxIdle() {
return maxIdle;
}
public void setMaxIdle(Integer maxIdle) {
this.maxIdle = maxIdle;
}
public Integer getMinIdle() {
return minIdle;
}
public void setMinIdle(Integer minIdle) {
this.minIdle = minIdle;
}
@Bean//初始化方法构造一个jedisCluster对象
public JedisCluster init(){
try{
Set<HostAndPort> set=new HashSet<HostAndPort>();
//"10.9.39.13:8000,10.9.39.13:8001"
String[] node = nodes.split(",");
for (String hostAndPort : node) {
//"10.9.39.13:8000",解析ip和port
String host=hostAndPort.split(":")[0];
int port=Integer.parseInt
(hostAndPort.split(":")[1]);
set.add(new HostAndPort(host,port));
}
//利用其它属性,编写config对象
JedisPoolConfig config=new JedisPoolConfig();
config.setMaxTotal(maxTotal);
config.setMaxIdle(maxIdle);
config.setMinIdle(minIdle);
return new JedisCluster(set,config);
}catch(Exception e){
//说明构造过程出现了一些问题,一般是因为没有提供
//redis相关配置
return null;}}}
○ 二次封装
○ 注入对象使用
测试jediscluster的高可用代码能力
编写一个简单的访问redis-cluster集群的功能;
一个访问,直接调用set/get方法
@Autowired
private JedisCluster cluster;
@RequestMapping("cluster")
public String setAndGet(String key){
cluster.set(key, "测试数据");
return cluster.get(key);}
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181943.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...