开发者社区> 攻城狮Chova> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

简介: 本文针对微服务项目中的多个服务难以管理的问题,提出了一个使用API网关对微服务中的多种服务进行管理的方案,使用API网关实现微服务中的服务聚合管理。介绍了微服务中的API Gateway网关技术的使用方式和在项目中集成使用API Gateway的具体配置。通过详细的实例说明了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;
    }
}

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
SSM+微信小程序实现物业管理系统
ssm微信小程序物业管理系统,有网站后台管理系统 项目描述 微信小程序物业管理系统,微信小程序端包括以下几个模块: 社区公告、报修、信息采集、生活缴费、二手置换 微信小程序后台管理界面可以增删改查社区公告、问卷、问卷问题、问题选项等 在微信小程序前端,用户提交信息后,可在我的界面查看提交的信息,管理员可以在微信小程序后台管理界面查看所有用户提交的信息。
17 0
SSM 整合redis,使用AOP实现缓存过滤器
SSM 整合redis,使用AOP实现缓存过滤器
23 0
【laravel项目】@2 账号密码登录验证(1)
【laravel项目】@2 账号密码登录验证
19 0
SSM项目使用拦截器实现登录验证功能
本文讲解SSM项目使用拦截器实现登录验证功能,希望对大家有所帮助。
45 0
使用C4C ABSL获得当前登录用户所在的organization unit信息
使用C4C ABSL获得当前登录用户所在的organization unit信息
23 0
全志A33 lichee lvds屏幕配置
开发平台 * 芯灵思SinlinxA33开发板 淘宝店铺: [https://sinlinx.taobao.com/]() 嵌入式linux 开发板 **芯灵思SinlinxA33开发板支持lcd,lvds,dsi屏幕接口,这节通过制作添加lvds配置文件,使其支持lvds屏幕。
1932 0
日志服务与SIEM(如Splunk)集成方案实战
本文主要介绍如何让阿里云日志服务与您的SIEM方案(如Splunk)对接, 以便确保阿里云上的所有法规、审计、与其他相关日志能够导入到您的安全运维中心(SOC)中。 注意:相关代码已经正式发布为Splunk采集插件,推荐直接访问下载使用:https://splunkbase.splunk.com/app/4934/
12212 0
日志服务(原SLS)2018-1 月功能发布
2018年1月版本已发布,包含:Mysql Binlog/JDBC/Http Reqeust采集,IP位置/经纬度分析函数,Log4J/LogBack Appender,OSS访问日志分析等功能,欢迎试用!
4389 0
分布式服务Dubbo从入门到"精通"之Schema实现
前言 尽管使用了Dubbo许久,但其实对于其了解还是九牛一毛,上个月通读了Netty实战(粗略的了解),突然有了解读Dubbo源码的欲望,时不待我,那就赶紧开始吧。 熟悉Dubbo的朋友,可能都知道其采用全Spring配置方式,透明化接入应用,对应用没有任何API侵入,只需用Spring加载Dubbo的配置即可,Dubbo基于Spring的Schema扩展进行加载。
5055 0
+关注
攻城狮Chova
一位有自我修养的攻城狮。 2006年《时代》周刊年度人物, 2008年感动中国组委会特别奖获得者。 专注分享技术干货,面试经验和攻城狮故事~ 欢迎点赞关注支持,是我持续进步的动力!
79
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载