目录
- spring cloud(一) 从一个简单的springboot服务开始
- spring cloud(二) 起步，集成Eureka服务发现
- spring cloud(三)Eureka高可用性+Feign声明式Rest客户端
-
spring cloud(四) Eureka配置Httpbasic验证+Eureka配置详解
未完待续
未完待续
一、 Eureka介绍
上一篇我们使用spring boot编写了两个简单的服务，并让consume_server通过硬编码的方式调用了product_server。我们发现这样的方式实现起来过于复杂，每次都要手工配置服务地址，如果服务地址有变动又需要重新改一遍。这样的方式过于繁琐，而且容易出错。如果这一切可以自动就好了。
这时我们需要一个服务发现，服务发现是基于微服务架构的关键原则之一。尝试配置每个客户端或某种形式的约定可能非常困难，非常脆弱。Netflix服务发现服务器和客户端是Eureka。可以将服务器配置和部署为高可用性，每个服务器将注册服务的状态复制到其他服务器。
我们需要用服务发现框架实现什么功能呢？
- 需要有一个服务注册器，可以将提供服务的微服务注册到注册器里面。
- 需要有服务发现机制，我们可以通过客户端方便的找到我们需要的服务。
- 容灾能力，当服务注册器挂掉之后还能保证服务之间交互正常。
Eureka为我们提供了以上的解决方案，它分为Eureka-server和Eureka-client两个部分，Eureka提供服务注册服务发现功能，可以部署为Eureka-server集群。Eureka-client的主要功能是将服务注册到Eureka-server,通过Eureka-server发现服务。接下来让我们基于上篇文章介绍的两个微服务一步步配置Eureka-server和Eureka-client，实现服务发现功能。
二、 EurekaServer配置
spring cloud为我们提供了开箱即用的工具，我们只需要简单的配置就可以启动一个EurekaServer。
1. 创建一个eureka_server项目
创建新的Module
2. 配置依赖pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<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/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.yshmsoft</groupId>
<artifactId>eureka_server</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
引入spring-cloud-starter-netflix-eureka-server依赖，并配置dependencyManagement。spring cloud使用的版本是当前最新的Finchley.RELEASE版。
3. 创建启动类
package com.yshmsoft;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaServerApplication.class, args);
}
}
@EnableEurekaServer，开启eureka-server自动配置。
4. 配置application.yml
spring:
application:
name: eureka-server
server:
port: 8761
eureka:
client:
fetch-registry: false # 是否获取注册信息, 目前只有自己一个eureka-server，无需同步注册信息
register-with-eureka: false # 是否注册到eureka， 因为自己就是eureka-server所以无需注册
service-url:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
instance:
hostname: localhost
4 . 启动项目访问http://localhost:8761
EurekaServerHome
现在我们可以看到在Instances currently registered with Eureka中并没有服务注册，接下来，让我们修改一下上篇文章中的两个示例，将他们作为服务注册到Eureka-server中。
三、 将服务注册到Eureka-Server中
1. 打开product_server项目，修改pom.xml为如下内容
<?xml version="1.0" encoding="UTF-8"?>
<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/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.yshmsoft</groupId>
<artifactId>product_server</artifactId>
<version>1.0-SNAPSHOT</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RELEASE</version>
<scope>import</scope>
<type>pom</type>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
引入spring-cloud-starter-netflix-eureka-client依赖。并配置dependencyManagement。
2. 在启动类加上EnableDiscoveryClient注解
package com.yshmsoft;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableDiscoveryClient
public class ProductApplocation {
public static void main(String[] args) {
SpringApplication.run(ProductApplocation.class, args);
}
}
EnableDiscoveryClient注解在spring cloud commons包下，它是一个抽象程度比较高的注解，在本项目中也可以使用EnableEurekaClient注解专门针对Eureka提供的注解。
3. 编辑application.yml
server:
port: 8080
spring:
datasource:
platform: h2
schema: classpath:schema.sql
data: classpath:data.sql
jpa:
generate-ddl: false
show-sql: true
hibernate:
ddl-auto: none
application:
name: product-server # 在eureka中此值作为vipaddress,在发现服务时使用
logging:
level:
root: info
org.hibernate: info
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka/
新增 cureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
4. 启动项目查看http://localhost:8761/eureka/是否注册成功
服务注册成功
5. 同样的步骤配置consume_server并查看http://localhost:8761/eureka/是否注册成功
所有服务注册成功
我们看到所有服务都已注册成功了。
三、 在consume_server使用EurekaClient发现服务并使用服务
分为四个步骤：
- 依赖注入EurekaClient。
- 调用EurekaClient的getNextServerFromEureka方法传入。vipaddress(application.yml中的spring.application.name的值)获取服务。
- 将之前硬编码的url替换成服务发现的url。
- 访问http://localhost:8000/user/1看是否成功
package com.yshmsoft.controller;
import com.netflix.appinfo.InstanceInfo;
import com.netflix.discovery.EurekaClient;
import com.yshmsoft.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.util.HashMap;
import java.util.Map;
@RestController
public class UserController {
@Autowired
RestTemplate restTemplate;
@Qualifier("eurekaClient")
@Autowired
EurekaClient eurekaClient;
@GetMapping("/user/{id}")
User getUserById(@PathVariable Long id) {
InstanceInfo instanceInfo = eurekaClient.getNextServerFromEureka("product-server", false);
Map urlVariables = new HashMap();
urlVariables.put("hostName", instanceInfo.getHostName());
urlVariables.put("port", instanceInfo.getPort());
User user = restTemplate.getForObject("http://{hostName}:{port}/" + id, User.class,urlVariables);
return user;
}
}
配置成功
到此通过spring-cloud配置Eureka服务发现完成。
通过spring-cloud集成Eureka服务发现框架完成，想想还有什么不足？
服务发现依赖于Eureka-server,如果Eureka-server挂点怎么办，是否可以将Eureka-server集群化？
拼接url太过繁琐有没有更好的方案？
那么请继续关注，下次再说。
