README.md · 千楼/springcloud alibaba

# springcloud alibaba

#### 介绍
springcloud alibaba常用组件,需要用到的直接拷贝一份demo即可以在此基础上开发(根据自己实际情况修改)

#### eureka高可用集群配置：
    在hosts文件配置:
    127.0.0.1 eureka7001.com,
    127.0.0.1 eureka7002.com,
    127.0.0.1 eureka7003.com
    eureka集群：cloud-eureka-server7001,cloud-eureka-server7002,cloud-eureka-server7003
#### 服务发现discovery
    通过DiscoveryClient获得注册服务的信息，如
    List<String> services = discoveryClient.getServices();
    for (String service : services) {
         log.info("*****element*****: {}", service);
    }
    List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
    for (ServiceInstance instance : instances) {
          log.info(instance.getServiceId() + "\t" + instance.getHost()+ "\t" + instance.getPort() + "\t" + instance.getUri());
    }
#### Eureka自我保护
    EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY'RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.
    1、某时刻某个微服务不可用了，eureka不会立刻清理，依旧会对微服务的信息进行保存
    2、属于CAP里面的AP分支  
    3、禁止自我保护模式
        Eureka集群/单机配置  
        server:
            enable-self-preservation: false 
            eviction-interval-timer-in-ms: 2000
#### jar包冲突
    mvn dependency:tree > 1.log，查看重复依赖，使用exclusions排除

#### 使用zookeeper为注册中心
      生产者: cloud-provider-payment8004
      消费者: cloud-consumer-zk-order80

#### 使用consul为注册中心
    docker安装consul：
    1、docker pull consul:latest
    –net=host docker参数, 使得docker容器越过了net namespace的隔离，免去手动指定端口映射的步骤
    -server consul支持以server或client的模式运行, server是服务发现模块的核心, client主要用于转发请求
    -advertise 将本机私有IP传递到consul
    -retry-join 指定要加入的consul节点地址，失败后会重试, 可多次指定不同的地址
    -client 指定consul绑定在哪个client地址上，这个地址可提供HTTP、DNS、RPC等服务，默认是>127.0.0.1
    -bind 绑定服务器的ip地址；该地址用来在集群内部的通讯，集群内的所有节点到地址必须是可达的，>默认是0.0.0.0
    allow_stale 设置为true则表明可从consul集群的任一server节点获取dns信息, false则表明每次请求都会>经过consul的server leader
    -bootstrap-expect 数据中心中预期的服务器数。指定后，Consul将等待指定数量的服务器可用，然后>启动群集。允许自动选举leader，但不能与传统-bootstrap标志一起使用, 需要在server模式下运行。
    -data-dir 数据存放的位置，用于持久化保存集群状态
    -node 群集中此节点的名称，这在群集中必须是唯一的，默认情况下是节点的主机名。
    -config-dir 指定配置文件，当这个目录下有 .json 结尾的文件就会被加载
    -enable-script-checks 检查服务是否处于活动状态，类似开启心跳
    -datacenter 数据中心名称
    -ui 开启ui界面
    -join 指定ip, 加入到已有的集群中
    2、docker run --name=consul01 -d -p 8500:8500 -p 8300:8300 -p 8301:8301 -p 8302:8302 -p 8600:8600 consul agent -server -bootstrap-expect 2 -ui -bind=0.0.0.0 -client=0 .0.0.0
        端口分析：
            8500 : http 端口，用于 http 接口和 web ui访问；
            8300 : server rpc 端口，同一数据中心 consul server 之间通过该端口通信；
            8301 : serf lan 端口，同一数据中心 consul client 通过该端口通信; 用于处理当前datacenter中LAN的gossip通信；
            8302 : serf wan 端口，不同数据中心 consul server 通过该端口通信; agent Server使用，处理与其他datacenter的gossip通信；
            8600 : dns 端口，用于已注册的服务发现；
    3、查看consul01的IP地址
        docker inspect --format='{{.NetworkSettings.IPAddress}}' consul01
    4、添加第二个节点到consul01
        docker run --name=consul02 -d -p 8501:8500 consul agent -server -ui -bind=0.0.0.0 -client=0.0.0.0 -join 172.17.0.4
        docker run --name=consul03 -d -p 8502:8500 consul agent -server -ui -bind=0.0.0.0 -client=0.0.0.0 -join 172.17.0.4
    5、查看集群信息
        docker exec -it consul01 consul members
    
    消费者：cloud-consumer-consul-order80
    生产者：cloud-provider-consul-payment8006

