黑龙江省建设厅网站首页,建一个淘宝客网站要多少钱,网页游戏推广平台,如何用网站做招聘前言#xff1a;
当前做法实现了对某个方法异步延迟的操作#xff0c;常见的场景如短信发送日志的延迟查询和记录。 一般来说#xff0c;短信的发送和接收#xff0c;在短信云服务商那里形成完整记录是需要一定的时间的#xff0c;只有这段时间过去才可以有效查到短信的发…前言
当前做法实现了对某个方法异步延迟的操作常见的场景如短信发送日志的延迟查询和记录。 一般来说短信的发送和接收在短信云服务商那里形成完整记录是需要一定的时间的只有这段时间过去才可以有效查到短信的发送详情。例如短信发送后的10秒我们主动去查询也是可以的但是这个查询也不能阻塞主线程那我们就要使用异步的方式常见的有三种方法可以实现该效果
编写一个回调接口并将该接口配置为回调地址等待短信服务商回调该接口接收数据并记录。使用MQ创建延迟队列在延迟队列触发后去查询数据并记录。使用定时任务定时批量查询数据并记录。
今天我来为大家介绍第四种方法在Springboot项目中实现这个做法更简便且代码简单资源可控性高利用kotlin的协程来完成这个功能。 协程的知识不在此处展开感兴趣的同学点此学习官方文档。
实现方法
由于比较简单直接上代码了比较直观
第一步注入默认协程作用域到SpringIoc
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import kotlin.coroutines.CoroutineContextConfiguration
class CoroutineScopeConfig {Beanfun coroutineScope(): CoroutineScope {return object : CoroutineScope {override val coroutineContext: CoroutineContextget() Dispatchers.Default}}
}
此时在其他地方都可以通过依赖注入的方式使用该CoroutineScope。这个CoroutineScope 是默认的全局作用域此时注册这个bean到springioc后它的生命周期就由spring来管理。
第二步在默认协程作用域下使用协程:
Component
class SmsSender(val coroutineScope: CoroutineScope) {fun sendSms(tempalteCode:String, mobile:String, params:MapString,String?) {//发送val request RequestBuilder().setMobile(mobile).setTemplateCode(templateCode).setParams(params).build()val response doSend(mobile,request)//启动一个协程延迟10s后查询日志并记录coroutineScope.launch {delay(10000) // 延迟10秒//查询val reuslt querySmsDetail(response.bizId)//保存 save(result) }}
}以上内容为伪代码发送短信后启动了一个协程协程的任务是延迟10s后查询并保存短信发送详情。 核心代码为
coroutineScope.launch {delay(10000) // 延迟10秒//... }}你看异步延迟执行一个任务就是这么简单。实际上协程还能实现很多的业务功能后面有机会有用例了再讲讲其他的使用方式。
