义齿

JedisClusterjedisクライアントが提供する操作クラスタの接続オブジェクト.下層は単一ノードの電気接続オブジェクトをカプセル化し、接続プールの対外的に使用されるクラスタオブジェクトをカプセル化した.

接続コードのテスト•

ノード情報の収集(redis-clusterは複数のノードのみを提供できます)

	@Test
	public void test(){
		// 
		Set set=new HashSet();
		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 set=new HashSet();
				//"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);}