SpringBoot事务-调度-缓存

news2024/11/24 11:38:30

一.Spring Boot中的事务管理

设置事务

        @Transactional(isolation = Isolation.DEFAULT)

        @Transactional(propagation = Propagation.REQUIRED)

开启事务

        @EnableTransactionManagement ​​​​​​​

1. 开启事务管理

要开启 Spring 的事务管理，你需要在你的 Spring Boot 应用中添加 @EnableTransactionManagement 注解。通常这个注解会放在你的主应用类或者配置类上。

@SpringBootApplication
@EnableTransactionManagement
public class Springboot01CenterTxApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot01CenterTxApplication.class, args);
    }

}

2. 使用事务注解

  • @Transactional 注解可以加在服务类的方法上，表示该方法是一个事务。这个注解可以接收多个参数来控制事务的行为，比如 isolation 和 propagation。
@Transactional
@Service
public class CustomerServiceImp implements ICustomerService{


    @Resource
    private ConsumeMapper mapper;

    @Override
    public void batchAdd() {
        mapper.insert(new Customer(1,"台湾君越酒店","五星级","佩洛西1","12345678"));
        int a = 10/0;
        mapper.insert(new Customer(2,"台湾君越酒店","五星级","佩洛西1","12345678"));
        mapper.insert(new Customer(3,"台湾君越酒店","五星级","佩洛西1","12345678"));

    }
}

3. 事务属性

  • Isolation：定义多个事务之间的隔离级别，主要有以下几个选择：
    • Isolation.DEFAULT：使用数据库默认的隔离级别。
    • Isolation.READ_UNCOMMITTED：允许读取未提交的数据。
    • Isolation.READ_COMMITTED：确保只读取已提交的数据。
    • Isolation.REPEATABLE_READ：确保在同一事务中多次读取的数据一致。
    • Isolation.SERIALIZABLE：完全隔离的事务，确保每个事务都按照某个顺序执行（性能较低）。
  • Propagation：定义事务的传播行为，主要有以下几种：
    • Propagation.REQUIRED：如果当前存在事务，则加入该事务；如果没有事务，则创建新的事务。
    • Propagation.REQUIRES_NEW：创建一个新的事务，如果当前存在事务，则将当前事务挂起。
    • Propagation.NESTED：如果当前存在事务，则在嵌套事务中执行；否则，就执行与 REQUIRED 相同的方式。
    • Propagation.SUPPORTS：如果当前存在事务，则加入该事务；否则以非事务方式执行。
    • Propagation.NOT_SUPPORTED：以非事务方式执行，挂起当前事务（如果存在）。
    • Propagation.NEVER： 不支持事务，如果当前存在事务则会抛出异常。

 4. 测试事务

你可以创建测试用例，验证事务的正确性。例如，如果在一个事务中执行了多个数据库操作，而其中一个操作失败，则整个事务应回滚，数据库应保持在失败前的状态。

public void batchAdd() {
        mapper.insert(new Customer(1,"台湾君越酒店","五星级","佩洛西1","12345678"));
       // int a = 10/0;
        mapper.insert(new Customer(2,"台湾君越酒店","五星级","佩洛西1","12345678"));
        mapper.insert(new Customer(3,"台湾君越酒店","五星级","佩洛西1","12345678"));

    }

public void batchAdd() {
        mapper.insert(new Customer(1,"台湾君越酒店","五星级","佩洛西1","12345678"));
        int a = 10/0;
        mapper.insert(new Customer(2,"台湾君越酒店","五星级","佩洛西1","12345678"));
        mapper.insert(new Customer(3,"台湾君越酒店","五星级","佩洛西1","12345678"));

    }

二.Spring Boot异步任务

在项目开发中，绝大多数情况下都是通过同步方式处理业务逻辑的，但是比如批量处理数据，批量发送 邮件，批量发送短信等操作 容易造成阻塞的情况，之前大部分都是使用多线程来完成此类任务而在 Spring 3+之后，就已经内置了@Async注解来完美解决这个问题，从而提高效率。

