Mybatis-plus更新多张表,保证事务安全的情况下使用异步多线程实现(待验证)

发布时间：2023年12月17日

Mybatis-plus更新多张表,保证事务安全的情况下使用异步多线程实现(待验证)

文章目录

Mybatis-plus更新多张表,保证事务安全的情况下使用异步多线程实现(待验证)

方案一:

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.IService;
import lombok.extern.slf4j.Slf4j;

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 使用mybatis-plus更新多张表，如何使用异步多线程更新多张表，并且保证事务安全
 *
 * @author hubin
 * @since 2018-08-20
 */
@Slf4j
public class AsyncUpdateMultiTableExample {

    public static void main(String[] args) {
        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(10);

        // 创建service对象
        IService<User> userService = new UserServiceImpl();

        // 创建查询条件
        QueryWrapper<User> queryWrapper = Wrappers.query();
        queryWrapper.eq("id", 1);

        // 查询数据
        List<User> users = userService.list(queryWrapper);

        // 使用异步多线程更新数据
        CompletableFuture.allOf(users.stream().map(user -> {
            return CompletableFuture.runAsync(() -> {
                // 更新数据
                userService.updateById(user);
            }, executorService);
        }).toArray(CompletableFuture[]::new)).join();

        // 关闭线程池
        executorService.shutdown();
    }

    /**
     * 用户表
     */
    public static class User {
        private Long id;
        private String name;
        private Integer age;

        public Long getId() {
            return id;
        }

        public void setId(Long id) {
            this.id = id;
        }
    }

要使用异步多线程更新多张表并保证事务安全，可以使用Spring框架的异步处理和事务管理功能。下面是一个简单的示例：

首先，需要在Spring配置文件中启用异步处理和事务管理。可以使用以下配置：

<task:annotation-driven executor="asyncExecutor" /> 
<task:executor id="asyncExecutor" pool-size="10" /> 
<tx:annotation-driven />

在Java代码中，可以使用@Async注解将方法标记为异步方法。在异步方法中，可以使用@Transactional注解来启用事务管理。例如：

@Service 
public class MyService { 
    @Autowired 
    private MyMapper1 myMapper1; 
    @Autowired 
    private MyMapper2 myMapper2; 
 
    @Async 
    @Transactional 
    public void updateMultipleTables() { 
        // 更新第一个表 
        myMapper1.updateTable1(); 
        // 更新第二个表 
        myMapper2.updateTable2(); 
        // 如果有其他需要更新的表，可以继续添加相应的代码 
    } 
}

在调用异步方法时，可以使用Spring的AsyncTaskExecutor来执行异步任务。例如：

@Service 
public class MyOtherService { 
    @Autowired 
    private MyService myService; 
    @Autowired 
    private AsyncTaskExecutor asyncTaskExecutor; 
 
    public void doUpdate() { 
        // 异步执行多个表的更新操作 
        asyncTaskExecutor.submit(() -> myService.updateMultipleTables()).get(); 
    } 
}

在上面的代码中，submit()方法将异步任务提交给asyncTaskExecutor执行，get()方法等待异步任务完成。由于异步任务使用了@Transactional注解，因此在异步任务中的所有数据库操作都将在一个事务中执行，保证了事务的完整性和一致性。

需要注意的是，异步任务的执行可能会影响系统的性能和稳定性。因此，需要根据具体的情况进行评估和优化。

方案二:

在使用mybatis-plus更新多张表时，可以使用异步多线程的方式来提高效率。以下是一个简单的实例，演示如何使用异步多线程更新多张表，并确保事务安全。

示例代码：

@Service
public class UpdateService {
    
    @Autowired
    private AsyncService asyncService;
    
    @Autowired
    private TransactionTemplate transactionTemplate;
    
    public void updateMultipleTables(UpdateRequest request) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                asyncService.updateTableA(request.getTableAData());
                asyncService.updateTableB(request.getTableBData());
                asyncService.updateTableC(request.getTableCData());
            }
        });
    }
}

@Service
public class AsyncService {
    
    @Autowired
    private TableAService tableAService;
    
    @Autowired
    private TableBService tableBService;
    
    @Autowired
    private TableCService tableCService;
    
    @Async
    public void updateTableA(TableAData data) {
        tableAService.update(data);
    }
    
    @Async
    public void updateTableB(TableBData data) {
        tableBService.update(data);
    }
    
    @Async
    public void updateTableC(TableCData data) {
        tableCService.update(data);
    }
}

