微服务服务之间远程调用的几种方式(RestTemplate、Eureka、Nacos、feign)

微服务服务之间远程调用的几种方式(RestTemplate、Eureka、Nacos、feign)

1.RestTemplate调用

首先在调用方的启动类中声明一个bean:

public class OrderApplication {

public static void main(String[] args) {

SpringApplication.run(OrderApplication.class, args);

}

//实现远程调用

@Bean

public RestTemplate restTemplate() {

return new RestTemplate();

}

} 然后在需要导入的接口实现中,使用restTemplate.getForObject(url,XX.class)

@Autowired

private RestTemplate restTemplate;

public Order queryOrderById(Long orderId) {

// 1.查询订单

Order order = orderMapper.findById(orderId);

// 4.返回

//2.远程调用查询user

String url="http://127.0.0.1:8081/user/"+order.getUserId();

User user=restTemplate.getForObject(url,User.class);

order.setUser(user);

return order;

}

二:Eureka注册中心

order-service如何得知user-service实例地址?

获取地址信息的流程如下:

user-service服务实例启动后,将自己的信息注册到eureka-server(Eureka服务端)。这个叫服务注册

eureka-server保存服务名称到服务实例地址列表的映射关系

order-service根据服务名称,拉取实例地址列表。这个叫服务发现或服务拉取

order-service如何从多个user-service实例中选择具体的实例?

order-service从实例列表中利用负载均衡算法选中一个实例地址

向该实例地址发起远程调用

order-service如何得知某个user-service实例是否依然健康,是不是已经宕机?

user-service会每隔一段时间(默认30秒)向eureka-server发起请求,报告自己状态,称为心跳

当超过一定时间没有发送心跳时,eureka-server会认为微服务实例故障,将该实例从服务列表中剔除

order-service拉取服务时,就能将故障实例排除了

具体使用:

引入SpringCloud为eureka提供的starter依赖:

org.springframework.cloud

spring-cloud-starter-netflix-eureka-server

给eureka-server服务编写一个启动类,一定要添加一个@EnableEurekaServer注解,开启eureka的注册中心功能:

package cn.itcast.eureka;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication

@EnableEurekaServer

public class EurekaApplication {

public static void main(String[] args) {

SpringApplication.run(EurekaApplication.class, args);

}

}

编写一个application.properties文件,内容如下:

server.port=8761

spring.application.name=eureka-server

eureka.client.service-url.defaultzone=http://127.0.0.1:8761/eureka

在服务提供方user-service的pom文件中,引入下面的eureka-client依赖:

org.springframework.cloud

spring-cloud-starter-netflix-eureka- client

在服务提供方user-service中,修改application.properties文件,添加服务名称、eureka地址:

spring.application.name=userservice

eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka

同样对于服务的调用方:order-service也增加相同的依赖,修改application.properties文件

对于服务调用方:order-service,在启动类中增加一个注解@LoadBalanced

//实现远程调用

@Bean

@LoadBalanced

public RestTemplate restTemplate() {

return new RestTemplate();

} 在调用时,将之前的url中IP地址和端口替换成服务名即可:

public Order queryOrderById(Long orderId) {

// 1.查询订单

Order order = orderMapper.findById(orderId);

// 4.返回

//2.远程调用查询user

String url="http://userservice/user/"+order.getUserId();

User user=restTemplate.getForObject(url,User.class);

order.setUser(user);

return order;

}

以上过程就能实现将服务注册到eureka注册中心中,并且实现服务间可直接通过服务名即可相互调用,但是不建议循环依赖。

三:Nacos服务注册、配置中心

服务注册:

本地解压安装好nacos,并使用单机的方式启动nacos服务,在浏览器http://127.0.01:8848/nacos可以访问服务信息

在cloud-demo父工程的pom文件中的中引入SpringCloudAlibaba的依赖:

com.alibaba.cloud

spring-cloud-alibaba-dependencies

2.2.6.RELEASE

pom

import

然后在user-service和order-service中的pom文件中引入nacos-discovery依赖:

com.alibaba.cloud

spring-cloud-starter-alibaba-nacos-discovery

配置服务的nacos地址、集群以及负载均衡的规则

spring.cloud.nacos.server-addr=localhost:8848

spring.cloud.nacos.discovery.cluster-name=HZ

userservice.ribbon.NFLoadBalancerRuleClassName=com.alibaba.cloud.nacos.ribbon.NacosRule

可复制多个服务生产者(配置端口,集群名称):

-Dserver.port=8083 -Dspring.cloud.nacos.discovery.cluster-name=SH

nacos的负载均衡会优先考虑同一个集群中的服务实例进行调用,而在同一个集群中则是以随机的方式调用服务实例,这是可以选择同一个服务下不同实例的权重来改变负载均衡的选择。

服务统一配置:

在nacos首页【配置管理】-【配置列表】-点击+号添加配置,然后在弹出的表单中,填写配置信息:

