皮皮网
皮皮网

【牛牛源码】【织梦门户源码】【软件网源码】springcloudeureka源码

时间:2024-12-23 22:46:44 来源:小说站源码 程序

1.搭建springcloud架构(springcloud完整架构流程)
2.Spring Cloud Eureka源码分析之心跳续约及自我保护机制
3.SpringCloud(3):使用Ribbon进行负载均衡配置,以及遇坑指南
4.SpringCloud组件:Eureka服务注册是采用主机名还是IP地址?

springcloudeureka源码

搭建springcloud架构(springcloud完整架构流程)

       微服务架构下的Spring Cloud项目搭建(一、框架简介)旨在为希望学习搭建Spring Cloud项目的开发者提供一个从零开始的详细教程。欢迎各位技术同仁参与讨论,互助学习,共同进步。牛牛源码项目源码存放于Gitee,具体链接请参考文末。使用IntelliJ IDEA从零开始搭建Spring Cloud微服务项目。以下内容基于一个微服务新手的实践经验,仅供参考。

       1. 启动Spring Cloud Eureka注册中心

        所有服务都将作为Eureka客户端注册到该中心,并通过服务名实现服务间的相互调用。

       2. Spring Cloud Config提供统一配置

        其他服务可以读取这些配置信息。

       3. 提供者服务(Provider)

        生产者服务不直接暴露给外部,仅供消费者服务调用。

       4. Spring Cloud Gateway作为统一入口

        用户通过该网关访问消费者服务。

       接下来,在空Maven项目中创建新的模块,可以选择使用Spring Initializr快速生成Spring Cloud模块,或者继续创建空模块。

       - `common`模块:存放公共库,如DAO、模型、织梦门户源码工具类等。

       - `config-dev`模块:存储开发环境配置文件,提交到git后,Spring Cloud Config会从中读取配置。

       大部分服务(非独立应用如Spring Cloud Config、Spring Cloud Gateway等)需要添加`spring-boot-starter-web`依赖以构建Web应用。

       以下是在IntelliJ IDEA中使用Spring Initializr构建新模块的步骤。

       在配置文件中,`bootstrap.yml`具有较高优先级,会首先加载且不会被`application.yml`覆盖。因此,相关的Spring Cloud配置需在`bootstrap.yml`中设置。

       在Spring Cloud Gateway的配置中,展示了如何从配置仓库`config-dev`中读取配置文件。`spring.cloud.config`和`eureka.client`的配置已经在`bootstrap.yml`中设置,故不再详述。

       在多模块项目中,为了扫描其他模块的MyBatis文件,需要进行额外的配置。

       消费者服务可以通过Feign进行声明式服务调用。

       Spring Cloud微服务架构能够将服务解耦,独立部署,结合devops实践能充分发挥其优势。软件网源码GitLab提供了内置的devops功能,通过在项目中添加`.gitlab-ci.yml`文件,推送至GitLab后可自动执行预设命令。接下来,简要介绍GitLab的安装部署。

       在CentOS 7中,默认的Git版本为1.8.3.1,需要更新至最新版本,否则在执行自动构建时会出现错误。更新步骤请参考GitLab官方文档。

       GitLab和GitLab Runner的安装配置请参考官方文档。

       在配置文件`/etc/gitlab/gitlab.rb`中进行必要的配置。

       下面通过一系列步骤快速搭建一个简单的Spring Cloud微服务工程。首先,父工程继承`spring-boot-starter-parent`,以便子工程能够作为Spring Boot项目自动创建,并统一Spring Cloud的依赖版本为`Finchley.RELEASE`。

       选择Eureka作为注册中心,创建一个新的子工程并指定父工程。导入Eureka服务端启动器和Web支持。

       订单服务作为一个Eureka客户端,同样指定父工程并导入相关依赖。

       用户服务同样作为Eureka客户端,家居网站源码导入依赖并启动。

       在IDE中配置好相关依赖和启动器后,启动Eureka服务端工程,随后启动订单服务和用户服务,验证服务是否成功注册至Eureka。

       接下来,在订单服务中作为服务提供者,允许用户服务调用订单信息。

       使用浏览器调用用户服务的接口,验证订单服务是否成功被调用。

       最后,列出开发工具和使用的版本信息,确保Spring Boot和Spring Cloud版本对应。

       本文档主要作为Spring Cloud微服务入门搭建及服务调用的教程,开发工具为IntelliJ IDEA .2.3,Java版本为1.8,Maven版本为3.3.9,Spring Boot为2.1.3.RELEASE,Spring Cloud为Greenwich.SR5。

       IDE配置不再详述,之后直接配置`pom.xml`。对于独立的服务项目,可以选择继承父项目或独立配置依赖。美菜网源码在`pom.xml`中,指定Spring Boot和Spring Cloud版本。

       在控制器中调用其他服务接口,可以使用RestTemplate实现,并配置相应的RestTemplate配置文件。

       在用户服务启动类中,通过RestTemplate调用订单服务接口。

       在浏览器中访问相应的接口,验证服务之间的调用是否成功。

