在分布式系统中避免重复推送条码

在涉及不同系统通信时，如从a 系统推送条码到b 系统的数据库中，网络不稳定和频繁推送会造成重复推送的问题。

要解决这一问题，可以采用以下方法：

采用消息队列

消息队列是一种异步通信机制，可将a系统和b 系统之间的交互转变为异步操作。断电时消息将被积攒，恢复后继续推送，保证消息不会丢失。消息队列采用消息确认机制，确保消息仅在成功写入数据库后才会被移除，否则将在超时后重新推送，防止消息重复。

消息幂等性

在消费端（b 系统）确保消息的幂等性，即使存在重复数据，也只处理一次。可以通过以下方法实现：

kashen-mysql DDLtoExcel

解析 MySQL 8.0 的 DDL 脚本，并将表结构导出为 Excel 格式。适用于用户需将 MySQL 的 `CREATE TABLE` 语句转换为结构化的 Excel 文件场景，导出内容包含字段名、数据类型、长度及精度等信息。支持多张表的批量处理，每张表对应 Excel 中的一个独立工作表。适用于数据库文档编写、数据字典生成及模式分析等任务。

下载

• 检查消息的主键是否唯一
• 使用版本号保证数据不会重复插入

利用on duplicate key update 语句（mysql）

如果双方都使用mysql 数据库，可以在a 系统使用on duplicate key update 语句，在重复插入时仅更新数据，保证数据正确性：

INSERT INTO table (id, ...)
ON DUPLICATE KEY UPDATE ...

状态一致性判断

a 系统可以通过访问b系统的数据库，判断两个系统的状态是否一致：

• a 已发送，状态已修改，b 已收到（正常）
• a 已发送，状态未修改，b 未收到（重新推送）
• a 已发送，状态已修改，b未收到（重新推送）
• a 已修改，状态未修改，b 已收到（重新推送）

其他解决方案

除了上述方法外，还可以考虑以下解决方案：

• 使用分布式锁机制，确保在a 系统和b 系统之间仅进行一次操作。
• 采用数据库事务回滚，在断电时回滚未完成的操作，防止数据不一致。