SpringCloud
SpringCloud是目前国内使用最广泛的微服务框架,集成了各种微服务功能组件,并基于Springboot实现了这些组件的自动装配,从而提供了良好的开箱即用体验
官网地址:https://spring.io/projects/spring-cloud
服务拆分&远程调用
服务拆分注意事项:
- 单一职责:不同微服务,不要重复开发相同业务
- 数据独立:不要访问其他微服务的数据库
- 面向服务:将自己的业务暴露为接口,供其他微服务调用
远程调用:
基于RestTemplate发起的http请求实现远程调用
http请求做远程调用时与语言无关的调用,只要知道对方的ip、端口、接口路径、请求参数即可
Eureka注册中心
Eureka 是 Netflix 公司开发的一款开源的服务注册与发现组件。
Spring Cloud 将 Eureka 与 Netflix 中的其他开源服务组件(例如 Ribbon、Feign 以及 Hystrix 等)一起整合进 Spring Cloud Netflix 模块中,整合后的组件全称为 Spring Cloud Netflix Eureka。
Eureka 是 Spring Cloud Netflix 模块的子模块,它是 Spring Cloud 对 Netflix Eureka 的二次封装,主要负责 Spring Cloud 的服务注册与发现功能。
Spring Cloud 使用 Spring Boot 思想为 Eureka 增加了自动化配置,开发人员只需要引入相关依赖和注解,就能将 Spring Boot 构建的微服务轻松地与 Eureka 进行整合
在Eureka架构中,微服务角色有两类:
- EurekaServer:服务端,注册中心- 记录服务信息
- EurekaClient:客户端- Provider:服务提供者- 注册自己的信息到EurekaServer- 每隔30秒向EurekaServer发送心跳- consumer:服务消费者- 根据服务名称从EurekaServer拉取服务列表- 基于服务列表做负载均衡,选中一个微服务后发起远程调用
1.服务调用关系
服务提供者:暴露接口给其他微服务调用
服务消费者:调用其他微服务提供的接口
- 提供者与消费者角色其实是相对的
- 一个服务可以同时是服务提供者和服务消费者
无论是消费者还是提供者,引入eureka-client依赖、知道eureka地址后,都可以完成服务注册
2.Eureka的作用
- 消费者该如何获取服务提供者具体信息?- 服务提供者启动时向eureka注册自己的信息- eureka保存这些信息- 消费者根据服务名称向eureka拉取提供者信息
- 如果有多个服务提供者,消费者该如何选择?- 服务消费者利用负载均衡算法,从服务列表中挑选一个
- 消费者如何感知服务提供者健康状态?- 服务提供者会每隔30秒向EurekaServer发送心跳请求,报告健康状态- eureka会更新记录服务列表信息,心跳不正常会被剔除- 消费者就可以拉取到最新的信息
3.实现
- 搭建EurekaServer(1)引入eureka-server依赖(2)添加@EnableEurekaServer注解(3)在application.yml中配置eureka地址
- 服务注册(1)引入eureka-client依赖(2)在application.yml中配置eureka地址
- 服务发现(1)引入eureka-client依赖(2)在application.yml中配置eureka地址(3)给RestTemplate添加@LoadBalanced注解(4)用服务提供者的服务名称远程调用
创建
enreka-server
模块,引入依赖,启动类上添加注解:
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency>
@EnableEurekaServer@SpringBootApplicationpublicclassEurekaApplication{publicstaticvoidmain(String[] args){SpringApplication.run(EurekaApplication.class, args);}}
在
user-service
模块引入依赖,配置文件:
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>
server:port:8081spring:application:name: userservice
datasource:url: jdbc:mysql://localhost:3306/cloud_user?useSSL=false
username: root
password:123456driver-class-name: com.mysql.jdbc.Driver
mybatis:type-aliases-package: cn.itcast.user.pojo
configuration:map-underscore-to-camel-case:truelogging:level:cn.itcast: debug
pattern:dateformat: MM-dd HH:mm:ss:SSS
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka/
在
order-service
模块引入依赖,配置文件:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
server:port:8080spring:application:name: orderservice
datasource:url: jdbc:mysql://localhost:3306/cloud_order?useSSL=false
username: root
password:123456driver-class-name: com.mysql.jdbc.Driver
mybatis:type-aliases-package: cn.itcast.user.pojo
configuration:map-underscore-to-camel-case:truelogging:level:cn.itcast: debug
pattern:dateformat: MM-dd HH:mm:ss:SSS
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka/
在
order-service
完成服务拉取:
服务拉取是基于服务名称获取服务列表,然后在对服务列表做负载均衡
@ServicepublicclassOrderService{@AutowiredprivateOrderMapper orderMapper;@AutowiredprivateRestTemplate restTemplate;publicOrderqueryOrderById(Long orderId){// 1.查询订单Order order = orderMapper.findById(orderId);// 2.查询用户String url ="http://userservice/user/"+ order.getUserId();// String url = "http://localhost:8081/user/" + order.getUserId(); 用服务名代替ip、端口User user = restTemplate.getForObject(url,User.class);//3.封装user信息
order.setUser(user);// 4.返回return order;}}
@Bean@LoadBalanced//负载均衡publicRestTemplaterestTemplate(){returnnewRestTemplate();}}
版权归原作者 Java之弟 所有, 如有侵权,请联系我们删除。