java로 web server만들기 과제(3트)

Question

안녕하세요. java로 web server만드는 과제로 며칠전에도 올렸었는데요..그때 답글로 알려주신 코드로 실행을 해봤는데title의 아이콘 부분만 로딩으로 계속 돌고 멈춰있습니다.디버그로 라인들을 따라가며 확인해봤는데요" int c = in.read(); " 라인 다음부터 break point에서부터 진행하던게 없어지고"The application is running"라고 메시지가 나오고 페이지는 로딩과 함께 멈춥니다.그리고 개발자도구를 확인해보면 response headers가 0으로 찍히는데 무슨 의미인지 모르겠습니다.디버그해도 찍히는게 없어서 뭔가 확인하기도 어려운데 멈추는 원인이 뭔지 알 수 있을까요?아래는 코드입니다.import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.Properties; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.logging.Level; import java.util.logging.Logger; public class HttpServer { private static final Logger logger = Logger.getLogger(HttpServer.class.getCanonicalName()); private static final int NUM_THREADS = 50; private static final String INDEX_FILE = "index.html"; private final File rootDirectory; private final int port; public HttpServer(File rootDirectory, int port) throws IOException { if (!rootDirectory.isDirectory()) { throw new IOException(rootDirectory + " does not exist as a directory"); } this.rootDirectory = rootDirectory; this.port = port; } public void start() throws IOException { ExecutorService pool = Executors.newFixedThreadPool(NUM_THREADS); try (ServerSocket server = new ServerSocket(port)) { logger.info("Accepting connections on port : " + server.getLocalPort()); logger.info("Document Root: " + rootDirectory); while (true) { try { logger.info("Runnable Start "); Socket request = server.accept(); Runnable r = new RequestProcessor(rootDirectory, INDEX_FILE, request); logger.info("Runnable r1 : " + r); pool.submit(r); logger.info("Runnable r2 : " + r); } catch (IOException ex) { logger.log(Level.WARNING, "Error accepting connection", ex); } } } } public static void main(String[] args) throws IOException { // get the Document root Properties properties = new Properties(); InputStream inputStream = new FileInputStream("src/main/resources/info.properties"); properties.load(inputStream); File absolPath; File docRoot; try { absolPath = new File(""); docRoot = new File(absolPath.getAbsolutePath() + properties.getProperty("server.HTTP_DOC_ROOT")); } catch (ArrayIndexOutOfBoundsException ex) { System.out.println("Usage: java JHTTP docroot port : " + ex); return; } // set the port to listen on int port; try { port = Integer.parseInt(properties.getProperty("server.port")); if (port < 0 || port > 65535) port = 80; } catch (RuntimeException ex) { port = 80; } try { HttpServer webserver = new HttpServer(docRoot, port); webserver.start(); } catch (IOException ex) { logger.log(Level.SEVERE, "Server could not start", ex); } } }import java.io.*; import java.net.Socket; import java.net.URLConnection; import java.nio.file.Files; import java.util.Arrays; import java.util.Date; import java.util.Properties; import java.util.logging.Level; import java.util.logging.Logger; public class RequestProcessor implements Runnable { private final static Logger logger = Logger.getLogger(RequestProcessor.class.getCanonicalName()); private File rootDirectory; private String indexFileName = "index.html"; private Socket connection; public RequestProcessor(File rootDirectory, String indexFileName, Socket connection) { if (rootDirectory.isFile()) { throw new IllegalArgumentException( "rootDirectory must be a directory, not a file"); } try { rootDirectory = rootDirectory.getCanonicalFile(); logger.info("rootDirectory : " + rootDirectory); } catch (IOException ex) { } this.rootDirectory = rootDirectory; if (indexFileName != null) this.indexFileName = indexFileName; this.connection = connection; } @Override public void run() { // for security checks String root = rootDirectory.getPath(); logger.info("RequestProcessor Start!!!!!!!"); try { Properties properties = new Properties(); InputStream inputStream = new FileInputStream("src/main/resources/info.properties"); properties.load(inputStream); OutputStream raw = new BufferedOutputStream(connection.getOutputStream()); Writer out = new OutputStreamWriter(raw); Reader in = new InputStreamReader(new BufferedInputStream(connection.getInputStream()), "UTF-8"); StringBuilder requestLine = new StringBuilder(); /* 추가 부분 */ BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); StringBuilder builder = new StringBuilder(); String line = null; while ((line = reader.readLine()) != null) { builder.append(line).append(" "); System.out.println("line : " + line); if (line.toLowerCase().startsWith("host")) { String[] kv = line.split(":"); String host = kv[1]; logger.info("host : " + host); break; } } String headers = builder.toString(); logger.info("headers : " + headers); /* 추가 부분 */ while (true) { int c = in.read(); if (c == ' ' || c == ' ') break; requestLine.append((char) c); } logger.info( "requestLine : " + requestLine); String get = requestLine.toString(); logger.info("connection.getRemoteSocketAddress" + connection.getRemoteSocketAddress() + " " + get); String[] tokens = get.split("\s+"); String method = tokens[0]; String version = ""; if (method.equals("GET")) { String fileName = tokens[1]; if (fileName.endsWith("/")) fileName += indexFileName; String contentType = URLConnection.getFileNameMap().getContentTypeFor(fileName); if (tokens.length > 2) { version = tokens[2]; } File theFile = new File(rootDirectory, fileName.substring(1, fileName.length())); if (theFile.canRead() // Don't let clients outside the document root && theFile.getCanonicalPath().startsWith(root)) { byte[] theData = Files.readAllBytes(theFile.toPath()); if (version.startsWith("HTTP/")) { // send a MIME header sendHeader(out, "HTTP/1.0 200 OK", contentType, theData.length); } // send the file; it may be an image or other binary data // so use the underlying output stream // instead of the writer raw.write(theData); raw.flush(); } else { // can't find the file String body = new StringBuilder(" ") .append("File Not Found ") .append(" ") .append("") .append("

HTTP Error 404: File Not Found

") .append(" ") .toString(); if (version.startsWith("HTTP/")) { // send a MIME header sendHeader(out, "HTTP/1.0 404 File Not Found", "text/html; charset=utf-8", body.length()); } out.write(body); out.flush(); } } else { // method does not equal "GET" String body = new StringBuilder(" ").append("Not Implemented ").append(" ") .append("") .append("

HTTP Error 501: Not Implemented

") .append(" ").toString(); if (version.startsWith("HTTP/")) { // send a MIME header sendHeader(out, "HTTP/1.0 501 Not Implemented", "text/html; charset=utf-8", body.length()); } out.write(body); out.flush(); } } catch (IOException ex) { logger.log(Level.WARNING, "Error talking to " + connection.getRemoteSocketAddress(), ex); } finally { try { connection.close(); } catch (IOException ex) { } } } private void sendHeader(Writer out, String responseCode, String contentType, int length) throws IOException { out.write(responseCode + " "); Date now = new Date(); out.write("Date: " + now + " "); out.write("Server: JHTTP 2.0 "); out.write("Content-length: " + length + " "); out.write("Content-type: " + contentType + " "); out.flush(); } }

뎅이 · Accepted Answer

뭐매... 교체하라고 알려드린걸 그냥 추가를 해 놓으셨네요.connection.getInputStream()은 한번만 호출할 수 있습니다.그리고 GET으로만 처리하니까 body부분은 없고 header 부분만 있을테니Char를 읽는 Reader로 감싼거고요.그래서 첫번째 라인이 Method URI Protocol 부분이니 따로 뗀거고그다음 라인들은 전부 header 들입니다.모든 헤더를 다 읽을건지 host 헤더만 읽을 건지만 결정하시면 되요.그리고 나서 in.read()는 의미 없는 로직인거죠. 이미 커서가 끝까지 갔을테니까요.

java로 web server만들기 과제(3트)

1개의 답변

Q&A 목록