#### AP:eureka, CP:zookeeper、consul

#### LB负载均衡（load balance）
     将用户的请求平均的分配到多个服务商，从而达到系统的HA（高可用）
     常见的负载均衡有Nginx,LVS,硬件F5等
#### Ribbon本地负载均衡客户端 VS Nginx服务端负载均衡
     Nginx是服务端负载均衡，客户端所有的请求都会交给Nginx，然后由Nginx实现转发请求。即负载均衡是由服务端实现的（集中式）
     Ribbon本地负载均衡，在调用微服务接口时候，会在注册中心上获取注册信息服务列表之后缓存到JVM本地，从而在本地实现RPC远程服务调用技术（进程内）

#### Ribbon负载均衡--随机
     消费者：cloud-consumer-order80 -> myrule -> MySelfRule   覆盖原有的轮询算法
     @RibbonClient(name = "CLOUD-PAYMENT-SERVICE", configuration = MySelfRule.class)
     
#### 负载均衡算法--轮询算法
    rest接口第几次请求数 % 服务器集群总数量 = 实际调用服务器位置下标， 每次服务重启后rest接口计数从1开始
    如：List[0] instances = 127.0.0.1:8002
        List[1] instances = 127.0.0.1:8001
        8002 + 8001 组成集群， 集群总数 2 ， 按照轮训算法原理：
        总请求数：1   1 % 2 = 1  -> 127.0.0.1:8001
                 2   2 % 2 = 0  -> 127.0.0.1:8002
                 3   3 % 2 = 1  -> 127.0.0.1:8001
                 .      .               .
                 .      .               .
                 .      .               .
#### 负载均衡源码
     public Server choose(ILoadBalancer lb, Object key) {
            if (lb == null) {
                log.warn("no load balancer");
                return null;
            }
    
            Server server = null;
            int count = 0;
            while (server == null && count++ < 10) {
                List<Server> reachableServers = lb.getReachableServers();
                List<Server> allServers = lb.getAllServers();
                int upCount = reachableServers.size();
                int serverCount = allServers.size();
    
                if ((upCount == 0) || (serverCount == 0)) {
                    log.warn("No up servers available from load balancer: " + lb);
                    return null;
                }
    
                int nextServerIndex = incrementAndGetModulo(serverCount);
                server = allServers.get(nextServerIndex);
    
                if (server == null) {
                    /* Transient. */
                    Thread.yield();
                    continue;
                }
    
                if (server.isAlive() && (server.isReadyToServe())) {
                    return (server);
                }
    
                // Next.
                server = null;
            }
    
            if (count >= 10) {
                log.warn("No available alive servers after 10 tries from load balancer: "
                        + lb);
            }
            return server;
        }
        
        private int incrementAndGetModulo(int modulo) {
                for (;;) {
                    int current = nextServerCyclicCounter.get();
                    int next = (current + 1) % modulo;
                    if (nextServerCyclicCounter.compareAndSet(current, next))
                        return next;
                }
            }
        
#### 自定义负载均衡算法--轮询
    cloud-consumer-order80 -> com.zeny.springcloud.lb -> 接口LoadBalancer
                                                      -> 实现类MyLoadBalancer
                                                  
#### openfeign
     参考cloud-consumer-feign-order80
     
#### hystrix
    服务降级:
        服务器忙，请稍后再试，不让客户端等待并立即返回一个友好提示
        服务降级情况: 1、程序运行异常
                     2、超时
                     3、服务熔断触发服务降级
                     4、线程池/信号量打满也会导致服务降级
    服务熔断:
        类似保险丝达到最大服务访问后，直接拒绝访问，拉闸限电，然后调用服务降级的方法返回友好提示
        就是保险丝 服务的降级 -> 进而熔断 -> 回复调用链路
    
    服务限流: 
        秒杀高并发等操作，严禁一窝蜂的过来拥挤，大家排队，一秒N个，有序进行
    
    生产者: cloud-provider-hystrix-payment8001
    消费者: cloud-consumer-feign-hystrix-order80
    监控平台: cloud-consumer-hystrix-dashboard9001

#### gateway网关  
    cloud-gateway-gateway9527
#### config配置中心
    配置中心从gitee上拉取: cloud-config-center-3344
    服务client从3344上拉取: cloud-config-client-3355
    需要发送curl -X POST "http://localhost:3355/actuator/refresh"，刷新一下3355上的配置

