【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秒//...           }}

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

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

微信小程序-day01

文章目录 前言微信小程序介绍 一、为什么要学习微信小程序?二、微信小程序的历史创建开发环境1.注册账号2.获取APPID 三、下载微信开发者工具1.创建微信小程序项目2.填写相关信息3.项目创建成功 四、小程序目录结构项目的主体组成结构 总结 前言 微信小程序介绍 微信小程序&…

新 树莓派4B 温湿度监测 基于debian12的树莓派OS

前言 本文旨在完成通过外接温湿度传感器至树莓派使得树莓派不断记录并存储温湿度数据 这个领域有很多文章&#xff0c;但是部分文章已经缺乏了时效性&#xff0c;在最新系统不适用&#xff0c;本文目前适用 硬件 硬件连接 温湿度传感器常选用DHT11和DHT22&#xff0c;淘宝…

每日OJ题_哈希表③_力扣217. 存在重复元素

目录 力扣217. 存在重复元素 解析代码 力扣217. 存在重复元素 217. 存在重复元素 难度 简单 给你一个整数数组 nums 。如果任一值在数组中出现 至少两次 &#xff0c;返回 true &#xff1b;如果数组中每个元素互不相同&#xff0c;返回 false 。 示例 1&#xff1a; 输…

私域流量运营的关键要素和基本步骤

解锁增长的四大关键&#xff1a; 关键要素一&#xff1a;精准营销 精准营销是私域流量运营的核心所在。通过精细化运营和个性化服务&#xff0c;企业可以将普通用户转化为忠实粉丝&#xff0c;提高用户的粘性和转化率。采用数据驱动的精准营销策略&#xff0c;深度挖掘用户需求…

26-5 SQL 注入攻击 - 利用dnslog带回回显信息范例

这篇文章是属于安全渗透的文章,选错专栏了,平台的机制不允许我再改,只能这样了,要学习python脚本的读者可以直接忽略这篇文章。 很抱歉我问了客服客服也没法解决。。 环境准备:构建完善的安全渗透测试环境:推荐工具、资源和下载链接_渗透测试靶机下载-CSDN博客 26-3 SQ…

Linux内核基础 - GICv3中断控制器常用寄存器描述

GICv3 寄存器概述 GICv3&#xff08;通用中断控制器版本3&#xff09;为ARM架构提供了一套先进的中断管理框架。它针对大型系统支持、高效虚拟化和增强的中断分发机制引入了改进。以下是标准寄存器、它们的地址偏移以及常见用途或功能的概述。 技术背景 GICv3 是为了满足现代…

HelpLook AI 升级!一键生成SEO设置关键要素

| 现代SEO营销为何选择与AI同行 众多企业面临SEO优化日趋复杂的挑战&#xff0c;投入的时间和资源不断攀升。然而&#xff0c;HelpLook利用AI技术&#xff0c;一键完成SEO关键词和描述的生成&#xff0c;无需额外付费或繁琐操作&#xff0c;轻松提升网站曝光和点击率&#xff…

Android 学习之追踪应用的安装情况

先上结论&#xff0c;急用的话直接看结论 结论一、借助 API 读取安装信息&#xff0c;然后上报二、借助手动埋点&#xff0c;然后上报三、对比 前提过程 结论 一、借助 API 读取安装信息&#xff0c;然后上报 通过 PackageManager 的 API&#xff0c;我们可以得知自身应用安装…

C语言代码 转换以下ASCII码为对应字符并输出它们,73,32,99,97,110,32,100,111,32,105,116,33

转换以下ASCII码为对应字符并输出它们&#xff0c; 73,32,99,97,110,32,100,111,32,105,116,33 代码示例&#xff1a; #include <stdio.h>int main() {int arr[] { 73,32,99,97,110,32,100,111,32,105,116,33 };int i 0;int sz sizeof(arr) / sizeof(arr[0]);whil…

【SSM】任务列表案例 基本CRUD SSM整合

