从今天起，我们将开启一个新的组件项目学习。该组件针对业务功能开发中的通用技术场景，提炼出一套技术解决方案，专为解决数据库事务完成时需同时对外发送消息（MQ）或发起HTTP调用的最终一致性问题而设计。
MQ消息发送和HTTP调用无法与数据库写操作纳入同一事务，导致一致性保障困难。若缺乏统一组件支持，各业务系统需自行实现相关逻辑，易引发重复开发和维护难题。为此，我们提炼并开发了该技术组件，统一化解这一共性挑战，从而提升系统的可靠性和开发效率。
使用方通过引入本地消息组件，使用服务；
设计并实现一个本地任务消息组件的系统工程框架，以及配套的测试工程服务。核心使用 Spring ApplicationEvent 事件机制，实现行为触达的通知发布与监听，支持后续异步处理外部 HTTP 请求和消息队列（MQ）调用操作。
如图，是本节关于 Spring Event 事件消息部分的流程。本节以这样一个简单功能诉求，引导工程创建。
设计通用的本地消息任务表及其数据插入处理。该表由引入技术组件的上游系统自行在数据库中创建配置。随后，在调用组件时，即可使用同一数据源对该库表进行统一操作。
如图，是本节关于写库操作的功能流程。
设计通用的本地消息任务表及其数据插入处理。该表由引入技术组件的上游系统自行在数据库中创建配置。随后，在调用组件时，即可使用同一数据源对该库表进行统一操作。
如图，是本节关于事件消息回调通知的处理流程（暂时先不处理关于数据库的更新流程）；
.drawio.png)
当 Spring Event 接收到事件消息后，MQ 发送或 HTTP 调用均存在失败风险。常见原因包括网络超时、服务不可用、线程阻塞、流量高峰等。
因此，在 MQ 与 HTTP 处理完成后，应立即更新数据库任务表的状态（成功或失败），随后由定时扫描任务执行补偿逻辑，从而保障最终一致性。
如图，定时扫描任务流程图，以及在 http、mq 通知完成后，也要调用 dao 做变更状态操作；
因为我们做的是一个通用组件项目，对于它的使用应该要提供出更简单轻量的方式，让使用方可以轻量化的接入。所以对于 handleService.acceptTaskMessage(taskMessageEntityCommand) 编码的方式，可以提供更为优化的处理手段。
这里我们选择增加一个本地任务消息的自定义注解，对于配置了此注解的方法进行拦截，并获取入参信息的 taskMessageEntityCommand 对象。之后，开始进行同一个事务或开启新的事物的方式，完成数据的插入操作，并进行 Spring Event 消息推送。这样可以让用户的使用更加简洁。
