【SpringCloud框架之Eureka服务注册与发现】

布满荆棘的人生 2023-09-24 23:16 132阅读 0赞

本笔记内容为尚硅谷SpringCloud框架开发Eureka部分

目录

一、微服务架构编码构建

1、微服务cloud整体聚合父工程Project

创建步骤

2、创建一个公共Module

3、Rest微服务工程构建

1.cloud-provider-payment8001微服务提供者支付Module模块

2、热部署Devtools

3、cloud-consumer-order80微服务消费者订单Module模块

二、Eureka服务注册与发现

1、Eureka基础知识

2、单机Eureka构建步骤

1.生成eurekaServer端服务注册中心

2.EurekaClient端cloud-provider-payment8001

3.EurekaClient端cloud-consumer-order80

3、集群Eureka构建步骤

1.Eureka集群原理说明

2.EurekaServer集群环境构建步骤

3.支付服务提供者8001集群环境构建

4.负载均衡

5.actuator微服务信息完善

6.服务发现Discovery

7.Eureka自我保护

一、微服务架构编码构建

1、微服务cloud整体聚合父工程Project

创建步骤

  1. New Project

4c18de98b4814bce8b3c666f9d27ec83.png

  1. 聚合总父工程名字

0edf700e3d8c476882f075e0e107db99.png

  1. Maven选版本

9b033686bfff456d94752bcf97490160.png

  1. 工程名字

40449437ec3b4226a1e91eac59b00cd1.png

  1. 字符编码

34239ef3a9d441199c4fcc1e6115b3b4.png

  1. 注解生效激活

98ae6c2947534c188abe5de244100b2a.png

  1. java编译版本选8

b45a7afdf6a046f78130670af48810b8.png

  1. File Type过滤

b1ee5a9a978342c0b44e0ba19aa08f90.png

pom文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  7.     <groupId>com.atguigu.springcloud</groupId>
  8.     <artifactId>mscloud03</artifactId>
  9.     <version>1.0-SNAPSHOT</version>
  10.     <packaging>pom</packaging>
  13.     <!-- 统一管理jar包版本 -->
  14.     <properties>
  15.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  16.         <maven.compiler.source>1.8</maven.compiler.source>
  17.         <maven.compiler.target>1.8</maven.compiler.target>
  18.         <junit.version>4.12</junit.version>
  19.         <log4j.version>1.2.17</log4j.version>
  20.         <lombok.version>1.16.18</lombok.version>
  21.         <mysql.version>5.1.47</mysql.version>
  22.         <druid.version>1.1.16</druid.version>
  23.         <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
  24.     </properties>
  27.     <!-- 子模块继承之后，提供作用：锁定版本+子modlue不用写groupId和version  -->
  28.     <dependencyManagement>
  29.         <dependencies>
  30.             <!--spring boot 2.2.2-->
  31.             <dependency>
  32.                 <groupId>org.springframework.boot</groupId>
  33.                 <artifactId>spring-boot-dependencies</artifactId>
  34.                 <version>2.2.2.RELEASE</version>
  35.                 <type>pom</type>
  36.                 <scope>import</scope>
  37.             </dependency>
  38.             <!--spring cloud Hoxton.SR1-->
  39.             <dependency>
  40.                 <groupId>org.springframework.cloud</groupId>
  41.                 <artifactId>spring-cloud-dependencies</artifactId>
  42.                 <version>Hoxton.SR1</version>
  43.                 <type>pom</type>
  44.                 <scope>import</scope>
  45.             </dependency>
  46.             <!--spring cloud alibaba 2.1.0.RELEASE-->
  47.             <dependency>
  48.                 <groupId>com.alibaba.cloud</groupId>
  49.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  50.                 <version>2.1.0.RELEASE</version>
  51.                 <type>pom</type>
  52.                 <scope>import</scope>
  53.             </dependency>
  54.             <dependency>
  55.                 <groupId>mysql</groupId>
  56.                 <artifactId>mysql-connector-java</artifactId>
  57.                 <version>${mysql.version}</version>
  58.             </dependency>
  59.             <dependency>
  60.                 <groupId>com.alibaba</groupId>
  61.                 <artifactId>druid</artifactId>
  62.                 <version>${druid.version}</version>
  63.             </dependency>
  64.             <dependency>
  65.                 <groupId>org.mybatis.spring.boot</groupId>
  66.                 <artifactId>mybatis-spring-boot-starter</artifactId>
  67.                 <version>${mybatis.spring.boot.version}</version>
  68.             </dependency>
  69.             <dependency>
  70.                 <groupId>junit</groupId>
  71.                 <artifactId>junit</artifactId>
  72.                 <version>${junit.version}</version>
  73.             </dependency>
  74.             <dependency>
  75.                 <groupId>log4j</groupId>
  76.                 <artifactId>log4j</artifactId>
  77.                 <version>${log4j.version}</version>
  78.             </dependency>
  79.             <dependency>
  80.                 <groupId>org.projectlombok</groupId>
  81.                 <artifactId>lombok</artifactId>
  82.                 <version>${lombok.version}</version>
  83.                 <optional>true</optional>
  84.             </dependency>
  85.         </dependencies>
  86.     </dependencyManagement>
  88.     <build>
  89.         <plugins>
  90.             <plugin>
  91.                 <groupId>org.springframework.boot</groupId>
  92.                 <artifactId>spring-boot-maven-plugin</artifactId>
  93.                 <configuration>
  94.                     <fork>true</fork>
  95.                     <addResources>true</addResources>
  96.                 </configuration>
  97.             </plugin>
  98.         </plugins>
  99.     </build>
  101. </project>

