当前位置： 首页 > news >正文

青州做网站b2b免费发布信息平台

news 2025/7/2 3:22:39
青州做网站,b2b免费发布信息平台,制作公司网页软件,目前做公司网站有没有用前言 SpringCloud 是微服务中的翘楚，最佳的落地方案。 使用 SpringCloud 的Hystrix Dashboard 组件可以监控单个应用服务的调用情况，但如果是集群环境，可能就 不能满足需求了，这时就用到了SpringCloud 另一个组件：T…

前言

SpringCloud 是微服务中的翘楚，最佳的落地方案。

使用 SpringCloud 的Hystrix Dashboard 组件可以监控单个应用服务的调用情况，但如果是集群环境，可能就

不能满足需求了，这时就用到了SpringCloud 另一个组件：Turbine。

Turbine 将每个应用服务的调用情况聚合在一起展示出来。

如果了解过Hystrix Dashboard，那么可以简单认为 Turbine 就相当于另起了一个工程，把其他工程的监控情况

全部显示到了 Turbine 工程中。

源码

GitHub地址：https://github.com/intomylife/SpringCloud

环境

  • JDK 1.8.0 +
  • Maven 3.0 +
  • SpringBoot 2.0.3
  • SpringCloud Finchley.RELEASE

开发工具

  • IntelliJ IDEA

正文

commons 工程

commons 工程 - POM 文件

<?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"><modelVersion>4.0.0</modelVersion><!-- 三坐标 --><groupId>com.zwc</groupId><artifactId>springcloud-turbine-commons</artifactId><version>1.0</version><!-- 工程名称和描述 --><name>springcloud-turbine-commons</name><description>公用工程</description><!-- 打包方式 --><packaging>jar</packaging><!-- 在 properties下声明相应的版本信息，然后在dependency下引用的时候用 ${} 就可以引入该版本jar包了 --><properties><!-- 编码 --><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><!-- jdk --><java.version>1.8</java.version><!-- SpringBoot --><platform-bom.version>Cairo-SR3</platform-bom.version><!-- SpringCloud --><spring-cloud-dependencies.version>Finchley.RELEASE</spring-cloud-dependencies.version></properties><!-- 加入依赖 --><dependencies></dependencies><!-- 依赖 jar 包版本管理的管理器 --><!-- 如果 dependencies 里的 dependency 自己没有声明 version 元素，那么 maven 就此处来找版本声明。 --><!-- 如果有，就会继承它；如果没有就会报错，告诉你没有版本信息 --><!-- 优先级：如果 dependencies 里的 dependency 已经声明了版本信息，就不会生效此处的版本信息了 --><dependencyManagement><dependencies><!-- SpringBoot --><dependency><groupId>io.spring.platform</groupId><artifactId>platform-bom</artifactId><version>${platform-bom.version}</version><type>pom</type><scope>import</scope></dependency><!-- SpringCloud --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud-dependencies.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><!-- 插件依赖 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
  • 配置一些共用依赖

commons 工程 - 项目结构

service 工程

① 此工程下有五个模块：一个注册中心，一个聚合监控中心以及服务 A、B、C

② A 提供服务并且调用服务 B、B 提供服务并且调用服务 C 以及 C 提供服务

registry-service（注册中心）

registry-service - POM 文件

<?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"><modelVersion>4.0.0</modelVersion><!-- 继承父 --><parent><groupId>com.zwc</groupId><artifactId>springcloud-turbine-service</artifactId><version>1.0</version></parent><!-- 三坐标 --><groupId>com.zwc</groupId><artifactId>springcloud-turbine-registry-service</artifactId><version>1.0</version><!-- 工程名称描述 --><name>springcloud-turbine-registry-service</name><description>注册中心</description><!-- 打包方式 --><packaging>jar</packaging><!-- 在 properties下声明相应的版本信息，然后在dependency下引用的时候用 ${} 就可以引入该版本jar包了 --><properties></properties><!-- 加入依赖 --><dependencies><!-- commons工程 依赖 --><dependency><groupId>com.zwc</groupId><artifactId>springcloud-turbine-commons</artifactId><version>1.0</version></dependency><!-- 服务注册中心 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency></dependencies><!-- 插件依赖 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
  • 主要是加入spring-cloud-starter-netflix-eureka-server依赖

registry-service - application.yml配置文件

# 端口
server:port: 8761# 应用名称
spring:application:name: eureka-servereureka:instance:# 使用 ip 代替实例名prefer-ip-address: true# 实例的主机名hostname: ${spring.cloud.client.ip-address}# 实例的 ID 规则instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}client:# 是否向注册中心注册自己registerWithEureka: false# 是否向注册中心获取注册信息fetchRegistry: falseserviceUrl:# 注册中心地址defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
  • 这里使用了默认的 8761 端口，当然也可以更改，不过在发现调用服务端的注册中心地址端口要与它一致

registry-service - 启动类

package com.zwc;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication
@EnableEurekaServer
public class SpringcloudTurbineRegistryServiceApplication {public static void main(String[] args) {SpringApplication.run(SpringcloudTurbineRegistryServiceApplication.class, args);}}
  • 在启动类中添加 @EnableEurekaServer 注解表示此工程是注册中心

registry-service - 启动项目

1. 项目启动成功后访问http://localhost:8761/即可看到eureka-server 主页面

master-service（聚合监控中心）

master-service - POM 文件

<?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"><modelVersion>4.0.0</modelVersion><!-- 继承父 --><parent><groupId>com.zwc</groupId><artifactId>springcloud-turbine-service</artifactId><version>1.0</version></parent><!-- 三坐标 --><groupId>com.zwc</groupId><artifactId>springcloud-turbine-master-service</artifactId><version>1.0</version><!-- 工程名称描述 --><name>springcloud-turbine-master-service</name><description>集群监控</description><!-- 打包方式 --><packaging>jar</packaging><!-- 在 properties下声明相应的版本信息，然后在dependency下引用的时候用 ${} 就可以引入该版本jar包了 --><properties></properties><!-- 加入依赖 --><dependencies><!-- commons工程 依赖 --><dependency><groupId>com.zwc</groupId><artifactId>springcloud-turbine-commons</artifactId><version>1.0</version></dependency><!-- 提供者消费者 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!-- actuator --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!-- hystrix --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency><!-- dashboard --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId></dependency><!-- turbine --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-netflix-turbine</artifactId></dependency></dependencies><!-- 插件依赖 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
  • 加入spring-cloud-starter-netflix-eureka-client依赖：提供和注册服务
  • 加入依赖 spring-boot-starter-actuator：开启并配置端点
  • 加入依赖 spring-cloud-starter-netflix-hystrix：熔断器
  • 加入依赖 spring-cloud-starter-netflix-hystrix-dashboard：熔断监控
  • 加入依赖spring-cloud-netflix-turbine：监控数据聚合

master-service - application.yml配置文件

# 端口
server:port: 8762# 应用名称
spring:application:name: hystrix-dashboard-turbineeureka:instance:# 使用 ip 代替实例名prefer-ip-address: true# 实例的主机名hostname: ${spring.cloud.client.ip-address}# 实例的 ID 规则instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}client:serviceUrl:# 注册中心地址defaultZone: http://${eureka.instance.hostname}:8761/eureka/turbine:# 监控的应用名称，多个以逗号隔开app-config: turbine-a,turbine-baggregator:# 指定聚合哪些集群，默认为 defaultclusterConfig: default# 指定集群名称为 defaultclusterNameExpression: new String("default")
  • 注意此处配置注册中心地址的端口为 8761 也就是上面注册中心工程配置的端口
  • 此工程需要和应用服务指定同一个注册中心地址
  • 配置的app-config 中的应用名称都将会被此工程监控

master-service - 启动类

package com.zwc;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.netflix.turbine.EnableTurbine;@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
@EnableHystrixDashboard
@EnableTurbine
public class SpringcloudTurbineMasterServiceApplication {public static void main(String[] args) {SpringApplication.run(SpringcloudTurbineMasterServiceApplication.class, args);}}
  • 添加 @EnableEurekaClient 注解表示此工程可以向注册中心提供服务
  • 添加@EnableHystrix 注解表示开启熔断器
  • 添加 @EnableHystrixDashboard 注解表示开启熔断监控
  • 添加@EnableTurbine 注解表示开启监控数据聚合

master-server - 启动项目

1. 项目启动成功后访问http://localhost:8762/hystrix可以看到

2. 在中间的输入框中输入：http://127.0.0.1:8762/turbine.stream?，点击Monitor Stream 按钮可以看到

3. 此时还未调用服务，所以一直显示 ‘Loading …’

服务工程 A（提供者和消费者）

服务工程 A- POM 文件

<?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"><modelVersion>4.0.0</modelVersion><!-- 继承父 --><parent><groupId>com.zwc</groupId><artifactId>springcloud-turbine-a-service</artifactId><version>1.0</version></parent><!-- 三坐标 --><groupId>com.zwc</groupId><artifactId>springcloud-turbine-a-service-core</artifactId><version>1.0</version><!-- 工程名称描述 --><name>springcloud-turbine-a-service-core</name><description>服务工程 - A 核心</description><!-- 打包方式 --><packaging>jar</packaging><!-- 在 properties下声明相应的版本信息，然后在dependency下引用的时候用 ${} 就可以引入该版本jar包了 --><properties></properties><!-- 加入依赖 --><dependencies><!-- commons工程 依赖 --><dependency><groupId>com.zwc</groupId><artifactId>springcloud-turbine-commons</artifactId><version>1.0</version></dependency><!-- api工程 依赖 --><dependency><groupId>com.zwc</groupId><artifactId>springcloud-turbine-a-service-api</artifactId><version>1.0</version></dependency><!-- 提供者消费者 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!-- feign --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!-- actuator --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!-- hystrix --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency><!-- dashboard --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId></dependency></dependencies><!-- 插件依赖 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
  • 加入spring-cloud-starter-netflix-eureka-client依赖：提供和注册服务
  • 加入 Feign 的起步依赖spring-cloud-starter-openfeign：消费服务
  • 加入依赖 spring-boot-starter-actuator：开启并配置端点
  • 加入依赖 spring-cloud-starter-netflix-hystrix：熔断器
  • 加入依赖 spring-cloud-starter-netflix-hystrix-dashboard：熔断监控

服务工程 A- application.yml配置文件

# 端口
server:port: 8090# 应用名称
spring:application:name: turbine-aeureka:instance:# 使用 ip 代替实例名prefer-ip-address: true# 实例的主机名hostname: ${spring.cloud.client.ip-address}# 实例的 ID 规则instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}client:serviceUrl:# 注册中心地址defaultZone: http://${eureka.instance.hostname}:8761/eureka/management:endpoints:web:exposure:# 开启监控端点include: hystrix.stream
  • 注意此处配置注册中心地址的端口为 8761 也就是上面注册中心工程配置的端口
  • spring.application.name：应用名称，被消费者调用时需要用到，它在消费的同时也可以被消费
  • 服务工程 B 和服务工程 C 配置与此类似，只是端口和应用名称不一样，不再赘述
  • 在 2.0 后需要主动开启端点 hystrix.stream，否则 404

服务工程 A- application.properties（注意）

# 开启断路器
feign.hystrix.enabled=true
  • 断路器要主动开启，服务调用失败时才会熔断
  • 此处有一个坑，把此配置写到 yml 中熔断不会生效
  • A 和 B 工程都有此配置，此次搭建中 C 工程只提供服务，没有消费服务。所以 C 工程不用该配置
  • application.properties 和bootstrap.yml 二选一就行

服务工程 A- bootstrap.yml（注意）

feign:hystrix:# 开启断路器enabled: true
  • 断路器要主动开启，服务调用失败时才会熔断
  • 此处有一个坑，把此配置写到 application.yml中熔断不会生效
  • application.properties 和bootstrap.yml 二选一就行

服务工程 A- controller 前端控制器（提供服务）

package com.zwc.a.controller;import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/** @ClassName ASayHelloController* @Desc TODO   Say Hello* @Date 2019/5/20 23:24* @Version 1.0*/
@RestController
public class ASayHelloController {/** @ClassName ASayHelloController* @Desc TODO   读取配置文件中的端口* @Date 2019/5/20 23:24* @Version 1.0*/@Value("${server.port}")private String port;/** @ClassName ASayHelloController* @Desc TODO   Say Hello* @Date 2019/5/20 23:24* @Version 1.0*/@RequestMapping("/a")public String a(){return "Hello！I'm a. port：" + port;}}
  • 提供一个服务：输出 Hello 和端口

服务工程 A- 服务调用

package com.zwc.a.api.feign;import com.zwc.a.api.impl.FeignApiFallBack;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;/** @ClassName FeignApi* @Desc TODO   使用 Feign 调用 b - 接口* @Date 2019/5/20 23:21* @Version 1.0*/
@FeignClient(value = "turbine-b" , fallback = FeignApiFallBack.class)
public interface FeignApi {/** @ClassName FeignApi* @Desc TODO   通过 turbine-b 服务名调用 b() 方法* @Date 2019/5/20 23:21* @Version 1.0*/@RequestMapping("/b")String b();}
  • 通过 @FeignClient 注解中 value = “turbine-b” 来指定调用哪个服务
  • turbine-b 就是提供者的spring.application.name：应用名称
  • 通过 @FeignClient 注解中 fallback= FeignApiFallBack.class 来指定熔断时调用的方法
  • FeignApiFallBack 就是此接口（FeignApi）的实现类，对应的实现方法就是熔断时调用的方法
  • b()：此方法是 B 工程中提供的服务，在这里定义成接口
  • 注意要与提供者具有相同返回值，相同方法名以及相同参数

服务工程 A- Fallback（FeignApiFallBack）

package com.zwc.a.api.impl;import com.zwc.a.api.feign.FeignApi;
import org.springframework.stereotype.Component;/** @ClassName FeignApi* @Desc TODO   fallback* @Date 2019/5/20 23:21* @Version 1.0*/
@Component
public class FeignApiFallBack implements FeignApi {/** @ClassName FeignApiFallBack* @Desc TODO   调用 turbine-b 服务中的 b() 方法失败时执行* @Date 2019/5/20 23:31* @Version 1.0*/@Overridepublic String b() {return "Hello！aUseB fail";}
}
  • 使用@Component 注解把此类交给 Spring 管理
  • 实现了FeignApi 接口，提供熔断时对应的方法

服务工程 A- controller 前端控制器（消费服务）

package com.zwc.a.controller;import com.zwc.a.api.feign.FeignApi;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/** @ClassName AUseBFeignController* @Desc TODO   使用 Feign 调用 b - 前端控制器* @Date 2019/5/20 23:23* @Version 1.0*/
@RestController
public class AUseBFeignController {@Autowired(required = false)private FeignApi feignApi;/** @ClassName FeignController* @Desc TODO   通过 turbine-b 服务名调用 b() 方法* @Date 2019/5/20 23:13* @Version 1.0*/@RequestMapping("/aUseB")public String aUseB(){return feignApi.b();}}
  • 使用 @Autowired 注解装配 Bean，通过此 Bean 中的方法调用服务
  • 此类对外暴露接口，调用的实则是提供者的服务

服务工程 A- 启动类

package com.zwc;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@EnableHystrix
@EnableHystrixDashboard
public class SpringcloudTurbineAServiceCoreApplication {public static void main(String[] args) {SpringApplication.run(SpringcloudTurbineAServiceCoreApplication.class, args);}}
  • 添加 @EnableEurekaClient 注解表示此工程可以向注册中心提供服务
  • 添加@EnableFeignClients 注解表示开启 Feign 功能进行远程调用
  • 添加@EnableHystrix 注解表示开启熔断器
  • 添加 @EnableHystrixDashboard 注解表示开启熔断监控

服务工程 A- 启动项目

1.项目启动成功后访问：http://localhost:8090/a（调用自己的服务）

2. 输出内容：‘Hello！I’m a. port：8090’

3. 访问地址：http://localhost:8090/aUseB（调用 B 工程的服务）

4. 输出内容：‘Hello！aUseB fail’ （此时因为 B 工程还未启动，所以调用了 fallback中的方法）

5. 这时再回到master-server 工程的 ‘Loading …’ 页面，发现刚刚服务调用失败已经被监控到了

6. 如果还是显示的 ‘Loading …’ ，请再稍等一会

7. 启动服务工程 B，项目启动成功后再次访问：http://localhost:8090/aUseB（调用 B 工程的服务）

8.输出内容：‘Hello！I’m b. port：8091’ （如果还未调用成功，等待一会再刷新试试）

9. 这时再回到 master-server 工程，可以看到

10. 另起页面，访问：http://localhost:8091/bUseC（调用 C 工程的服务）

11.输出内容：‘Hello！bUseC fail’ （此时因为 C 工程还未启动，所以调用了 fallback中的方法）

12. 这时再回到 master-server 工程，可以看到调用 C 工程也被监控到了

13.红色的百分比表示失败率

14.左边的六个数字对应着页面右上角的六个状态（Success、Short-Circuited…）

service 工程 -项目结构

把多工程项目使用 IntelliJ IDEA 打开

  1. 把项目从 GitHub 中下载到你的本地
  2. 打开IntelliJ IDEA
  3. 点击 File -> Open
  4. 打开你下载到本地的项目目录
  5. springcloud-turbine ->springcloud-turbine-service（选择打开此工程）
  6. 打开 service 工程后
  7. 再次点击 File -> Project Structrue
  8. 选择 Modules，点击 ‘+’ 符号
  9. 点击 ImportModule
  10. 还是打开你下载到本地的项目目录
  11. springcloud-turbine ->springcloud-turbine-commons -> pom.xml
  12. 点击 OK
  13. 点击 Next，Finish
  14. 点击 Apply，OK

希望能够帮助到你

over

http://www.dinnco.com/news/13886.html

相关文章：

  • 微信网站的链接标志图片如何做最新国际要闻
  • 安徽省建设行业质量与安全协会网站口碑推广
  • 掉关键词网站seo作弊
  • 西安h5网站建设搜索引擎大全
  • 网站降权怎么恢复seo关键词排名工具
  • dns是不是做网站用的网站流量来源
  • 游戏网站制作板式google搜索引擎入口2022
  • p2p金融网站开发发布软文网站
  • 群辉域名登录wordpressseo网站地图
  • 派代网手机优化大师下载
  • wordpress 浏览计数长沙网站seo推广
  • 网站设计广州深圳网络推广服务是什么
  • 沧州网站设计报价独立站seo推广
  • 怎么做网盘网站app拉新项目推广代理
  • 做网站大图片运营推广怎么做
  • 盐城做网站的价格关键词优化百家号
  • 做网站排名公司推荐找推网
  • 网站排名软件包年关键词挖掘ppt
  • 深圳哪家建设网站公司好seo网站营销公司哪家好
  • 湖州微信网站建设代运营公司是怎么运营的
  • wordpress能用代码吗seo外链工具
  • 如何加强英文网站建设网络营销案例ppt课件
  • 人力资源和社会保障部的证书查询seo的实现方式
  • 成都网站制作培训谷歌搜索引擎免费
  • 宁波网站建设设计至诚服务网络推广和竞价怎么做
  • wordpress开启子目录多站点模式外包公司到底值不值得去
  • 网站建设分析东莞最新消息今天
  • wordpress 中文附件seo网络优化专员
  • 正定seo搜索引擎优化seo怎么做
  • 深圳市无限空间工业设计有限公司常州seo建站