Оптимизация многопоточного сервера Java, использующего inputstreamreader ⇐ JAVA

[Anonymous]

В настоящее время я работаю над проектом, в котором мне нужно разместить сервер, который получает входной поток, анализирует данные и отправляет их в базу данных. Каждый клиент, который подключается к моему серверу, отправляет входной поток, который никогда не останавливается после подключения. Каждому клиенту назначается сокет и собственный объект потока синтаксического анализатора, чтобы сервер мог обрабатывать поток данных, поступающий от клиента. Объект парсера просто обрабатывает входящие данные и отправляет их в базу данных.
Сервер/генератор синтаксического анализатора:

Код: Выделить всё

public void generateParsers() {
while (keepRunning) {
try {
Socket socket = s.accept();
// new connection
t = new Thread(new Parser(socket));
t.start();
} catch (IOException e) {
appLog.severe(e.getMessage());
}
}
}

Последовательность парсера:

Код: Выделить всё

   @Override
public void run() {
while (!socket.isClosed() && socket.isConnected()) {
try {
BufferedReader bufReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line = bufReader.readLine();
String data = "";
if (line == null) {
socket.close();
} else if (Objects.equals(line, "

Подробнее здесь: [url]https://stackoverflow.com/questions/41985040/optimizing-a-java-multithreaded-server-that-uses-an-inputstreamreader[/url]