编码实现Spring Cloud微服务负载均衡调用(eureka、ribbon)

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: Spring 封装、揉和了一批开源项目,其中以Netflix开源的为主,比如zuul、eureka、hystrix、robbin等;然后就有了现在的Spring cloud微服务架构。这也充分展现了Spring的揉合能力。 Spring cloud通过封装使这些项目融入spring的bean管理机制中,从而方便使用。这套微服务的核心功能还是使用这些项目的。 由本篇的标题可以想到本篇就是

Spring 封装、揉和了一批开源项目,其中以Netflix开源的为主,比如zuul、eureka、hystrix、robbin等;然后就有了现在的Spring cloud微服务架构。这也充分展现了Spring的揉合能力。

Spring cloud通过封装使这些项目融入spring的bean管理机制中,从而方便使用。这套微服务的核心功能还是使用这些项目的。

由本篇的标题可以想到本篇就是不使用Spring的注解和配置来使用这套微服务。看看现在网上关于Spring cloud的示例,千篇一律那几行注解和代码。确实方便了使用。

本篇主要从微服务的调用端来讲解的,主要涉及如下几点:

  1. 全局配置,包括服务注册中心配置;
  2. 初始化服务发现客户端;
  3. 实例化负载均衡调用实现类;
  4. 实例化某个具体调用requset,再对根据服务均衡器选择的服务提供者进行调用;

如果你使用过dubbo的泛化调用,会发现很相似;难怪有人专门对比使用Spring cloud和dubbo来实现微服务。

如下为编码实现的例子,很多说明在注解中;

EurekaClientConfigBean bean = new EurekaClientConfigBean();
        Map<String, String> map = new HashMap<String, String>();
        //eureka服务注册中心地址
        map.put(EurekaClientConfigBean.DEFAULT_ZONE,"http://xx.xx.xxx.xx:1062/eureka/,http://xx.xx.xxx.xx:1063/eureka/,http://xx.xx.xxx.xx:1064/eureka/");
        bean.setServiceUrl(map);

        EurekaInstanceConfigBean instanceConfigBean = new EurekaInstanceConfigBean(new InetUtils(new InetUtilsProperties()));
        instanceConfigBean.setPreferIpAddress(true);

        ApplicationInfoManager applicationInfoManager = new ApplicationInfoManager(instanceConfigBean);
        //以上完成全局配置,基本使用默认配置

        //实例化eureka服务消费端,查询Eureka Server中的服务实例列表
        final DiscoveryClient client = new DiscoveryClient(applicationInfoManager, bean);
        Provider<EurekaClient> eurekaClientProvider = new Provider<EurekaClient>() {
            @Override
            public synchronized EurekaClient get() {
                return client;
            }
        };

        IClientConfig clientConfig = new DefaultClientConfigImpl();
        clientConfig.loadDefaultValues();
        //设置vipAddress,该值对应spring.application.name配置,指定某个应用
        clientConfig.set(CommonClientConfigKey.DeploymentContextBasedVipAddresses,"ZPROVIDER");

        //根据eureka client获取服务列表,client以provide形式提供
        DiscoveryEnabledNIWSServerList discoveryEnabledNIWSServerList = new DiscoveryEnabledNIWSServerList(clientConfig, eurekaClientProvider);

        //实例化负载均衡器接口ILoadBalancer,这里使用了ZoneAwareLoadBalancer,这也是spring cloud默认使用的。该实现可以避免了跨区域(Zone)访问的情况。
        //其中的参数分别为,1)某个具体应用的客户端配置,2)负载均衡的处理规则IRule对象,负载均衡器实际进行服务实例选择任务是委托给了IRule实例中的choose函数来实现,
        //这里使用了ZoneAvoidanceRule,3)实例化检查服务实例是否正常服务的IPing接口对象,负载均衡器启动一个用于定时检查Server是否健康的任务。该任务默认的执行间隔为:10秒。
        //这里没有做真实的ping操作,他只是检查DiscoveryEnabledNIWSServerList定时刷新过来的服务列表中的每个服务的状态;4)如上,ServerList接口有两个方法,分别为
        //获取初始化的服务实例清单和获取更新的服务实例清单;5)ServerListFilter接口实现,用于对服务实例列表的过滤,根据规则返回过滤后的服务列表;6)ServerListUpdater服务更新器接口
        //实现动态获取更新服务列表,默认30秒执行一次
        ILoadBalancer loadBalancer = new ZoneAwareLoadBalancer(clientConfig, new ZoneAvoidanceRule(), new NIWSDiscoveryPing(),
                discoveryEnabledNIWSServerList,new DefaultNIWSServerListFilter(), new EurekaNotificationServerListUpdater(eurekaClientProvider));

        //实例化request client,他对由负载均衡器选择的Server进行请求,Spring cloud封装了apache HttpClient和OkHttp两种实现
        RibbonLoadBalancingHttpClient ribbonLoadBalancingHttpClient = new RibbonLoadBalancingHttpClient(clientConfig, new DefaultServerIntrospector());
        ribbonLoadBalancingHttpClient.setLoadBalancer(loadBalancer);

