springcloud服务注册与发现
使用Eureka实现服务治理
作用:实现服务治理(服务注册与发现)
简介:
Spring Cloud Eureka是Spring Cloud Netflix项目下的服务治理模块。而Spring Cloud Netflix项目是Spring Cloud的子项目之一,主要内容是对Netflix公司一系列开源产品的包装,它为Spring Boot应用提供了自配置的Netflix OSS整合。通过一些简单的注解,开发者就可以快速的在应用中配置一下常用模块并构建庞大的分布式系统。它主要提供的模块包括:服务发现(Eureka),断路器(Hystrix),智能路由(Zuul),客户端负载均衡(Ribbon)等。
项目实战:
服务注册中心 :eureka-server
作用:服务注册中心提供服务注册功能
服务提供方:eureka-client
作用:注册服务到服务注册中心
服务注册中心 :eureka-server
新建一个springboot项目:eureka-server,其pom.xml配置如下:
- <properties>
- <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
- <java.version>1.8</java.version>
- </properties>
- <dependencies>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-eureka-server</artifactId>
- </dependency>
- </dependencies>
- <dependencyManagement>
- <dependencies>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-dependencies</artifactId>
- <version>Dalston.SR1</version>
- <type>pom</type>
- <scope>import</scope>
- </dependency>
- </dependencies>
- </dependencyManagement>
- @EnableEurekaServer
- @SpringBootApplication
- public class EurekaServerApplication{
- public static void main(String[] args) {
- new SpringApplicationBuilder(EurekaServerApplication.class)
- .web(true).run(args);
- }
- }
- spring.application.name=eureka-server
- server.port=1001
- eureka.instance.hostname=localhost
- eureka.client.register-with-eureka=false
- eureka.client.fetch-registry=false
服务提供方 :eureka-client
每一个实例注册之后需要向注册中心发送心跳,当client向server注册时,它会提供一些元数据,例如主机和端口,URL,主页等。Eureka server 从每个client实例接收心跳消息。 如果心跳超时,则通常将该实例从注册server中删除。
新建一个springboot项目:eureka-client,其pom.xml配置如下:
- <properties>
- <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
- <java.version>1.8</java.version>
- </properties>
- <dependencies>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-eureka</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-web</artifactId>
- </dependency>
- </dependencies>
- <dependencyManagement>
- <dependencies>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-dependencies</artifactId>
- <version>Dalston.SR1</version>
- <type>pom</type>
- <scope>import</scope>
- </dependency>
- </dependencies>
- </dependencyManagement>
- @EnableEurekaClient
- @SpringBootApplication
- public class EurekaClientApplication {
- public static void main(String[] args) {
- new SpringApplicationBuilder(
- EurekaClientApplication.class)
- .web(true).run(args);
- }
- }
- spring.application.name=eureka-client
- server.port=9002
- eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka/
通过spring.application.name属性,我们可以指定微服务的名称后续在调用的时候只需要使用该名称就可以进行服务的访问。
eureka.client.serviceUrl.defaultZone属性对应服务注册中心的配置内容,指定服务注册中心的位置。
使用server.port属性设置不同的端口。
启动EurekaClientApplication类
刷新 http://localhost:9001/,可以看到咱们的服务提供方已经注册到了服务注册中心
在新建一个DiscoveryController
使用discoveryClient.getServices()获取已经注册的服务名,使用@value将配置文件中的信息赋值到ip
- @RestController
- public class DiscoveryController {
- @Autowired
- private DiscoveryClient discoveryClient;
- @Value("${server.port}")
- private String ip;
- @GetMapping("/client")
- public String client() {
- String services = "Services: " + discoveryClient.getServices()+" ip :"+ip;
- System.out.println(services);
- return services;
- }
- }
最后说明一下@EnableEurekaClient 与@EnableDiscoveryClient这两个注解
首先这个两个注解都可以实现服务发现的功能,在spring cloud中discovery service有许多种实现(eureka、consul、zookeeper等等)
@EnableEurekaClient基于spring-cloud-netflix。服务采用eureka作为注册中心,使用场景较为单一。
@EnableDiscoveryClient基于spring-cloud-commons。服务采用其他注册中心。