【项目】仿牛客网社区开发第3章 Spring Boot 实践开发社区核心功能 4 事务管理

旧城等待， 2024-03-22 11:14 25阅读 0赞

### 【项目】仿牛客网社区开发 ###

#### 文章目录 ####

*   *  【项目】仿牛客网社区开发
     *   *  第3章 Spring Boot 实践 开发社区核心功能
         *   *  4 事务管理
             *   *  4.1 回顾
                 *  4.2 事务的隔离性
                 *  4.3 第一类丢失更新
                 *  4.4 第二类丢失更新
                 *  4.5 脏读
                 *  4.6 不可重复读
                 *  4.7 幻读
                 *  4.8 事务隔离级别
                 *  4.9 实现机制
                 *  4.10 Spring事务管理

![在这里插入图片描述][144f1cdfed034e95bacdb4d8245e878a.png_pic_center]

#### 第3章 Spring Boot 实践 开发社区核心功能 ####

##### 4 事务管理 #####

###### 4.1 回顾 ######

*  什么是事务
    
     *  事务是由N步数据库操作序列组成的逻辑执行单元，这系列操作要么全执行，要么全放弃执行。
 *  事务的特性（**ACID**）
    
     *  原子性（Atomicity）：事务是应用中不可再分的最小执行体。
     *  一致性（Consistency）：事务执行的结果，须使数据从一个一致性状态，变为另一个一致性状态。
     *  隔离性（Isolation）：各个事务的执行互不干扰，任何事务的内部操作对其他的事务都是隔离的。
     *  持久性（Durability）：事务一旦提交，对数据所做的任何改变都要记录到永久存储器中。

###### 4.2 事务的隔离性 ######

*  常见的并发异常
    
     *  第一类丢失更新、第二类丢失更新。
     *  脏读、不可重复读、幻读。
 *  常见的隔离级别
    
     *  Read Uncommitted：读取未提交的数据。
     *  Read Committed：读取已提交的数据。
     *  Repeatable Read：可重复读。
     *  Serializable：串行化。

###### 4.3 第一类丢失更新 ######

某一个事务的回滚， 导致另外一个事务已更新的数据丢失了。【$T1 到 T6 $ 可能只有1ms 甚至更短】

![在这里插入图片描述][92fd8b5f502b41a9896ba258c2249b20.png_pic_center]

###### 4.4 第二类丢失更新 ######

某一个事务的提交， 导致另外一个事务已更新的数据丢失了。

![在这里插入图片描述][7ca8163846c540bf9c5b87c27fe5d98e.png_pic_center]

###### 4.5 脏读 ######

某一个事务， 读取了另外一个事务未提交的数据。

![在这里插入图片描述][1692dde2a2a9457c962f260b966b9fe1.png_pic_center]

###### 4.6 不可重复读 ######

某一个事务， 对同一个数据前后读取的结果不一致。

![在这里插入图片描述][977e414fc6b04d12bf88db75350cdf2b.png_pic_center]

###### 4.7 幻读 ######

某一个事务， 对同一个表前后查询到的行数不一致。

![在这里插入图片描述][300b5183dd874feca9aee5275cc00baa.png_pic_center]

###### 4.8 事务隔离级别 ######

![在这里插入图片描述][b385261dcd9541bfb0a24c5a3046aaec.png_pic_center]

从上到下，隔离级别由低到高。Y 表示会出现该类问题。N 表示不会【当然这也对应着性能的下降】

> 通常中间两个是在应用中使用较多的

###### 4.9 实现机制 ######

*  悲观锁（数据库）
    
     *  共享锁（S锁）
        
        事务A对某数据加了共享锁后，其他事务只能对该数据加共享锁，但不能加排他锁。
     *  排他锁（X锁）
        
        事务A对某数据加了排他锁后，其他事务对该数据既不能加共享锁，也不能加排他锁。
 *  乐观锁（自定义）
    
     *  版本号、时间戳等
        
        在更新数据前，检查版本号是否发生变化。若变化则取消本次更新，否则就更新数据（版本号+1）。

###### 4.10 Spring事务管理 ######

*  声明式事务
    
     *  通过XML配置，声明某方法的事务特征。
     *  通过注解，声明某方法的事务特征。
 *  编程式事务
    
     *  通过 TransactionTemplate 管理事务， 并通过它执行数据库的操作。

![在这里插入图片描述][6e859b5237204373a51c56f7500aa4a9.png_pic_center]

> Spring 使用一套API 即可面向所有种类的数据库

代码演示：

【需求，在一个用户完成注册时，自动发布一条“新人报道” 的帖子】

@Autowired
        private UserMapper userMapper;
    
        @Autowired
        private DiscussPostMapper discussPostMapper;
    
        // REQUIRED: 支持当前事务(外部事务),如果不存在则创建新事务.【一定需要事务】
        // REQUIRES_NEW: 创建一个新事务,并且暂停当前事务(外部事务).
        // NESTED: 如果当前存在事务(外部事务),则嵌套在该事务中执行(独立的提交和回滚),否则就会REQUIRED一样.
        @Transactional(isolation = Isolation.READ_COMMITTED, propagation = Propagation.REQUIRED)
        public Object save1() {
        
            // 新增用户
            User user = new User();
            user.setUsername("alpha");
            user.setSalt(CommunityUtil.generateUUID().substring(0, 5));
            user.setPassword(CommunityUtil.md5("123" + user.getSalt()));
            user.setEmail("alpha@qq.com");
            user.setHeaderUrl("http://images.nowcoder.com/head/972t.png");
            user.setCreateTime(new Date());
            userMapper.insertUser(user);
    
            // 新增帖子
            DiscussPost post = new DiscussPost();
            post.setUserId(user.getId());
            post.setTitle("Hello");
            post.setContent("新人报道!");
            post.setCreateTime(new Date());
            discussPostMapper.insertDiscussPost(post);
    
            Integer.valueOf("abc"); // 故意报个错误出来
    
            return "ok";
        }

