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

许昌住房建设局的网站wordpress分类添加轮播图

许昌住房建设局的网站,wordpress分类添加轮播图,毕节做网站的公司,wordpress获取ssl证书前言 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/601408/

相关文章:

  • html欧美网站模板dedecms更改网站logo
  • 经销商自己做网站外贸公司怎么开
  • 怎么做论坛的网站企业 北京 响应式网站
  • 合作社网站模板asp.net h5网站开发
  • 深圳建网站公司 哪家售后服务最好大数据在营销中的应用
  • element ui做门户网站怎样建设一个自己的网站
  • 中国空间站图片单页网站编辑器
  • ps如何做音乐网站会宁网站建设
  • 上海建设网站哪家好wordpress 做成app
  • 长春建站优化无代码开发平台永久免费
  • 网站建设论文百度云盘wordpress修改首页调用
  • 免费的个人网站注册不允许网站建设协议
  • 青岛网站建设公司电话拓者设计吧免费获取注册码
  • thinkphp企业网站源码徐州英才网最新招聘信息
  • 阿里国际站韩语网站怎么做网站编辑框超链接怎么做
  • 网站开发 技术架构湘潭做网站出色磐石网络
  • 做网店去哪个网站货源好北京新闻最新消息
  • 网站运营的工作内容网站被k了怎么做
  • 网站建设需要域名服务器免费搭建商业网站
  • 自学做蛋糕的网站linux做网站
  • 企业网站的发展历史山东网站建设服务
  • 网站开发毕业实训总结北京青鸟培训机构哪家是正规的
  • 阿里云虚拟主机做网站网站生成器下载
  • wordpress建企业网站教程郑州快速网站建设
  • 吉林平台网站建设哪里有网络舆情研判分析报告
  • 哈尔滨城乡建设局网站国外ps素材网站
  • 博客网站程序网站服务费可以做宣传费吗
  • 中文 网站模板网站建设 问答
  • 泰兴市淘宝网站建设wordpress设置访问密码忘记
  • 昆明做百度网站电话号码会议网站