8、Spring Boot任务

1.异步任务

  Java应用中,绝大多数情况下都是通过同步的方式来实现交互处理的;但是在处理与第三方系统交互的时候,容易造成响应迟缓的情况,之前大部分都是使用多线程来完成此类任务,其实,在Spring 3.x之后,就已经内置了@Async来完美解决这个问题。

  主要使用两个注解完成,@EnableAysnc、@Aysnc

(1).Springboot04TaskApplication.java

@EnableAsync    //开启异步注解功能

@SpringBootApplication

public class Springboot04TaskApplication {

 

   public static void main(String[] args) {

      SpringApplication.run(Springboot04TaskApplication.class,args);

   }

 

}

(2).AsyncController.java

package com.hosystem.task.controller;

 

import com.hosystem.task.service.AsyncService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RestController;

 

@RestController

public class AsyncController {

 

    @Autowired

    AsyncService asyncService;

 

    @GetMapping("/hello")

    public String hello(){

        asyncService.hello();

        return "success";

    }

}

(3).AsyncService.java

package com.hosystem.task.service;

 

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;

 

@Service

public class AsyncService {

 

    //通知spring这是一个异步方法

    @Async

    public void hello(){

        try {

            Thread.sleep(3000);

        } catch (InterruptedException e) {

            e.printStackTrace();

        }

        System.out.println("处理数据....");

    }

}

 

2.定时任务

  开发中经常需要执行一些定时任务,比如需要在每天凌晨时候,分析一次前一天的日志信息。Spring为我们提供了异步执行任务调度的方式,提供TaskExecutor 、TaskScheduler 接口。

  使用到的注解有两个,@EnableScheduling、@Scheduled

  Cron表达式:

 

(1).ScheduledService.java

package com.hosystem.task.service;

 

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Service;

 

@Service

public class ScheduledService {

 

    /**

     *  second(),minute(分),hour(时),day of month(日),month(月),day of week(周几).

     *  0 * * * * MON-FRI

     * [0 0/5 14,18 * * ?]:每天14点整,和18点整,每隔5分钟执行一次

     * [0 15 10 ? * 1-6]:每个月的周一至周六10:15分执行一次

     * [0 0 2 ? * 6L]:每个月的最后一个周六凌晨2点执行一次

     * [0 0 2 LW * ?]:每个月的最后一个工作日凌晨2点执行一次

     * [0 0 2-4 ? * 1#1]:每个月的第一个周一凌晨2点到4点期间,每个整点都执行一次;

     */

    // @Scheduled(cron = "0 * * * * MON-SAT")

    //@Scheduled(cron = "0,1,2,3,4 * * * * MON-SAT")

    // @Scheduled(cron = "0-4 * * * * MON-SAT")

    @Scheduled(cron = "0/4 * * * * 0-7")  //4秒执行一次

    public void hello() {

        System.out.println("hello ...");

    }

}

(2).Springboot04TaskApplication.java

package com.hosystem.task;

 

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.scheduling.annotation.EnableAsync;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.Scheduled;

 

@EnableScheduling //开启基于注解定时任务

@SpringBootApplication

public class Springboot04TaskApplication {

 

   public static void main(String[] args) {

      SpringApplication.run(Springboot04TaskApplication.class,args);

   }

 

}

3.邮件任务

 

 

(1).导入pom.xml

<!--mail-->

<dependency>

   <groupId>org.springframework.boot</groupId>

   <artifactId>spring-boot-starter-mail</artifactId>

</dependency>

(2).开启POP3/SMTP

 

(3).开启IMAP/SMTP

 

(4).生成授权码

 

(5).applicaiton.properties

server.port=80

 

#配置邮箱信息

spring.mail.username=username@qq.com

#授权码

spring.mail.password=password

#smtp地址

spring.mail.host=smtp.qq.com

spring.mail.protocol=smtp

spring.mail.properties.mail.smtp.ssl.enable=true

(6).Springboot04TaskApplicationTests.java

  SendMailTest测试邮箱发送,一定要在mail中开启SMTP

package com.hosystem.task;

 

import org.junit.jupiter.api.Test;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.mail.SimpleMailMessage;

import org.springframework.mail.javamail.JavaMailSenderImpl;

import org.springframework.mail.javamail.MimeMessageHelper;

 

