微服务初始及Eureka注册中心

1,架构演变

单体架构:将所有业务功能集中在一个项目中开发,达成一个包部署

优点:·架构简单,部署成本低

缺点:项目耦合度高

分布式架构:根据业务功能对系统进行拆分,每个业务作为独立项目开发,成为一个服务

优点:降低耦合,有利于拓展升级。

缺点:架构复杂,难度大,适用于大型的互联网项目。

微服务:一种经过良好架构设计的分布式架构方案

微服务架构特征:

1,单一职责:微服务拆分粒度小,每一个服务对应唯一的业务,做到单一职责,避免业务重复开发

2,面向服务:微服务需要对外暴露接口。

3,自治:也就是独立,团队,技术,数据库,部署等各自独立

4,隔离性强

微服务落地技术

2,微服务技术发展:

                早期的实现Dubbo(Alibaba),不是很完善,Dubbo主要是做远程调用的,之后(2015-2017)微服务技术发展迅速,大量的技术出现,直至SpringCloud诞生,它整合了市面上流行的微服务技术,提供了注册中心,远程调用,配置中心,网关,监控保护等等,之后又诞生了SpringCloudAlibaba,他实现了SpringCloud的一系列标准。增加了自己的注册中心,配置中心等等

      企业需求:

3,Spring Cloud

       简介: Spring Cloud 是一系列框架的有序集合,它利用 Spring Boot 的开发便利性简化了分布式系统的开发,比如服务发现、服务网关、服务路由、链路追踪等。Spring Cloud 并不重复造轮子,而是将市面上开发得比较好的模块集成进去,进行封装,从而减少了各模块的开发成本。换句话说:Spring Cloud 提供了构建分布式系统所需的“全家桶”

Spring CloudLevel up your Java code and explore what Spring can do for you.icon-default.png?t=N7T8https://spring.io/projects/spring-cloud

服务拆分及远程调用注意事项

        1,微服务需要根据业务模块拆分,做到单一职责,不能重复开发相同的业务

        2,微服务可以将业务暴露为接口,提供给其他微服务使用。

        3,不同微服务都应该有自己独立的数据库

服务调用关系

服务消费者:调用其他服务的服务

服务提供者:被其他微服务调用的服务

总而言之:服务的消费者和提供者关系是相对的,提供者和消费者角色是相对的,既可以是消费者也可以是提供者。

4,Eureka注册中心

服务远程调用:

需求:目前有两个模块,一个订单模块,一个用户模块,订单中包含用户id,现在需要查询出订单的同时返回对应的用户信息,这时候就需要服务的远程调用,其本质就是发送http请求获取数据而已

实现方式:RestTemplate

代码实现:

        1,配置一个RestTemplate

@Configuration
public class RestTemplateConfig {@Beanpublic RestTemplate getRestTemplate(){return new RestTemplate();}
}

        2,发起调用


@Service
public class OrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate RestTemplate restTemplate;public Order queryOrderById(Long orderId) {// 1.查询订单Order order = orderMapper.findById(orderId);// 2.使用RestTemplate对象发送请求查询该用户id对应的用户Long userId = order.getUserId();String url="http://localhost:8081/user/"+userId;User us = restTemplate.getForObject(url, User.class);// 3.封装user到order中order.setUser(us);// 4.返回return order;}
}

但是这样调用存在硬编码的问题,请求的接口已经被写死了,代码耦合度太高,于是乎我们使用eureka搭建注册中心,来解决这个问题

Eurake作用:

        1,服务的注册中心:服务提供者启动时会想Eureka中注册自己的信息,Eureka记录,消费者根据服务名称想Eureka拉取提供者信息。

        2,感知服务健康状态:服务提供者会每隔30s向Eureka发送心跳请求,报告健康状态,如果心跳不正常会被踢出,消费者就可以拉取健康的服务。

        3,负载均衡:服务消费者会使用负载均衡算法从服务列表中选取提供者提供给消费者

 Eureka架构

 

