有大佬知道这个问题吗？我测试的是，sqlserver 同步sqlserver

这个问题通常是由于你使用的是简单的字符串比较，而不是使用 Rocketmq 提供的对比方法，导致同步出现问题。 具体来说，当你在 Rocketmq 中发送消息时，需要设置订阅模式为“只订阅不同步”，否则会出现数据不一致的情况。如果你没有设置订阅模式，或者使用了错误的订阅模式，就会导致同步出现问题。 下面是一些可能的解决方法：

设置订阅模式为“只订阅不同步”，即在发送消息时指定“订阅模式=0”，例如： Copy code producer.send("TopicTest", "Hello World", "orderId", 123456, 0); 检查发送消息的顺序和订阅消息的顺序是否一致，如果不一致，就需要调整订阅模式，例如： Copy code // 发送消息时，设置订阅模式为“只订阅不同步” producer.send("TopicTest", "Hello World", "orderId", 123456, 0);

// 然后，在消费者中设置订阅模式为“只订阅同步”，即“订阅模式=1” consumer.subscribe("TopicTest", "orderId", 123456, "onlySync");

// 最后，等待消息被同步 consumer.consume(); 检查数据库的记录是否已经被删除或更新，导致数据不一致，需要重新查询数据库中的记录，例如： Copy code // 查询数据库中 orderId 为 123456 的记录 QueryResult queryResult = jdbcTemplate.query(SQL_QUERY, new BeanPropertyRowMapper<>(Order.class)); List orders = queryResult.getRows();

// 将已经被消费的记录从数据库中删除 if (orders.size() > 0) { jdbcTemplate.update(SQL_DELETE, new BeanPropertyRowMapper<>(Order.class), orders.get(0)); } 综上所述，当你在 Rocketmq 中发送消息时，需要设置订阅模式为“只订阅不同步”，并且注意发送消息的顺序和订阅消息的顺序是否一致。如果出现问题，可以检查数据库中的记录是否正确，并且可以尝试调整订阅模式。