http回调测试自动化实践

内容简介：http回调测试自动化实践

背景：视频云点播支持用户设置回调地址，在上传或者转码结束后向用户的回调地址以http协议发送回调信息，例如上传完成后的视频信息，视频转码信息。 之前的测试方法：回调

背景： 视频 云点播支持用户设置回调地址，在上传或者转码结束后向用户的回调地址以http协议发送回调信息，例如上传完成后的 视频 信息，视频转码信息。

之前的 测试 方法：回调地址设置为 测试 服务器 地址， 自动化 脚本跑的同时去测试 服务器 查看回调信息。

缺点：随着业务扩展，点播依赖服务和NTS集群扩展迅速，每次 回归 量增大，回调测试无法自动化会耗费大量时间，同时，人眼观察回调，当测试代码发送大量请求，回调信息与发送的请求难以一一对应，可能请求后发但是回调先至。

问题的解决方式：

1、在运行测试代码的机器上找到可用端口

2、起HttpServer并监听端口。

3、将起的HttpServer地址设置成点播回调地址

4、HttpServer解析收到的回调信息，并与点播业务发送的请求信息进行断言

5、关闭HttpServer

下面从代码层面逐一实现上面四个步骤

一、找到可用端口：设置从指定端口开始向后遍历，查看端口是否可用。

public static int check（int port） {

int _port;

try {

ServerSocket sock = new ServerSocket（port）；

sock.close（）；

_port = port;

System.out.println（"Port : " + port + " is Ok"）；

} catch （IOException e） {

System.out.println（"Port : " + port + " is occupied ,Try to port : " + （port + 1））；

_port = port + 1;

check（_port）；

}

return _port;

}

再用String addrip = InetAddress.getLocalHost（）。getHostAddress（）；  得到本机IP，这样就可以获得起HttpServer服务需要的地址。

二、起HttpServer并监听端口

public static String callbackHttpServer（int minPort） throws IOException {

int port;

String addrip = InetAddress.getLocalHost（）。getHostAddress（）；

port = check（minPort）；

String ipAddress = addrip + ":" + port;

System.out.println（"address is " + ipAddress）；

InetSocketAddress addr = new InetSocketAddress（port）；

server = HttpServer.create（addr, 0）；

MyHandler myHandler=new MyHandler（）；

server.createContext（"/", myHandler）；

server.setExecutor（Executors.newCachedThreadPool（））；

server.start（）；

System.out.println（"Server is listening on port : " + port）；

return ipAddress;

}

三、解析HttpServer收到的消息

public void handle（HttpExchange exchange） throws IOException {

String requestMethod = exchange.getRequestMethod（）；

if （requestMethod.equalsIgnoreCase（"POST"）） {

Headers responseHeaders = exchange.getResponseHeaders（）；

responseHeaders.set（"Content-Type", "text/plain"）；

exchange.sendResponseHeaders（200, 0）；            //给请求发送方返回200的响应码，否则对方一直收不到响应。

InputStream requestBody = exchange.getRequestBody（）；          //收到的回调信息

Headers requestHeaders = exchange.getRequestHeaders（）；

Set<String> keySet = requestHeaders.keySet（）；

Iterator<String> iter = keySet.iterator（）；           //如需post请求的header信息，则可解析出来

String body = slurp（requestBody, 1024）；          //将InputStream 类型转换为String类型

JsonObject messageBody = new JsonParser（）。parse（body）。getAsJsonObject（）；

reparam=messageBody;

this.setReparam（reparam）；

System.out.println（"request body is >>>>>:" + this.getReparam（））；    //打印出回调请求体的内容

requestBody.close（）；

}

}

四、关闭HttpServer：

收到回调信息或者监听超时还未收到回调信息，则关闭HttpServer服务。

public JsonObject getCallbackBody（）throws IOException, InterruptedException

{

int i=0;

while （true） {

if（MyHandler.getReparam（）！=null||i++>30）

break;

else

TimeUnit.SECONDS.sleep（5）；

}

String type=MyHandler.judgeCallbackType（MyHandler.getReparam（））；

System.out.println（"type is "+type）；

JsonObject param=MyHandler.getReparam（）；

System.out.println（"jsonObject is : "+param.toString（））；

MyHttpServer.stopHttpServer（）；

System.out.println（"listen service is closed "）；

return param;

}

}

总结：如上即实现了http回调信息的解析及自动化，在应用中，需要保证起HttpServer的地址业务服务器可以telnet通，否则，业务服务器发送过去的post请求会被拒绝。

原文转自： http://qa.blog.163.com/blog/static/190147002201732491154667/

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

• [OC] 关于block回调、高阶函数“回调再调用”及项目实践
• 即使回调IsOneWay,WCF客户端也会因回调而死锁
• Java 回调机制解读
• 如何避免回调地狱
• 如何使用JPA回调?
• callback回调函数-python

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。