使用的注解

        @EnableAsync 启动类上开启基于注解的异步任务

        @Async 标识的方法会异步执行

1. 启用异步支持

在你的主应用类或配置类上添加 @EnableAsync 注解。这样 Spring 就会扫描带有 @Async 注解的方法并在异步执行它们。

@SpringBootApplication
@EnableAsync
public class Springboot02CenterAysncApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot02CenterAysncApplication.class, args);
    }

}

2. 创建异步方法

在你的服务类中，可以通过 @Async 注解来标记要异步执行的方法。这个方法应该返回 void 或者是 Future、CompletableFuture 等可用于异步结果的类型。

@Service
public class CustomerServiceImp implements ICustomerService{

    @Override
    @Async
    public void batchAdd() {

        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("======>批量新增");
    }
}

3. 调用异步方法

在其他服务或控制器中，可以调用上述异步方法。注意，由于这些方法是异步执行的，所以调用这些方法后不会等待其完成，调用者会立即继续执行后面的代码。

@RestController
public class CustomrControllerImp {

    @Autowired
    private ICustomerService service;

    @RequestMapping("/add")
    public String batchAdd() {
        service.batchAdd();
        return "成功";
    }

}

总结

通过 @EnableAsync 和 @Async 注解，Spring 允许你轻松地将方法异步执行，从而提高应用的吞吐量和响应速度。同时，自定义配置线程池也可以使你更好地控制异步任务的执行。使用异步任务时要注意，异步方法不能被同一类中的其他方法直接调用，因为那样不会触发代理，方法会在同一线程中执行。

三.SpringBoot定时任务调度

SpringTask

在项目开发中，经常需要执行一些定时任务，比如 每月1号凌晨需要汇总上个月的数据分析报表; 每天 凌晨分析前一天的日志信息等定时操作。Spring 为我们提供了异步执行定时任务调度的方式

 使用的注解

@EnableScheduling启动类上开启基于注解的定时任务

@Scheduled标识的方法会进行定时处理

        需要通过 cron 属性来指定 cron 表达式：秒 分 时 日 月 星期 年

        在线生成cron表达式 http://cron.qqe2.com/

1. 启用定时任务

在你的主应用类或配置类上添加 @EnableScheduling 注解，以启用 Spring 的定时任务功能。

@SpringBootApplication
@EnableScheduling
public class Springboot03CenterJobApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot03CenterJobApplication.class, args);
    }

}

2. 创建定时任务

在你的服务类中，可以使用 @Scheduled 注解来标识需要定时执行的方法。可以通过 cron 属性来指定 cron 表达式。

@Service  
public class MyScheduledService {  

    // 每分钟执行一次  
    @Scheduled(cron = "0 * * * * ?")  
    public void executeTaskEveryMinute() {  
        System.out.println("Executing task every minute: " + System.currentTimeMillis());  
    }  

    // 每天凌晨 1 点执行  
    @Scheduled(cron = "0 0 1 * * ?")  
    public void executeTaskAtOneAM() {  
        System.out.println("Executing task at 1 AM: " + System.currentTimeMillis());  
    }  

    // 每周一执行  
    @Scheduled(cron = "0 0 12 ? * MON")  
    public void executeTaskEveryMonday() {  
        System.out.println("Executing task every Monday at noon: " + System.currentTimeMillis());  
    }  
}

3. 使用 cron 表达式

cron 表达式的格式如下：

秒  分  时  日  月  星期  年（可选）

  • 秒：0-59
  • 分：0-59
  • 时：0-23
  • 日：1-31
  • 月：1-12 或者 JAN-DEC
  • 星期：1-7（1=星期日）或 SUN-SAT
  • 年：1970-2099（可选）
