微服务

程序员文章站 2022-06-13 22:30:13

...

微服务

微服务父级工程

依赖

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
    </parent>
    
	<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-autoconfigure</artifactId>
   </dependency>
   
     <dependencyManagement>
     <!--实现使用spring cloud所有依赖声明式导入-->
     <dependencies>
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-dependencies</artifactId>
             <version>Edgware.RELEASE</version>
             <scope>import</scope>
             <type>pom</type>
         </dependency>
     </dependencies>
 </dependencyManagement>

微服务服务端

该服务端基于父级工程所创建
这里使用两个服务端进行交互,是为了防止有一个服务端宕机所用的另一个类似于从节点的一个服务端进行交互

两个服务端一样的依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka-server</artifactId>
        </dependency>

application.properties配置文件

服务端01

server.port=8761
spring.application.name=eureka-server
eureka.client.fetch-registry=true
eureka.client.register-with-eureka=true
eureka.client.prefer-ip-address=true
eureka.client.service-url.defaultZone=http://127.0.0.1:8762/eureka
eureka.server.enable-self-preservation=false

服务端02

server.port=8762
spring.application.name=eureka-server
eureka.client.fetch-registry=true
eureka.client.register-with-eureka=true
eureka.client.prefer-ip-address=true
eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka
eureka.server.enable-self-preservation=false

这里两个服务端,服务端02写服务端01的port,01写02的port.如果只使用一个服务端,就把host:port的port号改成自己本身的就好了

服务端启动类

在启动类上增加两个注解

@SpringBootApplication
@EnableEurekaServer

zuul网关

依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zuul</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>

application.properties配置