Eureka实战
        1,搭建Eureka注册中心-Eureka的服务端

            首先在项目根目录下面重新创建一个maven项目,指定父工程,引入eureka依赖,这里没有指定版本是因为父工程已经制定了springCloud的版本(这里注意一下java版本

 <!--引入eureka服务端的依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency>

               之后编写启动类,添加@EnableEurekaServer注解,报名开启eureka服务,如果不加就会报错Cannot execute request on any known server

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {public static void main(String[] args) {SpringApplication.run(EurekaServerApplication.class,args);}
}

                    最后,在配置文件中配置eureka服务端口信心,服务名信息,eureka地址等

server:port: 10086 #Eureka服务端端口
spring:application:name: eurekaserver #eureka服务名,
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka/ #将eureka自己也注册进eureka

成功之后如下图,启动项目:

 

步骤参考如下图 

        2,服务注册-Eureka的客户端

首先在需要被注册近eureka中的服务中引入eureka客户端依赖

 <!--引入eureka客户端的依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

        之后在配置文件中配置该服务的名称,以及eureka注册中心的地址

server:port: 8080
spring:application:name: userservice #指定Eureka中这个项目的服务名
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka/ #将该服务注册进eureka注册中心

        最后启动该服务,若注册中心中存在该服务,则证明配置完成,如下图: 

并且,我们可以将一个服务的多次启动,在idea中如下操作:

 并且为避免端口冲突我们需要在VM options中配置参数  -Dserver.port=8082

我么可以看到userservice启动了两个实例,分别在8081和8082端口

其余服务也是类似操作 

完整步骤可参考下图: 

        3,服务发现-服务远程调用

        在上述步骤中我们已经搭建完成eureka注册中心,并且将两个服务userservice和orderservice注册进eureka注册中心中,接下来我们就从注册中心中拉取服务,远程调用

        第一步,在orderservice的service代码中们也就是向userservice中发起请求查询用户代码中修改url地址,将ip替换为服务名。也就是将localhost:8081替换为userservice即可

        第二步,在RestTemplate中加上@LoadBalanced注解,他就代表RestTemplate发起的请求要被Ribbon拦截和处理,也就是执行负载均衡,因为我们userservice中有两个服务,分别是8081和8082

·        实现步骤如下图,这里的注解添加位置根据自己的实际配置位置来添加:

        4 ,负载均衡原理 

        在我们使用orderservice向userservice中发起请求的时候,直接请求userservice是请求不到的没因为他不是一个ip,我们请求发送之后,会先到达Ribbon,他会向eureka注册中心拉取userservice服务,周eureka会发挥userservcice对应的服务列表,也就是真实的ip,然后Ribbon发现有多个服务列表,他就会进行负载均衡,流程图如下:

那莫Ribbon具体是如何实现负载均衡的呢, 我们的请求准确的来说会被LoadBanlancerInterceptor这个拦截器拦截,拦截之后根据服务名拉去服务,之后执行负载均衡,其中负载均衡执行策略有一个IRule接口来定义,主要有以下策略

负载均衡流程图: 

默认的负载均衡策略是ZoneAvoidanceRule,但是我们还是可以自定义负载均衡策略的,定义方式有两种:

第一种:直接在配置类中定义一个IRule,返回需要执行的负载均衡策略,这种方式会让整个服务都执行这种负载均衡策略,实现方式如下,可以自由选择:

第二:在当前服务的配置文件中指定需要更换负载均衡策略的服务,实现如下

两种负载均衡策略: 

至此,Eureka注册中心使用就到这里了,下个博客-Nacos注册中心 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/801484.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

PCB学习记录-----入门基础知识

一、搭建环境 1.下载嘉立创EDA 软件下载 - 嘉立创EDA (lceda.cn) 选专业版 在线编辑&#xff1a;嘉立创EDA(专业版) - V2.1.45 (lceda.cn) 官方教程&#xff1a;立创EDA专业版-使用教程 (lceda.cn) 2.新建工程 文件-新建-项目&#xff0c;右键Board1可以重命名&#xff…

-bash: cd: /etc/hadoop: 没有那个文件或目录

解决办法&#xff1a;source /etc/profile 运行 source /etc/profile 命令会重新加载 /etc/profile 文件中的配置&#xff0c;这样做的目的是使任何更改立即生效&#xff0c;而不需要注销并重新登录用户。通常&#xff0c;/etc/profile 文件包含系统范围的全局 Shell 配置&…

asp.net网上水果销售平台 水果购物商城系统+sqlserver

网上水果销售平台 说明文档 运行前附加数据库.mdf&#xff08;或sql生成数据库&#xff09; 主要技术&#xff1a; 基于asp.net架构和sql server数据库 功能模块&#xff1a; asp.net网上水果销售平台 水果购物商城系统 用户功能有 网站首页 全部水果 我的订单 购物车用户…

如何将CSDN的文章以PDF文件形式保存到本地

1.F12 打开开发者工具窗口 2.console下输入命令 (function(){$("#side").remove();$("#comment_title, #comment_list, #comment_bar, #comment_form, .announce, #ad_cen, #ad_bot").remove();$(".nav_top_2011, #header, #navigator").remove…

flutter组件_AbsorbPointer

官方说明&#xff1a;A widget that absorbs pointers during hit testing. 翻译&#xff1a;一个在命中测试期间吸收指针的Widget。 作者释义&#xff1a;阻止子元素的点击事件 。 AbsorbPointer的定义 const AbsorbPointer({super.key,this.absorbing true,this.ignoringSe…

Rust 标准库 API 文件和文件夹操作 File,读取/创建/修改/追加/删除/重命名文件等

File::create 使用File的关联函数&#xff08;类似Java中的静态方法&#xff09;create&#xff0c;创建文件&#xff0c;如果存在&#xff0c;则覆盖。 use std::fs::{File, Metadata};fn main() -> std::io::Result<()> {let file: File File::create("foo.…

【氮化镓】三星200mm 硅基高阈值电压p-GaN器件

【High threshold voltage p-GaN gate power devices on 200 mm Si】——IPSD2013 摘要&#xff1a; 三星公司的研究人员介绍了一种高阈值电压、低导通电阻和高速的GaN-HEMT功率器件&#xff0c;该器件在栅极堆叠中使用了p-GaN层。文章提出了三个创新点&#xff1a;首先&#…

SSL、TLS和HTTPS:网络安全的重要基石

随着互联网的快速发展&#xff0c;网络安全问题日益凸显。为了保护数据在传输过程中的安全&#xff0c;各种加密协议和技术应运而生。SSL&#xff08;安全套接层&#xff09;、TLS&#xff08;传输层安全&#xff09;和HTTPS&#xff08;超文本传输安全协议&#xff09;是三个最…

AI日报:北大Open Sora视频生成更强了;文心一言可以定制你自己的声音;天工 SkyMusic即将免费开放;

&#x1f916;&#x1f4f1;&#x1f4bc;AI应用 北大Open Sora视频生成更强了!时长可达10秒&#xff0c;分辨率更高 【AiBase提要:】 ⭐️ Open-Sora-Plan v1.0.0模型发布 显著提升视频生成质量和文本控制能力 ⭐️ 支持华为昇腾910b芯片&#xff0c;提升运行效率和质量。 ⭐…

Github 2024-04-08 开源项目周报Top15

根据Github Trendings的统计,本周(2024-04-08统计)共有15个项目上榜。根据开发语言中项目的数量,汇总情况如下: 开发语言项目数量Python项目7Jupyter Notebook项目2TypeScript项目2C项目1Shell项目1C++项目1JavaScript项目1Mojo项目1Rust项目1非开发语言项目1编程面试大学:…

pytorch演示pipeline并行

pytorch演示pipeline并行 1.单卡内存不够时,可以将网络切分成几段(stage),每个GPU负责一个stage。比如GPU0计算完之后将数据发送给GPU1算后续的stage 2.以上的方式,会导致GPU的利用率不高,可以将输入的batch切分成多份更小的batch,陆续送给GPU0,这样GPU0处理完micro batch0之后…

第四百四十八回

文章目录 1. 知识回顾2. 使用方法3. 代码与功能3.1 示例代码3.2 功能说明 4. 内容总结 我们在上一章回中介绍了"overlay_tooltip简介"相关的内容&#xff0c;本章回中将介绍OverlayTooltip用法.闲话休提&#xff0c;让我们一起Talk Flutter吧。 1. 知识回顾 我们在上…

MP4视频如何转OGV视频格式?视频格式转换的方法

一&#xff0c;什么是OGV视频格式 OGV是一个使用OGG开源格式的容器。 OGG不受软件专利的限制&#xff0c;这是其创建的主要目标之一。 OGV格式用于存储带或不带音频的视频流&#xff0c;而视频流又可以用Opus&#xff0c;Vorbis&#xff0c;Theora或Speex算法压缩。该格式用于…

以XX公司为例的Acrel1000DP分布式光伏监控系统在5.98MW分布式光伏10KV并网系统的应用

分布式光伏监控系统 目前&#xff0c;光伏电站中装设的电力二次系统主要有光伏后台监控系统、计量系统、远动通讯屏、调度数据网屏、防孤岛保护装置、电能质量在线监测装置、频率电压紧急控制装置等&#xff0c;部分光伏电站还建设有向发电集团传输数据的系统。 分布式光伏监…

初识SpringMVC

一、什么是MVC MVC是一种软件架构模式&#xff08;是一种软件架构设计思想&#xff0c;不止Java开发中用到&#xff0c;其它语言也需要用到&#xff09;&#xff0c;它将应用分为三块&#xff1a; M&#xff1a;Model&#xff08;模型&#xff09;V&#xff1a;View&#xff08…

xss.pwnfunction-Ligma

首先用jsFuckhttps://jsfuck.com/ [][(![][])[[]](![][])[![]![]](![][])[![]](!![][])[[]]][([][(![][])[[]](![][])[![]![]](![][])[![]](!![][])[[]]][])[![]![]![]](!![][][(![][])[[]](![][])[![]![]](![][])[![]](!![][])[[]]])[![][[]]]([][[]][])[![]](![][])[![]![]!…

设计模式之解释器模式(上)

解释器模式 1&#xff09;概述 1.定义 定义一个语言的文法&#xff0c;并且建立一个解释器来解释该语言中的句子&#xff0c;这里的“语言”是指使用规定格式和语法的代码。 2.结构图 3.角色 AbstractExpression&#xff08;抽象表达式&#xff09;&#xff1a;在抽象表达…

【uniapp】开发微信小程序 — 注意事项

底部导航栏 (tabBar) 图标的正确做法&#xff1a; 1、图片的标准尺寸为 81px * 81px&#xff0c;该尺寸在官方的文档中有明确的说明&#xff0c;可以参考微信小程序全局配置文档中对 iconPath 属性的说明。 2、为了保持良好的间距&#xff0c;图片的内容区域设置 60px* 比较好&…

java的封装

在Java中&#xff0c;封装是面向对象编程中的一种重要概念&#xff0c;它指的是将数据和方法打包在一个单一的单位&#xff08;类&#xff09;中&#xff0c;并对外部隐藏对象的内部细节。封装通过将类的成员变量声明为私有的&#xff0c;并提供公共的方法来访问和修改这些变量…

nacos分布式程序开发实例

1.通过windows docker desktop 完成 nacos 的安装/启动/配置 &#xff08;1&#xff09;先安装docker desktop docker-toolbox-windows-docker-for-windows-stable安装包下载_开源镜像站-阿里云 &#xff08;2&#xff09;配置docker 国内镜像源 Docker 镜像加速 | 菜鸟教程…