当前位置: 首页>编程语言>正文

springcloud集群怎么启动 springcloud集群搭建


这里写目录标题

  • 前言
  • 一、Spring Cloud 介绍
  • 1 Spring Cloud 技术组成
  • 2 Spring Cloud 与Dubbo的对比
  • 二、Eureka 注册中心基础知识
  • 1、 为什么需要注册中心?
  • 2、注册中心的功能
  • 3、eureka 注册中心的运行参数
  • (1)注册
  • (2)拉取
  • (3)心跳
  • (4)自我保护模式
  • 4、eureka 和zookeeper
  • 5、单台eureka服务器
  • 三、Eureka实践
  • 1、创建Eureka服务模块EurekaMain7001
  • (1)修改pom.xml
  • (2)添加application.yml
  • (3)添加主启动类
  • (4)项目启动后测试
  • 2、服务注册
  • (1)添加依赖
  • (2)application.yml 中添加eureka配置
  • (3)主启动添加注解 @EnableEurekaClient
  • (4)启动测试
  • 3、Eureka 集群搭建
  • (1)创建Eureka服务模块cloud-eureka-server7002
  • a)修改本机的端口映射
  • b)修改application.yml
  • c)测试
  • 4、服务注册到集群中
  • 5、负载均衡
  • (1)修改 8001 Controller
  • (2)创建多个服务如:cloud-provider-payment8002
  • (3)开启负载均衡
  • a)修改OrderController.java
  • b)RestTemplate中添加负载均衡注解 @LoadBalanced
  • (4)测试
  • 四、Actuator 微服务信息完善
  • 1、 自定义服务名称
  • 2、安全检查 /health
  • 3、暴露 IP 信息
  • 五、添加 DiscoveryClient 发现微服务
  • 1、修改8001项目controller层
  • 2、调用接口
  • 六、关闭自我保护机制。
  • 1、关闭服务端的自我保护机制
  • 2、修改客户端
  • 3、测试


前言

Spring Cloud 并不是一个单独的框架,而是一系列框架的集合,可以说是微服务的全家桶,具有微服务整套的解决方案。知识点也是比较多,脑子记不住,所以在学习的过程中写此文档,方便梳理与记忆。

一、Spring Cloud 介绍

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发,如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等,都可以用Spring Boot的开发风格做到一键启动和部署。Spring Cloud并没有重复制造轮子,它只是将各家公司开发的比较成熟、经得起实际考验的服务框架组合起来,通过Spring Boot风格进行再封装屏蔽掉了复杂的配置和实现原理,最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。(摘自百度百科)

1 Spring Cloud 技术组成

最初的版本:

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring,第1张

技术总是在不停的更新换代,spring cloud 中很多技术我还没来得及学就已经被淘汰了。T T

Cloud升级后的技术点:

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_02,第2张

2 Spring Cloud 与Dubbo的对比

同样都是微服务,Spring Cloud与Dubbo有何区别呢?

1、Spring Cloud

  • 是一个框架集,集成了多种工具,能够解决微服务中的多种问题
  • 基于HTTP协议调用,Rest API
  • 开源,易用,成本低

2、Dubbo

  • 只解决远程调用的问题
  • 基于长连接,Java序列化调用
  • 若要解决微服务中其他的问题,需要自己集成其他工具或自研解决方案

二、Eureka 注册中心基础知识

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_03,第3张

1、 为什么需要注册中心?

  • 便于服务者互相发现
  • 服务提供者,向注册中心注册自己的地址
  • 服务消费者,从注册中心发现服务
  • 服务提供者的地址,可以任意改变,消费者不受影响

2、注册中心的功能

用于维护服务的地址列表。

3、eureka 注册中心的运行参数

(1)注册

服务提供者启动时,会向 eureka 进行注册。

如果注册失败,它会一次次重复尝试注册,直到注册成功为止。

(2)拉取

服务消费者从注册中心拉取注册表。

每30秒拉取一次,更新地址表。

(3)心跳

服务提供者每30秒向 eureka 注册中心发送一次心跳数据。

eureka注册中心,如果连续3次没有收到一个服务的心跳,会认为服务已经死掉,就会剔除注册信息。

(4)自我保护模式

如果由于网络不稳定,15分钟内造成**85%**的服务器心跳异常,eureka这时会进入自我保护模式。

会保护所有注册信息不删除, 即使连续丢失3次心跳,也不删除注册信息。

直到网络稳定后,eureka会自动退出自我保护模式。

4、eureka 和zookeeper

同样都是注册中心,两者有什么区别呢?

  • eureka
  • AP —— 可用性,分区容错性
  • 集群 —— 对等结构
  • zookeeper
  • CP —— 一致性,分区容错性
  • 集群 —— 主从结构

eureka 的可用性主要体现在自我保存模式 ,一般情况可用性重于一致性。