示例 cron 表达式
  • "0 * * * * ?"：每分钟执行一次
  • "0 0 1 * * ?"：每天凌晨 1 点执行
  • "0 0 12 ? * MON"：每周一中午 12 点执行
  • "0 0/5 * * * ?"：每 5 分钟执行一次

你可以使用在线工具生成和测试 cron 表达式，例如 在线Cron表达式生成器。

总结

通过 @EnableScheduling 和 @Scheduled 注解，Spring 提供了一种简单而强大的方式来实现定时任务。你可以根据需要自定义 cron 表达式，以满足不同的调度需求。

四.SpringBoot 整合Mail

第一步添加坐标

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-mail</artifactId>
</dependency>

第二步开启配置

配置邮箱信息

        spring.mail.username=

        spring.mail.password=

发送邮件服务器

        spring.mail.host=smtp.qq.com

spring.mail.username=3058389349
spring.mail.password=topqjgemcudxdfch
spring.mail.host=smtp.qq.com
spring.mail.properties.smtp.ssl.enable=true

 第三步编写代码

邮件收发核心类

         JavaMailSenderImpl javaMailSender;

封装简单的邮件内容

        SimpleMailMessage

封装复杂的邮件（携带附件）

         MimeMessage MimeMessageHelper

@SpringBootTest
class Springboot04CenterMailApplicationTests {

    @Autowired(required = false)
    private JavaMailSenderImpl javaMailSender;

    //发送简单邮件

    @Test
    void show1() {
        //1.创建邮件对象
        SimpleMailMessage simpleMailMessage=new SimpleMailMessage();
        //2.设置信息
        simpleMailMessage.setSubject("疫情全面放开");
        simpleMailMessage.setText("2022年好难，做了11个月的核酸，结果在第12个月阳了~~~");
        simpleMailMessage.setFrom("3058389349@qq.com");
        simpleMailMessage.setTo("3418813089@qq.com");

        //3.发送邮件
        javaMailSender.send(simpleMailMessage);
        System.out.println("发送成功！！！");

    }

    //发送复杂邮件
    @Test
    void show2() throws MessagingException {
        //1.创建邮件对象
        MimeMessage mimeMessage = javaMailSender.createMimeMessage();
        //2.创建MimeMessageHelper
        MimeMessageHelper mimeMessageHelper=new MimeMessageHelper(mimeMessage,true);
        //3.设置信息
        mimeMessageHelper.setSubject("程序员的误解");
        mimeMessageHelper.setText("程序员是个<span style='color:red'>高薪,高危</span>的职业",true);
        mimeMessageHelper.addAttachment("pp.jpg",new File("D:\\1\\图片\\pp.jpg"));
        mimeMessageHelper.setFrom("3058389349@qq.com");
        mimeMessageHelper.setTo("3418813089@qq.com");
        //4.发送邮件
        javaMailSender.send(mimeMessage);


    }

    @Test
    public void show(){
        //1、new Jedis对象即可
        Jedis jedis=new Jedis("127.0.0.1",6379);
       //jedis所有的命令
        System.out.println(jedis.ping());
    }

}

​​​​​​​

五.SpringBoot 整合redis

1、添加坐标

        <!-- redis依赖 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter</artifactId>
            <version>RELEASE</version>
            <scope>test</scope>
        </dependency>

2、配置Redis

spring.redis.host=localhost
spring.redis.port=6379

3、使用 Redis

//演示1（专用对象）
    @Autowired
    public RedisTemplate redisTemplate;

    //演示2（专用字符串key value均是String）
    @Autowired
    public StringRedisTemplate stringRedisTemplate;

    //演示3（自定义）
    @Autowired
    public RedisTemplate jsonRedisTemplate;

4. 启动 Redis Server

5. 运行 Spring Boot 应用

