Go语言视频零基础入门到精通

admin

Eureka集群搭建

  搭建Eureka集群
  
1、Eureka集群搭建

  在介绍Eureka的时候，服务器实例、服务提供者实例都是只启动了一个，并没有体现高可用性
  本小节将对前面的Eureka应用进行改造，使其可以进行集群部署
  
1.1、集群结构图

  上节改造前
  


  本案例将运行两个服务器实例、两个服务提供者实例，然后服务调用者请求服务
  本节改造后
  

  Eureka服务器A，Eureka服务器B（114电话查询平台A接线员，B接线员）
服务提供者A，服务提供者B（多人向警察局拨打电话，人手不足，警察局也提供了A，B接线员）
Eureka客户端服务调用者（不在乎有多少接线员，只知道可以向114平台查询到对应想要的电话号码）

  在上一节中的Eureka应用，使用的是浏览器访问Eureka的服务调用者
  改造之后，为了能看到负载均衡的效果，会编写一个HttpClient的REST客户端访问服务调用者发布的服务
  本节的开发环境只有一台电脑，操作系统为Windows，如果要构建集群，需要修改hosts文件，为其添加主机名的映射
  修改C:\Windows\System32\drivers\etc\hosts文件，添加127.0.0.1 slave1 slave2
  

2、改造服务端

  新建Maven项目：atm_eureka_server_AB
  使用maven配置与上一节一致
  

2.1、修改配置文件

  由于需要对同一个应用启动两次，因此需要在配置文件中使用profiles
  

1. [code]server:
2. port: 8761
3. spring:
4. application:
5. name: first-cloud-server
6. profiles: slave1
7. eureka:
8. instance:
9. hostname: slave1
10. client:
11. serviceUrl:
12. defaultZone: http://slave2:8762/eureka/ ---
13. server:
14. port: 8762
15. spring:
16. application:
17. name: first-cloud-server
18. profiles: slave2
19. eureka:
20. instance:
21. hostname: slave2
22. client:
23. serviceUrl:
24. defaultZone: http://slave1:8761/eureka/

复制代码

[/code]

  配置了两个profiles，分别为slave1和slave2
  在slave1中，配置了应用端口8761，主机名为slave1，当使用 slave1这个profiles启动服务器时，将会向http://slave2:8762/eureka注册自己
  使用slave2来启动服务器时，会向http://slave1:8761/eureka注册自己
  简单点说 ， 就是两个服务器启动后 ， 它们会互相注册 。
  
2.2、修改启动类

  让类在启动时，读取控制台的输入，决定使用那个profiles来启动服务器
  

1. [code]package com.atm.cloud;
3. import java.util.Scanner;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. import org.springframework.boot.builder.SpringApplicationBuilder;
7. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
9. @SpringBootApplication
10. @EnableEurekaServer
11. public class MyApplicationServer {
13.     public static void main(String[] args) {
15.         //读取控制台输入，决定使用哪个profiles
16.         Scanner scanner=new Scanner(System.in);
18.         String profiles=scanner.nextLine();
20.         //SpringApplication.run(MyApplicationServer.class, args);
22.         new SpringApplicationBuilder(MyApplicationServer.class).profiles(profiles).run(args);
23.     }
25. }

复制代码

[/code]

  启动类中，先读取控制台的输入，再调用profiles方法来设置启动的profiles
  启动服务器会抛出异常， 异常原因在上一节已经阐述，此处不再理会
  

---

---

---

---

---

---

3、改造服务提供者

  服务提供者也需要启动两个实例
  服务提供者的改造与服务端类似
  复制或者新建上一节中“服务提供者”，Maven项目：atm_eureka_provider_AB
  

3.1、修改配置文件

1. [code]spring:
2. application:
3.   name: first-cloud-provider
4. eureka:
5. instance:
6.   hostname: localhost
7. client:
8.   serviceUrl:
9.    defaultZone: http://localhost:8761/eureka/,http://localhost:8762/eureka/

复制代码

[/code]

  注意注册的application.name为： first-cloud-provider
  
3.2、修改控制器

  启动类使用了profiles方法来设置启动端口
  为了能看到效果，还需要改造控制器，将服务调用者请求的URL保存起来并返回
  

1. [code]package com.atm.cloud;
3. import javax.servlet.http.HttpServletRequest;
5. import org.springframework.http.MediaType;
6. import org.springframework.web.bind.annotation.PathVariable;
7. import org.springframework.web.bind.annotation.RequestMapping;
8. import org.springframework.web.bind.annotation.RequestMethod;
9. import org.springframework.web.bind.annotation.RestController;
11. @RestController
12. public class MyController {
14.     @RequestMapping(value = "/person/{personId}", method = RequestMethod.GET,
15.             produces = MediaType.APPLICATION_JSON_VALUE)
16.     public Person findPerson(@PathVariable("personId")Integer personId,HttpServletRequest request){
17.         Person person=new Person();
19.         person.setId(personId);
20.         person.setAge(18);
21.         person.setName(request.getRequestURL().toString());
23.         return person;
24.     }
25. }

复制代码

[/code]

  控制器的findPerson方法，将请求的URL保存到Person实例的name属性中，调用服务后，可以通过name属性来查看请求的URL
  
