本文共 854 字,大约阅读时间需要 2 分钟。
Stream 概述
在这个项目中,我们采用Spring Cloud Stream框架,基于RabbitMQ作为消息中间件。通过选择适当的消息中间件组件,我们可以实现高效的微服务 communication。
基础
本项目基于Spring Cloud Stream框架,结合RabbitMQ实现消息队列功能。Spring Cloud Stream提供了一套简单易用的API,支持对消息中间件进行统一配置和管理。
hystrix-consumer 子工程
该子工程负责消费消息,集成了相关的Hystrix容错机制。项目结构包括以下几个关键部分: - pom文件配置了必要的依赖项,包括RabbitMQ相关的Spring Cloud Stream组件。 - 配置文件(application.yml)定义了消息的绑定器和绑定方法,确保消息能够按照预期的路由和格式接收。 - 监听器(MessageListener)类负责处理消息,实现消息的基本消费逻辑,适用于处理消息偏移或异常情况。
hystrix-provider 子工程
这个子项目主要负责消息生产,同样基于Spring Cloud Stream框架和RabbitMQ。项目结构包括: - pom文件类似hystrix-consumer部分,配置了相同的消息中间件组件。 - 配置文件定义了消息的发布渠道,包括消息的内容格式和目标交易号(test_exchange)。 - 生产者(MessageProducer)类负责构建并发布消息,支持消息的额外属性(如Endpoint)配置,支持集群发布。 - 控制器(GoodsController)提供了REST API接口,作为外部调用入口,负责消息的发布或调试。
测试
项目包含三个主要服务: 1. eureka-server 2. hystrix-consumer 3. hystrix-provider
通过自动化测试框架确保各组件的协同工作,确保消息能够顺利生产、传输、消费,并在出现故障时能够优雅降级。
转载地址:http://qgmwk.baihongyu.com/