父工程创建完成执行mvn:install将父工程发布到仓库方便子工程继承

mysql驱动说明

com.mysql.jdbc.Driver和mysql-connector-java 5一起用。

com.mysql.cj.jdbc.Driver和mysql-connector-java 6 一起用。

com.mysql.cj.jdbc.Driver是mysql-connector-java 6 中的特性，相比mysql-connector-java 5 多了一个时区：serverTimezone，把数据源配置的驱动改一下就好了

org.gjt.mm.mysql.Driver是当时最好的MySQL JDBC，但不是MySQL公司的，然后MySQL将MM的JDBC驱动 收为官方的JDBC驱动，所以将驱动的package也改了，但还保留了org.gjt.mm.mysql.Driver这个路径的引用，也就是你使用新版的JDBC驱动时还可以通过这个来引用，打开下载的新版JDBC驱动的jar文件可以看到，只有一个文件的目录是org.gjt.mm.mysql，就是为了兼容而设计的。

2、创建一个公共Module

1.新建一个Module：cloud-api-commons

2.POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-api-commons</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>org.springframework.boot</groupId>
  17.             <artifactId>spring-boot-devtools</artifactId>
  18.             <scope>runtime</scope>
  19.             <optional>true</optional>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>org.projectlombok</groupId>
  23.             <artifactId>lombok</artifactId>
  24.             <optional>true</optional>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>cn.hutool</groupId>
  28.             <artifactId>hutool-all</artifactId>
  29.             <version>5.1.0</version>
  30.         </dependency>
  31.     </dependencies>
  33. </project>

3.entities包下

Payment实体

  1. package com.atguigu.springcloud.entities;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. import java.io.Serializable;
  9. @Data
  10. @AllArgsConstructor
  11. @NoArgsConstructor
  12. public class Payment implements Serializable
  13. {
  14.     private Long id;
  15.     private String serial;
  16. }

CommonResult通用封装类

  1. package com.atguigu.springcloud.entities;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. @Data
  8. @AllArgsConstructor
  9. @NoArgsConstructor
  10. public class CommonResult<T>
  11. {
  12.     private Integer code;
  13.     private String  message;
  14.     private T data;
  16.     public CommonResult(Integer code, String message)
  17.     {
  18.         this(code,message,null);
  19.     }
  20. }

4.maven命令clean install

df9f46858b7a4067b3b4c99ab55a9731.png

在要用到的模块引用依赖即可

  1. <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  2.     <groupId>com.atguigu.springcloud</groupId>
  3.     <artifactId>cloud-api-commons</artifactId>
  4.     <version>${project.version}</version>
  5. </dependency>

3、Rest微服务工程构建

1.cloud-provider-payment8001微服务提供者支付Module模块

步骤

新建Module:cloud-provider-payment8001

改POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumer-order80</artifactId>
  14.     <dependencies>
  15.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  16.             <groupId>com.atguigu.springcloud</groupId>
  17.             <artifactId>cloud-api-commons</artifactId>
  18.             <version>${project.version}</version>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-web</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-actuator</artifactId>
  27.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-devtools</artifactId>
  32.             <scope>runtime</scope>
  33.             <optional>true</optional>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.projectlombok</groupId>
  37.             <artifactId>lombok</artifactId>
  38.             <optional>true</optional>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.boot</groupId>
  42.             <artifactId>spring-boot-starter-test</artifactId>
  43.             <scope>test</scope>
  44.         </dependency>
  45.     </dependencies>
  47. </project>

写YML

  1. server:
  2.   port: 8001
  4. spring:
  5.   application:
  6.     name: cloud-payment-service
  7.   datasource:
  8.     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
  9.     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包 com.mysql.jdbc.Driver
  10.     url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
  11.     username: root
  12.     password: 123456
  15. mybatis:
  16.   mapperLocations: classpath:mapper/*.xml
  17.   type-aliases-package: com.atguigu.springcloud.entities    # 所有Entity别名类所在包

新建主启动类

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. /**
  7.  * @auther zzyy
  8.  * @create 2020-01-27 19:50
  9.  */
  10. @SpringBootApplication
  11. public class PaymentMain8001
  12. {
  13.     public static void main(String[] args)
  14.     {
  15.         SpringApplication.run(PaymentMain8001.class,args);
  16.     }
  17. }

业务类

  1. 建表SQL

    CREATE TABLE payment (

    id bigint(20) NOT NULL AUTO_INCREMENT COMMENT ‘ID’,

    serial varchar(200) DEFAULT ‘’,

    PRIMARY KEY (id)

    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8

  2. dao

接口PaymentDao

  1. package com.atguigu.springcloud.dao;
  3. import com.atguigu.springcloud.entities.Payment;
  4. import org.apache.ibatis.annotations.Mapper;
  6. @Mapper  //import org.apache.ibatis.annotations.Mapper;
  7. public interface PaymentDao
  8. {
  9.     public int create(Payment payment);
  11.     public Payment getPaymentById(@Param("id") Long id);
  12. }

mybaits的映射文件PaymentMapper.xml (src\main\resources\mapper\PaymentMapper.xml)

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  4. <mapper namespace="com.atguigu.springcloud.dao.PaymentDao">
  6.     <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entities.Payment">
  7.         <id column="id" property="id" jdbcType="BIGINT"/>
  8.         <result column="serial" property="serial" jdbcType="VARCHAR"/>
  9.     </resultMap>
  11.     <insert id="create" parameterType="Payment" useGeneratedKeys="true" keyProperty="id">
  12.         INSERT INTO payment(SERIAL) VALUES(#{serial});
  13.     </insert>
  15.     <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap" >
  16.         SELECT * FROM payment WHERE id=#{id};
  17.     </select>
  19. </mapper>

3.service

接口PaymentService

  1. package com.atguigu.springcloud.service;
  3. import com.atguigu.springcloud.entities.Payment;
  4. import org.apache.ibatis.annotations.Param;
  6. public interface PaymentService
  7. {
  8.     public int create(Payment payment);
  10.     public Payment getPaymentById(@Param("id") Long id);
  12. }

实现类PaymentServiceImpl.java

  1. package com.atguigu.springcloud.service.impl;
  3. import com.atguigu.springcloud.dao.PaymentDao;
  4. import com.atguigu.springcloud.entities.Payment;
  5. import com.atguigu.springcloud.service.PaymentService;
  6. import org.springframework.stereotype.Service;
  8. import javax.annotation.Resource;
  11. @Service
  12. public class PaymentServiceImpl implements PaymentService
  13. {
  14.     @Resource
  15.     private PaymentDao paymentDao;
  18.     @Override
  19.     public int create(Payment payment)
  20.     {
  21.         return paymentDao.create(payment);
  22.     }
  24.     @Override
  25.     public Payment getPaymentById(Long id)
  26.     {
  27.         return paymentDao.getPaymentById(id);
  28.     }
  29. }

4.controller

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entities.CommonResult;
  4. import com.atguigu.springcloud.entities.Payment;
  5. import com.atguigu.springcloud.service.PaymentService;
  6. import com.sun.media.jfxmedia.logging.Logger;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.web.bind.annotation.*;
  10. import javax.annotation.Resource;
  12. /**
  13.  * @auther zzyy
  14.  * @create 2020-01-27 21:17
  15.  */
  16. @RestController
  17. @Slf4j
  18. public class PaymentController
  19. {
  20.     @Resource
  21.     private PaymentService paymentService;
  23.     @PostMapping(value = "/payment/create")
  24.     public CommonResult create(@RequestBody Payment payment)
  25.     {
  26.         int result = paymentService.create(payment);
  27.         log.info("*****插入操作返回结果:" + result);
  29.         if(result > 0)
  30.         {
  31.             return new CommonResult(200,"插入数据库成功",result);
  32.         }else{
  33.             return new CommonResult(444,"插入数据库失败",null);
  34.         }
  35.     }
  37.     @GetMapping(value = "/payment/get/{id}")
  38.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  39.     {
  40.         Payment payment = paymentService.getPaymentById(id);
  41.         log.info("*****查询结果:{}",payment);
  42.         if (payment != null) {
  43.             return new CommonResult(200,"查询成功",payment);
  44.         }else{
  45.             return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  46.         }
  47.     }
  48. }

535605b909f6413b9b10fa1d34946134.png

2、热部署Devtools

添加依赖

  1. <dependency>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-devtools</artifactId>
  4.     <scope>runtime</scope>
  5.     <optional>true</optional>
  6. </dependency>

下段配置我们粘贴进聚合父类总工程的pom.xml里

  1. <!--打包插件-->
  2. <build>
  3.     <finalName>你自己的工程名字</finalName>
  4.     <plugins>
  5.         <plugin>
  6.             <groupId>org.springframework.boot</groupId>
  7.             <artifactId>spring-boot-maven-plugin</artifactId>
  8.             <configuration>
  9.                 <fork>true</fork>
  10.                 <addResources>true</addResources>
  11.             </configuration>
  12.         </plugin>
  13.     </plugins>
  14. </build>

设置IDEA

059052158b9145f2adc5e4e2dd425437.png

b7150e341e2243c0ba38ff53159b6a07.png

最后重启生效

3、cloud-consumer-order80微服务消费者订单Module模块

1.新建cloud-consumer-order80

2.POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>cloud190805</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumer-order80</artifactId>
  14.     <dependencies>
  15.        <dependency>
  16. <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  17.             <groupId>com.atguigu.springcloud</groupId>
  18.             <artifactId>cloud-api-commons</artifactId>
  19.             <version>${project.version}</version>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter-web</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-actuator</artifactId>
  28.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-devtools</artifactId>
  33.             <scope>runtime</scope>
  34.             <optional>true</optional>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.projectlombok</groupId>
  38.             <artifactId>lombok</artifactId>
  39.             <optional>true</optional>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.springframework.boot</groupId>
  43.             <artifactId>spring-boot-starter-test</artifactId>
  44.             <scope>test</scope>
  45.         </dependency>
  46.     </dependencies>
  48. </project>

3.写YML

  1. server:
  2.   port: 80

4.新建主启动类

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. @SpringBootApplication
  7. public class MainApp80
  8. {
  9.     public static void main(String[] args)
  10.     {
  11.         SpringApplication.run(MainApp80.class,args);
  12.     }
  13. }

5.业务类

RestTemplate

RestTemplate提供了多种便捷访问远程Http服务的方法， 是一种简单便捷的访问restful服务模板类，是Spring提供的用于访问Rest服务的客户端模板工具集

官网地址

https://docs.spring.io/spring-framework/docs/5.2.2.RELEASE/javadoc-api/org/springframework/web/client/RestTemplate.html

使用

使用restTemplate访问restful接口非常的简单粗暴无脑。

(url, requestMap, ResponseBean.class)这三个参数分别代表

REST请求地址、请求参数、HTTP响应转换被转换成的对象类型。

6.config配置类ApplicationContextConfig

  1. package com.atguigu.springcloud.config;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.web.client.RestTemplate;
  7. @Configuration
  8. public class ApplicationContextConfig
  9. {
  10.     @Bean
  11.     public RestTemplate restTemplate()
  12.     {
  13.         return new RestTemplate();
  14.     }
  15. }

7.Controller类

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entities.CommonResult;
  4. import com.atguigu.springcloud.entities.Payment;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import org.springframework.web.client.RestTemplate;
  11. @RestController
  12. public class OrderController
  13. {
  15.     public static final String PaymentSrv_URL = "http://localhost:8001";
  17.     @Autowired
  18.     private RestTemplate restTemplate;
  20.     @GetMapping("/consumer/payment/create") //客户端用浏览器是get请求，但是底层实质发送post调用服务端8001
  21.     public CommonResult create(Payment payment)
  22.     {
  23.         return restTemplate.postForObject(PaymentSrv_URL + "/payment/create",payment,CommonResult.class);
  24.     }
  27.     @GetMapping("/consumer/payment/get/{id}")
  28.     public CommonResult getPayment(@PathVariable Long id)
  29.     {
  30.         return restTemplate.getForObject(PaymentSrv_URL + "/payment/get/"+id, CommonResult.class, id);
  31.     }
  32. }

86c858cb5de74568916eaf474564e742.png

9a84040e87b64fc59cc3246bd40acc18.png

二、Eureka服务注册与发现

1、Eureka基础知识

什么是服务治理　　

Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理

在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册。

什么是服务注册与发现

Eureka采用了CS的设计架构，Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。

在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息 比如 服务地址通讯地址等以别名方式注册到注册中心上。另一方（消费者|服务提供者），以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用RPC远程调用框架核心设计思想：在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址))

54ad422a3f574a2c984394f36becf272.png

Eureka包含两个组件：Eureka Server和Eureka Client

Eureka Server提供服务注册服务

各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到。

EurekaClient通过注册中心进行访问

是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）

2、单机Eureka构建步骤

1.生成eurekaServer端服务注册中心

步骤

建Module：cloud-eureka-server7001

改POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-eureka-server7001</artifactId>
  14.     <dependencies>
  15.         <!--eureka-server-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  19.         </dependency>
  20.         <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  21.         <dependency>
  22.             <groupId>com.atguigu.springcloud</groupId>
  23.             <artifactId>cloud-api-commons</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <!--boot web actuator-->
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-actuator</artifactId>
  34.         </dependency>
  35.         <!--一般通用配置-->
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-devtools</artifactId>
  39.             <scope>runtime</scope>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.projectlombok</groupId>
  44.             <artifactId>lombok</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-test</artifactId>
  49.             <scope>test</scope>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>junit</groupId>
  53.             <artifactId>junit</artifactId>
  54.         </dependency>
  55.     </dependencies>
  57. </project>

写YML

  1. server:
  2.   port: 7001
  4. eureka:
  5.   instance:
  6.     hostname: localhost #eureka服务端的实例名称
  7.   client:
  8.     #false表示不向注册中心注册自己。
  9.     register-with-eureka: false
  10.     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  11.     fetch-registry: false
  12.     service-url:
  13.     #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
  14.       defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

主启动

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  7. @SpringBootApplication
  8. @EnableEurekaServer
  9. public class EurekaMain7001
  10. {
  11.     public static void main(String[] args)
  12.     {
  13.         SpringApplication.run(EurekaMain7001.class,args);
  14.     }
  15. }

测试http://localhost:7001/

No application available 没有服务被发现O(∩_∩)O因为没有注册服务进来当然不可能有服务被发现

cb20181f0ff04ed18ce9d5b2953f3a52.png

#

2.EurekaClient端cloud-provider-payment8001

将注册进EurekaServer成为服务提供者provider

建Module:cloud-provider-payment8001

改POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8001</artifactId>
  15.     <dependencies>
  16.         <!--eureka-client-->
  17.         <dependency>
  18.             <groupId>org.springframework.cloud</groupId>
  19.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  20.         </dependency>
  21.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  22.             <groupId>com.atguigu.springcloud</groupId>
  23.             <artifactId>cloud-api-commons</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-web</artifactId>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-actuator</artifactId>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>org.mybatis.spring.boot</groupId>
  36.             <artifactId>mybatis-spring-boot-starter</artifactId>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>com.alibaba</groupId>
  40.             <artifactId>druid-spring-boot-starter</artifactId>
  41.             <version>1.1.10</version>
  42.         </dependency>
  43.         <!--mysql-connector-java-->
  44.         <dependency>
  45.             <groupId>mysql</groupId>
  46.             <artifactId>mysql-connector-java</artifactId>
  47.         </dependency>
  48.         <!--jdbc-->
  49.         <dependency>
  50.             <groupId>org.springframework.boot</groupId>
  51.             <artifactId>spring-boot-starter-jdbc</artifactId>
  52.         </dependency>
  53.         <dependency>
  54.             <groupId>org.springframework.boot</groupId>
  55.             <artifactId>spring-boot-devtools</artifactId>
  56.             <scope>runtime</scope>
  57.             <optional>true</optional>
  58.         </dependency>
  59.         <dependency>
  60.             <groupId>org.projectlombok</groupId>
  61.             <artifactId>lombok</artifactId>
  62.             <optional>true</optional>
  63.         </dependency>
  64.         <dependency>
  65.             <groupId>org.springframework.boot</groupId>
  66.             <artifactId>spring-boot-starter-test</artifactId>
  67.             <scope>test</scope>
  68.         </dependency>
  69.     </dependencies>
  70. </project>

写YML

  1. server:
  2.   port: 8001
  4. spring:
  5.   application:
  6.     name: cloud-payment-service
  7.   datasource:
  8.     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
  9.     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
  10.     url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
  11.     username: root
  12.     password: 123456
  14. eureka:
  15.   client:
  16.     #表示是否将自己注册进EurekaServer默认为true。
  17.     register-with-eureka: true
  18.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  19.     fetchRegistry: true
  20.     service-url:
  21.       defaultZone: http://localhost:7001/eureka
  24. mybatis:
  25.   mapperLocations: classpath:mapper/*.xml
  26.   type-aliases-package: com.atguigu.springcloud.entities    # 所有Entity别名类所在包

主启动

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. /**
  8.  * @auther zzyy
  9.  * @create 2020-01-27 19:50
  10.  */
  11. @SpringBootApplication
  12. @EnableEurekaClient
  13. public class PaymentMain8001
  14. {
  15.     public static void main(String[] args)
  16.     {
  17.         SpringApplication.run(PaymentMain8001.class,args);
  18.     }
  19. }

测试

先要启动EurekaServer

访问http://localhost:7001/

b34d17a553484206bd62dc16a6f41b54.png

微服务注册名配置说明

f121e0e4d0424388811b2b620eec5bcd.png

自我保护机制

cc0bceef5c1746738875eb0699216027.png

#

3.EurekaClient端cloud-consumer-order80

