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

山西省建设局官方网站wordpress安装disuz

news 2025/9/18 3:26:21
山西省建设局官方网站,wordpress安装disuz,中国建筑资料网,郑州七彩网站建设公司怎么样前言 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.yayakq.cn/news/93446/

相关文章：

  • 免费网站建设专业服务平台网站推广注册
  • 合伙开公司建设网站被骗做内网网站
  • 摄影网站排行wordpress公司主题破解版
  • 做网站怎么留接口支付网站模板
  • h5企业网站定制排名织梦cms网站
  • 房地产项目网站建设网站建立
  • 程序员做网站赚钱如何发布一个网页
  • 变性人做欲网站黑龙江省营商环境建设监督局网站
  • 中国建设银行官网站大同微网站平台微网站建设方案模板
  • 网站建设论文百度云盘海南最近三天的新闻大事
  • 如何用python做网站中国建设银行东莞市网站
  • 响应式网站 乐云seo品牌开店做网站
  • vps 上传网站怎样做金融理财网站
  • 快站公众号工具网站建站是什么
  • 西安找建网站公司泉州网站建设托管
  • 如何给自家网站做关键词优化网站开发合同 保密条款
  • 郑州网站建设q.479185700強连云港市住房和城乡建设局网站
  • 在服务器上布网站怎么做政务内网网站群建设
  • 网站界面设计尺寸规范做网站得叫什么
  • 做美工的网站建筑人才网招聘网官网首页
  • 哪些网站是做数据分析的100种禁用的视频软件短视频
  • aaaa景区网站建设标准给网站做路由
  • 有哪些外贸网站网站建设项目规划书社团宣传
  • 一品在线视频观看seo排名诊断
  • 怎么使用创客贴网站做图做国外衣服的网站有哪些
  • 手机可以建立网站吗做电缆好的网站
  • 怎么自己建网站wordpress换头像
  • 织梦cms发布侵权网站清单网站群的建设
  • 建设淘宝优惠券网站网架有限公司
  • 建设计公司网站要多少钱企业网站带后台模板