springboot整合jedisCluster[通俗易懂]

springboot整合jedisCluster[通俗易懂]JedisClusterjedis客户端提供的一个操作集群的连接对象;底层封装了单个节点电连接对象,封装了连接池的对外使用的集群对象;测试连接代码•收集节点信息(redis-cluster可以只提供若干个节点) @Test publicvoidtest(){ //收集若干个节点信息 Set<HostAndPort>set=newHashSet<Ho…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新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账号...

(0)


相关推荐

  • centos7安装python3.7_安装python教程

    centos7安装python3.7_安装python教程文章目录前言环境&组件说明组件用途说明准备阶段安装步骤详细步骤准备安装安装Python异常处理异常信息原因分析处理方法小技巧前言工作需要,服务器不能连接外网,因此需要离线安装。推荐在线安装,参考。环境&组件说明操作系统:CentOSLinuxrelease7.4.1708(Core)操作系统安装包:CentOS-7-x86_64-Minimal-1708.isoPython版本:3.8.5pip版本:20.1.1virtualenv版本:20.4.2组件用途说

  • 一个简单的多的socket http 下载原型 perl

    一个简单的多的socket http 下载原型 perl

  • awvs14安装教程_极品飞车14迅雷下载

    awvs14安装教程_极品飞车14迅雷下载Awvs14.1.210329187更新日期为2021年5月4日。首先卸载旧版awvs,然后重启电脑下载地址:Awvs14.1.210329187安装新版本运行AcunetixPremiumv14.2.210503151.exe。到如下填写登录的用户名和密码安装完后如下,此时没有激活激活安装完成后运行AcunetixPremiumActivationTool.exe进行激活,如下已经成功激活,然后改成中文版,如下,右上角点击保存既可以…

  • 什么是PV,UV。

    什么是PV,UV。

  • ASP.NET MVC 教程学习「建议收藏」

    ASP.NET MVC 教程学习「建议收藏」1.Why:为什么需要ASP.NETMVC本章主要为大家汇总了为什么学习Asp.netMVC替代WebForms,产生ASP.NETMVC的需求是什么,只有更好的理解了为什么需要MVC,出于什么目的开发的MVC框架,用MVC框架来弥补什么或是提升什么,才能利用其开发出最高效最满意的Web系统。 为什么会出现ASP.NET平台下的MVC框架?说明:本文摘自InfoQ,是作者JonathanAllen2007年发布的一篇的文章,首先描述了WebForms的优

  • mysql批量写入数据存储过程_mysql批量保存多大数据

    mysql批量写入数据存储过程_mysql批量保存多大数据一、以下共统计了3种批量插入的方法:1、普通方法:一条一条插入;2、使用拼接语句一次性插入,拼接语句的语法如下:insertintotable(col1,col2,col3)values(’a’,’b‘,’c‘),(’a1’,’b1‘,’c1‘),(’a2‘,’b2‘,’c2′),……对于拼接语句sql有一个长度限制:max_allowed_packet,查看限制最大值:showvariableslike‘%max_allowed_packet%’,使用Navic

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号