微服务项目服务管理混乱?来看这一篇生产者消费者服务实践,使用API网关实现服务聚合

Posted 攻城狮Chova

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了微服务项目服务管理混乱?来看这一篇生产者消费者服务实践,使用API网关实现服务聚合相关的知识,希望对你有一定的参考价值。

API网关的服务聚合

  • 通过同一个入口路由到不同的服务上

    服务聚合实现

  • 由于服务器在集群部署的时候,同一个服务内容存在多个不同的服务IP地址,所以不能直接通过IP地址访问服务
  • API服务访问的时候要先获取服务的IP地址,然后再访问服务
  • 进行服务聚合的项目要称为服务提供者(实现服务接口),服务提供者的SpringApplication要加Main.main(args)提供远程调用接口给API网关
  • 此时可以获取到服务的IP地址
  • 如何获取服务IP地址?

    上下文信息:
    上下文中存放的是当前调用过程中所需的环境信息,所有配置信息都将转换为 URL 的参数.
    RpcContext 是一个 ThreadLocal 的临时状态记录器,当接收到 RPC 请求,或发起 RPC 请求时,RpcContext 的状态都会变化.
    比如:A 调 B,B 再调 C,则 B 机器上,在 B 调 C 之前,RpcContext 记录的是 A 调 B 的信息,在 B 调 C 之后,RpcContext 记录的是 B 调 C 的信息
    
    服务消费方:
    ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
    // 远程调用
    xxxService.xxx();
    // 本端是否为消费端,这里会返回true
    boolean isConsumerSide = RpcContext.getContext().isConsumerSide();
    // 获取最后一次调用的提供方IP地址
    String serverIP = RpcContext.getContext().getRemoteHost();
    // 获取当前服务配置信息,所有配置信息都将转换为URL的参数
    String application = RpcContext.getContext().getUrl().getParameter("application");
    // 注意:每发起RPC调用,上下文状态会变化
    yyyService.yyy();
    --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
    服务提供方:
    --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
    public class XxxServiceImpl implements XxxService {
     
      public void xxx() {
          // 本端是否为提供端,这里会返回true
          boolean isProviderSide = RpcContext.getContext().isProviderSide();
          // 获取调用方IP地址
          String clientIP = RpcContext.getContext().getRemoteHost();
          // 获取当前服务配置信息,所有配置信息都将转换为URL的参数
          String application = RpcContext.getContext().getUrl().getParameter("application");
          // 注意:每发起RPC调用,上下文状态会变化
          yyyService.yyy();
          // 此时本端变成消费端,这里会返回false
          boolean isProviderSide = RpcContext.getContext().isProviderSide();
      } 
    }
    ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
  • 在配置文件的service中配置上需要聚合的服务以及版本
  • 创建路由controller

    @Controller
    public class RouterController{
    
      @Value(value=${services.ports.user})
      private String userPort;
    
      @Value(value=${services.ports.content})
      private String contentPort;
      
      @Reference
      private UserConsumerService userConsumerService;
    
      @Reference
      private ContentConsumerService contentConsumerService;
    
      @RequestMapping(value="user",method=RequestMethod.GET)
      public String user(String path){
          userConsumerService.info();
          return getRequest(userPort,path);
      }
    
      @RequestMapping(value="content",method=RequestMethod.GET)
      public String content(String path){
          contentConsumerService.info();
          return getRequest(contentPort,path);
      }
      
      public String getRouter(String serverPort,String path){
          // 判断是否为消费者
          boolean isConsumerSide=RpcContext.getContext().isConsumerSide();
          if(isConsumerSide){
              // 获取最后一次调用的提供方的IP地址
              String serverIP=RpcContext.getContext().getRemoteHost()
              return String.format("redirect:http://%s:%s%s",serverIP,serverPort,path);
          }
          return null;
      }
    }

以上是关于微服务项目服务管理混乱?来看这一篇生产者消费者服务实践,使用API网关实现服务聚合的主要内容,如果未能解决你的问题,请参考以下文章

微服务实战:落地微服务架构到直销系统(将生产者与消费者接入消息总线)

微服务设计指导-通过一个生产事故的具体例子来看微服务

002 服务中心

微服务上云后本地如何联调?

微服务上云后本地如何联调?

微服务上云后本地如何联调?