叢集: 高可用,滿足高併發, 把資料分佈在不同的節點上,提高單個節點的效能

1.redis叢集

架構細節: (1)所有的redis節點彼此互聯(PING-PONG機制),內部使用二進位制協議優化傳輸速度和頻寬. (2)節點的fail是通過叢集中超過半數的節點檢測失效時才生效. (3)客戶端與redis節點直連,不需要中間proxy層.客戶端不需要連線叢集所有節點,連線叢集中任何一個可用節點即可 (4)redis-cluster把所有的物理節點對映到[0-16383]slot上,cluster負責維護node<->slot<->value Redis叢集中內建了 16384個雜湊槽，當需要在 Redis叢集中放置一個 key-value時，redis先對 key使用 crc16演算法算出一個結果，然後把結果對 16384求餘數，這樣每個 key都會對應一個編號在 0-16383之間的雜湊槽，redis會根據節點數量大致均等的將雜湊槽對映到不同的節點 叢集中應該至少有三個節點，每個節點有一備份節點。需要6臺伺服器。 搭建偽分散式，需要6個redis例項。

2.搭建叢集的步驟：

1.正常安裝後在redis.conf 檔案中修改配置: 2.修改埠號: 建立6個redis例項指定埠(如從7001到7006) 3.修改叢集策略: 修改redis.conf開啟Cluster-enable yes前面的註釋。 4.需要一個ruby指令碼。在redis原始碼資料夾下的src目錄下。redis-trib.rb 5.把redis-trib.rb檔案複製到redis-cluster目錄下。 6.執行ruby指令碼之前，需要安裝ruby環境。 1、yum install ruby 2、yum install rubygems 3、安裝redis-trib.rb執行依賴的ruby的包。   [[email protected] ~]# gem install redis-3.0.0.gem 7：啟動所有的redis例項。 8：使用redis-trib.rb建立叢集。 ./redis-trib.rb create --replicas 1 192.168.25.153:7001 192.168.25.153:7002 192.168.25.153:7003 192.168.25.153:7004 192.168.25.153:7005  192.168.25.153:7006

使用客戶端連線叢集： redis01/redis-cli -p 7001-c 如何使用redis的java客戶端 需要使用Jedis連線redis伺服器。

3.叢集版使用Jedis

@Test publicvoid testJedisCluster()throws Exception { //建立一個JedisCluster物件           Set<HostAndPort>nodes =new HashSet<>(); nodes.add(newHostAndPort("192.168.25.153", 7001)); nodes.add(newHostAndPort("192.168.25.153", 7002)); nodes.add(newHostAndPort("192.168.25.153", 7003)); nodes.add(newHostAndPort("192.168.25.153", 7004)); nodes.add(newHostAndPort("192.168.25.153", 7005)); nodes.add(newHostAndPort("192.168.25.153", 7006)); //在nodes中指定每個節點的地址 //jedisCluster在系統中是單例的。           JedisCluster jedisCluster =new JedisCluster(nodes); jedisCluster.set("name","zhangsan"); jedisCluster.set("value","100");           String name =jedisCluster.get("name");           String value =jedisCluster.get("value");           System.out.println(name);           System.out.println(value); //系統關閉時關閉jedisCluster jedisCluster.close();      }

4.專案中使用jedis

思路：建立一個redis操作的介面。分別建立兩個實現類對應redis的單機版和叢集版。當使用單機版redis時，配置單機版的實現類，當使用叢集版本的時候，配置叢集版的實現類。 單機版: 見java操作redis 叢集版: publicclass JedisClientClusterimplements JedisClient { @Autowired private JedisClusterjedisCluster; @Override public String set(Stringkey, Stringvalue) { returnjedisCluster.set(key,value);      } @Override public String get(Stringkey) { returnjedisCluster.get(key);      } @Override public Long hset(Stringkey, Stringitem, Stringvalue) { returnjedisCluster.hset(key,item,value);      } @Override public String hget(Stringkey, Stringitem) { returnjedisCluster.hget(key,item);      } @Override public Long incr(Stringkey) { returnjedisCluster.incr(key);      } @Override public Long decr(Stringkey) { returnjedisCluster.decr(key);      } @Override public Long expire(Stringkey,intsecond) { returnjedisCluster.expire(key,second);      } @Override public Long ttl(Stringkey) { returnjedisCluster.ttl(key);      } }

5.Redis的Spring的配置

<!-- 包掃描器，掃描帶@Service註解的類 --> <context:component-scanbase-package="com.taotao.rest.service"></context:component-scan>     <!-- 配置redis客戶端單機版 --> <beanid="jedisPool"class="redis.clients.jedis.JedisPool"> <constructor-argname="host"value="192.168.25.153"></constructor-arg> <constructor-argname="port"value="6379"></constructor-arg> </bean> <!-- 配置redis客戶端實現類 --> <beanid="jedisClientSingle"class="com.taotao.rest.component.impl.JedisClientSingle"/>      <!-- 配置redis客戶端叢集版 --> <!-- <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">           <constructor-arg>                <set>                     <bean class="redis.clients.jedis.HostAndPort">                          <constructor-arg name="host" value="192.168.25.153"/>                          <constructor-arg name="port" value="7001"/>                     </bean>                     <bean class="redis.clients.jedis.HostAndPort">                          <constructor-arg name="host" value="192.168.25.153"/>                          <constructor-arg name="port" value="7002"/>                     </bean>                     <bean class="redis.clients.jedis.HostAndPort">                          <constructor-arg name="host" value="192.168.25.153"/>                          <constructor-arg name="port" value="7003"/>                     </bean>                     <bean class="redis.clients.jedis.HostAndPort">                          <constructor-arg name="host" value="192.168.25.153"/>                          <constructor-arg name="port" value="7004"/>                     </bean>                     <bean class="redis.clients.jedis.HostAndPort">                          <constructor-arg name="host" value="192.168.25.153"/>                          <constructor-arg name="port" value="7005"/>                     </bean>                     <bean class="redis.clients.jedis.HostAndPort">                          <constructor-arg name="host" value="192.168.25.153"/>                          <constructor-arg name="port" value="7006"/>                     </bean>                </set>           </constructor-arg>      </bean>      <bean id="jedisClientCluster" class="com.taotao.rest.component.impl.JedisClientCluster"/> --> </beans> 測試: publicvoid testJedisClientSpring()throws Exception { //建立一個spring容器           ApplicationContextapplicationContext =new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml"); //從容器中獲得JedisClient物件           JedisClientjedisClient =applicationContext.getBean(JedisClient.class); //jedisClient操作redis jedisClient.set("cliet1","1000");           Stringstring =jedisClient.get("cliet1");           System.out.println(string);  }