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
server:
 port: 8761
spring:
 application:
  name: first-cloud-server
 profiles: slave1
eureka:
 instance:
  hostname: slave1
 client:
  serviceUrl:
   defaultZone: http://slave2:8762/eureka/
---
server:
 port: 8762
spring:
 application:
  name: first-cloud-server
 profiles: slave2
eureka:
 instance:
  hostname: slave2
 client:
  serviceUrl:
   defaultZone: http://slave1:8761/eureka/
  • 配置了两个profiles,分别为slave1和slave2
  • 在slave1中,配置了应用端口8761,主机名为slave1,当使用 slave1这个profiles启动服务器时,将会向http://slave2:8762/eureka注册自己
  • 使用slave2来启动服务器时,会向http://slave1:8761/eureka注册自己
  • 简单点说 , 就是两个服务器启动后 , 它们会互相注册 。

2.2、修改启动类

  • 让类在启动时,读取控制台的输入,决定使用那个profiles来启动服务器
package com.atm.cloud;

import java.util.Scanner;

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

@SpringBootApplication
@EnableEurekaServer
public class MyApplicationServer {

    public static void main(String[] args) {

        //读取控制台输入,决定使用哪个profiles
        Scanner scanner=new Scanner(System.in);

        String profiles=scanner.nextLine();

        //SpringApplication.run(MyApplicationServer.class, args);

        new SpringApplicationBuilder(MyApplicationServer.class).profiles(profiles).run(args);
    }

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







3、改造服务提供者

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

3.1、修改配置文件

spring:
 application:
  name: first-cloud-provider
eureka:
 instance:
  hostname: localhost
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/,http://localhost:8762/eureka/
  • 注意注册的application.name为: first-cloud-provider

3.2、修改控制器

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

import javax.servlet.http.HttpServletRequest;

import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @RequestMapping(value = "/person/{personId}", method = RequestMethod.GET,
            produces = MediaType.APPLICATION_JSON_VALUE)
    public Person findPerson(@PathVariable("personId")Integer personId,HttpServletRequest request){
        Person person=new Person();

        person.setId(personId);
        person.setAge(18);
        person.setName(request.getRequestURL().toString());

        return person;
    }
}
  • 控制器的findPerson方法,将请求的URL保存到Person实例的name属性中,调用服务后,可以通过name属性来查看请求的URL

3.3、修改启动类

  • 为了避免端口冲突,启动时读取控制台输入,决定使用哪个端口来启动
package com.atm.cloud;

import java.util.Scanner;

import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class MyApplicationProvider {

    public static void main(String[] args) {

        //读取控制台输入,避免端口冲突
        Scanner scanner=new Scanner(System.in);

        String port=scanner.nextLine();

        new SpringApplicationBuilder(MyApplicationProvider.class).properties(
                "server.port=" + port).run(args);
    }
}




4、改造服务调用者

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

4.1、修改配置文件

  • 修改的配置,将服务调用注册到两个服务器上
server:
 port: 9000
spring:
 application:
  name: first-cloud-invoker
eureka:
 instance:
  hostname: localhost
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/,http:// localhost:8761/eureka/

4.2、修改控制器

package com.atm.cloud;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
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
@Configuration
public class InvokerController {

    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

    @RequestMapping(value="/router",method=RequestMethod.GET,
            produces=MediaType.APPLICATION_JSON_VALUE)
    public String router() {
        RestTemplate restTemplate = getRestTemplate();

        // 根据应用名称调用服务
        String json = restTemplate.getForObject(
                "http://first-cloud-provider/person/1", String.class);

        return json;
    }
}

5、REST客户端

  • 本案例使用的是HttpClient,HttpClient是Apache提供的一个Http工具包
  • 新建Maven项目:atm_eureka_REST_client

5.1、引入依赖

<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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.atm.cloud</groupId>
    <artifactId>atm_eureka_REST_client</artifactId>
    <packaging>war</packaging>
    <version>0.0.1-SNAPSHOT</version>
    <name>atm_eureka_REST_client Maven Webapp</name>
    <url>http://maven.apache.org</url>

    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>3.8.1</version>
            <scope>test</scope>
        </dependency>

        <!-- HttpClient -->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.2</version>
        </dependency>

    </dependencies>
    <build>
        <finalName>atm_eureka_REST_client</finalName>
    </build>
</project>

5.2、新建启动类

package atm_eureka_REST_client;

import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;

public class MyApplicationRESTClient {

    public static void main(String[] args) {

        //创建默认的HttpClient
        CloseableHttpClient client=HttpClients.createDefault();

        //调用6次服务并输出结果
        for (int i = 0; i < 6; i++) {

            //调用GET方法请求服务
            HttpGet httpGet=new HttpGet("http://location:9000/router");

            try {
                //获取响应
                HttpResponse response=client.execute(httpGet);

                //根据响应解析出字符串
                System.out.println(EntityUtils.toString(response.getEntity()));

            } catch (Exception e){
                System.out.println("Exception --->>>"+e);
            }

        }

    }

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

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


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

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