ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

2021-09-22

2021-09-22 20:05:01  阅读:141  来源: 互联网

标签:调用 服务 name 22 09 hello 2021 public 请求


1、dataX安装及基本使用

简介:多种数据库数据互导 同步工具

框架设计:reader writer framework

工作原理:将job 单个作业划分为若干个task schedule 将task组成组并发执行

前置要求:JDK python

使用示例:编写json脚本、执行脚本D:\JobSoftware\DataX\datax\bin>python datax.py D:\JobSoftware\DataX\datax\job\jobtest.json

2.Spring Cloud 和dubbo的区别?

底层协议:springCloud基于http协议 rest 风格的api dubbo基于TCP协议 决定了dubbo的型嫩相对会比较号

注册中心:springCloud 使用的是eureka dubbo推荐使用zookeeper

模型定义:springCloud将一个应用定义为一个服务 dubbo将一个接口定义为一个服务

springCloud是一个生态 二dubbo是springCloud生态中关于服务调用的一种解决方案

3.什么是Hystrix?简述实现机制

分布式容错框架:阻止故障的连锁反应,实现熔断 快速失败 实现优雅降级 提供实时的监控和告警

资源隔离:线程隔离:hystrix会给每一个command分配一个单独的线程池,这样在进行单个服务调用的时候 就可以在独立的线程池里面进行 而不会对其他线程池造成影响

信号量隔离:客户端向依赖服务发起请求时,首先要获取一个信号量才能真正发起调用 由于信号量的数量优先 当并发请求量超过信号量个数时,后续的请求都会直接拒绝 进入fallback流程

信号量隔离主要是通过控制并发请求量 防止请求线程大面积阻塞 从而达到限流和防止雪崩的目的

熔断和降级 调用服务失败后快速失败

熔断 是为了防止异常不扩散 保证系统的稳定性

降级 编写号调用失败的补救逻辑 然后对服务直接停止运行 这样这些接口就无法正常调用 但是油3不至于直接买报错 只是服务水平下降

用法:

pom:

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

HystrixCommand 注解修饰方法

@HystrixCommand(commandKey ="updateAgencyNameByAgencyNo", groupKey="null", fallbackMethod = "updateAgencyNameByAgencyNoFailure")

4.springCloud核心组件及其作用

Eureka:

服务注册与发现

注册:每个服务都向Eureka等级自己提供服务的元数据,包括服务的ip地址 端口号 版本号 通信协议等

eureka将各个服务维护在了一个服务请安中,同时哦对服务维持心跳 剔除不可用的服务 eureka集群各节点相互注册每个实例中都有一样的服务清单

发现:eureka 注册的服务之间调用不需要指定服务地址 而是通过服务名向注册中心想咨询 并获取所有服务实例清单 缓存到本地 然后实现服务的请求访问

Ribbon:

服务间发起请求的时候,基于ribbon做负载均衡,从一个服务的多台机器中选择一台,ribbon也是通过发起http请求 来进行调用 只不过是通过调用服务名的地址来实现的。虽然说ribbon不用区具体请求服务实例的ip地址域名,但是每调用一个接口都还要手动发起http请求

用法:

@Bean
@LoadBalanced//Ribbon负载均衡
public RestTemplate restTemplate(){
    return new RestTemplate();
}

public class HelloController {
    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping("/hello/{name}")
    public String hello(@PathVariable String name){
        String url ="http://localhost:7900/hello/"+name;
        url = "http://provider-user/hello/"+name;
        return restTemplate.getForObject(url,String.class);
    }
}

Feign:基于Feign的动态代理机制,根据注册和选择的机器,拼接请求URL地址 发起请求 简化服务间的调用在ribbon的基础上进行了进一步的封装

用法示例:

//调用服务提供者
@FeignClient("provider-user")(相当于远程调用服务提供这provider-user提供的hello服务)
public interface HelloFeign {
    @RequestMapping("/hello{name}")
    public String hello(@PathVariable("name") String name);
}


@RestController//不做业务 去调用服务的提供者
public class HelloController {
    @Autowired
    private HelloFeign helloFeign;
    @RequestMapping("/hello/{name}")
    public String hello(@PathVariable String name){
        return  helloFeign.hello(name);
    }
}

Hystrix:

发起请求是通过hystrix的线程池来走的 不同的服务走不同的线程池 实现了不同服务调用的隔离,通过统计接口超时次数返回默认值 实现服务熔断和降级

zuul:

如果前端、移动端要调用后端系统 统一由zuul网关进入 由zuul网关转发请求给对应的服务 通过与Eureka进行整合 将自身注册为Eureka下的应用 从Eureka下获取所有服务的示例 来进行服务的路由 zuul还提供了一套过滤器机制 开发这可以自己指定哪些规则的请求 需要执行校验逻辑 只有通过校验逻辑的请求才会被路由到具体的服务示例上

用法:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>
@SpringBootApplication
@EnableZuulProxy
public class RunAppZuul {
    public static void main(String[] args) {
        SpringApplication.run(RunAppZuul.class,args);
    }
}

server:
  port: 8050

spring:
  application:
    name: consumer-zuul

eureka:
  client:
    service-url:
      defaultZone: http://user:password123@localhost:8761/eureka

logging:
  level:
    root: INFO

zuul:
  routes:
    app-a:
      path:/user/**
      serviceId:consumer-hystrix

public class HelloFallback implements ZuulFallbackProvider { .... }

5.dubbo的整体架构设计及分层

五个角色:

注册中心 registry:服务注册与发现

服务提供者:provider :暴露服务

服务消费者:consumer:调用远程服务

监控中心 monitor :统计服务的调用次数和调用时间

容器container 服务运行容器

调用流程:

container容器负责启动、加载 运行provider

provider启动时候 向注册中心注册自己提供的服务

consuer 在启动时候 向注册人中心订阅自己所需的服务

registry返回服务提供者列表给consumer 如果由变更 registry将基于长链接推送变更数据给consumer

consumer调用provider 服务 基于负载均衡算法(轮询法、加权轮询法等)进行调用

consuner调用provider 的统计 基于短链接定时每分钟一次统计到monitor

注册中心与服务提供者的长连接是基于心跳机制

与消费者的长链接主要是发送服务端的服务列表

标签:调用,服务,name,22,09,hello,2021,public,请求
来源: https://blog.csdn.net/qq_43621789/article/details/120421770

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有