5、单台eureka服务器

如果配置只启动一台eureka服务器,它会自动配置另一台集群服务器: localhost:8761

启动的eureka服务器,会一次次反复尝试连接 `localhost:8761, 但是连不上,就会报错。

自己搭建 eureka 集群后,这个错误会消失。

三、Eureka实践

1、创建Eureka服务模块EurekaMain7001

创建 springboot 项目还是 maven 项目都可以。

创建 springboot 项目的话只需要引入 Eureka Server 依赖,如有需要再修改pom.xml,引入自己需要的jar包。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_04,第4张

(1)修改pom.xml

注意:引入自己定义的api通用包,首先得将jar包引入到项目中。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-eureka-server7001</artifactId>

    <dependencies>
        <!--eureka server-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!--引入自己定义的api通用包,可以使用payment支付Entity-->
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!--boot web actuator-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--一般通用配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
    </dependencies>

</project>

(2)添加application.yml

server:
  port: 7001

eureka:
  instance:
    hostname: localhost #eureka服务端的实例名称
  client:
    #false表示不向注册中心注册自己
    register-with-eureka: false
    #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZ4 one: http://${eureka.instance.hostname}:${server.port}/eureka/

(3)添加主启动类

启动类中添加了 ** @EnableEurekaServer ** 注解

package org.example.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

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

(4)项目启动后测试

打开 http://localhost:7001/,目前还没有服务注册。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_05,第5张

2、服务注册

将之前写的支付服务与订单服务都注册到eureka中。由于操作一致,下面以订单服务(80端口)为例。

(1)添加依赖

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

(2)application.yml 中添加eureka配置

spring:
  application:
    name: cloud-order-server

eureka:
  client:
    #表示是否将自己注册进EurekaServer默认为true
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

(3)主启动添加注解 @EnableEurekaClient

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring_06,第6张

(4)启动测试

刷新 http://localhost:7001/,可以看到两个服务已经注册成功了。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_07,第7张

3、Eureka 集群搭建

(1)创建Eureka服务模块cloud-eureka-server7002

创建过程基本类似,这里就不赘述了。主要还是修改yml的配置文件。

a)修改本机的端口映射

修改application.yml前需要修改本机的端口映射。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_08,第8张

根据这个路径找到这个文件后,在文件的最低端加上

127.0.0.1   eureka7001.com
127.0.0.1   eureka7002.com
b)修改application.yml
  • 修改7001 application.yml
server:
  port: 7001

eureka:
  instance:
    hostname: eureka7001.com  #eureka服务端的实例名称
  client:
    #false表示不向注册中心注册自己
    register-with-eureka: false
    #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://eureka7002.com:7002/eureka/
  • 修改7002 application.yml
server:
  port: 7002

eureka:
  instance:
    hostname: eureka7002.com #eureka服务端的实例名称
  client:
    #false表示不向注册中心注册自己
    register-with-eureka: false
    #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://eureka7001.com:7001/eureka/
c)测试

打开 http://eureka7001.com:7001/ 或http://eureka7002.com:7002/

7001和7002能够互相守望,那么集群就搭建成功了。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_09,第9张

4、服务注册到集群中

  • 修改80和8001项目配置,将服务注册到集群中。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_10,第10张

defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
  • 启动项目,测试 http://eureka7001.com:7001/ 与http://eureka7002.com:7002/

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_11,第11张

5、负载均衡

(1)修改 8001 Controller

为了方便查看服务的端口号,在Controller中加上端口号的信息。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring_12,第12张

package org.example.springcloud.controller;

import lombok.extern.slf4j.Slf4j;
import org.example.springcloud.entities.CommonResult;
import org.example.springcloud.entities.Payment;
import org.example.springcloud.service.PaymentService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

@RestController
@RequestMapping("/payment")
@Slf4j
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    @PostMapping(value = "/create")
    public CommonResult create(@RequestBody Payment payment){
        int result = paymentService.create(payment);
        log.info("*******插入结果为: "+result);
        if(result>0){
            return new CommonResult(200,"插入数据库成功,端口号为:"+serverPort,result);
        }else{
            return new CommonResult(444,"插入数据库失败,端口号为:"+serverPort,null);
        }
    }

    @GetMapping(value = "/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){
        Payment paymentById = paymentService.getPaymentById(id);
        log.info("*********查找结果为: "+paymentById);
        if(paymentById!=null){
            return new CommonResult(200,"查找成功,端口号为:"+serverPort,paymentById);
        }else{
            return new CommonResult(444,"查找为空,查找ID为: "+id +"。端口号为:"+serverPort,null);
        }

    }
}

(2)创建多个服务如:cloud-provider-payment8002

与cloud-provider-payment8002模块只有端口号不一致,可以直接复制整个项目然后修改端口号,再到父工程Pom.xml中添加 cloud-provider-payment8002,当然主启动类名也要改。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_13,第13张

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_14,第14张

创建好后,启动项目,可以看到项目已经注册进eureka。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_15,第15张

(3)开启负载均衡

订单模块中调用的接口就不能写死了,得用eureka服务中注册的地址名称。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring_16,第16张

a)修改OrderController.java

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_17,第17张

public static final String PAYMENT_URL= "http://CLOUD-PROVIDER-SERVICE";
b)RestTemplate中添加负载均衡注解 @LoadBalanced

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_18,第18张

(4)测试

http://localhost/consumer/payment/get/24

默认以轮询的方式实现负载均衡。

  • 8001 端口

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring_19,第19张

  • 8001 端口

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_20,第20张

四、Actuator 微服务信息完善

1、 自定义服务名称

instance:
    #自定义服务名称
    instance-id: payment8001

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_21,第21张

刷新http://eureka7001.com:7001/ 就可以看到服务名称已经修改了。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_22,第22张

2、安全检查 /health

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_23,第23张

点击服务名称后跳转到如下页面:

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_24,第24张

将 /info 改成 /health

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_25,第25张

UP代表正常。

3、暴露 IP 信息

instance:
    #自定义服务名称
    instance-id: payment8001
    #暴露ip信息
    prefer-ip-address: true

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_26,第26张

当鼠标放到刚配置的主机名上时,左下角就会显示主机的IP。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_27,第27张

五、添加 DiscoveryClient 发现微服务

1、修改8001项目controller层

package org.example.springcloud.controller;

import lombok.extern.slf4j.Slf4j;
import org.example.springcloud.entities.CommonResult;
import org.example.springcloud.entities.Payment;
import org.example.springcloud.service.PaymentService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;

@RestController
@RequestMapping("/payment")
@Slf4j
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    @Resource
    private DiscoveryClient discoveryClient;

    @PostMapping(value = "/create")
    public CommonResult create(@RequestBody Payment payment){
        int result = paymentService.create(payment);
        log.info("*******插入结果为: "+result);
        if(result>0){
            return new CommonResult(200,"插入数据库成功,端口号为:"+serverPort,result);
        }else{
            return new CommonResult(444,"插入数据库失败,端口号为:"+serverPort,null);
        }
    }

    @GetMapping(value = "/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){
        Payment paymentById = paymentService.getPaymentById(id);
        log.info("*********查找结果为: "+paymentById);
        if(paymentById!=null){
            return new CommonResult(200,"查找成功,端口号为:"+serverPort,paymentById);
        }else{
            return new CommonResult(444,"查找为空,查找ID为: "+id +"。端口号为:"+serverPort,null);
        }

    }

    @GetMapping(value = "/discovery")
    public Object discovery(){
    	//获取在Eureka注册中心上注册的微服务名称列表。
        List<String> services = discoveryClient.getServices();
        for (String service : services) {
            log.info("********服务名称*****"+service);
        }
		//获取"CLOUD-PROVIDER-SERVICE"微服务的信息。
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PROVIDER-SERVICE");
        for (ServiceInstance instance : instances) {
            log.info(instance.getServiceId()+"\t"+instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());
        }
        return this.discoveryClient;
    }

}

2、调用接口

http://localhost:8001/payment/discovery

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_28,第28张

控制台打印出服务名称+ip+端口号信息。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_springcloud集群怎么启动_29,第29张

六、关闭自我保护机制。

Eureka保证了高可用AP,但是很难保证一致性CP。
由于自我保护的存在,可以避免网络问题引起的服务失联,但带来的问题是可能导致注册中心的服务列表与真实的不一致。
为了缓解这种情况,可以采取关闭自我保护机制。(不推荐)
不然,干脆换一个注册中心,各有所长,各取所需吧。(比如Zookeeper)

Eureka 默认开启自我保护,所以Eureka页面上会有红色的这句话。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_微服务_30,第30张

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring_31,第31张

下面再来讲讲如何关闭Eureka的自我保护机制。

1、关闭服务端的自我保护机制

server:
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_spring_32,第32张

2、修改客户端

比如修改8001项目。

#Eureka客户端像服务端发送心跳的时间间隔,单位为秒
    lease-renewal-interval-in-seconds: 1
    #Eureka服务端在收到最后一次心跳后等待时间上限,单位为秒(默认90秒),超时将剔除服务
    lease-expiration-duration-in-seconds: 2

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_33,第33张

3、测试

可以看到自我保护模式已经关闭了。

springcloud集群怎么启动 springcloud集群搭建,springcloud集群怎么启动 springcloud集群搭建_Cloud_34,第34张

关闭8001项目,刷新Eureka,可以看到8001项目很快就被剔除出去了。


https://www.xamrdz.com/lan/59h1951247.html

相关文章: