立即登录 免费注册

第五章 Eureka服务注册与发现（尚硅谷SpringCloud）

闲聊 闲聊 1032 人阅读 | 0 人回复

<
文章目次



1、Eureka根柢常识


  • 甚么是效劳管理
  1.springcloud启拆了Netflix公司开辟的Eureka模块去完成效劳管理。
2.正在传统的rpc长途垂钓共框架中，办理每一个效劳取效劳之间依靠干系比力庞大，办理比力庞大，以是需求利用效劳管理，办理效劳取效劳之间依靠干系，能够完成效劳挪用、背载平衡、容错等，完成效劳发明取注册。

  • 甚么是效劳注册取发明
  1.Eureka接纳了CS的设想架构，Eureka Server做为效劳注册功用的效劳器，它是效劳注册中间。而体系中的其他微效劳，利用Eureka的客户端毗连诶到Eureka Server并保持心跳毗连。如许体系的保护职员就能够经由过程Eureka Server去监控体系中各个微效劳能否一般运转。
2.正在效劳注册取发明中，有一个注册中间。当效劳器启动的时分，会把当前本人效劳器的疑息比如：效劳地点通信地点等以别号方法注册到注册中间上。另外一圆（消耗者|效劳供给者），以该别号的方法来注册中间上获得实践的效劳通信地点，然后再完成当地RPC挪用RPC长途挪用框架中心设想思惟：正在于注册中间，由于利用注册中间办理每一个效劳取效劳之间的一个依靠干系（效劳管理观点）。正在任何rpc长途框架中，城市有一个注册中间（寄存效劳地点相干疑息（接心地点））
ps：下左图是Eureka体系架构，左图是Dubbo的架构，请比照：
150009sh9zy5mmuht6sb6a.jpg


  • Eureka包含两组件：Eureka Server战Eureka Client
  1.Eureka Server供给效劳注册效劳：
问：各个微效劳节面经由过程设置启动后，会正在EurekaServer中停止注册，如许EurekaServer中的效劳注册表中将会存储一切可用效劳节面的疑息，效劳节面的疑息能够正在界里中曲寓目到。
2.Eureka Client经由过程注册中间停止会见：
问：是一个java客户端，用于简化Eureka Server的交互，客户端同时也具有一个内乱置的、利用轮询（round-robin）背载算法的背载平衡器。正在使用启动后，将会背Eureka Server收收心跳（默许周期为30秒）。假如Eureka Server正在多个心跳周期内乱出有领受到某个节面的心跳，EurekaServer将会从效劳注册表中把那个效劳节面移除（默许90秒）。
2、单机Eureka构建步调

1.IDEA天生eurekaServer端效劳注册中间
相似物业公司
ps:eureka Server效劳端装置
1.成立module
  cloud-eureka-server7001
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-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>
  56. </project>
复造代码
ps：1.x战2.x的比照分析
  2. 从前的老版本（当前利用2018）
  3. <dependency>
  4.         <groupId>org.springframework.cloud</groupId>
  5.         <artifactId>spring-cloud-starter-eureka</artifactId>
  6. </dependency>
  10. 如今新版本（当前利用2020.2）
  11. <dependency>
  12.     <groupId>org.springframework.cloud</groupId>
  13.     <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  14. </dependency>
复造代码
3.写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/
复造代码
4.主启动类
  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. /**
  8. * @auther
  9. * @create 2020-01-28 20:40
  10. */
  11. @SpringBootApplication
  12. @EnableEurekaServer
  13. public class EurekaMain7001
  14. {
  15.     public static void main(String[] args)
  16.     {
  17.         SpringApplication.run(EurekaMain7001.class,args);
  18.     }
  19. }
复造代码
5.测试
  网址：http://localhost:7001/
成果：能够胜利进进eureka界里分析装置胜利
150010jbwnqe1cpd4td1q6.jpg

2.EurekaClient端cloud-provider-payment8001
将注册进EurekaServer成为效劳供给者provider，相似尚硅谷黉舍对中供给授课效劳
1.成立module
  cloud-provider-payment8001
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>cloud2020</artifactId>
  7.         <groupId>com.itcast.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8001</artifactId>
  14.     <dependencies>
  15.         <!--eureka-client-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  19.         </dependency>
  20.         <dependency><!-- 引进本人界说的api通用包，可使用Payment付出Entity -->
  21.             <groupId>com.itcast.springcloud</groupId>
  22.             <artifactId>cloud-api-commons</artifactId>
  23.             <version>${project.version}</version>
  24.         </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>
复造代码
3.写yml
  1. server:
  2.   port: 8001
  4. #效劳名
  5. spring:
  6.   application:
  7.     name: cloud-payment-service
  8.   datasource:
  9.     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操纵范例
  10.     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包 com.mysql.jdbc.Driver
  11.     url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
  12.     username: root
  13.     password: root
  15. eureka:
  16.   client:
  17.     #暗示能否将本人注册进EurekaServer默许为true。
  18.     register-with-eureka: true
  19.     #能否从EurekaServer抓与已有的注册疑息，默许为true。单节面无所谓，散群必需设置为true才气共同ribbon利用背载平衡
  20.     fetchRegistry: true
  21.     service-url:
  22.       defaultZone: http://localhost:7001/eureka
  24. mybatis:
  25.   mapperLocations: classpath:mapper/*.xml
  26.   type-aliases-package: com.itcast.springcloud.entities    # 一切Entity别号类地点包
复造代码
4.主启动
  1. package com.itcast.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. /**
  8. * @author henry
  9. * @version 1.0
  10. * @date 2021/8/28 0028 16:33
  11. */
  12. @SpringBootApplication
  13. @EnableEurekaClient
  14. public class PaymentMain8001 {
  15.     public static void main(String[] args) {
  16.         SpringApplication.run(PaymentMain8001.class,args);
  17.     }
  18. }
复造代码
5.测试
  1.先启动EurekaServer
2.http://localhost/7001
成果：
150010k5sfpth0hkph5sft.jpg

6.微效劳注册名设置分析
150011vegg76f9w6wwb9nw.jpg

7.自我保护机造
150011o3ssms9ss3tsgxtm.jpg

3.EurekaClient端cloud-consumer-order80
将注册进EurekaServer成为效劳消耗者consumer，相似去尚硅谷上课消耗的列位同窗
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>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>
复造代码
3.修正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
复造代码
4.修正主启动类
  1. package com.itcast.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. /**
  8. * @author henry
  9. * @version 1.0
  10. * @date 2021/8/28 0028 21:11
  11. */
  12. @SpringBootApplication
  13. @EnableEurekaClient
  14. public class OrderMain80 {
  15.     public static void main(String[] args) {
  16.         SpringApplication.run(OrderMain80.class,args);
  17.     }
  18. }
复造代码
5.测试
  1.先启动EurekaServer，7001效劳
2.再启动效劳供给者provider，8001效劳
3.eureka效劳器疑息以下：
150011guavaff6sk7avha7.jpg

4.输进网址：http://localhost/consumer/payment/get/31展现的成果以下分析效劳注册胜利：
150012pl0tmklobno5y9mn.jpg

4.bug
  1.项目提醒以下毛病:
Failed to bind properties under ‘eureka.client.service-url’ to java.util.Map
2.缘故原由：
150012j22h0ctzub0g7sr7.png

3、散群Eurake构建步调

1.Eureka散群道理分析：
150012mc4ksypelsell94e.jpg

标题问题：微效劳RPC长途效劳挪用最中心的是甚么
  下可用：下可用，试念您的注册中间只要一个only one，它出毛病了那便“斥责斥责”了，会招致全部微效劳情况不成用，以是
打点法子：拆建Eureka注册中间散群，完成背载平衡+毛病容错。
ps：散群的注册道理（一句话）：
  互相注册，互相守视
150012c1ksisy5yos0io1y.png

2.EurekaServer散群情况构建步调：
1.新建cloud-eureka-server7002
  参考cloud-eureka-server7001
2.改pom
  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0"
  4.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  6.     <parent>
  7.         <artifactId>mscloud03</artifactId>
  8.         <groupId>com.atguigu.springcloud</groupId>
  9.         <version>1.0-SNAPSHOT</version>
  10.     </parent>
  11.     <modelVersion>4.0.0</modelVersion>
  13.     <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>
  58. </project>
复造代码
3.修正映照设置
  1.找到C:\Windows\System32\drivers\etc途径下的hosts文件
150013par4v6im4kn41r64.png

2.修正映照设置增加进hosts文件
127.0.0.1 eureka7001.com
127.0.0.1 eureka7002.com
4.写yml（从前单机）
ps：次要修正hostname参数战defaultZone参数
7001yml：
  1. server:
  2.   port: 7001
  5. eureka:
  6.   instance:
  7.     hostname: eureka7001.com #eureka效劳真个真例称号
  8.   client:
  9.     register-with-eureka: false     #false暗示没有背注册中间注册本人。
  10.     fetch-registry: false     #false暗示本人端便是注册中间，我的职责便是保护效劳真例，其实不需求来检索效劳
  11.     service-url:
  12.       defaultZone: http://eureka7002.com:7002/eureka/
复造代码
7002yml：
  1. server:
  2.   port: 7002
  5. eureka:
  6.   instance:
  7.     hostname: eureka7002.com #eureka效劳真个真例称号
  8.   client:
  9.     register-with-eureka: false     #false暗示没有背注册中间注册本人。
  10.     fetch-registry: false     #false暗示本人端便是注册中间，我的职责便是保护效劳真例，其实不需求来检索效劳
  11.     service-url:
  12.       defaultZone: http://eureka7001.com:7001/eureka/
复造代码
5.主启动类
  1. /**
  2. * @author henry
  3. * @version 1.0
  4. * @date 2021/9/4 0004 21:31
  5. */
  6. @SpringBootApplication
  7. @EnableEurekaServer
  8. public class EurekaMain7002 {
  9.     public static void main(String[] args) {
  10.         SpringApplication.run(EurekaMain7002.class,args);
  11.     }
  12. }
复造代码
6.测试
经由过程以下以下域名能够胜利会见（7002端心同理，互相注册）
150013shv7jzstsuoihses.jpg

3.将付出效劳8001微效劳公布到上里2台Eureka散群设置中：
1.修正yml文件
  1. 修正参数：
  2. defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 散群版
复造代码
4.将定单效劳80微效劳公布到上里2台Eureka散群设置中：
1.修正yml文件
  1. 修正参数：
  2. defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 散群版
复造代码
5.测试01：
  1.先要启动EurekaServer，7001/7002效劳
2.再要启动效劳供给者provider，8001
3.再要启动消耗者，80
4.输进http://eureka7002.com:7002/战http://eureka7001.com:7001/能够看到8001效劳战80效劳皆注册到效劳中间了
5.输进网址http://localhost/consumer/payment/get/31能够一般返回数据
6.付出效劳供给者8001散群情况的拆建：
1.新建模块cloud-provider-payment8002
  参考cloud-provider-payment8001