测试一下

package com.nowcoder.community;
    
    import com.nowcoder.community.service.AlphaService;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringRunner;
    
    /**
     * @Projectname: community
     * @Classname: TransactionTests
     * @Author: Ding Jiaxiong
     * @Date:2023/4/19 10:53
     */
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    @ContextConfiguration(classes = CommunityApplication.class)
    public class TransactionTests {
        
    
        @Autowired
        private AlphaService alphaService;
    
        @Test
        public void testSave1() {
        
            Object obj = alphaService.save1();
            System.out.println(obj);
        }
    
    }

现在的save1方法中是有一个错误的，理想运行结果是 事务回滚，不执行插入操作，

运行结果

![在这里插入图片描述][a85c9f503cd14ef9b7a68f0d88d57818.png_pic_center]

OK，报错了，但是我更关心的是 数据有没有插入成功

![在这里插入图片描述][08a75b9cb3f94cc3b6450b412f67192a.png_pic_center]

验证了，没有，事务回滚了

这是注解式，接下来演示编程式事务：

@Autowired
        private TransactionTemplate transactionTemplate;
    
        public Object save2() {
        
            transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
            transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
    
            return transactionTemplate.execute(new TransactionCallback<Object>() {
        
                @Override
                public Object doInTransaction(TransactionStatus status) {
        
                    // 新增用户
                    User user = new User();
                    user.setUsername("beta");
                    user.setSalt(CommunityUtil.generateUUID().substring(0, 5));
                    user.setPassword(CommunityUtil.md5("123" + user.getSalt()));
                    user.setEmail("beta@qq.com");
                    user.setHeaderUrl("http://image.nowcoder.com/head/999t.png");
                    user.setCreateTime(new Date());
                    userMapper.insertUser(user);
    
                    // 新增帖子
                    DiscussPost post = new DiscussPost();
                    post.setUserId(user.getId());
                    post.setTitle("你好");
                    post.setContent("我是新人!");
                    post.setCreateTime(new Date());
                    discussPostMapper.insertDiscussPost(post);
    
                    Integer.valueOf("abc");
    
                    return "ok";
                }
            });
        }

![在这里插入图片描述][ae5c8fd7ac954f2dacd53ee9e1558f19.png_pic_center]

同样测试一下

@Test
        public void testSave2() {
        
            Object obj = alphaService.save2();
            System.out.println(obj);
        }

运行结果

![在这里插入图片描述][b5ede8d33e5742f094a953d3f5022124.png_pic_center]

OK，和注解式事务运行效果一样，看看数据库

![在这里插入图片描述][23a49463a5e943e5a8f9038d34d87a45.png_pic_center]

![在这里插入图片描述][c943fb96be044c17a8c092c26a803c21.png_pic_center]

肯定都是没有插入成功的，出现错误，回滚了

后面就是真正的运用到我们的项目了，注意优先使用注解式事务，如果运行过程中需要对一些东西进行控制，再使用编程式事务。

[144f1cdfed034e95bacdb4d8245e878a.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/360ca153f68b4f278e2fed38c5eec008.png
[92fd8b5f502b41a9896ba258c2249b20.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/998602f0457a441fb85c9ac0e7fcd5ca.png
[7ca8163846c540bf9c5b87c27fe5d98e.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/bf1aef41db4a4fb381693a9398fc6478.png
[1692dde2a2a9457c962f260b966b9fe1.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/00cca8ca3ee04a57b8f71cc09e267a56.png
[977e414fc6b04d12bf88db75350cdf2b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/75436f8f6ef746b499da78dbb1dae3c7.png
[300b5183dd874feca9aee5275cc00baa.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/406b2a588f4640b7953a522ff2ff48ee.png
[b385261dcd9541bfb0a24c5a3046aaec.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/14993d9a6d9d494f80c270fa6a69c31e.png
[6e859b5237204373a51c56f7500aa4a9.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/b6ad17fd3fd0456ab3923d3be51338bb.png
[a85c9f503cd14ef9b7a68f0d88d57818.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/0d28078c5307493c8a203652432538f2.png
[08a75b9cb3f94cc3b6450b412f67192a.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/15c4f9ae61fa4104b219a27db3f219f5.png
[ae5c8fd7ac954f2dacd53ee9e1558f19.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/d88d0a90ad124f89a3c0654742f105f5.png
[b5ede8d33e5742f094a953d3f5022124.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/38b22b88a0f947638ca0c04f0c489f80.png
[23a49463a5e943e5a8f9038d34d87a45.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/91081e71509749729482f09ddf9f7564.png
[c943fb96be044c17a8c092c26a803c21.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/87bdb72585214d2db9bed935b9d78415.png