异步接口是指在请求发送后客户端并不会立即收到响应结果。与同步接口不同异步接口需要等待一段时间后才能得到相应的结果。通常情况下异步接口可以通过消息队列或事件监听器来实现。当用户请求进入系统时可以将任务提交给消费者或监听程序进行处理并异步返回处理结果。1同步调用同步就是调用某个东西时调用方得等待这个调用返回结果才能继续往后执行。它是一种阻塞型的调用方式调用方总是要等到被调用方执行结束或者返回结果后才能继续往下执行它是一种单向的调用只存在调用方调用被调用方的行为。在同步调用模式下接口的调用方会一直等待被调用方返回执行结果除非调用超时。同步调用模式是最常见的接口调用形式。同步就是实时处理典型案例如打电话我们在和一个人进行电话通信的时候打电话是实时的当你说话之后对方立马就能收到并对你做出回应。2异步调用和同步相反调用方不会立刻得到结果而是在调用发出后调用者可用继续执行后续操作被调用者通过状态来通知调用者或者通过回调函数来处理这个调用。在异步调用模式下接口调用方给被调用方发出指令但不会等待结果。一般耗时比较长的处理工作会采用异步调用模式调用方会给被调用方提供一个回调接口意思是“你处理时间比较长等你处理完以后再调用这个回调接口通知我结果吧”异步就是分时处理典型案例如收发短信对方可能会稍等一会才会给你回信。一般我们只能跟一个人进行实时的通话别人打进来会占线而短信则没有这种情况你可以同时接收多条短信并逐步回信。异步调用示例1. 下订单举个简单的例子在电商交易系统中用户成单的时候需要获取非常多的资源除了要获取用户的基本信息、收货地址、商品信息、商品库存、卖家信息还要获取一些优惠、反垃圾信息如果系统是同步调用的那么我们只能够串行等待所有系统的返回如果我们能改成异步通信那么就能同时对多个系统发起查询。2. 支付常用的第三方支付当用户支付完成之后并不是立马接收到到用户的回调而是先给用户返回成功后续再由第三方支付进行回调。3异步单元测试方法一般而言对于那些实时性要求不高但却计算密集或者需要处理大数据量的耗时较长的任务或是有较慢 I/O 的任务选择异步化是一个不错的选择。在系统层面像引入消息中间件来解耦系统将耗时长的任务放在中间件后异步执行。在方法层面像把耗时较长的任务放到其他线程中去异步执行。与测试同步系统或方法不同当我们测试异步系统端到端测试、集成测试或异步方法的时候单元测试由于测试线程不会被异步任务线程阻塞而让测试变得不可控概率性失败以单元测试为例这样写异步测试是不稳定的Test public void testAsynchronousMethod() { callAsynchronousMethod(); assertXXX(...); //异步任务可能仍未完成这时assert可能 会失败 }异步任务的两种类型异步任务执行后对任务发起方或调用方有感知比如发出一个事件或通知;异步任务执行后对任务发起方或调用方没有感知只是改变了系统中的某些状态;对异步任务的测试也分以上两种类型讨论。对于第一种我们可以采用监听方式测试。import org.junit.Before; import org.junit.Test; public class ExampleTest { private final Object lock new Object(); Before public void init() { new Thread(new Runnable() { public void run() { synchronized (lock) { //获得锁 monitorEvent(); //监听异步事件的到来 lock.notifyAll(); //事件到达释放锁 } } }).start(); }Test public void testAsynchronousMethod() { callAsynchronousMethod(); //调用异步方法需要较长一 段时间才能执行完并触发事件通知 /** *事件未到达时由于init已经获得了锁而阻塞事件到达后因 init中的锁释放而获得锁 *此时异步任务已执行完成可以放心的执行断言验证结果了 */ synchronized (lock) { assertTestResult(); } } }这里的前提是事件通知会到来并被监听到可要是不来呢比如异常任务执行失败了我们就干等吗其实我们还可以在测试中引入超时机制这也引出了第二种类型的异常测试可以称之为轮询方式假设我们有如下一个异步系统应用发消息到 NSQ 消息中间件一个待测试的 Job 监听这个消息并在消息到达后处理消息那我们怎么测试呢站在端到端测试的角度可以测试从应用Job 的链路消息是应用直接构造的 NSQ (NSQ是一个基于Go语言的分布式实时消息平台)消息也可以是 MySQL-binlog 经转化后构造的 NSQ 消息站在集成测试的角度我们可以缩小测试范围直接在测试中构造 NSQ 消息测试从消息中间件到 Job 的链路。长链路测试耗时长且写测试前需要了解具体应用的消息触发逻辑写测试也比较慢无形中增加了很多测试成本。所以对于这样的系统我们可以采用集成测试方法来测。Test public void testAsynchronousJob() throws Exception { String msg buildNsqMsg(); //构造NSQ消息 nsqClient.send(TOPIC, msg, false); //发送Nsq消 息 with().pollInterval(ONE_HUNDRED_MILLISECONDS). //100ms后开始检查 and().with().pollDelay(10, MILLISECONDS). //此后每隔10ms检查一次 await(description). //描述信息 atMost(1L, SECONDS). //1s超时时间 until(() - xxxService.getState() changed); //业务相关的断言逻辑 }上述测试我们引入了 awaitility 工具类来做轮询操作一个靠谱的轮询至少包含以下特性超时机制不可能一直轮询首次延迟轮询轮询频率5异步接口测试实战测试案例提交视频异步检测任务业务接口/green/video/asyncscan异步检测视频文件或视频流中是否包含违规内容。支持检测的场景包括视频智能鉴黄、视频暴恐涉政识别、视频图文违规识别、视频不良场景识别、视频logo识别、视频语音违规内容识别。同时检测多个场景的情况下将按照“每个场景的检测视频截帧数量×每个场景的单价”进行累加计费。如果您同时检测视频中的语音违规内容则还将增加“视频时长×语音违规功能的单价”的费用。异步检测结果需要通过调用结果查询接口进行查询具体请参见查询视频异步检测结果或者通过callback的方式进行接收检测结果最多保留4个小时。具体的检测接口调用逻辑如下图所示。测试步骤0. 在线程组下添加用户自定义变量flag值为1 1. 构建提交视频异步检查任务的请求 2. 对该请求添加正则表达式后置处理器提取服务器返回的taskId; 3. 构建查询视频异步检测结果的请求将提取的taskId作为参数发 送 4. 对该请求添加正则表达式后置处理器提取服务器返回的code 5. 对该请求添加JSR223后置处理器代码如下def code vars.get(code) log.info(code is: code) if( code 280){ log.info(检测中...请等30秒后继续查询) Thread.sleep(30000) }else if( code 200){ log.info(检测完成处理结束) vars.put(flag,0) // 停止继续查询 }else if( code.startsWith(4)){ log.info(参数错误请重新提交检查任务) vars.put(flag,0) }else if( code.startsWith(5)){ log.info(服务器错误请线下联系技术人员处理) vars.put(flag,0) }6. 添加while控制器设置条件为 ${__groovy(${flag}1)} 并将3.4.5步骤中的元素按顺序移到while控制器节点下。 程序结构如下图所示