将注册进EurekaServer成为服务消费者consumer

建Module：cloud-consumer-order80

POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumer-order80</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>org.springframework.cloud</groupId>
  17.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  18.         </dependency>
  19.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  20.             <groupId>com.atguigu.springcloud</groupId>
  21.             <artifactId>cloud-api-commons</artifactId>
  22.             <version>${project.version}</version>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-web</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-actuator</artifactId>
  31.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-devtools</artifactId>
  36.             <scope>runtime</scope>
  37.             <optional>true</optional>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.projectlombok</groupId>
  41.             <artifactId>lombok</artifactId>
  42.             <optional>true</optional>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-test</artifactId>
  47.             <scope>test</scope>
  48.         </dependency>
  49.     </dependencies>
  51. </project>

YML

  1. server:
  2.   port: 80
  4. spring:
  5.     application:
  6.         name: cloud-order-service
  8. eureka:
  9.   client:
  10.     #表示是否将自己注册进EurekaServer默认为true。
  11.     register-with-eureka: true
  12.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  13.     fetchRegistry: true
  14.     service-url:
  15.       defaultZone: http://localhost:7001/eureka

主启动

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. @SpringBootApplication
  8. @EnableEurekaClient
  9. public class OrderMain80
  10. {
  11.     public static void main(String[] args)
  12.     {
  13.         SpringApplication.run(OrderMain80.class,args);
  14.     }
  15. }

测试

先要启动EurekaServer，7001服务

再要启动服务提供者provider，8001服务

eureka服务器

75ed44d4367b44ae8fec32240409655f.png

http://localhost/consumer/payment/get/31

注意：YML层次缩进和空格不能少

#

3、集群Eureka构建步骤

1.Eureka集群原理说明

c41135b44d874750b0bc109705a31b89.png

#

2.EurekaServer集群环境构建步骤

参考cloud-eureka-server7001

新建Module:cloud-eureka-server7002

改POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-eureka-server7002</artifactId>
  16.     <dependencies>
  17.         <!--eureka-server-->
  18.         <dependency>
  19.             <groupId>org.springframework.cloud</groupId>
  20.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  21.         </dependency>
  22.         <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  23.         <dependency>
  24.             <groupId>com.atguigu.springcloud</groupId>
  25.             <artifactId>cloud-api-commons</artifactId>
  26.             <version>${project.version}</version>
  27.         </dependency>
  28.         <!--boot web actuator-->
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-web</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-starter-actuator</artifactId>
  36.         </dependency>
  37.         <!--一般通用配置-->
  38.         <dependency>
  39.             <groupId>org.springframework.boot</groupId>
  40.             <artifactId>spring-boot-devtools</artifactId>
  41.             <scope>runtime</scope>
  42.             <optional>true</optional>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.projectlombok</groupId>
  46.             <artifactId>lombok</artifactId>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>org.springframework.boot</groupId>
  50.             <artifactId>spring-boot-starter-test</artifactId>
  51.             <scope>test</scope>
  52.         </dependency>
  53.         <dependency>
  54.             <groupId>junit</groupId>
  55.             <artifactId>junit</artifactId>
  56.         </dependency>
  57.     </dependencies>
  59. </project>

修改映射配置

c705f79c1a9e4d7bb85ec4541453dd9a.png

写YML(以前单机)

a4fd437dc78f457c9d97a9c1162757e2.png

7001现在

  1. server:
  2.   port: 7001
  4. eureka:
  5.   instance:
  6.     hostname: eureka7001.com #eureka服务端的实例名称
  7.   client:
  8.     register-with-eureka: false     #false表示不向注册中心注册自己。
  9.     fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  10.     service-url:
  11.       defaultZone: http://eureka7002.com:7002/eureka/

7002现在

  1. server:
  2.   port: 7002
  4. eureka:
  5.   instance:
  6.     hostname: eureka7002.com #eureka服务端的实例名称
  7.   client:
  8.     register-with-eureka: false     #false表示不向注册中心注册自己。
  9.     fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  10.     service-url:
  11.       defaultZone: http://eureka7001.com:7001/eureka/

主启动

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  7. @SpringBootApplication
  8. @EnableEurekaServer
  9. public class EurekaMain7002
  10. {
  11.     public static void main(String[] args)
  12.     {
  13.         SpringApplication.run(EurekaMain7002.class,args);
  14.     }
  15. }

将支付服务8001微服务发布到上面2台Eureka集群配置中:YML

defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

e7e2fe0a513344d9b19f765a806eb6e0.png

将订单服务80微服务发布到上面2台Eureka集群配置中:YML

eureka:
client:
#表示是否将自己注册进EurekaServer默认为true**。
register-with-eureka: true
#是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon**使用负载均衡
fetchRegistry: true
service-url:
#defaultZone: http://localhost:7001/eureka
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