3.3、修改启动类

  为了避免端口冲突，启动时读取控制台输入，决定使用哪个端口来启动
  

1. [code]package com.atm.cloud;
3. import java.util.Scanner;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. import org.springframework.boot.builder.SpringApplicationBuilder;
7. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
9. @SpringBootApplication
10. @EnableEurekaClient
11. public class MyApplicationProvider {
13.     public static void main(String[] args) {
15.         //读取控制台输入，避免端口冲突
16.         Scanner scanner=new Scanner(System.in);
18.         String port=scanner.nextLine();
20.         new SpringApplicationBuilder(MyApplicationProvider.class).properties(
21.                 "server.port=" + port).run(args);
22.     }
23. }

复制代码

[/code]

---

---

---

4、改造服务调用者

  本案例中的服务调用只需要启动一个实例
  复制/新建上一节的“服务提供者”，Maven项目：atm_eureka_invoker_AB
  

4.1、修改配置文件

  修改的配置，将服务调用注册到两个服务器上
  

1. [code]server:
2. port: 9000
3. spring:
4. application:
5.   name: first-cloud-invoker
6. eureka:
7. instance:
8.   hostname: localhost
9. client:
10.   serviceUrl:
11.    defaultZone: http://localhost:8761/eureka/,http:// localhost:8761/eureka/

复制代码

[/code]
4.2、修改控制器

1. [code]package com.atm.cloud;
3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
4. import org.springframework.context.annotation.Bean;
5. import org.springframework.context.annotation.Configuration;
6. import org.springframework.http.MediaType;
7. import org.springframework.web.bind.annotation.RequestMapping;
8. import org.springframework.web.bind.annotation.RequestMethod;
9. import org.springframework.web.bind.annotation.RestController;
10. import org.springframework.web.client.RestTemplate;
12. @RestController
13. @Configuration
14. public class InvokerController {
16.     @Bean
17.     @LoadBalanced
18.     public RestTemplate getRestTemplate() {
19.         return new RestTemplate();
20.     }
22.     @RequestMapping(value="/router",method=RequestMethod.GET,
23.             produces=MediaType.APPLICATION_JSON_VALUE)
24.     public String router() {
25.         RestTemplate restTemplate = getRestTemplate();
27.         // 根据应用名称调用服务
28.         String json = restTemplate.getForObject(
29.                 "http://first-cloud-provider/person/1", String.class);
31.         return json;
32.     }
33. }

复制代码

[/code]

5、REST客户端

  本案例使用的是HttpClient，HttpClient是Apache提供的一个Http工具包
  新建Maven项目：atm_eureka_REST_client
  
5.1、引入依赖

1. [code]<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
2.     <modelVersion>4.0.0</modelVersion>
3.     <groupId>com.atm.cloud</groupId>
4.     <artifactId>atm_eureka_REST_client</artifactId>
5.     <packaging>war</packaging>
6.     <version>0.0.1-SNAPSHOT</version>
7.     <name>atm_eureka_REST_client Maven Webapp</name>
8.     <url>http://maven.apache.org</url>
10.     <dependencies>
11.         <dependency>
12.             <groupId>junit</groupId>
13.             <artifactId>junit</artifactId>
14.             <version>3.8.1</version>
15.             <scope>test</scope>
16.         </dependency>
18.         <!-- HttpClient -->
19.         <dependency>
20.             <groupId>org.apache.httpcomponents</groupId>
21.             <artifactId>httpclient</artifactId>
22.             <version>4.5.2</version>
23.         </dependency>
25.     </dependencies>
26.     <build>
27.         <finalName>atm_eureka_REST_client</finalName>
28.     </build>
29. </project>

复制代码

[/code]
5.2、新建启动类

1. [code]package atm_eureka_REST_client;
3. import org.apache.http.HttpResponse;
4. import org.apache.http.client.methods.HttpGet;
5. import org.apache.http.impl.client.CloseableHttpClient;
6. import org.apache.http.impl.client.HttpClients;
7. import org.apache.http.util.EntityUtils;
9. public class MyApplicationRESTClient {
11.     public static void main(String[] args) {
13.         //创建默认的HttpClient
14.         CloseableHttpClient client=HttpClients.createDefault();
16.         //调用6次服务并输出结果
17.         for (int i = 0; i < 6; i++) {
19.             //调用GET方法请求服务
20.             HttpGet httpGet=new HttpGet("http://location:9000/router");
22.             try {
23.                 //获取响应
24.                 HttpResponse response=client.execute(httpGet);
26.                 //根据响应解析出字符串
27.                 System.out.println(EntityUtils.toString(response.getEntity()));
29.             } catch (Exception e){
30.                 System.out.println("Exception --->>>"+e);
31.             }
33.         }
35.     }
37. }

复制代码

[/code]

  在main方法，调用了6次9000端口的router服务并输出结果
  

---

  启动两个服务端，控制端分别输入“slave1”和“slave2”
  启动两个服务提供者，控制台分别输入“8081”和“8082”
  启动服务调用者
  运行MyApplicationRESTClient的main方法
  

---

  根据输出内容可知：8081与8082端口，分别被请求了3次，可见已经达成了负载均衡的目的
  关于负载均衡更详细的内容，将在后面章节中讲解