https://github.com/ZhongFuCheng3y/austin
单条
批量
渠道、用户维度消息发送
/**
* 普通发送执行流程
* 1. 前置参数校验
* 2. 组装参数
* 3. 后置参数校验
* 4. 发送消息至MQ
*
* @return
*/
@Bean("commonSendTemplate")
public ProcessTemplate commonSendTemplate() {
ProcessTemplate processTemplate = new ProcessTemplate();
processTemplate.setProcessList(Arrays.asList(sendPreCheckAction, sendAssembleAction,
sendAfterCheckAction, sendMqAction));
return processTemplate;
}
初始化各个渠道,下游各个渠道实现分发
Question :为什么发个消息需要MQ?
Answer:发送消息实际上是调用各个服务提供的API,假设某消息的服务超时,austin-api如果是直接调用服务,那存在超时风险,拖垮整个接口性能。MQ在这是为了做异步和解耦,并且在一定程度上抗住业务流量。
Question:能简单说下接入层做了什么事吗?
Question:austin-stream和austin-datahouse的作用?