7. 异步任务、异步消息、周期任务

ゝ一纸荒年。 2023-06-28 11:30 38阅读 0赞

## 7. 异步任务 ##

### 7.1 异步线程池 ###

在开发中，经常会有一些任务需要后台执行的情况。spring boot给出了异步调用的支持。我们只需要三步即可实现异步调用。

**配置异步线程池**

实现AsyncConfigurer接口。该接口有两个方法。

public interface AsyncConfigurer {
        
        //获取线程池
        @Nullable
        default Executor getAsyncExecutor() {
        
            return null;
        }
    	//获取异常处理器
        @Nullable
        default AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        
            return null;
        }
    }

**开启异步调用**

使用@EnableAsync注解开启异步调用

@Configuration
    @EnableAsync    //开启异步调用，在需要异步调用的方法上使用@Async执行异步
    public class AsyncConfig implements AsyncConfigurer {
        
        
        //获取线程池
        @Override
        public Executor getAsyncExecutor() {
        
            //定义线程池
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            //核心线程数
            executor.setCorePoolSize(10);
            //最大线程数
            executor.setMaxPoolSize(50);
            //队列最大数值
            executor.setQueueCapacity(2000);
            //初始化
            executor.initialize();
            return executor;
        }
    
        //获取异常处理器
        @Override
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        
            return null;
        }
    }

**开启指定的方法的异步调用**

在需要异步调用的方法上使用@Async注解即可启动该方法的异步调用。

@Async
    public void helloAsync() {
        
        System.out.println("执行线程："+Thread.currentThread().getName());
    }

### 7.2 异步消息 ###

Java具有JMS功能，JSM分为两类。常见的消息服务有：ActiveMQ、Kafka、RabbitMQ等。

*  点对点（Point-to-Point）
    
    一个系统发送消息到另一个系统，另一个系统接收消息，处理相应逻辑
 *  发布订阅（Publish/Subcribe）
    
    一个系统发送消息到一个主题（Topic），其他系统可以订阅这个主题，从而获得消息，处理相应逻辑。

官网下载ActiveMQ

http://activemq.apache.org/components/classic/download/

解压后运行，可打开网页查看是否运行成功（默认登录用户名admin，密码admin）

http://localhost:8161/admin/

引入相关依赖包

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>
    
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-pool</artifactId>
    </dependency>

配置activemq

# ActiveMQ地址
    spring.activemq.broker-url=tcp://localhost:61616
    # 配置用户名和密码
    spring.activemq.user=admin
    spring.activemq.password=admin
    # 是否为发布订阅模式，默认为false，即点对点模式
    spring.jms.pub-sub-domain=true
    # 默认目的地址
    spring.jms.template.default-destination=activemq.default.destination
    # 是否启用线程池
    spring.activemq.pool.enabled=true
    # 线程池最大连接数
    spring.activemq.pool.max-connections=50

spring会启动后会初始化**JMS连接工厂、连接池和JmsTemplate**对象等。我们可以通过JmsTemplate对象来进行消息的发布和订阅。Spring还提供了@JmsListener来处理消息的接收。

下面使用JmsTemplate进行消息的收发测试。定义消息接口

public interface ActiveMqService {
        
        //发送消息
        void sendMessage(String msg);
        //接收消息
        void receiveMessage(String msg);
    }

实现类

@Service
    public class ActiveMqServiceImpl implements ActiveMqService {
        
    
        @Autowired
        private JmsTemplate jmsTemplate;
    
        @Override
        public void sendMessage(String msg) {
        
            System.out.println("发送消息：" + msg);
            //使用配置的默认地址发送
            jmsTemplate.convertAndSend(msg);
            //自定义发送地址
            jmsTemplate.convertAndSend("your-destination",msg);
        }
    
        @Override
        @JmsListener(destination = "${spring.jms.template.default-destination}")
        public void receiveMessage(String msg) {
        
            System.out.println("接收消息：" + msg);
        }
    }