文章目录 一、案例功能预览二、接口分析三、前端工程导入四、后端程序实现和测试4.1 准备4.2 功能实现4.2.1 分页查询显示4.2.2 添加计划4.2.2 删除计划4.2.3 修改计划 4.3 前后联调 一、案例功能预览 Github 地址 &#xff1a; ssm-integration-part 二、接口分析 学习计划…

【话题】2024年AI辅助研发趋势,有那些应用领域

大家好&#xff0c;我是全栈小5&#xff0c;欢迎阅读文章&#xff01; 此篇是【话题达人】系列文章&#xff0c;这一次的话题是《2024年AI辅助研发趋势》 目录 背景概念实践医药领域汽车设计领域展望未来文章推荐 背景 随着人工智能技术的持续发展与突破&#xff0c;2024年AI辅…

postman学习

一、如何学习postman工具 1、下载和安装 Postman&#xff1a; 首先&#xff0c;从 Postman 官方网站&#xff08;https://www.postman.com&#xff09;下载并安装 Postman 应用程序。 2、了解基本概念&#xff1a; 在开始学习之前&#xff0c;了解一些基本概念&#xff0c;…

BI数据分析案例详解:零售人货场分析该怎么做?

在当今快节奏、高竞争的商业环境中&#xff0c;人货场分析已成为企业成功的关键因素之一。科技的进步和数据的日益丰富使得企业对人流、货物流和场地布局的深入洞察变得愈发重要。通过科学的人货场分析&#xff0c;企业能更好地理解顾客行为、优化供应链、提高运营效率&#xf…

【wine】WINEDEBUG 分析mame模拟器不能加载roms下面的游戏 可以调整参数,快速启动其中一个游戏kof98

故障现象&#xff0c;MAME启动后&#xff0c;游戏都没有识别 添加日志输出&#xff0c;重新启动wine #!/bin/bashexport WINEPREFIX$(pwd)/.wine export WINESERVER$(pwd)/bin/wineserver export WINELOADER$(pwd)/bin/wine export WINEDEBUG"file,mame,warn,err"…

加速渲染:Blender与在线渲染农场的结合

​在数字艺术和三维设计的世界里&#xff0c;Blender软件因其强大的功能和灵活性而广受欢迎。然而&#xff0c;随着项目复杂性的增加&#xff0c;渲染时间也随之增长&#xff0c;成为艺术家和设计师面临的一大挑战。在线渲染农场的出现&#xff0c;为这一问题提供了革命性的解决…

C语言例:(m=a==b)||(n=a==b);求解m,n的值

题目&#xff1a;设int a0,b0,m0,n0;执行语句(mab)||(nab);求解m,n的值。 #include<stdio.h> int main(void) {int a0,b0,m0,n0;(mab)||(nab);printf("m%d\n",m);printf("n%d\n",n);return 0; } 优先级: () 优先 优先 a b -->为真&am…

python字符串转换成字典

1、使用eval()函数将字符串转换为字典: string ‘{“name”: “Alice”, “age”: 25}’ dictionary eval(string) 2、使用json模块的loads()函数将字符串转换为字典: import json string ‘{“name”: “Alice”, “age”: 25}’ dictionary json.loads(string) 3、使…

UVC框架下USB摄像头驱动之设置属性

1. 在视频驱动程序中设置属性主要涉及3个ioctl &#xff1a; VIDIOC_QUERYCTRL VIDIOC_G_CTRL VIDIOC_S_CTRL 2. 硬件上怎么设置属性呢&#xff1f; 2.1 UVC规划定义了那些属性&#xff1a;定义在uvc_ctrl.c里面的数组 static struct uvc_control_info uvc_ctrls[] {{.enti…

Crash Course Computer Science1

Hello world, Im Carrie Anne, and welcome to Crash Course Computer Science! Hello world&#xff01;我是 Carrie Anne&#xff0c;欢迎收看计算机科学速成课&#xff01; Over the course of this series, were going to go from bits, bytes, transistors and logic gat…

【软件测试面试】银行项目测试面试题+答案(二)

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 面试题&#xff1…