4

マルチスレッドの Java Web サーバーを実装しようとしています。

これが私のメインです：

import java.net.*;

public class Main {
    public static void main(String argv[]) throws Exception{

        ServerSocket welcomeSocket = new ServerSocket(6790);
        while(true){
            System.out.println("Waiting...");
            Socket cSock = welcomeSocket.accept();
            System.out.println("Accepted connection : " + cSock);

            Server a = new Server(cSock);
            a.start();


        }
    }
}

ここに私のスレッドクラスがあります:

import java.io.*;
import java.net.*;
import java.util.Scanner;


public class Server extends Thread{
    Socket cSock;

    Server(Socket cSock){   //constructor
        this.cSock = cSock;
    }

    public void run(){
        try{
            String request;
            Scanner inFromClient = new Scanner(cSock.getInputStream());
            DataOutputStream outToClient = new DataOutputStream(cSock.getOutputStream());
            request = inFromClient.nextLine();
            System.out.println("Received: "+request);

            //trimming URL to extract file name
            String reqMeth = request.substring(0, 3);
            String reqURL = request.substring(5, (request.lastIndexOf("HTTP/1.1")));
            String reqProto = request.substring(request.indexOf("HTTP/1.1"));
            System.out.println("Request Method:\t" +reqMeth +"\nRequest URL:\t" +reqURL+ "\nRequest Protocol: " +reqProto);

            //passing file name to open
            File localFile = new File(reqURL.trim());
            byte [] mybytearray  = new byte [(int)localFile.length()];
            FileInputStream fis = new FileInputStream(localFile);
            BufferedInputStream bis = new BufferedInputStream(fis);
            bis.read(mybytearray,0,mybytearray.length);

            //sending file to stream
            System.out.println("Sending...");           
            outToClient.write(mybytearray,0,mybytearray.length);
            outToClient.flush();
            outToClient.close();

        }catch(Exception e){
            System.out.println(e);
        }
    }
}

ロジックにより、サーバーが取得するリクエストごとに、新しいスレッドが作成されます。各スレッドは特定のリクエストに関連付けられています。私の問題は、ファイル (例: index.html) を要求すると、サーバーが要求を取得しますが、ファイルが読み込まれず、ブラウザーが読み込みを続けることです。

各スレッドが開始されていることがわかりましたが、完了していません。

ここに出力があります：

Waiting...
Accepted connection : Socket[addr=/192.168.0.10,port=58957,localport=6790]
Waiting...
Accepted connection : Socket[addr=/192.168.0.10,port=58958,localport=6790]
Waiting...
Received: GET /html/index.html HTTP/1.1
Request Method: GET
Request URL:    html/index.html 
Request Protocol: HTTP/1.1
Accepted connection : Socket[addr=/192.168.0.10,port=59093,localport=6790]
Waiting...
Received: GET /index.html HTTP/1.1
Request Method: GET
Request URL:    index.html 
Request Protocol: HTTP/1.1

私は何を間違っていますか？より良い方法はありますか？1つのIPからのリクエストをテストするために1つのスレッドのみを実行したことに注意してください。これが解決されると、ビルドされます。

4

3 に答える 3

2

HTTP ヘッダーを作成することはありません。

outToClient.write("HTTP/1.0 200 OK\r\n");
outToClient.write("Connection: Close\r\n");
outToClient.write("\r\n");
outToClient.write(mybytearray,0,mybytearray.length);

独自のサーバーを実装する場合は、RFC 2616を読む必要があります。

于 2013-03-06T13:29:43.063 に答える
1

ブラウザを使用してサーバーに接続する場合は、ヘッダー付きの HTTP 応答を返す必要があります。 HTTP サーバーの簡単な例を次に示します。または、この回答済みの質問をよく見てください。

于 2013-03-06T13:31:14.480 に答える