Многопоточный Java-клиент TCP

Question

Я пишу клиентское приложение Java (базовый пакет Java Net с TCP/IP). Клиент должен принимать входные данные из system.in и в то же время должен слушать любые сообщения, поступающие с сервера через вход сокетов. После того, как будет получен вход из системы system.in, клиент получит этот ввод, выполнит некоторую обработку и отправит его на сервер в качестве запроса. Поэтому в основном 2 процессы выполняются,

-Прослушивание по запросу клиента

-listning для ответов сервера.

Я реализовал 2 потока для этого и управлял обработкой сообщений в основной теме. Это достаточно хороший дизайн.?

И есть способ вернуть сообщение, полученное от system.in в основной поток. Метод thread run() возвращает void. Я использовал переменную volatile, чтобы вернуть полученную строку, но ее сказали, что volatile очень дорогостоящий, поскольку он не использует кеш процессора для хранения переменной.

Answer 1

Вы можете просмотреть эти два проекта, которые я написал для примера сокетов Java и многопоточности.

• Client
• Server

Я предполагаю, что ClientExample это один вы searcing для но вы посмотрите на серверной части может тоже.

В принципе идея состоит в том, чтобы запустить два отдельных потока, которые прослушивают разные входы - разъем и консоль.

final Thread outThread = new Thread() { 
    @Override 
    public void run() { 
     System.out.println("Started..."); 
     PrintWriter out = null; 
     Scanner sysIn = new Scanner(System.in); 
     try { 
      out = new PrintWriter(socket.getOutputStream()); 
      out.println(name); 
      out.flush(); 

      while (sysIn.hasNext() && !isFinished.get()) { 
       String line = sysIn.nextLine(); 
       if ("exit".equals(line)) { 
        synchronized (isFinished) { 
         isFinished.set(true); 
        } 
       } 
       out.println(line); 
       out.flush(); 
       disconnect(); 
      } 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } finally { 
      if (out != null) { 
       out.close(); 
      } 
     } 
    }; 
}; 
outThread.start(); 

и другой поток для ввода сокета:

 final Thread inThread = new Thread() { 
      @Override 
      public void run() { 
       // Use a Scanner to read from the remote server 

       Scanner in = null; 
       try { 
        in = new Scanner(socket.getInputStream()); 
        String line = in.nextLine(); 
        while (!isFinished.get()) { 
         System.out.println(line); 
         line = in.nextLine(); 
        } 
       } catch (Exception e) { 
//     e.printStackTrace(); 
       } finally { 
        if (in != null) { 
         in.close(); 
        } 
       } 
      }; 
     }; 
     inThread.start(); 

Я надеюсь, что это поможет :)