//        OkHttpLoadBalancingClient okHttpLoadBalancingClient = new OkHttpLoadBalancingClient(clientConfig, new DefaultServerIntrospector());
//        okHttpLoadBalancingClient.setLoadBalancer(loadBalancer);

        //实例化某个具体request的上下文,如果对应到开放平台上,这些信息就是开放某个具体接口时,录入的API信息
        RibbonCommandContext context = new RibbonCommandContext("ZPROVIDER","get", "/test/weber", Boolean.FALSE, new HttpHeaders(),
                new LinkedMultiValueMap(), null, new ArrayList<RibbonRequestCustomizer>(), null);

        RibbonCommandContext context1 = new RibbonCommandContext("ZPROVIDER","get", "/sum?v=2&vv=3", Boolean.FALSE, new HttpHeaders(),
                new LinkedMultiValueMap(), null, new ArrayList<RibbonRequestCustomizer>(), null);

        BufferedReader br = null;
        String result = "";
        try {
            //实例化request,对Service请求调用
            RibbonApacheHttpResponse response = ribbonLoadBalancingHttpClient.executeWithLoadBalancer(new RibbonApacheHttpRequest(context1));

//            OkHttpRibbonResponse response = okHttpLoadBalancingClient.executeWithLoadBalancer(new OkHttpRibbonRequest(context1));

            //如果服务接口输出json或xml,可以拿到显示
            br = new BufferedReader(new InputStreamReader(response.getInputStream()));
            String line = null;
            while((line = br.readLine())!=null){
                result+=line;
            }
            System.out.println("Result: "+result);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            if(null!=br){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

zuul实现了网关框架,主要逻辑为执行pre、route、post三种类型的filter,且可以动态加载filter,使用方可以实现自己的filter。

Spring cloud封装实现的route类型filter,默认使用了ribbon对eureka 服务发现的负载均衡client。

Spring cloud在结合了ribbon的负载均衡实现中,封装增加了HttpClient和OkHttp两种HTTP请求端实现。

Spring cloud中还集成了Feign,方便的使用HTTP请求调用远程服务,且可以灵活的使用和自定义各种编解码器实现入参和出差的序列化和反序列化。

做上面的代码示例的想法来源于现在负责的网关项目中一些需求想法,之前网关只适配了dubbo类型的rpc服务集群,目前一些新项目开始试行spring cloud架构,所以网关在做对应的适配。图例如下:

网关适配

相关实践学习
部署高可用架构
本场景主要介绍如何使用云服务器ECS、负载均衡SLB、云数据库RDS和数据传输服务产品来部署多可用区高可用架构。
负载均衡入门与产品使用指南
负载均衡(Server Load Balancer)是对多台云服务器进行流量分发的负载均衡服务,可以通过流量分发扩展应用系统对外的服务能力,通过消除单点故障提升应用系统的可用性。 本课程主要介绍负载均衡的相关技术以及阿里云负载均衡产品的使用方法。
目录
相关文章
|
15天前
|
消息中间件 Java RocketMQ
Spring Cloud RocketMQ:构建可靠消息驱动的微服务架构
【4月更文挑战第28天】消息队列在微服务架构中扮演着至关重要的角色,能够实现服务之间的解耦、异步通信以及数据分发。Spring Cloud RocketMQ作为Apache RocketMQ的Spring Cloud集成,为微服务架构提供了可靠的消息传输机制。
28 1
|
17天前
|
负载均衡 Java 网络架构
【SpringCloud】如何理解分布式、微服务、集群
【SpringCloud】如何理解分布式、微服务、集群
24 1
|
17天前
|
Java 数据安全/隐私保护 Sentinel
微服务学习 | Spring Cloud 中使用 Sentinel 实现服务限流
微服务学习 | Spring Cloud 中使用 Sentinel 实现服务限流
|
18天前
|
负载均衡 算法
SpringCloud&Ribbon负载均衡原理与实践
SpringCloud&Ribbon负载均衡原理与实践
20 3
|
18天前
|
运维 监控 Java
SpringCloud&认识微服务
SpringCloud&认识微服务
18 0
|
25天前
|
人工智能 监控 安全
Java+Spring Cloud +Vue+UniApp微服务智慧工地云平台源码
视频监控系统、人员实名制与分账制管理系统、车辆管理系统、环境监测系统、大型设备监测(龙门吊、塔吊、升降机、卸料平台等)、用电监测系统、基坑监测系统、AI算法分析(安全帽佩戴、火焰识别、周界报警、人员聚众报警、升降机超载报警)、安全培训、设备监测。
30 4
|
26天前
|
负载均衡 Java 开发者
细解微服务架构实践:如何使用Spring Cloud进行Java微服务治理
【4月更文挑战第17天】Spring Cloud是Java微服务治理的首选框架,整合了Eureka(服务发现)、Ribbon(客户端负载均衡)、Hystrix(熔断器)、Zuul(API网关)和Config Server(配置中心)。通过Eureka实现服务注册与发现,Ribbon提供负载均衡,Hystrix实现熔断保护,Zuul作为API网关,Config Server集中管理配置。理解并运用Spring Cloud进行微服务治理是现代Java开发者的关键技能。
|
1月前
|
监控 负载均衡 Java
深入探究Java微服务架构:Spring Cloud概论
**摘要:** 本文深入探讨了Java微服务架构中的Spring Cloud,解释了微服务架构如何解决传统单体架构的局限性,如松耦合、独立部署、可伸缩性和容错性。Spring Cloud作为一个基于Spring Boot的开源框架,提供了服务注册与发现、负载均衡、断路器、配置中心、API网关等组件,简化了微服务的开发、部署和管理。文章详细介绍了Spring Cloud的核心模块,如Eureka、Ribbon、Hystrix、Config、Zuul和Sleuth,并通过一个电商微服务系统的实战案例展示了如何使用Spring Cloud构建微服务应用。
103533 9
|
1月前
|
负载均衡 算法 应用服务中间件
面试题:Nginx有哪些负载均衡算法?Nginx位于七层网络结构中的哪一层?
字节跳动面试题:Nginx有哪些负载均衡算法?Nginx位于七层网络结构中的哪一层?
42 0
|
24天前
|
负载均衡 应用服务中间件 nginx
Nginx 负载均衡
Nginx 负载均衡
25 2