- 一、前言
- 二、实践
- 三、测试
项目的业务存在如下场景:当系统启动后,定阅对应的kafka主题后,可能会存在积压的大量消息需要处理,此时如果开放本系统的服务,由于本身正在进行剧烈的数据处理,此时提供的服务并不可靠。
基于些,则需要一种机制在尽可能处理完消息后(或系统处于一个相对稳定的状态)再开放服务。
二、实践出于将业务与技术关注点分离的思路,则提炼出本文的所谓静默检查小框架。
import com.google.common.util.concurrent.ThreadFactoryBuilder; import暑期编程PK赛 得CSDN机械键盘等精美礼品!