Spring Cloud Eureka源码分析之心跳续约及自我保护机制

       Eureka Server 判断服务不可用的机制是基于心跳续约的健康检查。客户端每秒发起一次心跳续约请求,服务端通过该机制检测服务提供者的状态。心跳续约的周期可以调整,通过配置参数来修改。客户端的续约流程主要在 DiscoveryClient.initScheduledTasks 方法中实现,其中 renewalIntervalInSecs=s,即默认周期为秒。续约线程 HeartbeatThread 调用 renew() 方法,将请求发送到 Eureka Server 的 "apps/" + appName + '/' + id 地址,以更新服务端的最后一次心跳时间。

       服务端在收到心跳请求时,调用 InstanceResource 类的 renewLease 方法进行续约处理。续约实现主要涉及两个步骤:从应用对应的实例列表中获取实例信息,然后调用 Lease.renew() 方法进行续约。续约过程更新了服务端记录的服务实例的最后一次心跳时间。

       Eureka 提供了一种自我保护机制,以避免因网络问题导致健康服务被误删除的情况。该机制在服务端收到的心跳请求低于特定比例(默认为%)时启动,以保护服务实例免于过期被剔除,保证集群的稳定和健壮性。开启自我保护机制的配置项为 eureka.server.enable-self-preservation,并默认开启。若服务客户端与注册中心之间出现网络故障,Eureka Server 会检测到低于%的正常心跳请求,进而自动进入自我保护状态。

       自我保护机制的阈值设置通过配置参数进行调整,具体计算公式为:(服务实例总数 * 0.)。例如,对于个服务实例,预期每分钟收到的续约请求数量为个。若实际收到的续约请求数量低于这个值,Eureka Server 将触发自我保护机制。此外,预期续约数量会随着服务注册和下线的变化而动态调整。当服务提供者主动下线时,需要更新客户端数量,反之则需增加。每隔分钟,自我保护阈值自动更新一次,以适应服务动态变化的场景。

       在 Eureka Server 启动时,通过 EurekaServerBootstrap 类的 contextInitialized 方法初始化 Eureka Server 的上下文,包括配置预期每分钟收到的续约客户端数量(expectedNumberOfClientsSendingRenews)。在 openForTraffic 方法中,初始化 expectedNumberOfClientsSendingRenews 和 numberOfRenewsPerMinThreshold 值,以确保自我保护机制正常运行。这些值会根据服务注册和下线情况动态调整,以维持系统的稳定性和准确性。

SpringCloud(3):使用Ribbon进行负载均衡配置,以及遇坑指南

       使用Ribbon进行负载均衡配置是Spring Cloud体系中的一种关键实践。由于Eureka中已经集成了Ribbon,因此无需额外引入依赖。启动多个服务提供方时,在服务消费方的启动类中启用@LoadBalanced注解来激活负载均衡机制。将@LoadBalanced注解添加到消费方的RestTemplate方法上,即可实现通过服务名调用提供方的服务。

       在配置过程中,服务消费方通常使用DiscoveryClient来获取提供方的服务列表,并通过该列表指定具体的服务实例及其主机和端口。然而,开启负载均衡后,系统会自动选择合适的服务实例,无需人工指定,以提升服务调用的效率和可用性。

       值得注意的是,一旦使用了@LoadBalanced注解,直接访问提供方的特定主机名和端口号会引发异常(如java.lang.IllegalStateException: No instances available for localhost)。同时,服务名中应避免使用下划线,否则可能会遇到请求URI格式错误(如Request URI does not contain a valid hostname: service_provider/user/4...)的问题。

       在消费方控制器中,实现远程服务调用时,负载均衡效果通过LoadBalancerInterceptor和RibbonLoadBalancerClient类的源码展现。RibbonLoadBalancerClient通过默认的轮询策略分配服务实例,而其他策略如随机策略则可以在消费方配置文件中进行指定。重新运行测试用例后,负载均衡策略的切换效果明显。

       深入RibbonLoadBalancerClient源码,可以观察到通过BaseLoadBalancer类的chooseServer方法调用rule接口以执行负载均衡策略,其中轮询策略(RoundRobinRule)是默认设置。除了轮询策略之外,随机策略等其他负载均衡策略也可通过配置文件进行选择,以适应不同场景的需求。在实践过程中,通过测试和调整配置,可以有效提升服务调用的负载均衡效果。

SpringCloud组件:Eureka服务注册是采用主机名还是IP地址?

       1. 在微服务架构中,Eureka 服务注册通常涉及服务提供者和服务注册中心之间的交互。服务提供者在启动时会向 Eureka Server 注册自己,这个过程可以指定使用主机名或 IP 地址。

       2. 在本节的示例中,我们复制了 SpringCloud 组件的源码,并修改了项目名称,同时对 `application.yml` 配置文件进行了简单的调整。

       3. 配置文件中并未明确指定注册方式,因此服务会使用默认设置进行注册。默认情况下,Eureka Client 倾向于使用 IP 地址进行注册。

       4. 我们通过搭建一个 Eureka Server 实例,来探索服务注册的实际行为。当我们访问一个注册的服务时,默认情况下会被重定向到服务的监控信息界面,这里显示的 URL 表明了注册时使用的地址是 IP 地址。

       5. 如果我们希望服务使用主机名进行注册,可以在 `application.yml` 文件中修改 `eureka.instance.hostname` 配置。

       6. 在 Linux 系统中,我们需要更新 `/etc/hosts` 文件以包含主机名和 IP 地址的映射。对于 Windows 系统,则需编辑 `C:\Windows\System\drivers\etc\hosts` 文件。

       7. 修改配置后,观察到访问路径从 IP 地址变为了主机名,证实了服务已经使用主机名进行了注册。

       8. 如果你希望服务优先使用 IP 地址注册,可以通过设置 `eureka.instance.prefer-ip-address` 参数为 `true`。

       9. 如果我们想要服务使用一个特定的 IP 地址进行注册,可以设置 `eureka.instance.ip-address` 参数。

       . 完成配置文件修改后,进行测试以确保新的设置有效。我们发现访问地址已经反映了我们为服务设置的指定 IP 地址。

       . 本节详细介绍了 Eureka Client 注册时使用的不同服务名称方式,并指出了它们之间的优先级顺序。下一节将深入分析这些注册方式的内部机制和优先级。

       . 本文的源码已上传至恒宇少年的码云账户,建议结合源码进行学习,感谢您的阅读。

更多内容请点击【休闲】专栏