import javax.mail.internet.MimeMessage;

import java.io.File;

 

@SpringBootTest

class Springboot04TaskApplicationTests {

 

   @Autowired

   JavaMailSenderImpl mailSender;

 

   @Test

   public void contextLoads() {

      SimpleMailMessage simpleMailMessage = new SimpleMailMessage();

      //邮件设置

      simpleMailMessage.setSubject("通知-----");

      simpleMailMessage.setText("学习java");

  //setTo:目的邮件地址  setFrom:发送邮件地址

      simpleMailMessage.setTo("username@163.com");

      simpleMailMessage.setFrom("username@qq.com");

      mailSender.send(simpleMailMessage);

   }

 

   @Test

   public void test01() throws Exception{

      //1.创建一个复杂的消息邮件

      MimeMessage mimeMessage = mailSender.createMimeMessage();

      MimeMessageHelper helper = new MimeMessageHelper(mimeMessage,true);

 

      //邮件设置

      helper.setSubject("通知-----");

 

      /**

       *     public void setText(String text) throws MessagingException {this.setText(text,false);

       }

       */

      helper.setText("<b style='color:red'>学习java</b>",true);

  //setTo:目的邮件地址  setFrom:发送邮件地址

      helper.setTo("username@163.com");

      helper.setFrom("username@qq.com");

 

      //上传文件

      helper.addAttachment("8a92681cb892bf78ec83af62f2b6a82.jpg",new File("E:\\Users\\Asuna\\Desktop\\html\\8a92681cb892bf78ec83af62f2b6a82.jpg"));

      helper.addAttachment("8f82df421233241732db6ec6baed07e.jpg",new File("E:\\Users\\Asuna\\Desktop\\html\\8f82df421233241732db6ec6baed07e.jpg"));

 

 

      mailSender.send(mimeMessage);

   }

 

}

  

参考文档:

https://github.com/spring-projects/spring-boot/tree/v2.1.0.RELEASE/spring-boot-project/spring-boot-starters

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


这篇文章主要介绍了spring的事务传播属性REQUIRED_NESTED的原理介绍,具有一定借鉴价值,需要的朋友可以参考下。下面就和我一起来看看吧。传统事务中回滚点的使...
今天小编给大家分享的是一文解析spring中事务的传播机制,相信很多人都不太了解,为了让大家更加了解,所以给大家总结了以下内容,一起往下看吧。一定会有所收获...
这篇文章主要介绍了SpringCloudAlibaba和SpringCloud有什么区别,具有一定借鉴价值,需要的朋友可以参考下。下面就和我一起来看看吧。Spring Cloud Netfli...
本篇文章和大家了解一下SpringCloud整合XXL-Job的几个步骤。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。第一步:整合pom文件,在S...
本篇文章和大家了解一下Spring延迟初始化会遇到什么问题。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。List 坑列表 = new ArrayList(2);...
这篇文章主要介绍了怎么使用Spring提供的不同缓存注解实现缓存的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇...
本篇内容主要讲解“Spring中的@Autowired和@Resource注解怎么使用”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学...
今天小编给大家分享一下SpringSecurity怎么定义多个过滤器链的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家
这篇文章主要介绍“Spring的@Conditional注解怎么使用”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Spring的@Con...
这篇文章主要介绍了SpringCloudGateway的熔断限流怎么配置的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇SpringCloud&nb...
今天小编给大家分享一下怎么使用Spring解决循环依赖问题的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考
这篇文章主要介绍“Spring事务及传播机制的原理及应用方法是什么”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Sp...
这篇“SpringCloudAlibaba框架实例应用分析”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价
本篇内容主要讲解“SpringBoot中怎么使用SpringMVC”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习...
这篇文章主要介绍“SpringMVC适配器模式作用范围是什么”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“SpringMVC
这篇“导入SpringCloud依赖失败如何解决”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家...
这篇文章主要讲解了“SpringMVC核心DispatcherServlet处理流程是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来
今天小编给大家分享一下SpringMVCHttpMessageConverter消息转换器怎么使用的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以...
这篇文章主要介绍“Spring框架实现依赖注入的原理是什么”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Spring框架...
本篇内容介绍了“Spring单元测试控制Bean注入的方法是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下