0


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

1.RestTemplate调用

  1. 首先在调用方的启动类中声明一个bean:public class OrderApplication { public static void main(String[] args) { SpringApplication.run(OrderApplication.class, args); } //实现远程调用 @Bean public RestTemplate restTemplate() { return new RestTemplate(); }}
  2. 然后在需要导入的接口实现中,使用restTemplate.getForObject(url,XX.class)@Autowiredprivate 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注册中心

  1. order-service如何得知user-service实例地址?获取地址信息的流程如下:- user-service服务实例启动后,将自己的信息注册到eureka-server(Eureka服务端)。这个叫服务注册- eureka-server保存服务名称到服务实例地址列表的映射关系- order-service根据服务名称,拉取实例地址列表。这个叫服务发现或服务拉取
  2. order-service如何从多个user-service实例中选择具体的实例?- order-service从实例列表中利用负载均衡算法选中一个实例地址- 向该实例地址发起远程调用
  3. order-service如何得知某个user-service实例是否依然健康,是不是已经宕机?- user-service会每隔一段时间(默认30秒)向eureka-server发起请求,报告自己状态,称为心跳- 当超过一定时间没有发送心跳时,eureka-server会认为微服务实例故障,将该实例从服务列表中剔除- order-service拉取服务时,就能将故障实例排除了

具体使用:

  1. 引入SpringCloud为eureka提供的starter依赖:<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency>
  2. 给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@EnableEurekaServerpublic class EurekaApplication { public static void main(String[] args) { SpringApplication.run(EurekaApplication.class, args); }}
  3. 编写一个application.properties文件,内容如下:server.port=8761spring.application.name=eureka-servereureka.client.service-url.defaultzone=http://127.0.0.1:8761/eureka
  4. 在服务提供方user-service的pom文件中,引入下面的eureka-client依赖:<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka- client</artifactId></dependency>
  5. 在服务提供方user-service中,修改application.properties文件,添加服务名称、eureka地址:spring.application.name=userserviceeureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka
  6. 同样对于服务的调用方:order-service也增加相同的依赖,修改application.properties文件
  7. 对于服务调用方:order-service,在启动类中增加一个注解@LoadBalanced//实现远程调用@Bean@LoadBalancedpublic 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;}
  8. 以上过程就能实现将服务注册到eureka注册中心中,并且实现服务间可直接通过服务名即可相互调用,但是不建议循环依赖。

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

服务注册:

  1. 本地解压安装好nacos,并使用单机的方式启动nacos服务,在浏览器http://127.0.01:8848/nacos可以访问服务信息
  2. 在cloud-demo父工程的pom文件中的<dependencyManagement>中引入SpringCloudAlibaba的依赖:<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-dependencies</artifactId> <version>2.2.6.RELEASE</version> <type>pom</type> <scope>import</scope></dependency>然后在user-service和order-service中的pom文件中引入nacos-discovery依赖:<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>
  3. 配置服务的nacos地址、集群以及负载均衡的规则spring.cloud.nacos.server-addr=localhost:8848spring.cloud.nacos.discovery.cluster-name=HZuserservice.ribbon.NFLoadBalancerRuleClassName=com.alibaba.cloud.nacos.ribbon.NacosRule
  4. 可复制多个服务生产者(配置端口,集群名称):-Dserver.port=8083 -Dspring.cloud.nacos.discovery.cluster-name=SH

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

服务统一配置:

  1. 在nacos首页【配置管理】-【配置列表】-点击+号添加配置,然后在弹出的表单中,填写配置信息:Data ID: userservice-dev.propertiesGroup: DEFAULT_GROUP描述:开发环境配置配置格式:properties配置内容:pattern.dateformat=yyyy-MM-dd HH:mm:ss> 注意:项目的核心配置,需要热更新的配置才有放到nacos管理的必要。基本不会变更的一些配置还是保存在微服务本地比较好。
  2. 微服务要拉取nacos中管理的配置,并且与本地的application.yml配置合并,才能完成项目启动。但如果尚未读取application.yml,又如何得知nacos地址呢?因此spring引入了一种新的配置文件:bootstrap.yaml文件,会在application.yml之前被读取,流程就是在项目启动时会读取先bootstrap.yaml和nacos上的配置信息,并整合到项目中,读取application.properties文件,创建spring容器并加载bean。
  3. 首先,在user-service服务中,引入nacos-config的客户端依赖:<!--nacos配置管理依赖--><dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency>
  4. 然后,在user-service中添加一个bootstrap.properties文件,内容如下:spring.application.name=userservicespring.profiles.active=devspring.cloud.nacos.server-addr=localhost:8848spring.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,来读取配置。
  5. 在user-service中的UserController中添加业务逻辑,读取pattern.dateformat配置:@Value("${pattern.dateformat}")private String dateformat; @GetMapping("now")public String now(){ return LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateformat));}
  6. 我们最终的目的,是修改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;}
  7. 修改UserController的业务逻辑@Autowiredprivate PatternProperties patternProperties;​@GetMapping("now")public String now(){ return LocalDateTime.now().format(DateTimeFormatter. ofPattern(patternProperties.getDateformat()));}
  8. 配置共享:创建配置时,将Data ID设置为 服务名.properties 即可。

四:feign远程调用

  1. 使用RestTemplate的方式存在一些问题:•代码可读性差,编程体验不统一•参数复杂URL难以维护
  2. 可以创建一个新的module将feign的功能代码独立出来,并将对应的实体类也转移到新module中
  3. 首先在module服务的pom文件中引入feign的依赖:<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId></dependency>
  4. 创建UserClient接口:@FeignClient(value ="userservice",configuration = DefaultFeignConfiguration.class)public interface UserClient { @GetMapping("/user/{id}") User findById(@PathVariable("id") Long id);}
  5. 在order-service项目中导入feign-api服务的依赖:<dependency> <groupId>cn.itcast.demo</groupId> <artifactId>feign-api</artifactId> <version>1.0</version></dependency>
  6. 修改order-service中的OrderService类中的queryOrderById方法,使用Feign客户端代替RestTemplate:@Autowiredprivate 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;}
  7. 自定义配置比如设置日志打印机别,而日志的级别分为四种:- 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)

调试过程中遇到的问题

  1. 在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字段值
标签: java 微服务 eureka

本文转载自: https://blog.csdn.net/qq_43305367/article/details/123871958
版权归原作者 叽哩咕噜~~ 所有, 如有侵权,请联系我们删除。

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

还没有评论