Camel in Action微服务实战Spring Boot Hystrix熔断器构建高可用架构完整教程【免费下载链接】camelinaction2:camel: This project hosts the source code for the examples of the Camel in Action 2nd ed book :closed_book: written by Claus Ibsen and Jonathan Anstey.项目地址: https://gitcode.com/gh_mirrors/ca/camelinaction2本教程基于Camel in Action第二版官方示例库带你用Apache Camel Spring Boot搭建微服务并通过Hystrix 熔断器实现故障隔离、降级与超时控制快速构建生产级高可用微服务架构。文中所有示例均可在本仓库 chapter7Microservices 章节中直接找到并运行。为什么用 Apache Camel 做微服务微服务架构下每个服务都要面对网络抖动、下游超时、雪崩故障等问题。Camel 的路线Route机制天然适合编排服务调用链而它内置的Hystrix EIP只需几行声明式代码就能为任意一段调用链加上熔断保护——这正是本书第 7 章 Designing for failures 的核心内容。一键克隆与项目结构先获取示例代码仓库地址git clone https://gitcode.com/gh_mirrors/ca/camelinaction2微服务相关内容集中在 chapter7关键模块一览模块作用说明springboot-camelSpring Boot Camel 起步最简微服务骨架springboot-rest-camelREST 端点 健康检查微服务对外暴露 RESThystrix纯 Java 熔断器理解 HystrixCommand 基础hystrix-camelCamel 路线内熔断本教程重点prototype / prototype2五服务微服务原型完整业务案例 每个模块都是独立 Maven 工程进入目录执行mvn install或mvn test即可。Spring Boot Camel5分钟跑通第一个微服务springboot-camel 演示了Spring Boot 作为微服务容器、Camel 负责路由的经典组合。路由定义见 HelloRoute.javarest(/).produces(text/plain) .get(hello) .to(direct:hello);类上加Component注解后Spring Boot 会自动发现并启动该路由。运行方式mvn spring-boot:run # 浏览器访问 http://localhost:8080/camel/hellospringboot-rest-camel 更进一步它从 REST 端点接收请求内部交给 Camel 处理并提供http://localhost:8080/health健康检查接口——这是微服务接入负载均衡器的必备能力。Hystrix 熔断器基础什么是熔断、降级与超时先用纯 Java 理解概念示例在 hystrix。MyCommandWithFallback.java 继承HystrixCommand包含两个关键方法run()真正要执行的业务逻辑示例中每 5 次调用强制抛错模拟不稳定服务getFallback()失败时返回的降级值No Counter运行测试观察熔断行为mvn test -DtestMyCommandWithFallbackTest这就是高可用的三板斧隔离故障、超时快速失败、优雅降级。将 Hystrix 集成进 Camel 路线核心hystrix-camel 模块展示如何在路线中一行启用熔断。HystrixRoute.java 中from(direct:start) .hystrix() .to(bean:counter) // 被保护的服务调用 .end() .log(After calling counter service: ${body});被hystrix() ... end()包裹的调用链整体受到熔断保护而end()之后的节点不受影响。CounterService.java 故意每第 5 次调用抛出IOException用于模拟下游服务间歇性故障。为熔断配置降级onFallback 兜底仅熔断还不够还要告诉用户失败了给什么。HystrixWithFallbackRoute.java 在熔断块中追加了降级逻辑.from(direct:start) .hystrix() .to(bean:counter) .onFallback() .transform(constant(No Counter)) // 降级响应 .end()四个测试类覆盖了完整行为矩阵见 ReadMe.mdmvn test -DtestCamelHystrixTest # 基础熔断 mvn test -DtestCamelHystrixWithFallbackTest # 熔断降级 mvn test -DtestCamelHystrixTimeoutTest # 超时控制 mvn test -DtestCamelHystrixTimeoutAndFallbackTest # 超时降级 XML DSL 版本同样支持mvn test -DtestSpringCamelHystrixWithFallbackTest习惯 XML 配置的同学可以无缝切换。用 Hystrix Dashboard 实时观察熔断行为理论跑通后如何让团队看见熔断状态prototype2 的 rules2-springboot-hystrixdashboard 模块给出标准做法启动 inventory2 库存服务被调用的下游启动 rules2 服务mvn spring-boot:run它暴露http://localhost:8181/hystrix.stream用 Hystrix Dashboard 订阅该 stream即可看到每次调用的延迟、失败与熔断状态执行 hitme.sh 施加压力再故意停掉库存服务观察熔断器从 OPEN 到 HALF-OPEN 的状态切换这套stream dashboard模式是微服务可观测性的经典组合值得在自建监控平台时借鉴。完整案例Rider Auto Parts 推荐系统prototype 是贯穿全章的微服务原型由 5 个服务组成各自采用不同技术栈刻意设计帮助熟悉各技术服务技术栈职责cart独立 Java购物车inventory独立 Java库存ratingSpring Boot评分SaaSrulesWildFly Swarm规则引擎recommendSpring Boot推荐聚合在每个服务目录执行mvn compile exec:java或mvn spring-boot:run分别启动后访问http://localhost:8080/api/recommend即可看到跨服务调用链的完整效果。延伸从单机高可用走向集群熔断解决的是服务间调用的稳定性。当微服务横向扩展到集群时你还需要分布式缓存、集群协调等能力——仓库 chapter17 提供了基于 Hazelcast、Infinispan、Kafka 等的完整集群示例。其管理控制台截图如下生产环境观察分布式组件状态时可参考这种控制台化思路总结高可用微服务要点清单✅ 用Spring Boot做微服务运行时Camel Route做调用编排springboot-camel✅ 暴露/health健康检查接入负载均衡springboot-rest-camel✅ 用hystrix() ... end()包裹调用链实现熔断 超时HystrixRoute.java✅ 用onFallback()定义降级响应保证用户始终有值返回HystrixWithFallbackRoute.java✅ 用Hystrix Dashboard订阅hystrix.stream让熔断状态可见、可测从这 5 个示例出发你就拥有了构建高可用微服务的完整骨架。祝编码愉快 【免费下载链接】camelinaction2:camel: This project hosts the source code for the examples of the Camel in Action 2nd ed book :closed_book: written by Claus Ibsen and Jonathan Anstey.项目地址: https://gitcode.com/gh_mirrors/ca/camelinaction2创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考