PHPで分散トランザクション処理を実行するにはどうすればよいですか?

$mysql1 = new mysqli("localhost", "username1", "password1", "database1");
$mysql2 = new mysqli("localhost", "username2", "password2", "database2");

//开始一个XA事务
$xa = mysqli_init();
$conn1 = mysqli_real_connect($xa, "localhost", "username1", "password1", "database1");
$conn2 = mysqli_real_connect($xa, "localhost", "username2", "password2", "database2");
$xid = uniqid('', true);
mysqli_autocommit($xa, FALSE);
mysqli_begin_transaction($xa, MYSQLI_TRANS_START_WITH_XID, $xid);

//对数据库1进行操作
mysqli_query($mysql1, "INSERT INTO table1 (value) VALUES ('test')");

//对数据库2进行操作
mysqli_query($mysql2, "INSERT INTO table2 (value) VALUES ('test')");

//准备提交事务
$xares1 = mysqli_prepare($xa, "XA PREPARE '$xid'");
$xares2 = mysqli_prepare($xa, "XA PREPARE '$xid'");

if (mysqli_stmt_execute($xares1) && mysqli_stmt_execute($xares2)) {
    //提交事务
    $xacmt1 = mysqli_prepare($xa, "XA COMMIT '$xid'");
    $xacmt2 = mysqli_prepare($xa, "XA COMMIT '$xid'");
    if (mysqli_stmt_execute($xacmt1) && mysqli_stmt_execute($xacmt2)) {
        //事务提交成功
        mysqli_commit($mysql1);
        mysqli_commit($mysql2);
    } else {
        //事务提交失败
        mysqli_rollback($mysql1);
        mysqli_rollback($mysql2);
    }
} else {
    //准备操作失败
    mysqli_rollback($mysql1);
    mysqli_rollback($mysql2);
}

//关闭数据库连接
mysqli_close($mysql1);
mysqli_close($mysql2);