Наконец-то кто-то дал понять о распределенных транзакциях!

предисловие

1. Когда следует использовать распределенные транзакции?

2. Решения для распределенных транзакций

2.1 Представлено: стратегия двухфазной фиксации в MySQL

1. Во-первых, исполнитель найдет движок для получения строки данных с ID=2.
2. После получения данных он выполнит операцию +1 над данными, а затем вызовет интерфейс механизма для записи новых данных.
3. Движок обновляет данные в память и записывает операцию в журнал повторов, который в это время находится в состоянии подготовки. Но он не фиксирует транзакцию, а просто сообщает исполнителю, что задача выполнена и может быть зафиксирована в любой момент.
4. Исполнитель генерирует бинлог этой операции и записывает бинлог на диск
5. Наконец, исполнитель вызывает интерфейс транзакций механизма, изменяет журнал повторов на состояние фиксации, и обновление завершается.

2.2 Стратегия двухэтапной фиксации для распределенных транзакций

3. Платформа распределенных транзакций TX-LCN

1. Создайте группу транзакций. Прежде чем инициатор транзакции начнет выполнять бизнес-код, вызовите TxManager, чтобы создать объект группы транзакций, а затем получите процесс GroupId представления транзакции. Проще говоря, в центре управления транзакциями создается объект для операции выставления ордера, и получается id.
2. Присоединитесь к группе транзакций: после того, как участник завершит выполнение бизнес-метода, он уведомляет TxManager о транзакционной информации модуля. То есть после того, как каждый источник данных (каждый сервис) завершит операцию, обратитесь в центр управления транзакциями и зарегистрируйтесь.
3. Уведомление группы транзакций: после того, как инициатор выполнит бизнес-код, инициатор уведомляет TxManager о статусе результата выполнения инициатора. TxManager уведомит соответствующие участвующие модули о необходимости отправки или отката транзакции в соответствии с окончательным статусом транзакции и информацию о группе транзакций и вернуть результат инициатору транзакции. Служба заказов, которая имеет дело с клиентом, получит сообщение об успешном сокращении запасов и добавлении заказа.Он уведомит менеджера транзакций об этих двух сообщениях, а менеджер транзакций уведомит две службы инвентаризации для отправки транзакции или отката. сделка по ситуации.

public Object runTransaction(DTXInfo dtxInfo, BusinessCallback business) throws Throwable {
        if (Objects.isNull(DTXLocalContext.cur())) {
            DTXLocalContext.getOrNew();
        } else {
            return business.call();
        }
        log.debug("<---- TxLcn start ---->");
        DTXLocalContext dtxLocalContext = DTXLocalContext.getOrNew();
        TxContext txContext;
        // ---------- 保证每个模块在一个DTX下只会有一个TxContext ---------- //
        if (globalContext.hasTxContext()) {
            // 有事务上下文的获取父上下文
            txContext = globalContext.txContext();
            dtxLocalContext.setInGroup(true);
            log.debug("Unit[{}] used parent's TxContext[{}].", dtxInfo.getUnitId(), txContext.getGroupId());
        } else {
            // 没有的开启本地事务上下文
            txContext = globalContext.startTx();
        }
        //......
}

Механизм координации транзакций LCN

public class LcnConnectionProxy implements Connection {
    private Connection connection;
    public LcnConnectionProxy(Connection connection) {
        this.connection = connection;
    }
    /**
     * notify connection
     *
     * @param state transactionState
     * @return RpcResponseState RpcResponseState
     */
    public RpcResponseState notify(int state) {
        try {
            if (state == 1) {
                log.debug("commit transaction type[lcn] proxy connection:{}.", this);
                connection.commit();
            } else {
                log.debug("rollback transaction type[lcn] proxy connection:{}.", this);
                connection.rollback();
            }
            connection.close();
            log.debug("transaction type[lcn] proxy connection:{} closed.", this);
            return RpcResponseState.success;
        } catch (Exception e) {
            log.error(e.getLocalizedMessage(), e);
            return RpcResponseState.fail;
        }
    }
    @Override
    public void setAutoCommit(boolean autoCommit) throws SQLException {
        connection.setAutoCommit(false);
    }
    //......
}

Механизм компенсации транзакций LCN

Наконец