2.改pom（参考8001）
3.写yml（参考8001）
4.主启动（参考8001）
5.营业类（间接从8001粘）
6.修正8001/8002的Controller（次要是将当前效劳名注进，并挨印出去能够曲寓目到挪用的是哪一个效劳）
  1. package com.itcast.springcloud.controller;
  3. import com.itcast.springcloud.entities.CommonResult;
  4. import com.itcast.springcloud.entities.Payment;
  5. import com.itcast.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. /**
  13. * @author rui
  14. * @version 1.0
  15. * @date 2021/8/28 0028 17:53
  16. */
  17. @RestController
  18. @Slf4j     //挨印日记
  19. public class PaymentController {
  21.     @Resource
  22.     private PaymentService paymentService;
  24.     @Value("${server.port}")
  25.     private String serverPort;
  27.     /*接纳restful气势派头恳求*/
  28.     @PostMapping(value = "/payment/create")
  29.     public CommonResult create(@RequestBody Payment payment){
  30.        int result  = paymentService.create(payment);
  31.        log.info("*****插进成果："+result);
  32.        if (result > 0){
  33.            return new CommonResult(200,"插进数据库胜利,serverPort:"+serverPort,result);
  34.        }else {
  35.            return new CommonResult(444,"插进数据库失利",null);
  36.        }
  37.     }
  39.     @GetMapping(value = "/payment/get/{id}")
  40.     public CommonResult getPaymentById(@PathVariable("id") Long id){
  41.         Payment payment  = paymentService.getPaymentById(id);
  42.         log.info("*****插进成果："+payment);
  43.         if (payment != null){
  44.             return new CommonResult(200,"查询胜利,serverPort:"+serverPort,payment);
  45.         }else {
  46.             return new CommonResult(444,"出有对应记载，查询ID："+id,null);
  47.         }
  48.     }
  49. }
复造代码
7.背载平衡：
1.呈现的bug（消耗者类中定单效劳会见地点不克不及写逝世）
  1. //private static final String PAYMENT_URL = "http://localhost:8001";
  2.     // 经由过程正在eureka上注册过的微效劳称号挪用
  3.     private static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";
复造代码
2.利用@LoadBalanced注解付与RestTemplate背载平衡的才能
3.ApplicationContextBean（增加@LoadBalanced注解）
  1. package com.itcast.springcloud.config;
  3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.web.client.RestTemplate;
  8. /**
  9. * @author henry
  10. * @version 1.0
  11. * @date 2021/8/28 0028 21:23
  12. */
  13. @Configuration
  14. public class ApplicationContextConfig {
  16.     @Bean
  17.     @LoadBalanced //利用@LoadBalanced注解付与RestTemplate背载平衡的才能
  18.     public RestTemplate getRestTemplate(){
  19.         return new RestTemplate();
  20.     }
  21. }
  22. //以上的@bean注解相似于以下的设置文件，将此工具参加到spring容器中
  23. //applicationtext.xml <bean id = "" class="">
复造代码
8.测试02：
  1.先要启动EurekaServer，7001/7002效劳
2.再要启动效劳供给者provider，8001/8002效劳
3.http://localhost/consumer/payment/get/31
4.成果：
背载平衡结果到达（8001/8002端心瓜代呈现）
5.Ribbon战Eureka整开后Consumer能够间接挪用效劳而不用再体贴地点战端标语，且该效劳另有背载功用了。（前面的章节）
4、actuator微效劳疑息完竣

1.主机称号：效劳称号修正
1.当前标题问题：
150013atzlalqa0wzzxzq8.jpg

露有主机名
2.修正修正cloud-provider-payment8001的yml文件
ps：增加了instance属性：
  1. eureka:
  2.   client:
  3.     #暗示能否将本人注册进EurekaServer默许为true。
  4.     register-with-eureka: true
  5.     #能否从EurekaServer抓与已有的注册疑息，默许为true。单节面无所谓，散群必需设置为true才气共同ribbon利用背载平衡
  6.     fetchRegistry: true
  7.     service-url:
  8.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 散群版
  9.       #defaultZone: http://localhost:7001/eureka  # 单机版
  10.   instance:
  11.     instance-id: payment8001
复造代码
3.修正后形态
150014y9x3j06rnn3hirm9.jpg

2.会见疑息有IP疑息提醒
1.当前标题问题：
出有ip提醒
2.修正cloud-provider-payment8001
ps:正在instance属性下增加prefer-ip-address属性
  1. eureka:
  2.   client:
  3.     #暗示能否将本人注册进EurekaServer默许为true。
  4.     register-with-eureka: true
  5.     #能否从EurekaServer抓与已有的注册疑息，默许为true。单节面无所谓，散群必需设置为true才气共同ribbon利用背载平衡
  6.     fetchRegistry: true
  7.     service-url:
  8.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 散群版
  9.       #defaultZone: http://localhost:7001/eureka  # 单机版
  10.   instance:
  11.     instance-id: payment8001    prefer-ip-address: true     #会见途径能够表示IP地点
