mindol1004/excel-download
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

#19 was : multi thread

Browse Source
This commit is contained in:
haerong22
2022-09-02 02:35:43 +09:00
parent 1295814dba
commit e665a970b5
2 changed files with 53 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
my-framework/was-practice/src/main/java/org/example/ClientRequestHandler.java Normal file
View File

@@ -0,0 +1,51 @@
package org.example;
import org.example.calculator.domain.Calculator;
import org.example.calculator.domain.PositiveNumber;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.*;
import java.net.Socket;
import java.nio.charset.StandardCharsets;
public class ClientRequestHandler implements Runnable {
private static final Logger logger = LoggerFactory.getLogger(ClientRequestHandler.class);
private final Socket clientSocket;
public ClientRequestHandler(Socket clientSocket) {
this.clientSocket = clientSocket;
}
@Override
public void run() {
logger.info("[ClientRequestHandler] new client {} started.", Thread.currentThread().getName());
try (InputStream in = clientSocket.getInputStream(); OutputStream out = clientSocket.getOutputStream()) {
BufferedReader br = new BufferedReader(new InputStreamReader(in, StandardCharsets.UTF_8));
DataOutputStream dos = new DataOutputStream(out);
HttpRequest httpRequest = new HttpRequest(br);
if (httpRequest.isGetRequest() && httpRequest.matchPath("/calculate")) {
QueryStrings queryStrings = httpRequest.getQueryStrings();
int operand1 = Integer.parseInt(queryStrings.getValue("operand1"));
String operator = queryStrings.getValue("operator");
int operand2 = Integer.parseInt(queryStrings.getValue("operand2"));
int result = Calculator.calculate(new PositiveNumber(operand1), operator, new PositiveNumber(operand2));
byte[] body = String.valueOf(result).getBytes();
HttpResponse response = new HttpResponse(dos);
response.response200Header("application/json", body.length);
response.responseBody(body);
}
} catch (IOException e) {
logger.error(e.getMessage());
}
}
}

24
my-framework/was-practice/src/main/java/org/example/CustomWebApplicationServer.java
View File

@@ -31,30 +31,10 @@ public class CustomWebApplicationServer {
logger.info("[CustomWebApplicationServer] client connected!");
/**
* Step1 - 사용자 요청을 메인 Thread 가 처리하도록 한다.
* Step2 - 사용자 요청이 들어올 때마다 Thread 를 새로 생성해서 사용자 요청을 처리하도록 한다.
*/
try (InputStream in = clientSocket.getInputStream(); OutputStream out = clientSocket.getOutputStream()) {
BufferedReader br = new BufferedReader(new InputStreamReader(in, StandardCharsets.UTF_8));
DataOutputStream dos = new DataOutputStream(out);
HttpRequest httpRequest = new HttpRequest(br);
if (httpRequest.isGetRequest() && httpRequest.matchPath("/calculate")) {
QueryStrings queryStrings = httpRequest.getQueryStrings();
int operand1 = Integer.parseInt(queryStrings.getValue("operand1"));
String operator = queryStrings.getValue("operator");
int operand2 = Integer.parseInt(queryStrings.getValue("operand2"));
int result = Calculator.calculate(new PositiveNumber(operand1), operator, new PositiveNumber(operand2));
byte[] body = String.valueOf(result).getBytes();
HttpResponse response = new HttpResponse(dos);
response.response200Header("application/json", body.length);
response.responseBody(body);
}
}
new Thread(new ClientRequestHandler(clientSocket)).start();
}
}
}