StringRedisTemplate(专用字符串key value均是String)

    @Test
    public void stringRedisTemplate(){
        //1.key相关
        Set<String> keys = stringRedisTemplate.keys("*");
        for (String key : keys) {
            System.out.println(key);
        }
        //2.各种类型支持
        stringRedisTemplate.opsForValue();
        stringRedisTemplate.opsForList();//List
        stringRedisTemplate.opsForHash();//hash
        stringRedisTemplate.opsForSet();//set
        stringRedisTemplate.opsForZSet();//zset
        //3.举例字符串
        stringRedisTemplate.opsForValue().set("name","水果");
        String name = stringRedisTemplate.opsForValue().get("name");
        System.out.println(name);
        //4.操作list列表
        stringRedisTemplate.opsForList().leftPush("myList","香蕉");
        stringRedisTemplate.opsForList().leftPush("myList","苹果");
        stringRedisTemplate.opsForList().leftPushAll("mylistAll","苹果","香蕉","香蕉");
        List<String> list =  stringRedisTemplate.opsForList().range("mylistAll",0,2);
        System.out.println(list);
    }

 

 

RedisTemplate(专用对象)

注意:
1.测试RedisTemplate与stringRedisTemplate存的数据相互独立
2.redisTemplate默认使用key序列化方式和value的序列化方式都使用的是jdk serializer序列化
  所以存对象会乱码

@Test
    public void show2(){

        ValueOperations valueOperations = redisTemplate.opsForValue();
        valueOperations.set("name","蜜蜂");
        String name = (String) valueOperations.get("name");
        System.out.println(name);


        redisTemplate.opsForValue();//String
        redisTemplate.opsForList();//List
        redisTemplate.opsForHash();//hash
        redisTemplate.opsForSet();//set
        redisTemplate.opsForZSet();//zset


        Student stu1 = new Student(1,"蜜蜂","采蜜");
        redisTemplate.opsForValue().set("stu1",stu1);
        Student ss1 = (Student)redisTemplate.opsForValue().get("stu1");
        System.out.println(ss1);

        redisTemplate.opsForList().leftPushAll("mylist","睡觉","游戏");
        List<String> list = redisTemplate.opsForList().range("mylist",0,-1);
        for (int i = 0; i < list.size(); i++) {
            String s =  list.get(i);
            System.out.println(s);
        }

        System.out.println("打印默认序列策略"+redisTemplate.getDefaultSerializer());


    }

 

 RedisTemplate(自定义) 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2039542.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Docker 日志管理

Docker 日志管理

一、ELK -Filebeat Elasticsearch 数据的存储和检索 常用端口&#xff1a; 9100&#xff1a;elasticsearch-head提供web访问 9200&#xff1a;elasticsearch与其他程序连接或发送消息 9300&#xff1a;elasticsearch集群状态 Logstash 有三个组件构成input&#xff0c;fi…
阅读更多...
网安行业薪资：「3人拿4干5」

网安行业薪资：「3人拿4干5」

吉祥知识星球http://mp.weixin.qq.com/s?__bizMzkwNjY1Mzc0Nw&mid2247485367&idx1&sn837891059c360ad60db7e9ac980a3321&chksmc0e47eebf793f7fdb8fcd7eed8ce29160cf79ba303b59858ba3a6660c6dac536774afb2a6330#rd 《网安面试指南》http://mp.weixin.qq.com/s…
阅读更多...
计算机毕业设计 农家乐管理平台 Java+SpringBoot+Vue 前后端分离 文档报告 代码讲解 安装调试

计算机毕业设计 农家乐管理平台 Java+SpringBoot+Vue 前后端分离 文档报告 代码讲解 安装调试

&#x1f34a;作者&#xff1a;计算机编程-吉哥 &#x1f34a;简介&#xff1a;专业从事JavaWeb程序开发&#xff0c;微信小程序开发&#xff0c;定制化项目、 源码、代码讲解、文档撰写、ppt制作。做自己喜欢的事&#xff0c;生活就是快乐的。 &#x1f34a;心愿&#xff1a;点…
阅读更多...
Linux | Linux开发工具链全攻略：yum、vim、gcc/g++、GDB、Makefile与git版本控制