ActiveMQ除了可以发送基本类型的消息，还可以发送POJO。如发送一个User对象。只有被Active MQ信任的包下的类对象才能被发送成功，可以通过配置文件中配置信任的包路径

# 配置信任的包，被信任的包下的类对象才能被发送
    spring.activemq.packages.trusted=xyz.mxlei.async,java.lang
    # 信任所有包
    # spring.activemq.packages.trust-all=true

### 7.3 定时任务 ###

Spring提供了定时任务的支持，只需要@EnableScheduling开启定时任务，然后在需要进行执行的方法上使用@Scheduled即可。

@SpringBootApplication
    @EnableScheduling
    public class AsyncApplication {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(AsyncApplication.class, args);
        }
    
    }

@Service
    public class ScheduleServiceImpl implements ScheduleService {
        
    
        @Override
        @Scheduled(fixedRate = 1000)    //开启周期任务
        @Async                          //异步执行
        public void job1() {
        
            System.out.println(Thread.currentThread().getName()+"：job1");
        }
    
        @Override
        @Scheduled(fixedRate = 1000)    //开启周期任务
        @Async                          //异步执行
        public void job2() {
        
            System.out.println(Thread.currentThread().getName()+"：job2");
        }
    }

这样运行程序后，就可以在控制台看到两个周期任务每秒执行一次，且每次的线程互不相同。

ThreadPoolTaskExecutor-9：job1
    ThreadPoolTaskExecutor-9：job2
    ThreadPoolTaskExecutor-1：job1
    ThreadPoolTaskExecutor-1：job2
    ThreadPoolTaskExecutor-4：job1
    ThreadPoolTaskExecutor-4：job2
    ThreadPoolTaskExecutor-6：job1

@Scheduled注解有很多的配置项

public @interface Scheduled {
        
        String CRON_DISABLED = "-";
        //使用表达式的方式定义任务在特定时间执行
        String cron() default "";
    	//设置区域时间
        String zone() default "";
    	//固定延迟执行，单位毫秒
        long fixedDelay() default -1L;
    	//固定延迟执行，以字符串定义，可以使用SpEL
        String fixedDelayString() default "";
    	//固定延迟执行
        long fixedRate() default -1L;
    	//固定延迟执行，以字符串定义，可以使用SpEL
        String fixedRateString() default "";
    	//IOC容器初始化后，首次任务延迟时间
        long initialDelay() default -1L;
    	//IOC容器初始化后，首次任务延迟时间，以字符串定义，可以使用SpEL
        String initialDelayString() default "";
    }

cron的配置比较复杂，有多个元素组成。分别为

**秋 分 时 天 月 星期 年**

每个元素用空格分隔，如下定义

![UTOOLS1578539500509.png][]

表达式中可以添加通配符

<table> 
 <thead> 
  <tr> 
   <th>通配符</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>*</td> 
   <td>任意值</td> 
  </tr> 
  <tr> 
   <td>？</td> 
   <td>不指定值，用于处理天和星期配置的冲突</td> 
  </tr> 
  <tr> 
   <td>-</td> 
   <td>指定时间区间</td> 
  </tr> 
  <tr> 
   <td>/</td> 
   <td>指定时间间隔执行</td> 
  </tr> 
  <tr> 
   <td>L</td> 
   <td>最后的</td> 
  </tr> 
  <tr> 
   <td>#</td> 
   <td>第几个</td> 
  </tr> 
  <tr> 
   <td>，</td> 
   <td>列举多个项</td> 
  </tr> 
 </tbody> 
</table>

[UTOOLS1578539500509.png]: https://imgconvert.csdnimg.cn/aHR0cDovL3lhbnh1YW4ubm9zZG4uMTI3Lm5ldC83MGRlY2ExN2QxM2MwNjBmN2VlNzlmZjA1ODFlNDZiOC5wbmc?x-oss-process=image/format,png