1、Eurake的简介
今天咱们来介绍下springcloud的核心组件Eureka,Eurake是负责微服务架构中服务治理的功能,负责各个服务实例的注册与发现。
Eureka包含了服务器端和客户端组件。服务器端,也被称做是服务注册中心,用于提供服务的注册与发现。 客户端组件包含服务消费者与服务生产者。在应用程序运行时,服务生产者向注册中心注册本身的服务实例,当消费者须要调用这个服务时,会先从注册中心去查找对应的生产者,而后就能够实现对该服务的消费了。
上图是一个较为简单的服务注册消费过程,也是Eureka组件的一个基本运转流程。下面咱们来搭建一个Eureka实例。java
2、使用Eureka进行服务的注册消费
一、建立一个服务注册中心
首先,打开intellij idea,建立一个springboot项目的主Maven工程,名称是eureka,勾选上须要用到的依赖,提醒一下,笔者这里选择的springboot版本是2.0.3,建议读者们也选择一样的版本。
点击下一步后,填写上项目名并点击完成便可。
这样,主工程就建立成功了,建立完主工程后,咱们须要建立两个子工程,一个是服务注册中心eureka-server,另外一个做为客户端,咱们命名为eureka-client.
下面,咱们先建立server的例子,右键主工程,选择New -> model -> spring initialir 建立一个新module,
点击下一步,填完信息后跳转到选择依赖的界面,选择Eureka Server依赖
建立后的pom文件以下:git
<?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.yeya</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>eureka</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.3.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
</properties>
<dependencies>
<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-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<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>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
要想开启服务注册中心,咱们须要在springboot项目中的main入口文件添加@EnableEurekaServer注解
默认状况下,Eureka server会本身向本身注册,咱们须要在配置文件application.yml添加一些配置,代码以下:github
#端口
server:
port: 8761
eureka:
instance:
hostname: localhost
client:
registerWithEureka: false
fetchRegistry: false
serviceUrl:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
设置服务的端口为1111,同时,经过设置eureka.client.register-with-eureka和eureka.client.fetch-registry都为false便可关闭服务向本身注册。
完成这一切后,咱们右键main方法启动项目,而后再浏览器中访问地址
http://localhost:1111,结果以下图:
这是eureka注册中心的界面图,咱们能够看到不少信息,好比“System Status”能够看到咱们的环境以及系统时间等信息,以及“General Info”里有不少关于注册中心的常规信息,包括了cpu,可用空间等,这些知识点比较多,并且不影响咱们的项目效果,因此笔者今天不打算讨论太多,看改天有空再写一篇博文来为你们专门介绍,咱们要关注的是“Instances currently registered with Eureka” 这一栏,栏中显示 No instances available ,很明显,由于咱们没有注册服务,也就没有可用的服务,因此,咱们要再建立客户端项目eureka-client.web
二、建立服务的提供者
eureka-client的建立过程同server相似,在选择依赖时换成Eureka Discovery,建立后的pom文件以下:spring
<?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.yeya</groupId>
<artifactId>eureka</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>eureka</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.3.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
</properties>
<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-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<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>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
一样,咱们须要在main加上注解@EnableDiscoveryClient
而后,在eureka-client的配置文件中加入如下配置:apache
# 设置服务名
spring:
application:
name: eureka-client
# 设置注册中心地址
eureka:
client:
service-url:
defaultZone: http://localhost:1111/eureka
首先,指明本身的服务名为eureka-client,同时,指明注册中心的地址,这样,注册中心才能找到这个服务。
这里要说明一下,idea的配置文件是能够自动提示的,可是写注册中心地址时只能提示到service-url,以后的defaultZone是须要读者本身编写的,有人会怀疑是否是我写错了,其实不是,咱们能够按ctrl点击defaultZone跳转到它的bean类查看源码。
能够看到,这里的默认标识的确是”defaultZone”,因此配置文件这么写是没有问题的,你们若是对配置的解析过程有兴趣的话,能够本身一步步跟着源码查看。
配置完以后,启动eureka-client项目,而后返回eureka-server的访问界面,能够看到咱们的服务注册成功了!
这样,咱们的服务注册就完成了,接下来咱们来测试一下服务消费的过程。浏览器
三、建立服务的消费者
接下来,咱们建立一个服务消费者的工程,命名为eureka-consumer,建立过程同eureka-client同样,建立成功后在main入口文件加入注解@EnableDiscoveryClient,而后修改一下配置文件application.yml:springboot
# 设置服务名
spring:
application:
name: eureka-consumer
# 设置注册中心地址
eureka:
client:
service-url:
defaultZone: http://localhost:1111/eureka
server:
port: 1113
为了能测试服务消费的效果,咱们先在eureka-client中的主类中建立一个接口dc,服务器
@EnableDiscoveryClient
@SpringBootApplication
@RestController
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
@GetMapping("/hello")
public String dc() {
return "hello";
}
}
在eureka-consumer的应用主类中,初始化 RestTemplate ,用来真正发起REST请求。
在这里,咱们稍微介绍一下RestTemplate ,RestTemplate是用来访问restful API的网络框架,其主要方法与rest的http协议相关,例如GET 、POST 、PUT 、DELETE,这些方法对应这个类中的getForObject()、getForEntity()、postForObject()、put()和delete()等,本文里咱们用getForObject()来请求API并返回对应的信息。
新建一个controller文件,添加一个接口(”/consumer”),用来消费eureka-client提供的接口 :restful
@RestController
public class ConsumeController {
@Autowired
private LoadBalancerClient client;
@Autowired
RestTemplate restTemplate;
@GetMapping("/consumer")
public String consumer() {
ServiceInstance serviceInstance = client.choose("eureka-client");
String url = "http://" + serviceInstance.getHost() + ":" + serviceInstance.getPort() + "/hello";
String dc = restTemplate.getForObject(url,String.class);
return dc;
}
}
先经过 @Autowired 注入 LoadBalancerClient 一个实例client,client.choose()的参数是须要调用到的服务的名称,传入以后便可建立一个服务实例,经过实例的方法调用就能够访问到eureka-client的”hello”接口并返回字符串信息。分别启动eureka-server、eureke-client、eureka-consumer三个工程,在浏览器访问http://localhost:1111/,从下图中能够看到两个服务都已经注册成功
接着,打开新页面访问http://localhost:1113/consumer,能够看到浏览器成功输出”hello”字符串。
这代表,咱们成功经过eureka-consumer提供的接口来消费了eureka-client这个微服务了。
总结
本文给你们简单介绍了服务注册发现组件eureka的实例,同时也实现了服务之间的调用,虽然例子简单,但也算开了个好头,接下来的系列教程会继续为你们讲解其余组件的用法,欢迎读者们能跟我一块儿学习,如若文章有错误或不足之处,读者们能够在评论区指出,我会积极给于回复!
源码地址:https://github.com/Taoxj/SpringCloudDemo/tree/master/eureka
本文分享 CSDN - 鄙人薛某。
若有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一块儿分享。