在上面的代码中，UpdateService 是一个服务类，用于协调多个异步更新操作，并确保它们在同一事务中执行。AsyncService 是一个异步服务类，用于实际执行每个异步更新操作。

在 UpdateService 中，使用 TransactionTemplate 来启用事务，并在事务中调用异步服务类中的更新方法。由于更新方法被标记为异步，因此它们将在一个独立的线程中执行。

在 AsyncService 中，每个更新方法都被标记为异步，并且使用相应的服务类来执行实际的更新操作。

注意，@Async 标注了每个更新方法，这意味着每个更新操作将在独立的线程中执行。因此，我们需要确保每个更新方法都是线程安全的，并且能够在多个线程之间正确地共享数据。

总之，使用异步多线程更新多张表可以提高系统的并发处理能力和效率。而使用事务模板可以确保多个更新操作在同一个事务中执行，从而保证了事务安全。 ```

方案三:使用mybatis-plus更新数据库的五张不同的表,开启五个线程，每个线程负责更新一张表，如何在保证事务和线程安全的情况下，做到异步更新，编写详细的示例，并详细说明

在使用多线程更新多张表时，需要注意以下几个方面：

保证事务安全：多个线程操作多张表需要保证事务的一致性，即要么所有表的更新操作都成功，要么所有表的更新操作都失败。因此，在多个线程中，需要使用同一个事务管理器，并且在事务范围内执行更新操作。
保证线程安全：在多线程环境下，多个线程并发地更新同一张表可能会导致数据不一致。因此，在更新操作时，需要使用线程同步机制，例如使用synchronized关键字或者Lock接口。
优化性能：使用线程池可以有效地减少线程的创建和销毁，提高程序的性能。

下面是一个使用mybatis-plus更新五张不同表的示例代码：

@Service
public class UpdateService {

    @Autowired
    private TransactionTemplate transactionTemplate;

    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;

    @Autowired
    private Table1Mapper table1Mapper;

    @Autowired
    private Table2Mapper table2Mapper;

    @Autowired
    private Table3Mapper table3Mapper;

    @Autowired
    private Table4Mapper table4Mapper;

    @Autowired
    private Table5Mapper table5Mapper;

    public void updateAllTables() {
        // 开启事务
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
                // 使用线程池异步更新五张表
                taskExecutor.execute(() -> updateTable1());
                taskExecutor.execute(() -> updateTable2());
                taskExecutor.execute(() -> updateTable3());
                taskExecutor.execute(() -> updateTable4());
                taskExecutor.execute(() -> updateTable5());
            }
        });
    }

    private synchronized void updateTable1() {
        // 更新表1
        table1Mapper.updateById(new Table1());
    }

    private synchronized void updateTable2() {
        // 更新表2
        table2Mapper.updateById(new Table2());
    }

    private synchronized void updateTable3() {
        // 更新表3
        table3Mapper.updateById(new Table3());
    }

    private synchronized void updateTable4() {
        // 更新表4
        table4Mapper.updateById(new Table4());
    }

    private synchronized void updateTable5() {
        // 更新表5
        table5Mapper.updateById(new Table5());
    }
}

在上述代码中，我们使用了TransactionTemplate和ThreadPoolTaskExecutor来保证事务和线程安全。在updateAllTables方法中，我们使用TransactionTemplate开启事务，并使用线程池异步更新五张表。在每个更新方法中，使用synchronized关键字来保证线程安全。

需要注意的是，在使用线程池时，线程池的大小需要根据系统的实际情况进行调整，以避免线程池过大或过小导致的性能问题。 ```

方案四:

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.IService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@Service
public class UserService {
@Autowired
private UserMapper userMapper;

public void updateUser(int userId, String userName) {
    UpdateWrapper<User> updateWrapper = new UpdateWrapper<>();
    updateWrapper.eq("user_id", userId);
    updateWrapper.set("user_name", userName);
    userMapper.update(null, updateWrapper);
}

public void testAsyncUpdate() throws InterruptedException {
    // 创建一个 CountDownLatch 对象，并设置计数器为 5
    CountDownLatch countDownLatch = new CountDownLatch(5);

    // 创建一个线程池
    ExecutorService executorService = Executors.newFixedThreadPool(5);

    // 启动 5 个线程，每个线程负责更新一张表
    for (int i = 0; i < 5; i++) {
        executorService.submit(() -> {
            // 获取当前线程的 id
            int threadId = Thread.currentThread().getId();

            // 获取要更新的表名
            String tableName = "user_" + threadId;

            // 创建一个 QueryWrapper 对象
            QueryWrapper<User> queryWrapper = new QueryWrapper<>();

            // 设置查询条件
            queryWrapper.eq("user_id", threadId);

            // 查询数据
            User user = userMapper.selectOne(queryWrapper);

            // 更新数据
            updateUser(threadId, user.getUserName() + "_update");

            // 计数器减一
            countDownLatch.countDown();
        });
    }

    // 等待所有线程执行完毕
    countDownLatch.await();

    // 关闭线程池
    executorService.shutdown();
	}
}

