Spring Cloud 使用 Netflix Eureka作为服务发现和注册

演示项目源码下载：（访问密码：9987）
Spring-Cloud-discovery-server.zip 

了解如何创建微服务的基础上，Spring Cloud，对Netflix的Eureka注册表服务器以及如何等微服务（Eureka客户端）使用它来注册和发现服务来调用其API。
我们将使用基于 Spring Boot 的 Spring Cloud API。我们将使用 Netflix Eureka 服务器来构建服务注册服务器和 Eureka 客户端，这些客户端将自行注册并发现其他服务以调用 REST API。

概述

1. Eureka 服务注册服务器——这个微服务将提供服务注册和发现服务器。
2. 学生微服务——它将提供一些基于学生实体的功能。它将是一个基于休息的服务，最重要的是它将是一个 eureka 客户端服务，它将与 eureka 服务对话以在服务注册表中注册自己。
3. 学校微服务 - 与学生服务类型相同 - 唯一增加的功能是它将通过服务查找机制调用学生服务。我们不会使用学生服务的绝对 URL 与该服务进行交互。

技术栈和运行时

• Java 1.8
• Eclipse IDE
• Spring cloud
• Spring boot
• Spring Rest
• Maven

什么是 Netflix Eureka 服务器和客户端？

Eureka服务注册服务器

创建Eureka服务器

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  
@EnableEurekaServer
@SpringBootApplication
public class SpringEurekaServerApplication {
  
    public static void main(String[] args) {
        SpringApplication.run(SpringEurekaServerApplication.class, args);
    }
}

服务器配置

server:
  port: ${PORT:8761} # Indicate the default PORT where this service will be started
 
eureka:
  client:
    registerWithEureka: false   #telling the server not to register himself in the service registry
    fetchRegistry: false
  server:
    waitTimeInMsWhenSyncEmpty: 0    #wait time for subsequent sync

spring:
  application:
    name: eureka
  cloud:
    config:
      uri: ${CONFIG_SERVER_URL:http://localhost:8888}

测试Eureka服务器

Eureka客户 - 学生服务

创建 Eureka 客户端项目

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  
@SpringBootApplication
@EnableEurekaClient
public class SpringEurekaClientStudentServiceApplication {
  
    public static void main(String[] args) {
        SpringApplication.run(SpringEurekaClientStudentServiceApplication.class, args);
    }
}

客户端配置

server:
  port: 8098    #default port where the service will be started
 
eureka:         #tells about the Eureka server details and its refresh time
  instance:
    leaseRenewalIntervalInSeconds: 1
    leaseExpirationDurationInSeconds: 2
  client:
    serviceUrl:
      defaultZone: http://127.0.0.1:8761/eureka/
    healthcheck:
      enabled: true
    lease:
      duration: 5
 
spring:     
  application:
    name: student-service   #current service name to be used by the eureka server
     
management:
  security:
    enabled: false  #disable the spring security on the management endpoints like /env, /refresh etc. 
 
logging:
  level:
    com.example.howtodoinjava: DEBUG

添加 REST API

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
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;
 
import com.example.howtodoinjava.springeurekaclientstudentservice.domain.Student;
 
@RestController
public class StudentServiceController {
 
    private static Map<String, List<Student>> schooDB = new HashMap<String, List<Student>>();
 
    static {
        schooDB = new HashMap<String, List<Student>>();
 
        List<Student> lst = new ArrayList<Student>();
        Student std = new Student("Sajal", "Class IV");
        lst.add(std);
        std = new Student("Lokesh", "Class V");
        lst.add(std);
 
        schooDB.put("abcschool", lst);
 
        lst = new ArrayList<Student>();
        std = new Student("Kajal", "Class III");
        lst.add(std);
        std = new Student("Sukesh", "Class VI");
        lst.add(std);
 
        schooDB.put("xyzschool", lst);
 
    }
 
    @RequestMapping(value = "/getStudentDetailsForSchool/{schoolname}", method = RequestMethod.GET)
    public List<Student> getStudents(@PathVariable String schoolname) {
        System.out.println("Getting Student details for " + schoolname);
 
        List<Student> studentList = schooDB.get(schoolname);
        if (studentList == null) {
            studentList = new ArrayList<Student>();
            Student std = new Student("Not Found", "N/A");
            studentList.add(std);
        }
        return studentList;
    }
}

public class Student 
{
    private String name;
    private String className;
     
    public Student(String name, String className) {
        super();
        this.name = name;
        this.className = className;
    }
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public String getClassName() {
        return className;
    }
 
    public void setClassName(String className) {
        this.className = className;
    }
}

测试Eureka客户端

Eureka客户 – 学校服务

创建 Eureka 客户端项目

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 
@SpringBootApplication
@EnableEurekaClient
public class SpringEurekaClientSchoolServiceApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(SpringEurekaClientSchoolServiceApplication.class, args);
    }
}

客户端配置

server:
  port: 9098    #port number
 
eureka:
  instance:
    leaseRenewalIntervalInSeconds: 1
    leaseExpirationDurationInSeconds: 2
  client:
    serviceUrl:
      defaultZone: http://127.0.0.1:8761/eureka/
    healthcheck:
      enabled: true
    lease:
      duration: 5
 
spring:
  application:
    name: school-service    #service name
 
logging:
  level:
    com.example.howtodoinjava: DEBUG

添加使用学生服务的 REST API 的 REST API

现在添加一个RestController并公开一个休息端点以获取学校详细信息。此端点将使用使用应用程序名称的服务发现样式 URL，而不是带有 host:port 的完整 URL。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
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;
import org.springframework.web.client.RestTemplate;
 
@RestController
public class SchoolServiceController {
    @Autowired
    RestTemplate restTemplate;
 
    @RequestMapping(value = "/getSchoolDetails/{schoolname}", method = RequestMethod.GET)
    public String getStudents(@PathVariable String schoolname) 
    {
        System.out.println("Getting School details for " + schoolname);
 
        String response = restTemplate.exchange("http://student-service/getStudentDetailsForSchool/{schoolname}",
                                HttpMethod.GET, null, new ParameterizedTypeReference<String>() {}, schoolname).getBody();
 
        System.out.println("Response Received as " + response);
 
        return "School Name -  " + schoolname + " \n Student Details " + response;
    }
 
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

这样我们就可以摆脱特定的服务配置，我们可以将服务查找责任交给Eureka服务器和这里提供的休息模板。@LoadBalanced如果多个实例正在为同一服务运行，我们也可以在此处应用负载平衡（请参阅注释）。
我们使用的 URL 是http://student-service/getStudentDetailsForSchool/{schoolname}. 显然，我们只使用服务名称student-service来代替host:port. 这将由 spring 框架、eureka 服务器和 rest 模板一起在内部处理。
 

服务发现和调用演示

现在也开始学校服务。所有三个服务都已启动。检查Eureka服务器控制台。学生和学校服务都必须在那里注册。

如果遇到任何错误要检查的事项

1. 注释@EnableEurekaServer和@EnableEurekaClient是应用生态系统的心脏。没有这两件事就根本行不通。
2. 确保在启动配置客户端服务时，eureka 服务器服务已经在运行，否则可能需要一些时间来注册，这可能会在测试时造成混乱。

总结

演示项目源码下载：（访问密码：9987）
Spring-Cloud-discovery-server.zip 

标签： Spring Cloud Netflix Eureka Spring Cloud 服务注册发现 Spring Cloud

地址：https://www.leftso.com/article/861.html