server.port=8103
spring.application.name=gateway
eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka
#路由配置
zuul.routes.name.path=/zuul-name/**
zuul.routes.name.service-id=nameserver
#关闭敏感头
zuul.sensitive-headers=

这里路由配置是根据Nginx以及微服务的客户端来配置的.第一行的两个name还有第二行的第一name配置一样.后面的nameserver是服务端客户端的配置文件的名字来进行配置的
3. 启动类
增加三个注解

@SpringBootApplication
@EnableEurekaClient
@EnableZuulProxy

客户端

依赖

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>

application.properties配置

server.port=自己根据需求
spring.application.name=自己根据需求来创建
eureka.instance.prefer-ip-address=true
eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka

启动类
添加两个注解

@SpringBootApplication
@EnableEurekaClient

都搭建好之后,所有工厂都启动.然后去访问 http://localhost:8761 去查看客户端以及服务端是否都起来了

spring cloud eureka服务治理组件

eureka是spring cloud支持的微服务框架中实现服务治理的和核心组件.服务治理就是管理微服务集群中所有微服务
eureka的实现逻辑
eureka实现了2个核心的功能,一个是注册,一个是发现
eureka的角色:
eureka服务端: 提供服务管理的功能,所有eureka客户端都是服务提供者.
eureka客户端: 就是将拆分之后的每一个服务提供者,注册在eureka服务端.发现所有的注册信息

eureka治理组件的管理逻辑

服务端:
接受请求,接受客户端参数,实现客户端信息的功能.服务端会在底层创建当前注册中心所有服务注册信息的数据结构-----双层map

每个服务端的提供者,作为eureka治理组件的客户端进程,携带自身的详细信息,访问注册中心的接口地址/eureka,注册中心接受到请求,开始在内存的map对象存储双层map的数据
第一层map的key值: 服务名称
第一层map的value值: 就是第二层map的对象
第二层map的key值: 就是服务提供者实力名称系统名称:服务名称:端口
第二次map的value: 该实例的详细信息 ip port 时间戳等

Map<String,String> map2 = new HashMap<String,String>();
Map<String,Map<String,String>> map1 = new HashMap<String,Map<String,String>>();
map2.put("实例1","ip:port");//表示map2里保存了一个实例对象.有一个eureka client启动注册
map1.put("服务名称",map2);

定时判断失效的客户端
服务端根据客户端发送的心跳检测最后时间戳,每隔60秒就执行一个定时任务,判断双层map中第二层map里携带时间戳的值,一旦超过90秒,就会认为客户端节点失效了,从双层map记录的数据中剔除这个节点.
保护模式
正常情况下,服务提供者非常庞大的集群,按故障概略,应该由经常性的有部分故障无法满足心跳检测的要求,将会被提出,但是异常情况下,例如网络波动,导致心跳检测超时的服务实例大量达到超时时间条件.eureka-server默认开启一个应对这种场景的非正常剔除的保护模式,防止错误剔除导致微服务集群瘫痪.只要集群节点数量超时达到15%以上,保护模式一旦开启,所有服务将不会被剔除,等待网络恢复.
客户端功能
- 注册
  客户端在启动时,根据配置的地址service-url.defaultZone发起http请求,访问eureka注册中心,携带详细当前客户端信息.
- 心跳
  启动完成,注册也就完成,后续为了让eureka-server不做剔除处理,每隔30秒,发送新题奥续约请求,携带新的更新数据到eureka-server服务端,服务端接收心跳,修改更新注册信息
- 发现-同步
  客户端一旦开启fetch-registry的功能,每隔30秒中,到注册中心抓取注册信息,本质上通过网络访问获取的就是双层map的数据,如果客户端在抓取数据后,发现本地已经抓取过数据了,就不会做过多的操作,一旦发现更新内容,将会同步到本地(新服务,老服务剔除)

Spring cloud ribbon组件

ribbon介绍
ribbon是spring cloud中进行负载均衡调用服务提供者集群的一个客户端组件,需要依赖eureka-client的发现机制,先从注册中心抓取注册信息,才能根据注册信息实现负载均衡调用(拦截逻辑)
依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
        </dependency>

application.properties配置

server.port=9004 自己起
spring.application.name=service-ribbon 自己起
eureka.instance.prefer-ip-address=true
eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka

启动类
三个注解 一个是在类上面,另外两个在main方法下.

	@SpringBootApplication
    @Bean
    @LoadBalanced
    public RestTemplate initTemplate(){
        return new RestTemplate();
    }

在业务层使用的方法

@Resource private RestTemplate restTemplate;
String url = "http://productservice/product/manage/item/"+cart.getProductId();
Product product = restTemplate.getForObject(url, Product.class);
这里使用了一个项目模板的例子来解释业务层调用

ribbon负载均衡逻辑和原理
ribbon配合了eureka-client组件,实现了服务的抓取,抓取到了注册所有信息,包含service,然后ribbon中编写RestTemplate的访问代码实现调用服务,完成负载均衡.底层经过ribbon过滤逻辑.
- ribbon中已经抓取到了服务信息
- RestTemplate调用api时候,就进入到了拦截逻辑
  - 先去对请求地址http://productservice/product/manage/item/****
  - 获取服务名称 productservice
  - 从双层map通过key的服务名称找到9001/9002详细信息
  - 经过负载均衡计算,拿到详细信息中某个节点的具体信息 ip+port
  - 请求地址中 productservice服务名称替换称了ip:port真实节点信息
  - 发起了从ribbon工程出去的最终访问http://127.0.0.1:9001/product/manage/item/****

zuul网关组件

**zuul网关,是微服务集群唯一对外访问的入口工程**

zuul网关的实现功能
路由: zuul接受到外界请求后,根据请求地址url判断该请求访问后端哪个微服务.
过滤: 不是所有的请求都是合法请求,在过略过程中,可以根据校验逻辑,判断哪些请求来到网关可以向后调用微服务,不合法就拒绝了访问.
流转逻辑
js发起请求地址
http://www.easymall.com/products/pageManage?page=1&rows=5
ip映射到了Nginx,进入Nginx
Nginx匹配端口和域名,剩余/products/pageManage?page=1&rows=5
location ^~/products 剩余/pageManage?page=1&rows=5
proxy_pass http://localhost:8103/zuul-product/product/manage
zuul网关接受地址
http://localhost:8103/zuul-product/product/manage
匹配path /zuul-product/** 剩余/product/manage
找到路由规则 product 拼接 productservice服务
http://productservice/product/manage
拼接服务信息详细信息 http://productservice/product/manage/pageManage?page=1&rows=5

所以说,后端某一个微服务的具体访问路径,经过nginx匹配过滤,经过zuul匹配过了,可以做到完全对外界是屏蔽的.想要调用服务功能必须通过nginx,必须通过网关

检查微服务功能问题

uctservice服务
http://productservice/product/manage
拼接服务信息详细信息 http://productservice/product/manage/pageManage?page=1&rows=5

所以说,后端某一个微服务的具体访问路径,经过nginx匹配过滤,经过zuul匹配过了,可以做到完全对外界是屏蔽的.想要调用服务功能必须通过nginx,必须通过网关

检查微服务功能问题

微服务

微服务

微服务

微服务父级工程

微服务服务端

服务端01

服务端02

服务端启动类

zuul网关

客户端

spring cloud eureka服务治理组件

eureka治理组件的管理逻辑

Spring cloud ribbon组件

zuul网关组件

检查微服务功能问题

检查微服务功能问题

微信客服怎么联系查询微信客服电话人工服务方法

[9.12]新浪微博突发大面积故障功能服务近乎全部瘫痪

微信登陆失败提示：该公众账号暂时无法提供服务，请稍后再试怎么办？

新浪微博图片服务器出现大面积故障延参法师称被坑哭了

微信端调取相册和摄像头功能，实现图片上传，并上传到服务器

微信服务号如何每天发消息，微信公众号实现模板消息的推送

小程序server请求微信服务器超时的解决方法

.net微信服务号发送红包

基于腾讯云服务器部署微信小程序后台服务（Python+Django）

go上传图片微信服务器<<临时素材

微服务

微服务

微服务父级工程

微服务服务端

服务端01

服务端02

服务端启动类

zuul网关

客户端

spring cloud eureka服务治理组件

eureka治理组件的管理逻辑

Spring cloud ribbon组件

zuul网关组件

检查微服务功能问题

检查微服务功能问题

微信客服怎么联系 查询微信客服电话人工服务方法

[9.12]新浪微博突发大面积故障 功能服务近乎全部瘫痪

微信登陆失败提示：该公众账号暂时无法提供服务，请稍后再试怎么办？

新浪微博图片服务器出现大面积故障 延参法师称被坑哭了

微信端调取相册和摄像头功能，实现图片上传，并上传到服务器

微信服务号如何每天发消息，微信公众号实现模板消息的推送

小程序server请求微信服务器超时的解决方法

.net微信服务号发送红包

基于腾讯云服务器部署微信小程序后台服务（Python+Django）

go上传图片微信服务器<<临时素材

微信客服怎么联系查询微信客服电话人工服务方法

[9.12]新浪微博突发大面积故障功能服务近乎全部瘫痪

新浪微博图片服务器出现大面积故障延参法师称被坑哭了