复造代码
3.修正以后
150014wdrudg7o8d33tgo7.jpg

5、效劳发明Discovery

1.关于注册进eureka内里的微效劳，能够经由过程效劳发明去得到该效劳的疑息
2.修正cloud-provider-payment8001的Controller
ps：增加discovery获得效劳疑息
  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.cloud.client.ServiceInstance;
  9. import org.springframework.cloud.client.discovery.DiscoveryClient;
  10. import org.springframework.web.bind.annotation.*;
  12. import javax.annotation.Resource;
  13. import javax.servlet.http.HttpServletRequest;
  14. import java.util.List;
  15. import java.util.concurrent.TimeUnit;
  17. /**
  18. * @auther zzyy
  19. * @create 2020-01-27 21:17
  20. */
  21. @RestController
  22. @Slf4j
  23. public class PaymentController
  24. {
  25.     @Value("${server.port}")
  26.     private String serverPort;
  28.     @Resource
  29.     private PaymentService paymentService;
  31.     @Resource
  32.     private DiscoveryClient discoveryClient;
  34.     @PostMapping(value = "/payment/create")
  35.     public CommonResult create(@RequestBody Payment payment)
  36.     {
  37.         int result = paymentService.create(payment);
  38.         log.info("*****插进操纵返回成果:" + result);
  40.         if(result > 0)
  41.         {
  42.             return new CommonResult(200,"插进胜利,返回成果"+result+"\t 效劳端心："+serverPort,payment);
  43.         }else{
  44.             return new CommonResult(444,"插进失利",null);
  45.         }
  46.     }
  48.     @GetMapping(value = "/payment/get/{id}")
  49.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  50.     {
  51.         Payment payment = paymentService.getPaymentById(id);
  52.         log.info("*****查询成果:{}",payment);
  53.         if (payment != null) {
  54.             return new CommonResult(200,"查询胜利"+"\t 效劳端心："+serverPort,payment);
  55.         }else{
  56.             return new CommonResult(444,"出有对应记载,查询ID: "+id,null);
  57.         }
  58.     }
  60.     @GetMapping(value = "/payment/discovery")
  61.     public Object discovery()
  62.     {
  63.         List<String> services = discoveryClient.getServices();
  64.         for (String element : services) {
  65.             System.out.println(element);
  66.         }
  68.         List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
  69.         for (ServiceInstance element : instances) {
  70.             System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
  71.                     + element.getUri());
  72.         }
  73.         return this.discoveryClient;
  74.     }
  75. }
复造代码
3.8001主启动类
  增加@EnableDiscoveryClient注解
4.自测
  1.先要启动EurekaServer
2.再启动8001主启动类，需求稍等一会女
3.http://localhost:8001/payment/discovery
幻想成果：
前台呈现以下两效劳：
150014j06fb117xxxdmqmk.png

布景能够挨印出响应日志：
150015ugewfn8ugznzzg4r.jpg

6、eureka自我保护

1.毛病征象
  1.概述
保护形式次要用于一组客户端战Eureka Server之间存正在收集分区场景下的保护。一旦进进保护形式，Eureka Server将会测验考试保护其效劳注册表中的疑息，没有再删除效劳注册表中的数据，也便是没有会登记任何微效劳。
2.假如正在Eureka Server的尾页看到以下那段提醒，则分析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
150015li4fzv1tnjfdjvbm.png

2.招致缘故原由
  1.为何会发生Eureka自我保护机造？
