如何解决HttpClient和HttpServer之间通信的Java问题
这是我在这里的第一个问题,所以我很抱歉,如果不是所有需要的信息都在这篇文章中。
java.net.http.HttpClient和HttpServer之间的通信出现问题。 我将请求从带有HttpClient的应用程序发送到带有Httpserver的应用程序,稍后再读取,根据消息中的信息发送邮件,然后通过HttpClient向应用程序发送响应,如果一切正常,或者如果出现问题,则失败。
前几次(通常是随机的,有时是2个,有时是24个)通常由Server正确发送并正确处理,这导致httpClient收到响应“成功”,但是突然间Server收到了带有正确头但没有正文的请求,即使它在请求中始终是同一条消息,从而导致“失败”响应。
我的HttpClient:
private Boolean sendMail(String requestBody) throws IOException,InterruptedException {
HttpClient client = HttpClient.newBuilder()
.version(HttpClient.Version.HTTP_1_1)
.cookieHandler(CookieHandler.getDefault())
.build();
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create(this.uri))
.header("Content-Type","application/json")
.POST(HttpRequest.BodyPublishers.ofString(requestBody))
.build();
//creating response body handler
HttpResponse.BodyHandler<String> bodyHandler = HttpResponse.BodyHandlers.ofString();
HttpResponse<String> response = client
.send(request,bodyHandler);
String requestOutcome = response.body();
System.out.println(requestOutcome);
我的HttpServer:
HttpServer server = HttpServer.create(new InetSocketAddress(port),0);
ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);
server.createContext("/mial",new ServerHttpHandler(this.dbHandler,this.mailHandler));
server.setExecutor(threadPoolExecutor);
//Start HttpServer
server.start();
我的自定义ServerHttpHandler:
public void handle(HttpExchange httpExchange) throws IOException {
String requestParamValue=null;
if("GET".equals(httpExchange.getRequestMethod())) {
requestParamValue = handleGetRequest(httpExchange);
}else if("POST".equals(httpExchange.getRequestMethod())) {
requestParamValue = handlePostRequest(httpExchange);
}
handleResponse(httpExchange,requestParamValue);
}
private String handleGetRequest(HttpExchange httpExchange) {
return httpExchange.
getRequestURI()
.toString()
.split("\\?")[1]
.split("=")[1];
}
private String handlePostRequest(HttpExchange httpExchange){
// get request
Headers reqHeaders = httpExchange.getRequestHeaders();
reqHeaders.forEach((key,value) -> System.out.println(key + ": " + value));
String message = null;
try (InputStream in = httpExchange.getRequestBody()) {
BufferedReader br = new BufferedReader(new InputStreamReader(in));
StringBuilder msgbuilder = new StringBuilder();
while (br.ready()) {
msgbuilder.append((char) br.read());
}
message = msgbuilder.toString();
System.out.println("Message: " + message);
br.close();
} catch (IOException e) {
e.printstacktrace();
}
return message;
}
private void handleResponse(HttpExchange httpExchange,String requestParamValue) throws IOException {
boolean success = this.convertMsgAndSendMail(requestParamValue);
String htmlResponse = "failure";
if(success) {
htmlResponse = "success";
}
httpExchange.sendResponseHeaders(200,htmlResponse.length());
OutputStream outputStream = httpExchange.getResponseBody();
outputStream.write(htmlResponse.getBytes());
outputStream.flush();
outputStream.close();
}
错误的请求:
Connection: [Upgrade,HTTP1_1-Settings]
Http2-settings: [AAEAAEAAAAIAAAABAAMAAABkAAQBAAAAAAUAAEAA]
Host: [localhost:587]
Upgrade: [h2c]
User-agent: [Java-http-client/11.0.6]
Content-type: [application/json]
Content-length: [180]
Message:
因此标题每次都是相同的,但是这次我没有收到任何消息。而且,由于该消息后来被转换为JSON,所以我得到的唯一错误是该消息不是以“ {”开头,因此它不是Json兼容的。
我在StackOverflow和其他站点上搜索了此问题的解决方案,但没有找到任何有用的技巧来解决此问题。你有什么主意吗?
解决方法
这里有几个错误:
- 在将字节转换为字符时(反之),您实际上应该始终指定一个字符集;这不是您的主要问题所在,但您应该考虑一下。
- 您的while循环错误。
您有:
while (br.ready()) {
msgbuilder.append((char) br.read());
}
它的作用是,如果没有立即可用的字符,它将停止读取;您想要的是在没有更多要阅读的字符时停止阅读。这应该是这样的:
int c;
while ((c = br.read()) > -1) {
msgbuilder.append((char) c);
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。