#### bus
    总线:
        在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个公用的消息主题, 并让系统中所有微服务实例都连接上来。
    由于该主题中产生的消息会被所有实例监听和消费，所以称它为消息总线。在总线的各个实例，都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息
    基本原理:
        ConfigClient实例都监听MQ中同一个topic（默认是springCloudBus）。当一个服务刷新数据的时候, 它会把这个消息放入到topic中
        这样其他监听同一个topic的服务就能得到通知, 然后去更新自身的配置
        
    安装rabbitmq
    配置中心从gitee上拉取: cloud-config-center-3344
    服务client从3344上拉取: 
        client01: cloud-config-client-3355
        client02: cloud-config-client-3366
        需要发送curl -X POST "http://localhost:3344/actuator/bus-refresh", 刷新一下3355上的配置
        
        -> 实现了所有client不用重启就刷新了本地配置
    
    动态刷新定点通知: 只想通知某一个实例
        格式: curl -X POST "http://配置中心IP:配置中心端口/actuator/bus-refresh/[微服务名称(spring.application.name)]:[微服务端口(server.port)]"
        例如: curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"
        
#### stream
    中间件: rabbitmq
    生产者: cloud-stream-rabbitmq-provider8801
    消费者: 
            cloud-stream-rabbitmq-consumer8802
            cloud-stream-rabbitmq-consumer8803
    重复消费:
        原因: 默认分组group是不同的, 组流水号不一样，被认为不同组, 可以消费
        解决办法: 自定义配置分为同一个组,同时可以持久化消息, 当服务重启后能继续接受到消息（不设置自定义分组会出现消息丢失）
    
#### zipkin
    下载zipkin-server-2.10.1-exec.jar
    运行: java -jar zipkin-server-2.10.1-exec.jar
    访问地址: http://localhost:9411
    调用者:cloud-consumer-order80
    被调用者: cloud-provider-payment8001
    在zipkin中可以看到详细的调用情况

####  springcloud alibaba
    地址: https://github.com/alibaba/spring-cloud-alibaba/blob/master/README-zh.md

#### nacos
    下载: nacos-server-1.1.4
    运行: 点击 bin 下的 startup.cmd
    访问: http://localhost:8848/nacos
          用户名: nacos
          密码:   nacos
    消费者: cloudalibaba-consumer-nacos-order83
    生产者: 
        client01: cloudalibaba-provider-payment9001
        client02: cloudalibaba-provider-payment9002
#### nacos配置中心config
    bootstrap优先级高于application
    项目: cloudalibaba-config-nacos-client3377