Linux | Linux开发工具链全攻略：yum、vim、gcc/g++、GDB、Makefile与git版本控制

目录 Linux开发环境全解析&#xff1a;工具、编程与版本控制 1、软件包管理器YUM 查看可用的软件包 安装软件包 更新软件包 卸载软件包 查找软件包信息 清理缓存 检查可更新的软件包 显示软件包的依赖关系 2、Vim编辑器 vim的三种模式&#xff1a;命令模式、插入模…
阅读更多...
计算机基础知识复习8.13

计算机基础知识复习8.13

cookie和session区别 cookie:是服务器发送到浏览器&#xff0c;并保存在浏览器端的一小块数据 浏览器下次访问服务时&#xff0c;会自动携带该块数据&#xff0c;将其发送给服务器 session:是javaEE标准&#xff0c;用于在服务端记录客户端信息 数据存放在服务端更加安全&a…
阅读更多...
Leetcode JAVA刷刷站（14）最长公共前缀

Leetcode JAVA刷刷站（14）最长公共前缀

一、题目概述 二、思路方向 在Java中&#xff0c;要编写一个函数来查找字符串数组中的最长公共前缀&#xff0c;我们可以遵循以下步骤&#xff1a; 处理边界条件&#xff1a;如果数组为空或长度为0&#xff0c;直接返回空字符串。初始化最长公共前缀&#xff1a;将数组的第一个…
阅读更多...
[0CTF 2016]piapiapia1

[0CTF 2016]piapiapia1

打开题目 看到登录口 字符串绕过长度限制strlen($_POST[nickname]) > 10
阅读更多...
Json Formatter工具

Json Formatter工具

JSON 格式化工具的选择与使用 作为开发人员&#xff0c;我们经常需要查看和格式化 JSON 数据。虽然市面上有很多 JSON 工具可以满足这一需求&#xff0c;但在某些情况下&#xff0c;标准的 JSON 工具可能并不够用。 例如&#xff0c;处理一个 JavaScript 对象的格式&#xff…
阅读更多...
【Qt】QWidget的windowTitle属性

【Qt】QWidget的windowTitle属性

QWidget的windowTitle属性 API说明 windowTitle() 获取到控件的窗⼝标题. setWindowTitle(const QString& title) 设置控件的窗⼝标题. 例子&#xff1a;设置窗口标题 当前windowTitle属性是从属于Qwidget的&#xff0c;Qwidget是一个广泛的定义&#xff0c;window…
阅读更多...
Qt第十四章 模型视图

Qt第十四章 模型视图

