1.RestTemplate实现远程调用
如果将一个系统进行拆分后,比如可以将一个电商系统可以拆分成订单模块,用户模块,商品模块,分别可以从数据库中的订单表,用户表,商品表中查询数据,那么如果根据订单id查询订单记录时,订单又需要根据userId查询用户信息,我们就需要在查询订单的时候,一并查询出用户信息,我们就需要使用RestTemplate进行跨服务查询.步骤如下:
-
注册一个RestTemplate的实例到Spring容器
-
根据RestTemplate对象进行远程调用
1.1 注册RestTemplate
在配置类中注册RestTemplate实例
@Bean
public RestTemplate restTemplate() {
? ?return new RestTemplate();
}1.2 实现远程调用
通过restTemplate对象的getForObject方法实现远程调用,传入两个参数,一个是需要远程调用的url,二是返回的数据类型.
@Autowired
private RestTemplate restTemplate;
?
public Order queryOrderById(Long orderId) {
? ?// 1.查询订单
? ?Order order = orderMapper.findById(orderId);
? ?// 2.利用RestTemplate发起http请求，查询用户
? ?// 2.1.url路径
? ?String url = "http://localhost:8081/user/" + order.getUserId();
? ?// 2.2.发送http请求，实现远程调用
? ?User user = restTemplate.getForObject(url, User.class);
? ?// 3.封装user到Order
? ?order.setUser(user);
? ?// 4.返回
? ?return order;
}在此服务调用过程中,会有两个不同的角色
服务提供者：一次业务中，被其它微服务调用的服务。（提供接口给其它微服务）
服务消费者：一次业务中，调用其它微服务的服务。（调用其它微服务提供的接口）
2.Eureka注册中心
2.1 Eureka两大组件
-
Eureka Server提供服务注册
-
Eureka Client通过注册中心进行访问
2.2 搭建eureka-server
创建一个eureka-server的maven工程
2.2.1 引入eureka依赖
<dependency>
? ?<groupId>org.springframework.cloud</groupId>
? ?<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>2.2.2 编写启动类
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
? ?public static void main(String[] args) {
? ? ? ?SpringApplication.run(EurekaApplication.class, args);
? }
}2.2.3 编写配置文件
创建application.yml文件
server:
port: 10086
spring:
application:
? name: eureka-server
eureka:
client:
? service-url:
? ? defaultZone: http://127.0.0.1:10086/eureka接下来启动微服务,然后在浏览器就可以访问: http://127.0.0.1:10086
2.3 服务注册
如果我们需要将user-service注册到eureka-server中去,那么我们只需要引入依赖和修改配置文件
2.3.1 引入依赖
<dependency>
? ?<groupId>org.springframework.cloud</groupId>
? ?<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>2.3.2 编写配置文件
创建application.yml文件,添加服务名称,eureka地址
server:
port: 8081
spring:
application:
? name: userservice
eureka:
client:
? service-url:
? ? defaultZone: http://127.0.0.1:10086/eureka为了模拟一个服务有多个实例的场景,我们可以再创建一个user-service2,修改其端口号为8082,其余配置和user-service完全一样.
2.4 服务发现
2.4.1 引入依赖
<dependency>
? ?<groupId>org.springframework.cloud</groupId>
? ?<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>2.4.2 编写配置文件
server:
port: 8080
spring:
application:
? name: orderservice
eureka:
client:
? service-url:
? ? defaultZone: http://127.0.0.1:10086/eureka2.5 服务拉取与负载均衡
最后，我们要去eureka-server中拉取user-service服务的实例列表，并且实现负载均衡。
使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
? ?return new RestTemplate();
}修改服务调用的url地址
@Autowired
private RestTemplate restTemplate;
?
public Order queryOrderById(Long orderId) {
? ?// 1.查询订单
? ?Order order = orderMapper.findById(orderId);
? ?// 2.利用RestTemplate发起http请求，查询用户
? ?// 2.1.url路径
? ?String url = "http://userservice/user/" + order.getUserId();
? ?// 2.2.发送http请求，实现远程调用
? ?User user = restTemplate.getForObject(url, User.class);
? ?// 3.封装user到Order
? ?order.setUser(user);
? ?// 4.返回
? ?return order;
}3.Eureka自我保护
Eureka-Client默认30秒会向Eureka-Server发送一次心跳,证明它还活着,如果Eureka-Server在一定时间内(默认90秒)没有收到Eureka-Client发来的心跳,那么Eureka-Server将会把Eureka-Client服务剔除,但是如果Eureka-Server在短时间内丢失大量服务实例心跳,那Eureka-Server会开启自我保护机制,不会立刻将Eureka-Client服务剔除,而让其进入自我保护模式,待它再次发送心跳,该节点便会回到正常.
一句话：某时刻某一个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存