系列文章目錄
- [微服務(wù)系列] 微服務(wù)構(gòu)建框架--Spring Boot
- [微服務(wù)系列] 服務(wù)治理--Eureka
- [微服務(wù)系列] 高可用的服務(wù)治理--Eureka集群
一、 高可用注冊(cè)中心
在上一篇[微服務(wù)系列] 服務(wù)治理--Eureka文章中颜骤，介紹了服務(wù)注冊(cè)中心的單節(jié)點(diǎn)搭建部署。然而在常用的微服務(wù)結(jié)構(gòu)設(shè)計(jì)中，一般都是采用分布式的環(huán)境，以避免單機(jī)故障導(dǎo)致服務(wù)調(diào)用不可用埃唯，所以需要對(duì)微服務(wù)中的各個(gè)組件進(jìn)行高可用的部署摄闸，服務(wù)治理中的服務(wù)注冊(cè)中心也是一樣。
二跟衅、 服務(wù)的發(fā)現(xiàn)與消費(fèi)
在上一篇文章中，我們僅僅對(duì)服務(wù)發(fā)現(xiàn)與消費(fèi)做了簡(jiǎn)單的流程說(shuō)明播歼，在本文中伶跷，將基于已構(gòu)建好的注冊(cè)中心和服務(wù)生產(chǎn)者，來(lái)構(gòu)建服務(wù)消費(fèi)者。通過(guò)服務(wù)消費(fèi)者叭莫，來(lái)發(fā)現(xiàn)注冊(cè)在注冊(cè)中心的服務(wù)并消費(fèi)服務(wù)蹈集。本章將結(jié)合以下的拓?fù)鋱D構(gòu)建高可用的服務(wù)治理。
三雇初、 快速實(shí)踐
1. 構(gòu)建高可用注冊(cè)中心
Eureka的高可用就是將自己作為服務(wù)想其他服務(wù)注冊(cè)中心注冊(cè)自己拢肆，這樣就可以形成一組互相注冊(cè)的服務(wù)注冊(cè)中心，已實(shí)現(xiàn)服務(wù)清單的互相同步靖诗，達(dá)到高可用的目的郭怪。
基于上一節(jié)創(chuàng)建的項(xiàng)目，將配置文件application.properties修改為application-peer1.properties刊橘，同時(shí)修改配置內(nèi)容如下：
spring.application.name=eureka-server
server.port=1111
eureka.instance.hostname=registry1
# 向注冊(cè)中心注冊(cè)自己
eureka.client.register-with-eureka=false
# 允許使用IP地址的形式來(lái)定義注冊(cè)中心地址
eureka.instance.ip-address=true
# 關(guān)閉保護(hù)機(jī)制
eureka.server.enable-self-preservation=false
# 檢索服務(wù)
eureka.client.fetch-registry=true
# 將serviceUrl指向其他的注冊(cè)中心
eureka.client.service-url.defaultZone=http://127.0.0.1:1112/eureka
再創(chuàng)建一個(gè)配置文件application-peer2.properties移盆，配置內(nèi)容如下：
spring.application.name=eureka-server
server.port=1112
eureka.instance.hostname=registry2
# 向注冊(cè)中心注冊(cè)自己
eureka.client.register-with-eureka=false
# 允許使用IP地址的形式來(lái)定義注冊(cè)中心地址
eureka.instance.ip-address=true
# 關(guān)閉保護(hù)機(jī)制
eureka.server.enable-self-preservation=false
# 檢索服務(wù)
eureka.client.fetch-registry=true
# 將serviceUrl指向其他的注冊(cè)中心
eureka.client.service-url.defaultZone=http://127.0.0.1:1111/eureka
使用Maven命令clean package將項(xiàng)目eureka-server打包成Jar包，并使用如下兩個(gè)命令來(lái)別調(diào)用不同的配置文件伤为，并啟動(dòng)項(xiàng)目：
java -jar eureka-server-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1
java -jar eureka-server-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2
2. 服務(wù)的發(fā)現(xiàn)與消費(fèi)
1. 生產(chǎn)服務(wù)
服務(wù)發(fā)現(xiàn)與消費(fèi)主要涉及到兩個(gè)內(nèi)容：一是發(fā)現(xiàn)服務(wù)咒循，而是對(duì)發(fā)現(xiàn)的服務(wù)進(jìn)行消費(fèi)(即調(diào)用)。服務(wù)的發(fā)現(xiàn)由Eureka的客戶端完成绞愚，服務(wù)的消費(fèi)則有Ribbon完成叙甸。
首先，通過(guò)java -jar xxx.jar --server.port=xxxx的方式在不同端口啟動(dòng)之前搭建的hello-service服務(wù)位衩。
java -jar springbootdemo-0.0.1-SNAPSHOT.jar --server.port=8088 --management.port=60000
java -jar springbootdemo-0.0.1-SNAPSHOT.jar --server.port=8089 --management.port=60001
如下圖裆蒸，啟動(dòng)hello-service之后在注冊(cè)中心的出現(xiàn)了兩個(gè)實(shí)例單元。
[圖片上傳失敗...(image-6946e7-1510659484119)]
2. 消費(fèi)服務(wù)
服務(wù)消費(fèi)者采用Ribbon負(fù)載均衡器來(lái)實(shí)現(xiàn)糖驴。重新構(gòu)建一個(gè)基于SpringBoot的基礎(chǔ)工程ribbon-consumer來(lái)實(shí)現(xiàn)服務(wù)消費(fèi)者僚祷，并且在pom.xml文件中添加如下的依賴文件。
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-start-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Brixton.SR5</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
在主類上添加@EnableDiscoveryClient注解贮缕，使其作為Eureka客戶端辙谜，已獲取服務(wù)發(fā)現(xiàn)的能力。在主類中注入RestTemplateJavaBean感昼，并使用@LoadBalanced注解装哆，使其開(kāi)啟客戶端負(fù)載均衡能力。
@EnableDiscoveryClient
@SpringBootApplication
public class ConsumerApplication {
@Bean
@LoadBalanced
RestTemplate restTemplate(){
return new RestTemplate();
};
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
}
在配置文件application.yml中配置注冊(cè)中心地址并設(shè)置服務(wù)的名稱和端口
# 服務(wù)名稱
spring:
application:
name: hello-consumer
# 服務(wù)端口號(hào)
server:
port: 9000
# 注冊(cè)中心地址
eureka:
client:
service-url:
defaultZone: http://localhost:3333/eureka
創(chuàng)建ConsumerController并在一個(gè)接口方法中調(diào)用HELLO-SERVICE中的/hello接口定嗓，具體如下：
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
public class ConsumerController {
private Logger logger=Logger.getLogger(ConsumerController.class);
@Autowired
private RestTemplate restTemplate;
@RequestMapping(value = "helloConsume",method = RequestMethod.GET)
public String helloConsume(){
logger.info("============Start consume========");
return restTemplate.getForEntity("http://HELLO-SERVICE/hello",String.class).getBody();
}
}
啟動(dòng)服務(wù)蜕琴，并查看注冊(cè)中心信息面板，可以看到服務(wù)已經(jīng)被注冊(cè)進(jìn)了注冊(cè)中心：
java -jar consumer-0.0.1-SNAPSHOT.jar --server.port=9000
訪問(wèn)地址localhost:9000/helloConsume可以看到輸出結(jié)果宵溅。
四凌简、小結(jié)
通過(guò)本文簡(jiǎn)單介紹了Eureka集群的配置中以及如何在集群中發(fā)布服務(wù)和消費(fèi)服務(wù)。