Model/View(模型/视图&#xff09;结构 文章目录 Model/View(模型/视图&#xff09;结构简介视图组件Model/View结构的一些概念项目控件组&#xff08;item Widgets&#xff09;模型/视图 如何使用项目视图组设置行的颜色交替变换拖拽设置编辑操作其他操作 选择模型自定义选择多…
阅读更多...
打靶记录10——hacksudo---Thor

打靶记录10——hacksudo---Thor

靶机&#xff1a; https://download.vulnhub.com/hacksudo/hacksudo---Thor.zip难度&#xff1a; 中 目标&#xff1a; 取得root权限flag 涉及攻击方法&#xff1a; 主机发现端口扫描Web目录爬取开源源码泄露默认账号密码SQL注入破壳漏洞GTFOBins提权 主机发现&#xff…
阅读更多...
Windows的cmd命令行使用Linux类命令

Windows的cmd命令行使用Linux类命令

Windows的cmd使用Linux类命令 去我的个人博客观看&#xff0c;观感更佳哦&#xff0c;&#x1f619;&#x1f619; 前言 我在使用Vscode编写C/C代码的时候&#xff0c;经常会用到Shell(你可以理解为命令行)&#xff0c;但是我不得不说Windows下Dos命令极其难用且拉跨&#x1f…
阅读更多...
【应用层协议】自定义协议 {定义结构化数据；数据格式转换：序列化和反序列化，使用json库进行数据格式交换；分包和解包：为报文内容添加报头}

【应用层协议】自定义协议 {定义结构化数据；数据格式转换：序列化和反序列化，使用json库进行数据格式交换；分包和解包：为报文内容添加报头}

一、简单了解TCP协议&#xff08;引子&#xff09; 1.1 三次握手 三次握手就是客户端向服务端发起连接的过程 服务器初始化 调用socket&#xff0c;创建套接字文件 调用bind&#xff0c;将当前的文件描述符和ip/port绑定在一起&#xff1b;如果这个端口已经被其他进程占用了&…
阅读更多...
整理 酷炫 Flutter 开源UI框架 按钮

整理 酷炫 Flutter 开源UI框架 按钮

flutter_percent_indicator Flutter 百分比指示器库 项目地址&#xff1a;https://github.com/diegoveloper/flutter_percent_indicator 项目Demo&#xff1a;https://download.csdn.net/download/qq_36040764/89631340
阅读更多...
springboot整合doris(doris创建表)

springboot整合doris(doris创建表)

Doris 的数据模型主要分为 3 类： 明细模型（Duplicate Key Model）：允许指定的 Key 列重复；适用于必须保留所有原始数据记录的情况主键模型（Unique Key Model）：每一行的 Key 值唯一；可确保给定的 Key 列不会存在重复行聚合模型（Aggregate Key Model）：可根据 Key 列聚…
阅读更多...
力扣每日一题 特殊数组 II 前缀和

力扣每日一题 特殊数组 II 前缀和

Problem: 3152. 特殊数组 II &#x1f468;‍&#x1f3eb; 参考题解 Code class Solution {public boolean[] isArraySpecial(int[] nums, int[][] queries) {int[] s new int[nums.length];for (int i 1; i < nums.length; i) {s[i] s[i - 1] (nums[i - 1] % 2 num…
阅读更多...
用R语言进行数据的特征缩放主要方法

用R语言进行数据的特征缩放主要方法

下面内容摘录自《R 语言与数据科学的终极指南》专栏文章的部分内容&#xff0c;每篇文章都在 5000 字以上&#xff0c;质量平均分高达 94 分&#xff0c;看全文请点击下面链接&#xff1a; 4章11节&#xff1a;用R做数据重塑&#xff0c;数据的特征缩放和特征可视化-CSDN博客文…
阅读更多...
第八季完美童模全球冠军·韩嘉滢 破浪扬帆写就传奇

第八季完美童模全球冠军·韩嘉滢 破浪扬帆写就传奇

在这个充满奇迹与梦想的舞台上&#xff0c;星光少女韩嘉滢以她独有的光芒&#xff0c;照亮了第八季完美童模的每一个角落。从亚特兰蒂斯的神秘海域到典故里的中国古韵&#xff0c;她以多变的风格与卓越的表现&#xff0c;征服了全球观众的心&#xff0c;最终荣登全球冠军的宝座…
阅读更多...
K8S资源之Service

K8S资源之Service

概念 将一组 Pods 公开为网络服务的抽象方法。 ClientIP 模型 集群内访问类型。 命令行 # 暴露端口 kubectl expose deployment my-dep-nginx --port8000 --target-port80Yml文件 apiVersion: v1 kind: Service metadata:labels:app: my-dep-nginxname: my-dep-nginx spe…
阅读更多...
中小型企业可用的数据采集监控平台 为生产带来众多改变

中小型企业可用的数据采集监控平台 为生产带来众多改变

中小型企业采用数据采集监控平台可以显著提升生产效率、优化生产流程、增强决策能力&#xff0c;并带来一系列积极的改变。 数据采集监控平台可提供从边缘感知设备到云端的数据采集、存储、分析、可视化等服务&#xff0c;实现生产工艺流程仿真、设备运行状态监控、数据报表、趋…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023