zookeeper簡介:

在分散式環境中，多個服務之間協調一致。有提供分散式鎖、服務配置。實現分散式領域CAP（consistency一致性，Availiablity高可用，patition tolrenance 分割槽容錯性）原理中的CP。

問題一：為何zookeeper要有leader?

zookeeper是以Fast Paxos演算法為基礎，paxos演算法存在活鎖的問題，即當有多個proposer交錯提交時，有可能互相排斥導致沒有一個proposer能提交成功，而Fase Paxos作了一些優化，通過選舉產生一個leader，只有leader才能提交proposer，具體的可以看一下Fast Paxos演算法

zookeeper協調一致原理paxos演算法：

在分散式系統只發生幾起宕機或網路異常情況下，在叢集內部對某個資料達成一致（proposer和accepter和learner都認為某個value被選定），並且保證不論發生上述任何異常，都不會整個系統的一致性。

在paxos演算法中，分為以下角色：

proposer:提議者

accepter:決策者

learners:最終決策學習者

提議者想決策者提出方案，決策者會根據zookeeper的權重（時間約後啟動，權重越大）選擇leader，如果過半的決策者同意則產生主節點。

選舉狀態:

looking:競選狀態

following:隨從狀態，參與投票

observing:觀察狀態，不參與投票

leading:領導中

選舉流程：

假設有5臺機器，分別A,B,C,D,E。  注：zookeeper啟動的時候，會讀叢集的配置Ip

1.A啟動，當前沒有leader,給自己投票，其他機器沒有啟動，收不到反饋資訊，處於LOOKING

2.B啟動，當前沒有leader,給自己投票，B發訊息給其他機器，A接受到了來自B的投票，B比自己服務號大，接受投票，支援B當選，B接收到A 小於或等於自己的投票，支援A投自己。所以2:1，但是沒有超過一半；following狀態

3.C啟動，當前沒有leader,給自己投票，廣播給A和B，A和B收到比自己大的服務號，支援C當選並且A清空支援B的投票，此時比分為A:B:C=1:1:3，超過一半，C勝出，成為LEADER,狀態為leading

4.D啟動，已經有leader了，同步leader狀態，不參與投票，observing狀態

zookeeper弱點--腦裂：

zookeeper之間是通過心跳檢測來確認節點是否可用，在網路延遲的情況下，會出現假死情況。假設A,B,C,D,E,F,E七個節點，C為主節點。現在C假死了，A,B可用連C，D,E,F都連不上C，D,E,F會通知叢集所有可用的zk(master掛掉了，超過半數都連不上C，我們要重新選舉)，從而F會成為新的主節點。F去通知client主節點切換了，但是會有網路延遲。此時有兩部分client，一部分連線新master，一部分連線老大master，如果此時client要更新同一份資料進行更新，就無法保持一致性了。

eureka(希臘語，詞義：我找到啦，我發現了)

特點：

1.如果某臺伺服器宕機了，不會有選舉過程，客戶端會自動切換到其他eureka,如果故障伺服器回覆後，又將重新納入叢集，並同步新的服務註冊資訊。當網路故障，每個eruka吃持續對外提供服務，zookeeper要先選舉，只有master對外提供服務

2.eureka當機器心跳異常，會進入自我保護模式，延長註冊服務過期時間，就是好資料和壞資料都留著總比丟掉好資料強，等網路恢復後再推出保護模式

部署：

1.下載war包：

http://search.maven.org/#search%7Cga%7C1%7Ceureka-server

2.git下載原始碼編譯:

3.自己建spring-boot專案：

<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>1.5.9.RELEASE</version>
		<relativePath />
	</parent>
	<artifactId>luochaoqun-spring-cloud-eureka</artifactId>
	<properties>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
			<version>1.4.2.RELEASE</version>
		</dependency>
	</dependencies>

	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Dalston.SR5</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>


		</dependencies>
	</dependencyManagement>

package com.main;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**
*@author:luo.cq
*@email:[email protected]
*@since:2018年5月30日
*@description:
*
**/
@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {

	public static void main(String[] args) {
		SpringApplication.run(EurekaServerApplication.class, args);
	}
}

配置項application.properties：

server.port=9000
eureka.instance.hostname=localhost
#don't regist self
eureka.client.register-with-eureka=false
#jinzhi jiansuo fuwu
eureka.client.fetch-registry=false
eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka

介面：