课程咨询: 400-996-5531 / 投诉建议: 400-111-8989
认真做教育 专心促就业
消息队列技术的原理与基本概念我们在前几期的文章中已经给大家介绍过很多了,而本文我们就简单来学习一下,消息队列技术应用场景都有哪些。
1.消息应用中心
消息应用中心(任务中心)使用了消息队列的异步处理、数据同步、重试补偿、系统解耦、流量消峰等特性。其中:
消息应用中心(任务中心),支持RabbitMQ和Kafka两种消息通道,支持在任务元数据层面设置
任务:就是一个包含了任务执行上下文的消息,同时代表了异步处理
任务发送者(ITaskSender)发送任务:消息的生产者将任务消息发送的消息队列
任务类型:消息队列名称,例如:HaKeepAcco***Queue,充电补偿记账队列
消息队列:任务的临时存储
任务中心:任务集中处理,消息消费者
任务处理完成:消息Ack确认
任务的多级重试:多个重试消息队列,HaSysTaskStore2Queue
2.日志组件
日志组件,使用了消息队列的高并发缓冲和发布订阅特性。其中:
日志组件使用Kafka作为消息通道,因为Kafka的性能好,吞吐量大,可以容忍偶尔的消息数据丢失
日志组件使用发布订阅的消息模型
日志组件包含日志服务SDK和日志HSF服务,二者都是消息的生产者Producer
日志类型:消息的Topic主题
日志处理器:消息的消费者、Topic的订阅、日志数据处理(Hbase\ES\其他)
3.RPC服务状态变化通知
RPC服务状态变化通知,使用了消息队列的发布订阅特性。其中:
RPC服务状态变化通知,使用了RabbitMQ消息队列技术
使用发布订阅的消息模型
Topic:RPCServiceState
RPCService.Proxy:RPC服务状态变化消息的订阅者
RPC服务注册、发布:消息的生产者,发送RPC服务状态变化消息。
【免责声明】:本内容转载于网络,转载目的在于传递信息。文章内容为作者个人意见,本平台对文中陈述、观点保持中立,不对所包含内容的准确性、可靠性与完整性提供形式地保证。请读者仅作参考。更多内容请加danei0707学习了解。欢迎关注“达内在线”参与分销,赚更多好礼。