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

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

编程语言2024-05-09 22:44:08

这里写目录标题

前言
一、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