Browse Source

qq

parseRequest
esoe 2 years ago
parent
commit
4069e1f3fb
  1. 60
      src/main/java/ru/molokoin/InputReader.java
  2. BIN
      target/classes/ru/molokoin/InputReader.class

60
src/main/java/ru/molokoin/InputReader.java

@ -15,7 +15,6 @@ public class InputReader extends Thread{ @@ -15,7 +15,6 @@ public class InputReader extends Thread{
@Override
public void run(){
String line;
StringBuilder header = new StringBuilder();
Boolean f = true;
InputStreamReader isr = new InputStreamReader(connection.in);
@ -24,6 +23,7 @@ public class InputReader extends Thread{ @@ -24,6 +23,7 @@ public class InputReader extends Thread{
while (!isr.ready());//ожидание открытия потока
index++;
System.out.println("Номер запроса: " + index);
StringBuilder header = new StringBuilder();
StringBuilder body = new StringBuilder();
Boolean isHeader = true;
//Boolean isBody = false;
@ -44,41 +44,39 @@ public class InputReader extends Thread{ @@ -44,41 +44,39 @@ public class InputReader extends Thread{
break;
}
//header.append(c);
// //
// line = isr.readLine(); // ждем сообщения с сервера
// if(isHeader){
// if (line != null){
// header.append(line);
// System.out.println("header: " + line);
// }else {
// isHeader = false;
// //isBody = true;
// }
// }
// if(!isHeader){
// if (line != null){
// body.append(line);
// System.out.println("body: " + line);
// }
// }
// /**
// * тут происходит:
// * - анализ поступающих от клиента сообщений
// * - инициация событий (методов), запрошенных клиентом
// */
//
line = isr.readLine(); // ждем сообщения с сервера
if(isHeader){
if (line != null){
header.append(line);
System.out.println("header: " + line);
}else {
isHeader = false;
//isBody = true;
}
}
if(!isHeader){
if (line != null){
body.append(line);
System.out.println("body: " + line);
}
}
/**
* тут происходит:
* - анализ поступающих от клиента сообщений
* - инициация событий (методов), запрошенных клиентом
*/
// if (line.equals("stop")) {
// connection.down(); // харакири
// break; // выходим из цикла если пришло "stop"
// }
// // if (line.equals("stop")) {
// // connection.down(); // харакири
// // break; // выходим из цикла если пришло "stop"
// // }
}
System.out.println(header);
} catch (IOException | NullPointerException e) {

BIN
target/classes/ru/molokoin/InputReader.class

Binary file not shown.
Loading…
Cancel
Save