a94a2b88748e4addbe46d55c07880e28.png

测试

先要启动EurekaServer，7001/7002服务

再要启动服务提供者provider，8001

再要启动消费者，80

访问：http://localhost/consumer/payment/get/31

#

3.支付服务提供者8001集群环境构建

参考cloud-provider-payment8001

新建cloud-provider-payment8002

改POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>mscloud03</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8002</artifactId>
  16.     <dependencies>
  17.         <!--eureka-client-->
  18.         <dependency>
  19.             <groupId>org.springframework.cloud</groupId>
  20.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  21.         </dependency>
  22.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  23.             <groupId>com.atguigu.springcloud</groupId>
  24.             <artifactId>cloud-api-commons</artifactId>
  25.             <version>${project.version}</version>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-actuator</artifactId>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.mybatis.spring.boot</groupId>
  37.             <artifactId>mybatis-spring-boot-starter</artifactId>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>com.alibaba</groupId>
  41.             <artifactId>druid-spring-boot-starter</artifactId>
  42.             <version>1.1.10</version>
  43.         </dependency>
  44.         <!--mysql-connector-java-->
  45.         <dependency>
  46.             <groupId>mysql</groupId>
  47.             <artifactId>mysql-connector-java</artifactId>
  48.         </dependency>
  49.         <!--jdbc-->
  50.         <dependency>
  51.             <groupId>org.springframework.boot</groupId>
  52.             <artifactId>spring-boot-starter-jdbc</artifactId>
  53.         </dependency>
  54.         <dependency>
  55.             <groupId>org.springframework.boot</groupId>
  56.             <artifactId>spring-boot-devtools</artifactId>
  57.             <scope>runtime</scope>
  58.             <optional>true</optional>
  59.         </dependency>
  60.         <dependency>
  61.             <groupId>org.projectlombok</groupId>
  62.             <artifactId>lombok</artifactId>
  63.             <optional>true</optional>
  64.         </dependency>
  65.         <dependency>
  66.             <groupId>org.springframework.boot</groupId>
  67.             <artifactId>spring-boot-starter-test</artifactId>
  68.             <scope>test</scope>
  69.         </dependency>
  70.     </dependencies>
  71. </project>

写YML

defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

3481177dd05c47c783748026fbd967c7.png

主启动

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. @SpringBootApplication
  8. @EnableEurekaClient
  9. public class PaymentMain8002
  10. {
  11.     public static void main(String[] args)
  12.     {
  13.         SpringApplication.run(PaymentMain8002.class,args);
  14.     }
  15. }

业务类

直接从8001粘

修改Controller

8001

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entities.CommonResult;
  4. import com.atguigu.springcloud.entities.Payment;
  5. import com.atguigu.springcloud.service.PaymentService;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.springframework.beans.factory.annotation.Value;
  8. import org.springframework.web.bind.annotation.*;
  10. import javax.annotation.Resource;
  12. @RestController
  13. @Slf4j
  14. public class PaymentController
  15. {
  16.     @Value("${server.port}")
  17.     private String serverPort;
  19.     @Resource
  20.     private PaymentService paymentService;
  22.     @PostMapping(value = "/payment/create")
  23.     public CommonResult create(@RequestBody Payment payment)
  24.     {
  25.         int result = paymentService.create(payment);
  26.         log.info("*****插入操作返回结果:" + result);
  28.         if(result > 0)
  29.         {
  30.             return new CommonResult(200,"插入成功,返回结果"+result+"\t 服务端口："+serverPort,payment);
  31.         }else{
  32.             return new CommonResult(444,"插入失败",null);
  33.         }
  34.     }
  36.     @GetMapping(value = "/payment/get/{id}")
  37.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  38.     {
  39.         Payment payment = paymentService.getPaymentById(id);
  40.         log.info("*****查询结果:{}",payment);
  41.         if (payment != null) {
  42.             return new CommonResult(200,"查询成功"+"\t 服务端口："+serverPort,payment);
  43.         }else{
  44.             return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  45.         }
  46.     }
  47. }

