背景：
视频云点播支持用户设置回调地址，在上传或者转码结束后向用户的回调地址以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
keySet = requestHeaders.keySet();
Iterator
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();
}
}
