【kotlin】在SpringBoot项目中使用kotlin协程coroutine实现方法的异步延迟调用,例如延迟查询短信发送详情结果。

本文主要是介绍【kotlin】在SpringBoot项目中使用kotlin协程coroutine实现方法的异步延迟调用,例如延迟查询短信发送详情结果。,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前言:

当前做法实现了对某个方法异步延迟的操作,常见的场景如短信发送日志的延迟查询和记录。
一般来说,短信的发送和接收,在短信云服务商那里形成完整记录是需要一定的时间的,只有这段时间过去才可以有效查到短信的发送详情。例如短信发送后的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.CoroutineContext@Configuration
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:Map<String,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秒//...           }}

你看,异步延迟执行一个任务,就是这么简单。实际上协程还能实现很多的业务功能,后面有机会有用例了再讲讲其他的使用方式。

这篇关于【kotlin】在SpringBoot项目中使用kotlin协程coroutine实现方法的异步延迟调用,例如延迟查询短信发送详情结果。的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/805228

相关文章

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

Spring Bean初始化及@PostConstruc执行顺序示例详解

《SpringBean初始化及@PostConstruc执行顺序示例详解》本文给大家介绍SpringBean初始化及@PostConstruc执行顺序,本文通过实例代码给大家介绍的非常详细,对大家的... 目录1. Bean初始化执行顺序2. 成员变量初始化顺序2.1 普通Java类(非Spring环境)(

Spring Boot 中的默认异常处理机制及执行流程

《SpringBoot中的默认异常处理机制及执行流程》SpringBoot内置BasicErrorController,自动处理异常并生成HTML/JSON响应,支持自定义错误路径、配置及扩展,如... 目录Spring Boot 异常处理机制详解默认错误页面功能自动异常转换机制错误属性配置选项默认错误处理

Python实现PDF按页分割的技术指南

《Python实现PDF按页分割的技术指南》PDF文件处理是日常工作中的常见需求,特别是当我们需要将大型PDF文档拆分为多个部分时,下面我们就来看看如何使用Python创建一个灵活的PDF分割工具吧... 目录需求分析技术方案工具选择安装依赖完整代码实现使用说明基本用法示例命令输出示例技术亮点实际应用场景扩

java如何实现高并发场景下三级缓存的数据一致性

《java如何实现高并发场景下三级缓存的数据一致性》这篇文章主要为大家详细介绍了java如何实现高并发场景下三级缓存的数据一致性,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 下面代码是一个使用Java和Redisson实现的三级缓存服务,主要功能包括:1.缓存结构:本地缓存:使

C++中detach的作用、使用场景及注意事项

《C++中detach的作用、使用场景及注意事项》关于C++中的detach,它主要涉及多线程编程中的线程管理,理解detach的作用、使用场景以及注意事项,对于写出高效、安全的多线程程序至关重要,下... 目录一、什么是join()?它的作用是什么?类比一下:二、join()的作用总结三、join()怎么

Java Spring的依赖注入理解及@Autowired用法示例详解

《JavaSpring的依赖注入理解及@Autowired用法示例详解》文章介绍了Spring依赖注入(DI)的概念、三种实现方式(构造器、Setter、字段注入),区分了@Autowired(注入... 目录一、什么是依赖注入(DI)?1. 定义2. 举个例子二、依赖注入的几种方式1. 构造器注入(Con

SpringBoot 异常处理/自定义格式校验的问题实例详解

《SpringBoot异常处理/自定义格式校验的问题实例详解》文章探讨SpringBoot中自定义注解校验问题,区分参数级与类级约束触发的异常类型,建议通过@RestControllerAdvice... 目录1. 问题简要描述2. 异常触发1) 参数级别约束2) 类级别约束3. 异常处理1) 字段级别约束

mybatis中resultMap的association及collectio的使用详解

《mybatis中resultMap的association及collectio的使用详解》MyBatis的resultMap定义数据库结果到Java对象的映射规则,包含id、type等属性,子元素需... 目录1.reusltmap的说明2.association的使用3.collection的使用4.总