#### nacos集群和持久化--Linux + mysql下
    Nacos官网: https://nacos.io/zh-cn/docs/deployment.html
    Nacos默认自带的嵌入式数据库derby
    window单机:derby到mysql的切换配置步骤:
        1、安装数据库，版本要求：5.6.5+
        1、nacos-server-1.1.4\nacos\conf目录下找到sql脚本 -> 执行nacos-mysql.sql脚本
        2、nacos-server-1.1.4\nacos\conf目录下找到application.properties,增加支持mysql数据源配置（目前只支持mysql）,添加mysql数据源的url、用户名和密码
            添加(根据自己的实际情况修改):
                #持久化到mysql
                spring.datasource.platform=mysql
                db.num=1
                db.url.0=jdbc:mysql://192.168.1.19:3311/nacos_config?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
                db.user=root
                db.password=123456
    Linux版nacos集群:
        1个Nginx+3nacos注册中心+1个mysql
        1、nacos集群
            1)下载: nacos-server-1.1.4.tar.gz
            2)解压: tar -zxvf nacos-server-1.1.4.tar.gz
            3)进入conf文件夹下修改cluster.conf,修改后(注意,这个IP不能写127.0.0.1，必须是Linux命令hostname -i能够识别的IP):
                #it is ip
                #example
                192.168.1.19:3333
                192.168.1.19:4444
                192.168.1.19:5555
            4)修改application.properties, 切换到mysql数据库(需要在mysql数据库中新建nacos_config,步骤跟window上一样，找到脚本执行就行了):
                spring.datasource.platform=mysql
                db.num=1
                db.url.0=jdbc:mysql://192.168.1.19:3311/nacos_config?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
                db.user=root
                db.password=123456
            5)编辑nacos的启动脚本startup.sh，使它能够接受不同的启动端口:
                找到/mynacos/nacos/bin目录下的startup.sh,修改2处地方:
                找到对应的地方,修改成如下的样子
                (1)while getopts ":m:f:s:p:" opt
                   do
                       case $opt in
                           m)
                               MODE=$OPTARG;;
                           f)
                               FUNCTION_MODE=$OPTARG;;
                           s)
                               SERVER=$OPTARG;;
                   	       p)
                   	           PORT=$OPTARG;;
                           ?)
                           echo "Unknown parameter"
                           exit 1;;
                       esac
                   done
                (2)# start
                   echo "$JAVA ${JAVA_OPT}" > ${BASE_DIR}/logs/start.out 2>&1 &
                   (主要是这里,新增-Dserver.port=${PORT}):
                   nohup $JAVA -Dserver.port=${PORT} ${JAVA_OPT} nacos.nacos >> ${BASE_DIR}/logs/start.out 2>&1 &
                   echo "nacos is starting，you can check the ${BASE_DIR}/logs/start.out"
            6)启动集群:
                在nacos/bin目录下:
                    ./startup.sh -p 3333
                    ./startup.sh -p 4444
                    ./startup.sh -p 5555
                 查看集群个数:ps -ef | grep nacos |grep -v grep|wc -l
                 结果: 3
        2、Nginx(负载均衡)配置
            1)下载nginx-linux
            2)修改配置文件nginx.conf:
                upstream cluster{
                        server 127.0.0.1:3333;
                        server 127.0.0.1:4444;
                        server 127.0.0.1:5555;
                }
                server监听端口修改为1111
                  server {
                        listen       1111; #修改监听端口
                        server_name  localhost;
                
                        #charset koi8-r;
                
                        #access_log  logs/host.access.log  main;
                
                        location / {
                            #root   html;
                            #index  index.html index.htm;
                            proxy_pass http://cluster; 
                        }
                        .
                        .
                        .
                        省略
            3)启动: 
                在sbin目录下:
                    ./nginx - c 配置文件
                    例如: ./nginx -c /opt/nginx/conf/nginx.conf
        
        3、访问: http://192.168.1.19:1111/nacos(根据自己实际情况)     
      
#### Sentinel限流熔断
    sentinel-dashboard-1.6.0.jar
    生产者: cloudalibaba-provider-payment9003
            cloudalibaba-provider-payment9004
    消费者: cloudalibaba-consumer-nacos-order84
    测试sentinel功能: cloudalibaba-sentinel-service8401
        sentinel配置持久化:
            在nacos中新建配置文件,dataId是服务名称,json格式,内容如下
            [{
                "resource":"/rateLimit",
                "limitApp":"default",
                "grade":1,
                "count":1,
                "strategy":0,
                "controlBehavior":0,
                "clusterMode":false
            }]
            参数解析:
                "resource":资源名称,
                "limitApp":来源应用,
                "grade":阈值类型, 0表示线程数, 1表示QPS,
                "count":单机阈值,
                "strategy":流控模式, 0表示直接, 1表示关联, 2表示链路,
                "controlBehavior": 流控效果, 0表示快速失败, 1表示Warm Up, 2表示排队等待,
                "clusterMode":是否集群
#### seata 
    官网http://seata.io/zh-cn/
    全局事务实战:
        seata-order-service2001
        seata-storage-service2002
        seata-account-service2003
        在业务上添加 @GlobalTransactional(name = "fsp-create-order", rollbackFor = Exception.class)
    
####  hutool https://hutool.cn/
    利用雪花算法生成分布式ID  
    优点:
        毫秒数在高位,自增序列在低位,整个ID都是趋势递增
        不依赖数据库等第三方系统,以服务的方式部署,稳定性更高,生成ID的性能也是非常高
        可以根据自身业务特性分配bit,非常灵活
    缺点:
        依赖机器时钟,如果机器时钟回拨,会导致重复ID生成
        在单机上是递增的,但是由于设计到分布式环境,每台机器上的时钟不可能完全同步,有时候会出现不是全局递增的情况
        (此缺点可以认为无所谓,一般分布式ID只要趋势递增,并不会严格要求递增,90%的需求都只要求趋势递增)
        
        解决时钟回拨导致的问题参考:
            百度开源的分布式唯一ID生成器UidGenerator
            leaf--美团点评分布式ID生成系统
#### 详情参考 SpringCloudAlibaba.mmap
#### 作者：zeny

千楼/springcloud alibaba

简介

发行版

贡献者

近期动态

千楼/springcloud alibaba .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

千楼/springcloud alibaba