Data ID: userservice-dev.properties

Group: DEFAULT_GROUP

描述:开发环境配置

配置格式:properties

配置内容:pattern.dateformat=yyyy-MM-dd HH:mm:ss

注意:项目的核心配置,需要热更新的配置才有放到nacos管理的必要。基本不会变更的一些配置还是保存在微服务本地比较好。

微服务要拉取nacos中管理的配置,并且与本地的application.yml配置合并,才能完成项目启动。

但如果尚未读取application.yml,又如何得知nacos地址呢?

因此spring引入了一种新的配置文件:bootstrap.yaml文件,会在application.yml之前被读取,流程就是在项目启动时会读取先bootstrap.yaml和nacos上的配置信息,并整合到项目中,读取application.properties文件,创建spring容器并加载bean。

首先,在user-service服务中,引入nacos-config的客户端依赖:

com.alibaba.cloud

spring-cloud-starter-alibaba-nacos-config

然后,在user-service中添加一个bootstrap.properties文件,内容如下:

spring.application.name=userservice

spring.profiles.active=dev

spring.cloud.nacos.server-addr=localhost:8848

spring.cloud.nacos.config.file-extension=properties 这里会根据spring.cloud.nacos.server-addr获取nacos地址,再根据

${spring.application.name}-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}作为文件id,来读取配置。

在user-service中的UserController中添加业务逻辑,读取pattern.dateformat配置:

@Value("${pattern.dateformat}")

private String dateformat;

@GetMapping("now")

public String now(){

return LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateformat));

}

我们最终的目的,是修改nacos中的配置后,微服务中无需重启即可让配置生效,也就是配置热更新。

使用@ConfigurationProperties注解代替@Value注解。

在user-service服务中,添加一个类,读取patterrn.dateformat属性:

package cn.itcast.user.config;

import lombok.Data;

import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.stereotype.Component;

@Component

@Data

@ConfigurationProperties(prefix = "pattern")

public class PatternProperties {

private String dateformat;

}

修改UserController的业务逻辑

@Autowired

private PatternProperties patternProperties;

@GetMapping("now")

public String now(){

return LocalDateTime.now().format(DateTimeFormatter.

ofPattern(patternProperties.getDateformat()));

}

配置共享:创建配置时,将Data ID设置为 服务名.properties 即可。

四:feign远程调用

使用RestTemplate的方式存在一些问题:

•代码可读性差,编程体验不统一

•参数复杂URL难以维护

可以创建一个新的module将feign的功能代码独立出来,并将对应的实体类也转移到新module中

首先在module服务的pom文件中引入feign的依赖:

org.springframework.cloud

spring-cloud-starter-openfeign

创建UserClient接口:

@FeignClient(value ="userservice",configuration = DefaultFeignConfiguration.class)

public interface UserClient {

@GetMapping("/user/{id}")

User findById(@PathVariable("id") Long id);

}

在order-service项目中导入feign-api服务的依赖:

cn.itcast.demo

feign-api

1.0

修改order-service中的OrderService类中的queryOrderById方法,使用Feign客户端代替RestTemplate:

@Autowired

private UserClient userClient;

public Order queryOrderById(Long orderId) {

// 1.查询订单

Order order = orderMapper.findById(orderId);

// 4.返回

//2.远程调用查询user

User user=userClient.findById(order.getUserId());

order.setUser(user);

return order;

}

自定义配置比如设置日志打印机别,而日志的级别分为四种:

NONE:不记录任何日志信息,这是默认值。

BASIC:仅记录请求的方法,URL以及响应状态码和执行时间

HEADERS:在BASIC的基础上,额外记录了请求和响应的头信息

FULL:记录所有请求和响应的明细,包括头信息、请求体、元数据。

可以基于Java代码来修改日志级别,先声明一个类,然后声明一个Logger.Level的对象:

public class DefaultFeignConfiguration {

@Bean

public Logger.Level feignLogLevel(){

return Logger.Level.BASIC; // 日志级别为BASIC

}

} 如果要全局生效,将其放到启动类的@EnableFeignClients这个注解中:但是由于启动类和该配置类不在同一个包中,注解信息需要修改

@EnableFeignClients(defaultConfiguration = DefaultFeignConfiguration .class)

=======

@EnableFeignClients(basePackages = "com.yudh.feign.service") 如果是局部生效,则把它放到对应的@FeignClient这个注解中:

@FeignClient(value ="userservice",configuration = DefaultFeignConfiguration.class)

调试过程中遇到的问题

在idea中同时开启多个服务进行调试,并且都是连接同一个服务器的同一个数据库,需要修改hikari的最长连接时间,报错如下:

- Failed to validate connection com.mysql.cj.jdbc.ConnectionImpl@4fda9dd2 \

(No operations allowed after connection closed.). Possibly consider using a shorter maxLifetime value. 修改如下:

spring.datasource.hikari.max-lifetime=20000 具体值应当小于数据库wait_timeout字段值