Austin 是一个消息推送平台。推送下发【邮件】【短信】【微信服务号】【微信小程序】【企业微信】【钉钉】等消息类型。所使用的技术栈包括:SpringBoot、SpringDataJPA、MySQL、Docker、docker-compose、Kafka、Redis、Apollo、prometheus、Grafana、GrayLog、Flink、Xxl-job、Echarts 等等。
austin 项目核心功能:统一的接口发送各种类型消息,对消息生命周期全链路追踪
项目出现意义:只要公司内有发送消息的需求,都应该要有类似austin
的项目,对各类消息进行统一发送处理。这有利于对功能的收拢,以及提高业务需求开发的效率。
系统项目架构
austin 项目核心流程:austin-api
接收到发送消息请求,直接将请求进MQ
。austin-handler
消费MQ
消息后由各类消息的 Handler 进行发送处理。
Question :为什么发个消息需要MQ?
Answer:发送消息实际上是调用各个服务提供的API,假设某消息的服务超时,austin-api
如果是直接调用服务,那存在超时风险,拖垮整个接口性能。MQ在这是为了做异步和解耦,并且在一定程度上抗住业务流量。
Question:能简单说下接入层做了什么事吗?
Answer:
Question:austin-stream
和austin-datahouse
的作用?
Answer:austin-handler
在发送消息的过程中会做些通用业务处理以及发送消息,这个过程会产生大量的日志数据。日志数据会被收集至MQ,由austin-stream
流式处理模块进行消费并最后将数据写入至austin-datahouse
Question:austin-admin
和austin-web
和austin-cron
的作用?
Answer:autsin-admin
是austin
项目的前端项目,可通过它实现对管理消息以及查看消息下发的情况,而austin-web
则是提供相关的接口给到austin-admin
进行调用(austin项目是前后端分离的)
业务方可操作austin-admin
管理后台调用austin-web
创建定时发送消息,austin-cron
就承载着定时任务处理的工作。