基于Storm统计API时长

/ Spring Cloud大数据 / 没有评论 / 0浏览

有时我们会遇到几个问题,

这些问题都会影响用户体验和教课质量,为了解决上述问题,让服务更稳定,开发出预警服务,让开发人员及时了解接口的健康状态,及时处理

预警架构 alt

处理流程:

  1. 网关拦截API请求,计算该请求的总时长,封装消息发送到kafka消息队列
  2. 使用apache storm消费kafka队列的消息,拆分三个不同的bolt处理
  1. 定时任务将计数统计和请求超时地址发送预警服务,预警服务会通过延迟队列定期向用户发送通知(一条消息不管在15分钟内预警多少次,都会给用户发送一次,然后进入下个周期)

效果图:

alt