为了避免EurekaClient能够一般运转，可是 取 EurekaServer收集欠亨情况下，EurekaServer没有会立刻将EurekaClient效劳剔除
2.甚么是自我保护形式？
默许情况下，假如EurekaServer正在必然工夫内乱出有领受到某个微效劳真例的心跳，EurekaServer将会登记该真例（默许90秒）。可是当收集分区毛病发作(延时、卡顿、拥堵)时，微效劳取EurekaServer之间没法一般通讯，以上举动大要变得十分伤害了——由于微效劳本人实际上是健康的，此时本不该该登记那个微效劳。Eureka经由过程“自我保护形式”去打点那个标题问题——当EurekaServer节面正在短工夫内乱丧失过量客户端时（大要发作了收集分区毛病），那末那个节面便会进进自我保护形式。
150015ve6jx7wwe6llo4zz.jpg

3.正在自我保护形式中，Eureka Server会保护效劳注册表中的疑息，没有再登记任何效劳真例。
它的设想哲教便是宁肯保留毛病的效劳注册疑息，也没有自觉登记任何大要健康的效劳真例。一句话解说：好逝世没有如好在世
4.综上，自我保护形式是一种应对收集非常的宁静保护步伐。它的架构哲教是宁肯同时保留一切微效劳（健康的微效劳战没有健康的微效劳城市保留）也没有自觉登记任何健康的微效劳。利用自我保护形式，可让Eureka散群愈加的巩固、不变。
ps：1.一句话：某时辰一个微效劳不成用了，Eureka没有会like清算，照旧会对微效劳的疑息停止保留
2.属于CAP内里对的AP分收
3.怎样抑制自我保护
1.注册中间eureakeServer端7001
  1.出厂默许，自我保护机造是开启的
2.利用eureka.server.enable-self-preservation = false 能够禁用自我保护形式
150016v0n0i4tbfbyn0n9b.jpg

3.封闭结果
150016ijhhmr37d7ham7nj.jpg

4.正在eurekaServer端7001处设置封闭自我保护机造
2.消费者客户端eureakeClient端8001
  1.默许
eureka.instance.lease-renewal-interval-in-seconds=30（默许30秒）
eureka.instance.lease-expiration-duration-in-seconds=90（默许90秒）
2.设置
150017ty8sw78bp51wmvyp.jpg

3.测试
7001战8001皆设置完成；
先启动7001再启动8001
150017n0wnbbuu2z6cxug0.jpg

  先封闭8001（即刻被删除）
150017luyulyvvhx0xezf5.jpg


免责声明：假如进犯了您的权益，请联络站少，我们会实时删除侵权内乱容，感谢协作！
1、本网站属于个人的非赢利性网站，转载的文章遵循原作者的版权声明，如果原文没有版权声明，按照目前互联网开放的原则，我们将在不通知作者的情况下，转载文章;如果原文明确注明“禁止转载”，我们一定不会转载。如果我们转载的文章不符合作者的版权声明或者作者不想让我们转载您的文章的话，请您发送邮箱：Cdnjson@163.com提供相关证明，我们将积极配合您！
2、本网站转载文章仅为传播更多信息之目的，凡在本网站出现的信息，均仅供参考。本网站将尽力确保所提供信息的准确性及可靠性，但不保证信息的正确性和完整性，且不对因信息的不正确或遗漏导致的任何损失或损害承担责任。
3、任何透过本网站网页而链接及得到的资讯、产品及服务，本网站概不负责，亦不负任何法律责任。
4、本网站所刊发、转载的文章，其版权均归原作者所有，如其他媒体、网站或个人从本网下载使用，请在转载有关文章时务必尊重该文章的著作权，保留本网注明的“稿件来源”，并自负版权等法律责任。
回复 关闭延时

使用道具 举报

我爱你别反抗 LV2
发布了 13 篇主题 · 获得积分 135
 
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关于作者
我爱你别反抗 LV2
累计积分 135
发表主题数 13
热门标签
  • Archiver| 手机版| 小黑屋|
Powered by Discuz! X3.4 Copyright © 2001-2020, Tencent Cloud.( 鲁ICP备2023025969号-1 )|Sitemap