cap不是自动分布式事务，需数据库表+消息队列+后台调度器协同；publishasync仅写本地cap.published表并标记processing，由dispatcher轮询投递；未配连接串或事务未提交会导致消息丢失；订阅依赖特性标注与程序集扫描；幂等需业务层实现，推荐用messageid查cap.received表去重；调度器卡住常因bootstrapper executeasync阻塞或配置缺失。
CAP 不是“开启事务开关就能自动分布式”，它靠的是数据库表 + 消息队列 + 后台调度器三者协同，消息必须先落库、再发队列、再由消费者执行，漏掉任一环都会导致最终不一致。
ICapPublisher.PublishAsync 为什么没立刻发到 Kafka/RabbitMQ？
CAP 的 PublishAsync 方法根本不会直连消息中间件。它只做两件事：把消息序列化后写入本地数据库的 Cap.Published 表，并标记为 Processing 状态。真正的投递由后台 Dispatcher 定期轮询该表触发。
- 如果你没配
StorageOptions.ConnectionString或数据库连接失败，PublishAsync会直接抛InvalidOperationException：“Failed to insert message into database” - 如果业务代码在
using var tx = await _context.Database.BeginTransactionAsync()中调用PublishAsync，但没显式Commit，那这条记录会随事务回滚——消息彻底消失，不会重试 -
PublishAsync支持传入headers字典，但只有cap-msg-id、cap-msg-name等内置 key 会被调度器识别，自定义 header 需要在消费者端手动解析
Consumer 方法不触发？检查这三个地方
CAP 的订阅发现完全基于程序集扫描 + 特性标注，不是运行时反射所有 public 方法。常见失效点：
- 消费者类没加
[CapSubscribe("xxx.order.created")]特性，或特性值和发布时的 topic 名不完全一致（区分大小写） - 方法签名必须是
async Task或Task，且参数只能是CapMessage、string、byte[]或具体 DTO 类型（需匹配 JSON 序列化结构），多一个ILogger参数就会跳过注册 - 项目未引用
DotNetCore.CAP.Kafka（或 RabbitMQ/SQL Server 包），或AddCap时没调用对应扩展方法如.UseKafka(...)，会导致ConsumerRegister找不到任何订阅者
消息重复消费怎么防？CAP 本身不保证 Exactly-Once
CAP 的重试机制是“至少一次（At-Least-Once）”，网络抖动、消费者进程崩溃、超时未响应都会触发重发。业务层必须自己实现幂等：
- 推荐在消费者方法开头查
Cap.Received表，用MessageId做唯一索引去重（CAP 自动写该表，但需确保你没禁用EnableReceivedLog） - 避免用“订单号”作为幂等键——如果发布方重发了两次不同内容但相同订单号的消息，后一次会覆盖前一次状态
- 不要依赖数据库主键冲突报错来判断重复，因为 CAP 可能因配置错误导致
Cap.Received表未启用，此时唯一防护就是业务逻辑内嵌判重（如更新时加WHERE status = 'pending'）
调度器卡住不动？看 Bootstrapper 的 ExecuteAsync 是否完成
CAP 启动本质是 Bootstrapper 实现了 IHostedService，它的 ExecuteAsync 方法必须成功返回，否则 Dispatcher 不会开始轮询。典型阻塞原因：
- 数据库连接字符串指向了不可达实例，
StorageInitializer.InitializeAsync无限重试（默认 5 秒间隔，无上限） - 调用
AddCap时传入了空setupAction，导致KafkaOptions或SqlServerOptions未初始化，后续Dispatcher获取不到发送器实例而静默失败 - 日志级别设为
Warning以上，会掩盖Dispatcher内部的Failed to publish message错误，实际需开Debug级别才能看到轮询频率和异常堆栈
最易被忽略的是：CAP 的“事务绑定”只对 EF Core 的 SaveChangesAsync 生效，如果你用 Dapper 或原生 ADO.NET 手动提交事务，PublishAsync 写入的记录不会和业务数据共用同一事务——必须显式传入 DbContext.Database.CurrentTransaction 到 PublishAsync 的 transaction 参数里。
