消息系统
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
3y ba14aee461
update readme.md
3 years ago
austin-common 1. 定时任务 处理 读取 csv文件开发 3 years ago
austin-cron 修改些注释 3 years ago
austin-handler 1. austin.sql 测试数据修改 3 years ago
austin-service-api 1.延迟队列实现 优化 3 years ago
austin-service-api-impl 1. austin.sql 测试数据修改 3 years ago
austin-stream austin-steam模块(flink) 3 years ago
austin-support austin-steam模块(flink) 3 years ago
austin-web austin-steam模块(flink) 3 years ago
sql 修改些注释 3 years ago
.gitignore 1. update gitgnore 3 years ago
INSTALL.md update readme.md 3 years ago
LICENSE add LICENSE. 4 years ago
README.md update README.md 3 years ago
pom.xml flink init 3 years ago

README.md

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

作者 gitee Starts gitee Starts 作者 996.icu 对线面试官

项目介绍

austin项目核心功能:发送消息

项目出现意义:只要公司内有发送消息的需求,都应该要有类似austin的项目,对各类消息进行统一发送处理。这有利于对功能的收拢,以及提高业务需求开发的效率

系统项目架构

austin项目核心流程austin-api接收到发送消息请求,直接将请求进MQaustin-handler消费MQ消息后由各类消息的Handler进行发送处理

Question 为什么发个消息需要MQ

Answer发送消息实际上是调用各个服务提供的API假设某消息的服务超时austin-api如果是直接调用服务,那存在超时风险拖垮整个接口性能。MQ在这是为了做异步和解耦并且在一定程度上抗住业务流量。

Question:能简单说下接入层做了什么事吗?

Answer

Questionaustin-streamaustin-datahouse的作用?

Answeraustin-handler在发送消息的过程中会做些通用业务处理以及发送消息这个过程会产生大量的日志数据。日志数据会被收集至MQaustin-stream流式处理模块进行消费并最后将数据写入至austin-datahouse

Questionaustin-adminaustin-cron的作用?

Answerautsin-adminaustin项目的管理后台,负责管理消息以及查看消息下发的情况。业务方可根据通过austin-admin管理后台直接定时发送消息,而austin-cron就是承载着定时任务的工作了。

使用姿势

目前引用的中间件教程的安装姿势均基于Centos 7.6austin项目强依赖MySQL/Redis/Kafka/apollo弱依赖prometheus/graylog。如果缺少相关的组件可戳:安装相关组件教程

1、austin使用的MySQL版本5.7x。如果目前使用的MySQL版本8.0,注意改变pom.xml所依赖的版本

2、填写application.propertiesaustin-database对应的ip/port/username/password信息

3、执行sql文件夹下的austin.sql创建对应的表以及插入测试数据

4、填写application.propertiesaustin-kafka对应的ip/port信息

5、填写application.propertiesaustin-redis对应的ip/port信息

6、检查apolloapp.id/apollo.bootstrap.namespaces检查创建的消息队列topicaustin.business.topic.name

7、以上配置信息都在application.properties文件中修改。

8、由于使用了Apollo且我是在云服务器上安装的我这边会直接跳过metaserver服务发现,在AustinApplication需要配置对应的apollo地址(注意端口!)

9、目前短信和邮件账号的信息都配置在apollo,配置的示例参照com.java3y.austin.support.utils#getAccount中的注释

10、调用http接口com.java3y.austin.web.controller#send给自己发一条短信或者邮件感受


curl -XPOST "127.0.0.1:8080/send"  -H 'Content-Type: application/json'  -d '"{"code":"send","messageParam":{"extra":null,"receiver":"13719333899","variables":{"content":"2222","url":"1111"}},"messageTemplateId":1}"'

11、austin前端管理系统部署一分钟即能打开GitHubGitee查看

里程碑

第四季度:三个月已完成的内容

短时间内规划:

  • 01、搭建消息推送Web后台管理页面进一步降低接入和使用门槛
  • 02、引入分布式定时任务框架实现定时推送消息提高运营侧下发营销消息的效率。
  • 03、接入流式处理平台实时处理日志数据多维度聚合后产生全链路追踪数据供业务方自行排查问题减少排查问题的人效
  • 04、持续提高消息推送系统的影响力让更多的业务方了解其功能进而挖掘更多拉新和唤醒用户的玩法提高站内的次留率和转化率

近期更新时间2022年2月22日

近期更新功能接入flink流式处理平台编写实时相关数据多维度进redis

项目交流

可以添加我的个人微信备注:【项目】,我会空闲的时候拉进项目交流群

Java3y公众号在持续更新austin系列文章保姆级讲解搭建项目的过程(包括技术选型以及一些业务的探讨)以及相关环境的搭建。扫下面的码直接关注,带你了解整个项目

如果你需要用这个项目写在简历上,强烈建议关注公众号看实现细节的思路。如果⽂档中有任何的不懂的问题,都可以直接来找我询问,我乐意帮助你们!公众号下有我的联系方式

如何准备面试?

对线面试官公众号持续更新面试系列文章对线面试官系列深受各大开发的好评已有不少的同学通过对线面试官系列得到BATTMD等一线大厂的的offer。一个讲人话的面试系列,八股文不再是背诵。