在上述示例中，我们使用了 mybatis-plus 的 QueryWrapper 和 UpdateWrapper 对象来构建查询条件和更新条件。我们还使用了 CountDownLatch 对象来等待所有线程执行完毕。

在保证事务和线程安全的情况下，做到异步更新，可以通过以下方式实现：

使用 synchronized 关键字来保证方法的线程安全。
使用 @Transactional 注解来开启事务。
使用 ExecutorService 来创建线程池。
使用 submit() 方法来启动线程。
使用 countDownLatch.await() 方法来等待所有线程执行完毕。
使用 countDownLatch.countDown() 方法来减小计数器

通过以上方式，我们可以保证事务和线程安全的情况下，做到异步更新。

方案五:

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
import com.google.common.util.concurrent.CompletableFuture;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;
import java.util.concurrent.ExecutionException;

public class MybatisPlusAsyncUpdateExample {

    private static final String NAMESPACE = "com.example.mybatisplus.mapper.UserMapper";

    @Transactional
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 创建五个线程，每个线程负责更新一张表
        List<CompletableFuture<Void>> futures = new ArrayList<>();
        for (int i = 0; i < 5; i++) {
            futures.add(updateAsync(i));
        }

        // 等待所有线程执行完成
        CompletableFuture.allOf(futures).join();
    }

    private static CompletableFuture<Void> updateAsync(int tableIndex) {
        return CompletableFuture.runAsync(() -> {
            // 获取 UserMapper 接口
            IService<User> userService = SpringContextHolder.getBean(NAMESPACE + ".UserService");

            // 创建 QueryWrapper 对象
            QueryWrapper<User> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("id", tableIndex);

            // 更新数据
            userService.update(queryWrapper);
        });
    }

    static class User {
        private Long id;
        private String name;
    }
}

在上述示例中，我们使用了 CompletableFuture 来实现异步更新。CompletableFuture 是一个异步计算工具，它可以让我们以异步的方式执行任务，并在任务完成时获取结果。

在示例中，我们创建了五个 CompletableFuture 对象，每个 CompletableFuture 对象对应一个线程，每个线程负责更新一张表。我们使用 CompletableFuture.allOf() 方法等待所有线程执行完成，然后再继续执行后续的代码。

这样，我们就实现了在保证事务和线程安全的情况下，做到异步更新。

方案六:

@Service
@Transactional
public class AsyncUpdateService {

    @Autowired
    private Table1Mapper table1Mapper;

    @Autowired
    private Table2Mapper table2Mapper;

    @Autowired
    private Table3Mapper table3Mapper;

    @Autowired
    private Table4Mapper table4Mapper;

    @Autowired
    private Table5Mapper table5Mapper;

    public void asyncUpdate() {
        CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> {
            table1Mapper.updateTable1();
        });
        CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> {
            table2Mapper.updateTable2();
        });
        CompletableFuture<Void> future3 = CompletableFuture.runAsync(() -> {
            table3Mapper.updateTable3();
        });
        CompletableFuture<Void> future4 = CompletableFuture.runAsync(() -> {
            table4Mapper.updateTable4();
        });
        CompletableFuture<Void> future5 = CompletableFuture.runAsync(() -> {
            table5Mapper.updateTable5();
        });

        CompletableFuture.allOf(future1, future2, future3, future4, future5).join();
    }
}

在这个示例中，我们使用了CompletableFuture.runAsync()方法来异步更新每张表。每个CompletableFuture都在自己的线程中执行，保证了线程安全性。同时，我们使用了CompletableFuture.allOf()方法来等待所有CompletableFuture完成，保证了事务的一致性。

需要注意的是，这个示例中使用了@Transactional注解来保证事务的一致性。如果在实际项目中使用，需要根据具体情况来选择是否需要事务。同时，需要根据具体情况来调整线程池的大小，以充分利用系统资源

文章来源:https://blog.csdn.net/LuckFairyLuckBaby/article/details/134980577
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系我的编程经验分享网邮箱：chenni525@qq.com进行投诉反馈，一经查实，立即删除！