8002

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.entities.CommonResult;
  4. import com.atguigu.springcloud.entities.Payment;
  5. import com.atguigu.springcloud.service.PaymentService;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.springframework.beans.factory.annotation.Value;
  8. import org.springframework.web.bind.annotation.*;
  10. import javax.annotation.Resource;
  12. @RestController
  13. @Slf4j
  14. public class PaymentController
  15. {
  16.     @Value("${server.port}")
  17.     private String serverPort;
  19.     @Resource
  20.     private PaymentService paymentService;
  22.     @PostMapping(value = "/payment/create")
  23.     public CommonResult create(@RequestBody Payment payment)
  24.     {
  25.         int result = paymentService.create(payment);
  26.         log.info("*****新增结果:" + result);
  28.         if(result > 0)
  29.         {
  30.             return new CommonResult(200,"插入成功,返回结果"+result+"\t 服务端口："+serverPort,payment);
  31.         }else{
  32.             return new CommonResult(444,"插入失败",null);
  33.         }
  34.     }
  36.     @GetMapping(value = "/payment/get/{id}")
  37.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  38.     {
  39.         Payment payment = paymentService.getPaymentById(id);
  40.         log.info("*****查询结果:{}",payment);
  41.         if (payment != null) {
  42.             return new CommonResult(200,"查询成功"+"\t 服务端口："+serverPort,payment);
  43.         }else{
  44.             return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  45.         }
  46.     }
  47. }

#

4.负载均衡

消费者cloud-consumer-order80
OrderController访问不能写死

  1. //public static final String PaymentSrv_URL = "http://localhost:8001";
  2.     // 通过在eureka上注册过的微服务名称调用
  3.     public static final String PaymentSrv_URL = "http://CLOUD-PAYMENT-SERVICE";

使用@LoadBalanced注解赋予RestTemplate负载均衡的能力

ApplicationContextBean

  1. @Configuration
  2. public class ApplicationContextBean
  3. {
  4.     @Bean
  5.     @LoadBalanced //使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
  6.     public RestTemplate getRestTemplate()
  7.     {
  8.         return new RestTemplate();
  9.     }
  10. }

3816572164e04e9bbf10253ff43d7e0b.png

#

5.actuator微服务信息完善

主机名称:服务名称修改

62e27a9eaef64169aa104a7e2347be74.png

修改cloud-provider-payment8001：YML

  1. instance:
  2.     instance-id: payment8001

50b9cc68327449a7823f47d1e5e16488.png

访问信息有IP信息提示

没有IP显示

修改cloud-provider-payment8001：YML

  1. prefer-ip-address: true     #访问路径可以显示IP地址

" class="reference-link">a92ec9cf3e6445e19ecdf909c1a8a02c.png

6.服务发现Discovery

对于注册进eureka里面的微服务，可以通过服务发现来获得该服务的信息

修改cloud-provider-payment8001的Controller

  1. @Resource
  2.     private DiscoveryClient discoveryClient;
  5. @GetMapping(value = "/payment/discovery")
  6.     public Object discovery()
  7.     {
  8.         //查看有Eureka有什么服务
  9.         List<String> services = discoveryClient.getServices();
  10.         for (String element : services) {
  11.             System.out.println(element);
  12.         }
  13.         //查看CLOUD-PAYMENT-SERVICE名称下有什么实例
  14.         List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
  15.         for (ServiceInstance element : instances) {
  16.             System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
  17.                     + element.getUri());
  18.         }
  19.         return this.discoveryClient;
  20.     }

8001主启动类

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. @EnableDiscoveryClient //服务发现
  4. public class PaymentMain8001
  5. {
  6.     public static void main(String[] args)
  7.     {
  8.         SpringApplication.run(PaymentMain8001.class,args);
  9.     }
  10. }

d5de45bd89db440b8777a10acda9412d.png

#

7.Eureka自我保护

故障现象

2458ed5328bb4135b7a7b711167f6d36.png

导致原因

为什么会产生Eureka自我保护机制？

为了防止EurekaClient可以正常运行，但是 与 EurekaServer网络不通情况下，EurekaServer不会立刻将EurekaClient服务剔除

什么是自我保护模式？

默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒）。但是当网络分区故障发生(延时、卡顿、拥挤)时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。Eureka通过“自我保护模式”来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。

0cad3b373ef64625ae03012327c4bfa1.png

怎么禁止自我保护

注册中心eureakeServer端7001

修改YML

使用eureka.server.enable-self-preservation = false 可以禁用自我保护模式

bce1a582a30b4db3a4763cd3c5595705.png

关闭效果

e56055140646442bbfc952ccfba2fe5c.png

生产者客户端eureakeClient端8001

  1. #心跳检测与续约时间
  2. #开发时设置小些，保证服务关闭后注册中心能即使剔除服务
  3.   instance:
  4.   #Eureka客户端向服务端发送心跳的时间间隔，单位为秒(默认是30秒)
  5.     lease-renewal-interval-in-seconds: 1
  6.   #Eureka服务端在收到最后一次心跳后等待时间上限，单位为秒(默认是90秒)，超时将剔除服务
  7.     lease-expiration-duration-in-seconds: 2

4ac8646a75e44cff9ee076ecff272f80.png

0beda5602973453f9db6dd96a3f95cf9.png

发表评论

表情：
评论列表 （有 0 条评论，132人围观）

还没有评论，来说两句吧...

相关阅读