Spring Cloud学习01--Eureka基本使用

Eureka的功能：云端服务发现，一个基于 REST 的服务，用于定位服务，以实现云端中间层服务发现和故障转移。

在微服务框架中，是一个用于“服务注册与发现”的工具。在Spring Cloud的H版(Hoxton)已经不再推荐使用此工具，而是建议使用Nacos或者Consul来代替。

因此本文属于@Deprecated，已经过时的知识。当然官方的推荐只是建议而已，实际项目仍然可以继续使用这个工具。下面通过一个项目演示此工具的基本使用。

本文包含1个主项目，4个子模块：

主项目：srpingclouddemo，用于承载各个模块，以及Eureka的版本配置。

01-eureka：用于提供eureka服务

02-customer：用于模拟服务的实际使用者

03-search：用国语模拟服务的实际提供者

04-eureka：用于提供eureka的高可用(eureka集群)

1.创建主体项目：

使用IDEA创建一个Spring Boot的项目，取名为springclouddemo。修改pom文件，添加如下节点：

<properties>
    <java.version>1.8</java.version>
    <spring.cloud-version>Hoxton.SR8</spring.cloud-version>
</properties>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring.cloud-version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

2.创建Eureka服务子项目一：

在第1步创建的项目中，新建一个Module，创建一个Maven项目，取名为01-eureka。

并在pom文件中添加以下引用：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-security</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

第4行配置是引入spring boot的安全控制。

第8行配置是引入Eureka的服务端。

第12行配置是引入spring mvc开启web站点功能。

新建一个SpringBoot启动类，并添加相关注解：

package com.yangasen;

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

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class,args);
    }
}

添加配置文件，application.yml：

server:
  port: 8761

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: true
    fetchRegistry: true
    serviceUrl:
      defaultZone: http://root:root@localhost:8762/eureka/

spring:
  security:
    user:
      name: root
      password: root
  application:
    name: EUREKA

添加配置类，WebSecurityConfig，开启安全控制：

package com.yangasen.config;

import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;

@EnableWebSecurity
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http.csrf().ignoringAntMatchers("/eureka/**");
        super.configure(http);
    }
}

3.创建Eureka服务子项目二：

在第1步创建的项目中，新建一个Module，创建一个Maven项目，取名为04-eureka。

配置均与第2步相同，只是application.yml配置修改如下：

server:
  port: 8762

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: true
    fetchRegistry: true
    serviceUrl:
      defaultZone: http://root:root@localhost:8761/eureka/

spring:
  security:
    user:
      name: root
      password: root
  application:
    name: EUREKA

4.创建Eureka客户端子项目，用于调用服务：

在第1步创建的项目中，新建一个Module，创建一个Maven项目，取名为02-customer。

pom文件配置如下：

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

添加一个spirngboot启动类：

package com.yangasen;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;


@SpringBootApplication
@EnableEurekaClient
public class CustomerApplication {
    public static void main(String[] args) {
        SpringApplication.run(CustomerApplication.class,args);
    }
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

添加配置文件application.yml：

eureka:
  client:
    serviceUrl:
      defaultZone: http://root:root@localhost:8761/eureka,http://root:root@localhost:8762/eureka

spring:
  application:
    name: CUSTOMER

添加用于测试的Controller：

package com.yangasen.controller;

import com.netflix.appinfo.InstanceInfo;
import com.netflix.discovery.EurekaClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class CustomerController {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private EurekaClient eurekaClient;
    
    @GetMapping("/customer")
    public String customer(){
        InstanceInfo instanceInfo = eurekaClient.getNextServerFromEureka("SEARCH",false);
        String url = instanceInfo.getHomePageUrl();
        System.out.println(url);
        String result = restTemplate.getForObject(url+"/search",String.class);
        return result;
    }
}

5.创建Eureka客户端子项目，用于提供服务：

在第1步创建的项目中，新建一个Module，创建一个Maven项目，取名为03-search。

pom文件配置如下：与02项目相同。

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

添加springboot启动类，与03项目相同。

package com.yangasen;

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

@SpringBootApplication
@EnableEurekaClient
public class SearchApplication {
    public static void main(String[] args) {
        SpringApplication.run(SearchApplication.class,args);
    }
}

添加配置文件application.yml，注意端口与02项目不同：

eureka:
  client:
    serviceUrl:
      defaultZone: http://root:root@localhost:8761/eureka,http://root:root@localhost:8762/eureka

spring:
  application:
    name: SEARCH

server:
  port: 8081

添加用于测试的Controller文件：

package com.yangasen.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SearchController {

    @GetMapping("/search")
    public String search(){
        return "search";
    }
}

6.测试效果：

将以上四个模块都启动，在浏览器中访问如下地址：http://localhost:8080/customer

浏览器中会显示“search”字样，测表示Eureka服务运行正常。

同时，可以通过http://localhost:8761以及http://localhost:8762这两个地址(账户：root，密码：root)登录，查看Eureka服务的信息。如图所示：

登录界面

8761端口管理界面：

8762端口管理界面：

两个子项目启动了eureka的高可用，假如其中某一台eureka服务出现问题，整个服务仍然可以使用。

即停掉01或者04任意一个项目，仍然可以通过02项目的controller中的action，访问到03项目的controller的action。