SpringCloud的入门学习之概念理解、Eureka入门
- 2019 年 11 月 26 日
- 笔记
1、微服务与微服务架构。微服务概念如下所示：
答：微服务强调的是服务的大小，它关注的是某一个点，是具体解决某一个问题、提供落地对应服务的一个服务应用，狭意的看，可以看作Eclipse里面的一个个微服务工程/或者Module模块。
2、微服务架构是一种架构模式，微服务架构概念如下所示：
答：微服务架构是一种架构模式，它提倡将单一应用程序划分成一组小的服务，服务之间互相协调、互相配合，为用户提供最终价值。每个服务运行在其独立的进程中，服务与服务间采用轻量级的通信机制互相协作（通常是基于HTTP协议的RESTful API，区别于dubbo的RPC远程调用）。每个服务都围绕着具体业务进行构建，并且能够被独立的部署到生产环境、类生产环境等。另外，应当尽量避免统一的、集中式的服务管理机制，对具体的一个服务而言，应根据业务上下文，选择合适的语言、工具对其进行构建。
微服务和微服务架构，从技术维度理解，微服务化的核心就是将传统的一站式应用，根据业务拆分成一个一个的服务，彻底地去耦合，每一个微服务提供单个业务功能的服务，一个服务做一件事，从技术角度看就是一种小而独立的处理过程，类似进行概念，能够自行单独启动或者销毁，拥有自己独立的数据。
3、SpringCloud是什么？
答：1）、SpringCloud，基于SpringBoot提供了一套微服务解决方案，包括服务注册与发现，配置中心，全链路监控，服务网关，负载均衡，熔断器等组件，除了基于NetFlix的开源组件做高度抽象封装之外，还有一些选型中立的开源组件。
2）、SpringCloud利用SpringBoot的开发便利性巧妙地简化了分布式系统基础设施的开发，SpringCloud为开发人员提供了快速构建分布式系统的一些工具，包括配置管理、服务发现、断路器、路由、微代理、事件总线、全局锁、决策竞选、分布式会话等等,它们都可以用SpringBoot的开发风格做到一键启动和部署。
3）、SpringBoot并没有重复制造轮子，它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过SpringBoot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。
4）、SpringCloud等于分布式服务架构下的一站式解决方案，是各个微服务架构落地技术的集合体，俗称微服务全家桶。
4、微服务全家桶。SpringCloud集成相关优质项目推荐，这些项目是SpringCloud官方项目或者是对SpringCloud进行了有益的补充以及基于SpringCloud最佳实践。
1）、Spring Cloud Config，配置管理工具包，让你可以把配置放到远程服务器，集中化管理集群配置，目前支持本地存储，Git以及Subversion。 2）、Spring Cloud Bus，事件，消息总线，用于在集群（例如，配置变化事件）中传播状态变化，可以与Spring Cloud Config联合实现热部署。 3）、Eureka，云端服务发现，一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移。 4）、Hystrix，熔断器，容错管理工具，旨在通过熔断机制控制服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。 5）、Zuul，Zuul是在云平台上提供动态路由，监控，弹性，安全等边缘服务的框架。Zuul相当于是设备和Netflix流应用的web网站后端所有请求的前门。 6）、Archaius，配置管理api，包含一系列配置管理api，提供动态类型化属性，线程安全配置操作，轮询框架，回调机制等等功能。 7）、Consul，封装了Consul操作，consul是一个服务发现于配置工具，与Docker容器可以无缝集成。 8）、Spring Cloud for Cloud Foundry，通过Oauth2协议绑定服务到CloudFoundry，CloudFoundry是Vmware推出的开源PaaS云平台。 9）、Spring Cloud Sleuth，日志收集工具包，封装了Dapper和log-based追踪以及Zipkin和HTrace操作，为Spring Cloud应用实现了一种分布式追踪解决方案。 10）、Spring Cloud Data Flow，大数据操作工具，作为Spring XD替代产品，它是一个混合计算模型，结合了流数据与批量数据的处理方式。 11）、Spring Cloud Security，基于spring security的安全工具包，为你的应用程序添加安全控制。 12）、Spring Cloud Zookeeper，操作Zookkeper的工具包，用于使用zookeeper方式的服务发现和配置管理。 13）、Spring Cloud Stream，数据流操作开发包，封装了与Redis，Rabbit，kafka等发送接收消息。 14）、Spring Cloud Cli，基于Spring Boot Cli，可以让你以命令行方式快速建立云组件。 15）、Ribbon，提供云端负载均衡，有多种负载均衡策略可供选择，可以配置服务发现和断路器的使用。 16）、Turbine，Turbine是聚合服务器发送事件流数据的一个工具，用来监控集群下hystrix的metrics情况。 17）、Feign，Feign是一种声明式，模板化的http客户端。 18）、Spring Cloud Task提供云端计划任务管理，任务调度。 19）、Spring Cloud Connectors，便于云端应用程序在各种PaaS平台连接到后端，如数据库和消息代理服务。 20）、Spring Cloud Cluster，提供Leadership选举，如zookeeper，redis，hazelcast，consul等等常见状态模式的抽象和实现。 21）、Spring Cloud Starters，Spring Boot式的启动项目，为Spring Cloud提供开箱即用的依赖管理。
5、SpringCloud和SpringBoot是什么关系。
1）、SpringBoot专注于快速方便的开发单个个体微服务。 2）、SpringCloud是关注全局的微服务协调整理治理框架，它将SpringBoot开发的一个个单体微服务整合并管理起来，为各个微服务之间提供，配置管理、服务发现、断路器、路由、微代理、事件总线、全局锁、决策竞选、分布式会话等等集成服务。 3）、SpringBoot可以离开SpringCloud独立使用开发项目，但是SpringCloud离不开SpringBoot，属于依赖的关系。 4）、SpringBoot专注于快速、方便的开发单个微服务个体，SpringCloud关注全局的服务治理框架。
6、Eureka服务注册与发现。Eureka是什么？
答：Eureka是Netflix的一个子模块，也是核心模块之一。Eureka是一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移。 服务注册与发现对于微服务架构来说是非常重要的，有了服务发现与注册，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了。功能类似于dubbo的注册中心，比如Zookeeper。Netflix在设计Eureka的时候遵循的就是AP原则。
Spring Cloud封装了Netflix公司开发的Eureka模块来实现服务注册和发现(请对比Zookeeper)。Eureka采用了C-S的设计架构。Eureka Server作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka 的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。SpringCloud的一些其他模块（比如Zuul）就可以通过 Eureka Server来发现系统中的其他微服务，并执行相关的逻辑。
7、Eureka包含两个组件：Eureka Server和Eureka Client。
答：Eureka Server提供服务注册服务，各个节点启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。 EurekaClient是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）。
Eureka的三大角色。Eureka Server提供服务的注册与发现。Service Provider服务提供方将自身服务注册到Eureka，从而使服务消费方能够找到。Service Consumer服务消费方从Eureka获取注册服务列表，从而能够消费服务。
8、构建一个聚合工程，父工程创建maven类型packaging是pom类型的，使用的jdk1.8版本，Spring Cloud版本是Dalston.SR1，SpringBoot版本是1.5.9.RELEASE。详细依赖如下所示：
1 <project xmlns="http://maven.apache.org/POM/4.0.0" 2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 3 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 4 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <modelVersion>4.0.0</modelVersion> 6 <groupId>com.bie.springcloud</groupId> 7 <artifactId>microservicecloud</artifactId> 8 <version>0.0.1-SNAPSHOT</version> 9 <packaging>pom</packaging> 10 11 <properties> 12 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 13 <maven.compiler.source>1.8</maven.compiler.source> 14 <maven.compiler.target>1.8</maven.compiler.target> 15 <junit.version>4.12</junit.version> 16 <log4j.version>1.2.17</log4j.version> 17 <lombok.version>1.16.18</lombok.version> 18 </properties> 19 20 <dependencyManagement> 21 <dependencies> 22 <!-- spring-cloud --> 23 <dependency> 24 <groupId>org.springframework.cloud</groupId> 25 <artifactId>spring-cloud-dependencies</artifactId> 26 <version>Dalston.SR1</version> 27 <type>pom</type> 28 <scope>import</scope> 29 </dependency> 30 <!-- spring-boot --> 31 <dependency> 32 <groupId>org.springframework.boot</groupId> 33 <artifactId>spring-boot-dependencies</artifactId> 34 <version>1.5.9.RELEASE</version> 35 <type>pom</type> 36 <scope>import</scope> 37 </dependency> 38 <!-- mysql --> 39 <dependency> 40 <groupId>mysql</groupId> 41 <artifactId>mysql-connector-java</artifactId> 42 <version>5.0.4</version> 43 </dependency> 44 <!-- druid --> 45 <dependency> 46 <groupId>com.alibaba</groupId> 47 <artifactId>druid</artifactId> 48 <version>1.0.31</version> 49 </dependency> 50 <!-- mybatis --> 51 <dependency> 52 <groupId>org.mybatis.spring.boot</groupId> 53 <artifactId>mybatis-spring-boot-starter</artifactId> 54 <version>1.3.0</version> 55 </dependency> 56 <!-- logback --> 57 <dependency> 58 <groupId>ch.qos.logback</groupId> 59 <artifactId>logback-core</artifactId> 60 <version>1.2.3</version> 61 </dependency> 62 <!-- junit --> 63 <dependency> 64 <groupId>junit</groupId> 65 <artifactId>junit</artifactId> 66 <version>${junit.version}</version> 67 <scope>test</scope> 68 </dependency> 69 <!-- log4j --> 70 <dependency> 71 <groupId>log4j</groupId> 72 <artifactId>log4j</artifactId> 73 <version>${log4j.version}</version> 74 </dependency> 75 </dependencies> 76 </dependencyManagement> 77 78 <build> 79 <finalName>microservicecloud</finalName> 80 <resources> 81 <resource> <!-- 允许加载src/main/resources下面的所有配置文件 ---> 82 <directory>src/main/resources</directory> 83 <filtering>true</filtering> 84 </resource> 85 </resources> 86 <plugins> 87 <plugin> <!-- 此插件负责解析和解读的，所有以$符号开头，以$符号结尾的，在上面的配置路径下面的配置文件信息，都可以读取。可以自定义添加信息。 --> 88 <groupId>org.apache.maven.plugins</groupId> 89 <artifactId>maven-resources-plugin</artifactId> 90 <configuration> 91 <delimiters> 92 <delimit>$</delimit> 93 </delimiters> 94 </configuration> 95 </plugin> 96 </plugins> 97 </build> 98 99 <!-- 父工程里面显示子模块 --> 100 <modules> 101 <module>microservicecloud-api</module> 102 <module>microservicecloud-provider-dept-8001</module> 103 <module>microservicecloud-consumer-dept-80</module> 104 <module>microservicecloud-eureka-7001</module> 105 </modules> 106 107 </project>
创建Eureka Server注册中心模块（注意，聚合工程，这里创建的是Maven Module），引入Eureka Server的依赖包，（注意，如果是SpringBoot2.x版本，对应的Spring Cloud版本已经发生了巨大变化，引入的依赖包坐标也发生了巨大变化，请仔细，认真，对比区别）如下所示：
1 <project xmlns="http://maven.apache.org/POM/4.0.0" 2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 3 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 4 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <modelVersion>4.0.0</modelVersion> 6 <parent> 7 <groupId>com.bie.springcloud</groupId> 8 <artifactId>microservicecloud</artifactId> 9 <version>0.0.1-SNAPSHOT</version> 10 </parent> 11 <artifactId>microservicecloud-eureka-7001</artifactId> 12 13 <dependencies> 14 <!-- eureka-server服务端 --> 15 <dependency> 16 <groupId>org.springframework.cloud</groupId> 17 <artifactId>spring-cloud-starter-eureka-server</artifactId> 18 </dependency> 19 <!-- 修改后立即生效，热部署 --> 20 <dependency> 21 <groupId>org.springframework</groupId> 22 <artifactId>springloaded</artifactId> 23 </dependency> 24 <dependency> 25 <groupId>org.springframework.boot</groupId> 26 <artifactId>spring-boot-devtools</artifactId> 27 </dependency> 28 </dependencies> 29 30 </project>
Eureka Server注册中心的配置文件application.yml，如下所示：
1 server: 2 port: 7001 # 端口号 3 4 eureka: 5 instance: 6 hostname: localhost #eureka服务端的实例名称，因为注册中心安装到本机，又是单节点Eureka Server注册中心，起名为了localhost。 7 client: 8 register-with-eureka: false # false表示不向注册中心注册自己 9 fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 10 service-url: 11 #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。 12 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
Eureka Server注册中心的启动主类，如下所示：
1 package com.bie; 2 3 import org.springframework.boot.SpringApplication; 4 import org.springframework.boot.autoconfigure.SpringBootApplication; 5 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; 6 7 @SpringBootApplication 8 @EnableEurekaServer // EurekaServer服务器端启动类,接受其它微服务注册进来 9 public class MicroServiceCloudEurekaServerApplication { 10 11 public static void main(String[] args) { 12 SpringApplication.run(MicroServiceCloudEurekaServerApplication.class, args); 13 } 14 15 }
Eureka Server注册中心，主类启动以后，可以访问界面，效果如下所示：
9、Eureka Server注册中心搭建完毕以后，就可以开发服务的提供者和服务的消费者，现在将服务的提供者注册到Eureka Server注册中心。如下所示：
注意使用的Springboot的版本、SpringCloud的版本，我使用的是低版本的。不是Springboot的2.x版本。注意对比。
1 <project xmlns="http://maven.apache.org/POM/4.0.0" 2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 3 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 4 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <modelVersion>4.0.0</modelVersion> 6 <parent> 7 <groupId>com.bie.springcloud</groupId> 8 <artifactId>microservicecloud</artifactId> 9 <version>0.0.1-SNAPSHOT</version> 10 </parent> 11 <artifactId>microservicecloud-provider-dept-8001</artifactId> 12 13 <dependencies> 14 <dependency><!-- 引入自己定义的api通用包，可以使用Dept部门Entity --> 15 <groupId>com.bie.springcloud</groupId> 16 <artifactId>microservicecloud-api</artifactId> 17 <version>${project.version}</version> 18 </dependency> 19 <dependency> 20 <groupId>junit</groupId> 21 <artifactId>junit</artifactId> 22 </dependency> 23 <dependency> 24 <groupId>mysql</groupId> 25 <artifactId>mysql-connector-java</artifactId> 26 </dependency> 27 <dependency> 28 <groupId>com.alibaba</groupId> 29 <artifactId>druid</artifactId> 30 </dependency> 31 <dependency> 32 <groupId>ch.qos.logback</groupId> 33 <artifactId>logback-core</artifactId> 34 </dependency> 35 <dependency> 36 <groupId>org.mybatis.spring.boot</groupId> 37 <artifactId>mybatis-spring-boot-starter</artifactId> 38 </dependency> 39 <dependency> 40 <groupId>org.springframework.boot</groupId> 41 <artifactId>spring-boot-starter-jetty</artifactId> 42 </dependency> 43 <dependency> 44 <groupId>org.springframework.boot</groupId> 45 <artifactId>spring-boot-starter-web</artifactId> 46 </dependency> 47 <dependency> 48 <groupId>org.springframework.boot</groupId> 49 <artifactId>spring-boot-starter-test</artifactId> 50 </dependency> 51 <!-- 修改后立即生效，热部署 --> 52 <dependency> 53 <groupId>org.springframework</groupId> 54 <artifactId>springloaded</artifactId> 55 </dependency> 56 <dependency> 57 <groupId>org.springframework.boot</groupId> 58 <artifactId>spring-boot-devtools</artifactId> 59 </dependency> 60 <!-- 将微服务provider侧注册进eureka --> 61 <dependency> 62 <groupId>org.springframework.cloud</groupId> 63 <artifactId>spring-cloud-starter-eureka</artifactId> 64 </dependency> 65 <dependency> 66 <groupId>org.springframework.cloud</groupId> 67 <artifactId>spring-cloud-starter-config</artifactId> 68 </dependency> 69 <!-- actuator监控信息完善,主管监控和信息配置 --> 70 <dependency> 71 <groupId>org.springframework.boot</groupId> 72 <artifactId>spring-boot-starter-actuator</artifactId> 73 </dependency> 74 </dependencies> 75 76 </project>
修改服务提供者的配置文件application.yml。客户端注册进eureka服务列表内。
1 server: 2 port: 8001 3 4 mybatis: 5 config-location: classpath:mybatis/mybatis.cfg.xml # mybatis配置文件所在路径 6 type-aliases-package: com.bie.po # 所有实体类别名类所在包 7 mapper-locations: 8 - classpath:mybatis/mapper/**/*.xml # mapper映射文件 9 10 spring: 11 application: 12 name: microservicecloud-provider-dept # 微服务的名称 13 datasource: 14 type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型 15 driver-class-name: org.gjt.mm.mysql.Driver # mysql驱动包 16 url: jdbc:mysql://localhost:3306/cloudDb # 数据库名称 17 username: root 18 password: 123456 19 dbcp2: 20 min-idle: 5 # 数据库连接池的最小维持连接数 21 initial-size: 5 # 初始化连接数 22 max-total: 5 # 最大连接数 23 max-wait-millis: 200 # 等待连接获取的最大超时时间 24 25 eureka: 26 client: # 客户端注册进eureka服务列表内 27 service-url: 28 defaultZone: http://localhost:7001/eureka 29 instance: 30 instance-id: microservicecloud-provider-dept8001 # 将eureka-server注册中心的服务,显示你想看的名称 31 prefer-ip-address: true # 访问路径可以显示IP地址 32 33 info: # 微服务info内容显示详细信息 34 app.name: microservicecloud-provider-dept # 应用名称 35 company.name: www.baidu.com # 公司地址 36 build.artifactId: $project.artifactId$ # 构建项目artifactId 37 build.version: $project.version$ # 构建项目版本号 38
1 package com.bie.controller; 2 3 import java.util.List; 4 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.cloud.client.ServiceInstance; 7 import org.springframework.cloud.client.discovery.DiscoveryClient; 8 import org.springframework.web.bind.annotation.PathVariable; 9 import org.springframework.web.bind.annotation.RequestBody; 10 import org.springframework.web.bind.annotation.RequestMapping; 11 import org.springframework.web.bind.annotation.RequestMethod; 12 import org.springframework.web.bind.annotation.RestController; 13 14 import com.bie.po.Dept; 15 import com.bie.service.DeptService; 16 17 /** 18 * 19 * 20 * @author biehl 21 * 22 */ 23 @RestController 24 public class DeptController { 25 26 @Autowired 27 private DeptService deptService; 28 29 // 服务的发现接口。 30 @Autowired 31 private DiscoveryClient discoveryClient; 32 33 @RequestMapping(value = "/dept/add", method = RequestMethod.POST) 34 public boolean addDept(@RequestBody Dept dept) { 35 return deptService.addDept(dept); 36 } 37 38 @RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET) 39 public Dept getById(@PathVariable(value = "id") Long id) { 40 Dept dept = deptService.getById(id); 41 return dept; 42 } 43 44 @RequestMapping(value = "/dept/list", method = RequestMethod.GET) 45 public List<Dept> getAll() { 46 List<Dept> list = deptService.findAll(); 47 return list; 48 } 49 50 /** 51 * 服务的发现 52 * 53 * @return 54 */ 55 @RequestMapping(value = "/dept/discovery", method = RequestMethod.GET) 56 public Object discovery() { 57 List<String> list = discoveryClient.getServices(); 58 System.out.println("**********" + list); 59 60 List<ServiceInstance> srvList = discoveryClient.getInstances("MICROSERVICECLOUD-PROVIDER-DEPT"); 61 for (ServiceInstance element : srvList) { 62 System.out.println(element.getServiceId() + "t" + element.getHost() + "t" + element.getPort() + "t" 63 + element.getUri()); 64 } 65 return this.discoveryClient; 66 } 67 68 }
修改服务提供者的主类，@EnableEurekaClient本服务启动后会自动注册进eureka服务中。
1 package com.bie; 2 3 import org.springframework.boot.SpringApplication; 4 import org.springframework.boot.autoconfigure.SpringBootApplication; 5 import org.springframework.cloud.netflix.eureka.EnableEurekaClient; 6 7 /** 8 * 9 * 10 * @author biehl 11 * 12 */ 13 @SpringBootApplication 14 @EnableEurekaClient // 本服务启动后会自动注册进eureka服务中 15 public class MicroServiceCloudProviderApplication { 16 17 public static void main(String[] args) { 18 SpringApplication.run(MicroServiceCloudProviderApplication.class, args); 19 } 20 21 }
先启动Eureka Server服务注册中心，再启动服务的提供者。可以看到已经将服务提供者注册到Eureka Server注册中心了。
注册到注册中心的服务名称可以进行修改的，访问信息有ip提示可以修改的，微服务info信息访问可以修改的（需要添加spring-boot-starter-actuator监控依赖，定义info配置信息）。效果如下所示：
10、什么是Eureka Server注册中心的自我保护模式？
答：默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒）。但是当网络分区故障发生时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。Eureka通过"自我保护模式"来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。一旦进入该模式，EurekaServer就会保护服务注册表中的信息，不再删除服务注册表中的数据（也就是不会注销任何微服务）。当网络故障恢复后，该Eureka Server节点会自动退出自我保护模式。
在自我保护模式中，Eureka Server会保护服务注册表中的信息，不再注销任何服务实例。当它收到的心跳数重新恢复到阈值以上时，该Eureka Server节点就会自动退出自我保护模式。它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。
在Spring Cloud中，可以使用eureka.server.enable-self-preservation = false 禁用自我保护模式。建议不要禁用。切记，在Eureka-server注册中心添加该配置。
11、Eureka服务的注册与发现，Eureka服务的提供者Provider已经注册到了Eureka Server注册中心，如何进行服务的发现呢。
1 <project xmlns="http://maven.apache.org/POM/4.0.0" 2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 3 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 4 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <modelVersion>4.0.0</modelVersion> 6 <parent> 7 <groupId>com.bie.springcloud</groupId> 8 <artifactId>microservicecloud</artifactId> 9 <version>0.0.1-SNAPSHOT</version> 10 </parent> 11 <artifactId>microservicecloud-consumer-dept-80</artifactId> 12 13 <dependencies> 14 <!-- 自己定义的api --> 15 <dependency> 16 <groupId>com.bie.springcloud</groupId> 17 <artifactId>microservicecloud-api</artifactId> 18 <version>${project.version}</version> 19 </dependency> 20 <dependency> 21 <groupId>org.springframework.boot</groupId> 22 <artifactId>spring-boot-starter-web</artifactId> 23 </dependency> 24 <!-- 修改后立即生效，热部署 --> 25 <dependency> 26 <groupId>org.springframework</groupId> 27 <artifactId>springloaded</artifactId> 28 </dependency> 29 <dependency> 30 <groupId>org.springframework.boot</groupId> 31 <artifactId>spring-boot-devtools</artifactId> 32 </dependency> 33 <!-- 将微服务provider侧注册进eureka --> 34 <dependency> 35 <groupId>org.springframework.cloud</groupId> 36 <artifactId>spring-cloud-starter-eureka</artifactId> 37 </dependency> 38 <dependency> 39 <groupId>org.springframework.cloud</groupId> 40 <artifactId>spring-cloud-starter-config</artifactId> 41 </dependency> 42 </dependencies> 43 44 </project>
配置服务发现的Consumer的配置文件application.yml。
1 server: 2 port: 80 3 4 eureka: 5 client: # 客户端注册进eureka服务列表内 6 service-url: 7 defaultZone: http://localhost:7001/eureka
RestTemplate提供了多种便捷访问远程Http服务的方法, 是一种简单便捷的访问restful服务模板类,是Spring提供的用于访问Rest服务的客户端模板工具集
1 package com.bie.config; 2 3 import org.springframework.context.annotation.Bean; 4 import org.springframework.context.annotation.Configuration; 5 import org.springframework.web.client.RestTemplate; 6 7 /** 8 * 9 * 10 * @author biehl 11 * 12 * RestTemplate提供了多种便捷访问远程Http服务的方法, 是一种简单便捷的访问restful服务模板类, 13 * 是Spring提供的用于访问Rest服务的客户端模板工具集 14 * 15 */ 16 @Configuration 17 public class ConfigBean { 18 19 @Bean 20 public RestTemplate getRestTemplate() { 21 return new RestTemplate(); 22 } 23 }
如何进行服务的发现呢，开发消费者的控制层，然后可以使用Spring封装好的RestTemplate进行访问。
1 package com.bie.controller; 2 3 import java.util.List; 4 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.web.bind.annotation.PathVariable; 7 import org.springframework.web.bind.annotation.RequestBody; 8 import org.springframework.web.bind.annotation.RequestMapping; 9 import org.springframework.web.bind.annotation.RestController; 10 import org.springframework.web.client.RestTemplate; 11 12 import com.bie.po.Dept; 13 14 /** 15 * 16 * RestTemplate提供了多种便捷访问远程Http服务的方法, 是一种简单便捷的访问RESTFul服务模板类, 17 * 是Spring提供的用于访问Rest服务的客户端模板工具集 18 * 19 * 使用restTemplate访问restful接口非常的简单粗暴无脑。 (url, requestMap, 20 * ResponseBean.class)这三个参数分别代表 REST请求地址、请求参数、HTTP响应转换被转换成的对象类型。 21 * 22 * 23 * @author biehl 24 * 25 */ 26 @RestController 27 public class DeptControllerConsumer { 28 29 private static final String REST_URL_PREFIX = "http://localhost:8001"; 30 // private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT"; 31 32 @Autowired 33 private RestTemplate restTemplate; 34 35 /** 36 * 37 * @param dept 38 * @return 39 */ 40 @RequestMapping(value = "/consumer/dept/add") 41 public boolean addDept(@RequestBody Dept dept) { 42 43 return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class); 44 } 45 46 /** 47 * 注意,从路径中获取到参数值,使用注解@PathVariable 48 * 49 * @param id 50 * @return 51 */ 52 @RequestMapping(value = "/consumer/dept/get/{id}") 53 public Dept getById(@PathVariable(value = "id") Long id) { 54 55 return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class); 56 } 57 58 /** 59 * 60 * @return 61 */ 62 @SuppressWarnings("unchecked") 63 @RequestMapping(value = "/consumer/dept/list") 64 public List<Dept> list() { 65 66 return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class); 67 } 68 69 // 测试@EnableDiscoveryClient,消费端可以调用服务发现 70 @RequestMapping(value = "/consumer/dept/discovery") 71 public Object discovery() { 72 return restTemplate.getForObject(REST_URL_PREFIX + "/dept/discovery", Object.class); 73 } 74 75 }
效果如下所示：
12、Eureka Server注册中心的集群配置。
新建microservicecloud-eureka-7002、microservicecloud-eureka-7003，再加上microservicecloud-eureka-7001可以配置成三台节点的Eureka Server注册中心集群。将microservicecloud-eureka-7001节点的pom.xml配置复制到microservicecloud-eureka-7002、microservicecloud-eureka-7003，这里省略，修改microservicecloud-eureka-7001、microservicecloud-eureka-7002、microservicecloud-eureka-7003三个主启动类的名称，避免启动的时候出现重复。修改C:WindowsSystem32driversetchost的映射地址，如下所示：
1 127.0.0.1 eureka7001.com 2 127.0.0.1 eureka7002.com 3 127.0.0.1 eureka7003.com
修改三个节点的配置文件application.yml，microservicecloud-eureka-7001如下所示：
1 server: 2 port: 7001 3 4 eureka: 5 server: 6 enable-self-preservation: false 7 instance: 8 hostname: eureka7001.com #eureka服务端的实例名称 9 client: 10 register-with-eureka: false # false表示不向注册中心注册自己 11 fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 12 service-url: 13 #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。 14 # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 15 defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/ 16 17 18
microservicecloud-eureka-7002如下所示：
1 server: 2 port: 7002 3 4 eureka: 5 server: 6 enable-self-preservation: false 7 instance: 8 hostname: eureka7002.com #eureka服务端的实例名称 9 client: 10 register-with-eureka: false # false表示不向注册中心注册自己 11 fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 12 service-url: 13 #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。 14 # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 15 defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/ 16 17 18
microservicecloud-eureka-7003如下所示：
1 server: 2 port: 7003 3 4 eureka: 5 server: 6 enable-self-preservation: false 7 instance: 8 hostname: eureka7003.com #eureka服务端的实例名称 9 client: 10 register-with-eureka: false # false表示不向注册中心注册自己 11 fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 12 service-url: 13 #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。 14 # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 15 defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/ 16 17
修改服务提供者microservicecloud-provider-dept-8001的application.yml配置文件，如下所示：
1 server: 2 port: 7003 3 4 eureka: 5 server: 6 enable-self-preservation: false 7 instance: 8 hostname: eureka7003.com #eureka服务端的实例名称 9 client: 10 register-with-eureka: false # false表示不向注册中心注册自己 11 fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 12 service-url: 13 #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。 14 # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 15 defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/ 16 17
启动microservicecloud-eureka-7001、microservicecloud-eureka-7002、microservicecloud-eureka-7003、microservicecloud-provider-dept-8001注册中心和服务提供者，可以看到监控界面，如下所示：
