2

キープアライブ接続を提供できる Java で http サーバーを作成しようとしています。私は com.sun.net.httpserver.HttpServer クラスを使用しています。

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;

import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;

public class httpHandler implements HttpHandler {

private String resp = "<?xml version='1.0'?><root-node></root-node>";

private OutputStream os = null;

public void handle(HttpExchange t) throws IOException {
    System.out.println("Handling message...");
    java.io.InputStream is = t.getRequestBody();

    System.out.println("Got request body. Reading request body...");
    byte[] b = new byte[500];
    is.read(b);
    System.out.println("This is the request: " + new String(b));

    String response = resp;
    Headers header = t.getResponseHeaders();
    header.add("Connection", "Keep-Alive");
    header.add("Keep-Alive", "timeout=14 max=100");
    header.add("Content-Type", "application/soap+xml");
    t.sendResponseHeaders(200, response.length());

    if(os == null) {
        os = t.getResponseBody();
    }

    os.write(response.getBytes());

    System.out.println("Done with exchange. Closing connection");
    os.close();
}

public static void main(String[] args) {
    HttpServer server = null;
    try {
        server = HttpServer.create(new InetSocketAddress(8080), 5);
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    server.createContext("/", new httpHandler());
    server.setExecutor(null); // creates a default executor
    System.out.println("Starting server...");
    server.start();
}
}

クライアントは接続を閉じません。サーバーは、交換が発生した直後にそれを閉じているようです。os.close 行を削除しようとしましたが、サーバーは 2 番目の要求に応答しません。しかし、それも閉じません。サーバーオブジェクトを使用してメインコードで何かを行う必要があると感じていますが、何がわかりません。グーグルもあまり伸びていない。

ここに誰かアイデアがありますか？どんな助けでも大歓迎です。

4

4 に答える 4

3

問題は、リクエストからすべてのデータを排出しなかったことにあるようです。is.read()-1が返るまでやり続けてから閉じてください。

リクエストを排出しなかったため、まだバイトが残っています。サーバーは単純に次のリクエストに「ジャンプ」することはできません。ディスクではなく、テープのようなものです。サーバーは、次のリクエストに到達する前に、現在のリクエストからすべてのデータを読み取る (および破棄する) 必要があります。

制限なしで、これを使用してサーバーを攻撃できます。そのため、サーバーは制限 (デフォルトでは 64K) までしか排出を試みません。64K を超えるリクエストを受け取っている可能性があります。

通常、ハンドラーは最初にリクエスト全体を読み取る必要があります。そうでなければ、どのようにしてリクエストを処理するかを知ることができますか?

さらに深刻なことに、リクエストが最初に排出されないと、デッドロックが発生する可能性があります。通常、クライアントは単純です。リクエストを書き込んでから、レスポンスを読み取ります。サーバーがすべての要求を読み取る前に応答を書き込んだ場合、クライアントはまだ要求を書き込んでいる可能性があります。どちらもお互いに書き込みを行っていますが、どちらも読み取りを行っていません。バッファがいっぱいの場合、デッドロック状態になり、両方とも書き込み時にブロックされます。write() にはタイムアウトがないことに注意してください!

于 2011-06-29T02:40:14.123 に答える
1

電話をかけてみてくださいt.close()、サーバーは応答します

于 2011-09-21T15:25:16.917 に答える
1

以前が null の場合にのみ ResponseBody OutputStream を取得するのはなぜですか?

if(os == null) {
    os = t.getResponseBody();
}

前のものが現在の Request のものと同一であるかどうかわからないため、毎回 OutputStream を取得する方がよい場合があります。

于 2012-07-20T13:18:47.203 に答える
0

キープアライブヘッダーを送信するのはクライアントです。その場合、HttpServerは接続を閉じません。あなたはそれについて何もする必要はありません。

于 2011-06-29T01:12:43.733 に答える