dubbo调用 实现同步回滚事务

在分布式系统中，实现同步回滚事务通常需要使用分布式事务管理器，例如Atomikos、Narayana等。在Dubbo中，可以使用Dubbo XA扩展来实现分布式事务。

Dubbo XA扩展是基于JTA规范的，它提供了一种在分布式环境下实现同步回滚事务的方式。具体实现方式如下：

1. 首先，需要在Dubbo服务提供者和消费者的配置文件中启用Dubbo XA扩展：

<dubbo:provider xa="true" />
<dubbo:consumer xa="true" />

2. 在Dubbo服务提供者中，需要使用`@Transactional`注解将服务方法标记为事务方法：

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    @Transactional
    public void addUser(User user) {
        userMapper.addUser(user);
    }
}

3. 在Dubbo服务消费者中，需要使用`TransactionContext`对象来实现同步回滚事务：

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Reference(version = "1.0.0")
    private UserDubboService userDubboService;

    @Override
    @Transactional
    public void addUser(User user) {
        userMapper.addUser(user);

        // 同步回滚事务
        TransactionContext transactionContext = DubboTransactionContext.getContext();
        transactionContext.setXid(XidUtils.generateXid());
        transactionContext.setAttachment("user", user);
        try {
            userDubboService.addUser(user);
            transactionContext.setStatus(TransactionContext.Status.COMMITTING);
        } catch (Exception e) {
            transactionContext.setStatus(TransactionContext.Status.ROLLBACKING);
            throw e;
        }
    }
}

在消费者调用`userDubboService.addUser(user)`之前，需要先设置`TransactionContext`对象的XID和附加属性。如果调用成功，将`TransactionContext`对象的状态设置为COMMITTING，否则将状态设置为ROLLBACKING。

通过以上步骤，就可以实现Dubbo调用中的同步回滚事务了。需要注意的是，Dubbo XA扩展仅支持同步回滚事务，不支持异步回滚。如果需要异步回滚，可以考虑使用TCC或MQ等方式。