一、通过配置文件创建eureka集群
如图所示，创建了有两个分区的Eureka集群。Zone2-1和Zone2-2分别有一个注册中心，服务A的四个实例（instance）分别注册在不同的注册中心，两个注册中心相互注册。
服务A的提供的服务如下：
@RestController
public class HelloController {
@Value("${zone.message}")
private String hello;
@RequestMapping(value="/hi")
public String hi() {
return hello;
}
}
consumer的调用如下：
@RestController
public class HiController {
@Autowired
private RestTemplate restTemplate;
@RequestMapping(value="/hello")
public String hi() {
return restTemplate.getForObject("http://zone-demo/hi", String.class);
}
}
以下是注册中心和服务的配置文件。
注册中心的配置如下：
#server2-1的配置文件
server.port=1111
eureka.instance.hostname=zone-server2-1
spring.application.name=eureka-server
eureka.client.registerWithEureka=false
eureka.client.fetchRegistry=false
eureka.server.enableSelfPreservation=false
eureka.client.region=region2
#配置region2内的可用zone
eureka.client.availability-zones.region2=zone2-1,zone2-2
#配置每个zone的注册中心的地址
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
#server2-2的配置文件
server.port=1112
eureka.instance.hostname=zone-server2-2
spring.application.name=eureka-server
eureka.client.registerWithEureka=false
eureka.client.fetchRegistry=false
eureka.server.enableSelfPreservation=false
eureka.client.region=region2
eureka.client.availability-zones.region2=zone2-2,zone2-1
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
服务A的配置文件如下：
#服务A1的配置文件
server.port=4561
spring.application.name=zone-demo
eureka.client.region=region2
eureka.client.availability-zones.region2=zone2-1,zone2-2
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
eureka.client.prefer-same-zone-eureka=true
eureka.instance.prefer-ip-address=true
# 获取与此实例相关联的元数据(key,value)。这个信息被发送到eureka服务器，其他实例可以使用。此处用于向其他实例，如调用者传递自己的所属zone
eureka.instance.metadata-map.zone=zone2-1
zone.message=serviceA1-region2.zone2-1
#服务A2的配置文件
server.port=4562
spring.application.name=zone-demo
eureka.client.region=region2
eureka.client.availability-zones.region2=zone2-1,zone2-2
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
eureka.client.prefer-same-zone-eureka=true
eureka.instance.prefer-ip-address=true
eureka.instance.metadata-map.zone=zone2-1
zone.message=serviceA2-region2.zone2-1
#服务A3的配置文件
server.port=4563
spring.application.name=zone-demo
eureka.client.region=region2
eureka.client.availability-zones.region2=zone2-2,zone2-1
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
eureka.client.prefer-same-zone-eureka=true
eureka.instance.prefer-ip-address=true
eureka.instance.metadata-map.zone=zone2-2
zone.message=serviceA3-region2.zone2-2
#服务A4的配置文件
server.port=4564
spring.application.name=zone-demo
eureka.client.region=region2
eureka.client.availability-zones.region2=zone2-2,zone2-1
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
eureka.client.prefer-same-zone-eureka=true
eureka.instance.prefer-ip-address=true
eureka.instance.metadata-map.zone=zone2-2
zone.message=serviceA4-region2.zone2-2
Consumer的配置文件：
server.port=8888
spring.application.name=zone-consumer
eureka.client.region=region2
eureka.client.availability-zones.region2=zone2-2,zone2-1
eureka.client.service-url.zone2-1=http://server2-1:1111/eureka/
eureka.client.service-url.zone2-2=http://server2-2:1112/eureka/
eureka.client.prefer-same-zone-eureka=true
eureka.instance.prefer-ip-address=true
eureka.instance.metadata-map.zone=zone2-1
二、服务分区演示
2.1 服务准备
依次启动注册中心server2-1，server2-2、服务A1 A2 A3 A4。打开注册中心，可以看到每个注册中心，服务zone-demo都有四个注册的实例
2.2 服务调用
启动consumer后，在浏览器地址栏输入localhost:8888/hello,不断刷新页面，浏览器会依次出现以下两种结果，这就说明，consumer是轮询调用serviceA1和serviceA2的。
如果关掉serviceA2，不断刷新后，页面就只会出现serviceA1的
如果同时关掉serviceA1和serviceA2，页面则会轮询出现serviceA3和serviceA4
三、服务注册及注册中心的选择
3.1 服务实例注册
以启动serviceA1为例，来看一下服务实例启动时如何选择注册中心，以及如何注册。
作为服务，配置文件中有一个配置：
eureka.client.registerWithEureka=true
即把自己作为服务向注册中心进行注册。
com.netflix.discovery.DiscoveryClient类在初始化的时候会判断该属性，如果为true，则启动一个InstanceInfoReplicator的定时任务。该定时任务会层层调用 的装饰类，这里不细说，最终RetryableEurekaHttpClient类的execute（）方法会创建一个到注册中心的httpClient，注册中心的地址从candidateHosts里面取第一个EndPoint（其实获取注册中心的实例是先于注册自身的，这里不细表）。
3.2 选择注册中心地址
前面说到实例是如何向注册中心注册，以及RetryableEurekaHttpClient会选择注册中心的serviceUrl，那么实例是如何获取serviceUrl列表呢？
DiscoveryClient初始化的时候
scheduleServerEndpointTask(eurekaTransport, args);
EurekaHttpClients.newBootstrapResolver
EurekaHttpClients.defaultBootstrapResolver
通过instanceInfo获取到Myzone，即eureka.client.availability-zones属性的第一个值。获取到MyZone之后，调用ZoneAffinityClusterResolver的getClusterEndpoints方法，将所有的serviceUrl按照一定顺序得到一个AwsEndPoint 的列表，这个列表里面，属于同一个zone的EndPoint在列表的前面。以下几行代码，将配置文件中所有的注册中心地址按照zone进行了排序，将属于同一区的serviceUrl排在前面。在这里判定myzone是根据
eureka.client.availability-zones.region2=zone2-1,zone2-2
ZoneAffinityClusterResolver的getClusterEndPoints方法还调用了很多类，大约见下图，不细表。
一个AwsPoint列表大概长下面这样子：
至此，将AsyncResolver返回给DiscoveryClient，在进行一些初始化工作，就给DiscoveryClient返回了一个用于注册的HttpClient：
四、消费者调用服务
启动consumer，在discoveryClient获取注册中心的实例见下图，
很明显，获取的instanceInfo是有四个zone-demo的实例的。
4.1 zone filter
DynamicServerListLoadBalancer的updateListOfServers经过如下图filter之后只剩下两个属于zone2-1的实例。
4.2 使用ZoneAvoidanceRule负载均衡方法
使用自定义的负载均衡策略有两种方式：
- 如果你使用高版本的springcloud可以采用配置文件
#zone-demo为服务名
zone-demo.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule
- 还可以手动配置
在启动类上面添加注解
@RibbonClient(name="zone-demo", configuration=MyRibbonConfiguration.class)
配置类
public class MyRibbonConfiguration {
@Bean
public IRule myRule() {
return new ZoneAvoidanceRule();
}
}
使用其中任意一种，就可以使自定义的负载均衡方式生效
com.netflix.discovery.shared.resolver.aws.ZoneAffinityClusterResolver
It is a cluster resolver that reorders the server list, such that the first server on the list is in the same zone as the client. The server is chosen randomly from the available pool of server in that zone. The remaining servers are appended in a random order, local zone first, followed by servers from other zones.
com.netflix.loadbalancer.DynamicServerListLoadBalancer.class的
org.springframework.cloud.netflix.ribbon.ZonePreferenceServerListFilter
@Override
public List<Server> getFilteredListOfServers(List<Server> servers) {
List<Server> output = super.getFilteredListOfServers(servers);
if (this.zone != null && output.size() == servers.size()) {
List<Server> local = new ArrayList<Server>();
for (Server server : output) {
if (this.zone.equalsIgnoreCase(server.getZone())) {
local.add(server);
}
}
if (!local.isEmpty()) {
return local;
}
}
return output;
}
参考http://blog.didispace.com/springcloud-sourcecode-ribbon/
ribbon部分待更新
小结：
关于服务分区有两个步骤：
一是：一般一个服务可能会配多个注册中心的地址，服务注册时，如果eureka.client.prefer-same-zone-eureka这个属性为true，会优先向同一zone的注册中心注册。判定eureka.client.availability-zones这个属性下的第一个分区为MyZone，从而向这个分区的serviceurl注册；
二是，服务消费，一个consumer启动之后从注册中心获取了同个服务的很多实例，这里会对所有实例进行filter，优先调用同一zone的实例，这个时候，实例属于哪个zone是根据eureka.instance.metadata-map的这个属性里面的键值zone来确定的。
属性eureka.client.prefer-same-zone-eureka和eureka.instance.metadata-map.zone都有区的概念，但是使用的场景不同。前者是服务向注册中心注册时使用的属性，后者是实例间调用时使用的属性；前者是client的属性，后者是instance的属性，应区分。
