один сервер нескольких клиентов

Question

Я участие следующих проблем:

1. мне нужно написать программу сервера, будет принимать несколько клиентов
2. всех клиентов подписываются одни и те же данные с сервера, например, цена акций Обновить.
3. каждый клиент может посылать простые команды на сервер, как «вход», «стоп»

Так вот мое решение, так как я не очень Произошел в многопоточном/TCP, я хочу знать, это хорошо решение? если нет, есть ли лучшее решение? нужно ли иметь поток для каждого клиентского сокета? Спасибо BTW: извините за запутывание каждого, это небольшой проект, который включает только 5-10 классов.

class AcceptThread { 
    ...... 
    public void run() { 
     ControlThread controlThread = new ControlThread(); 
     controlThread.start(); 

     Socket socket = new Socket(port); 
     while (!stop) { 
      Socket s = socket.accept(); 
      controlThread.addClient (s); 
     } 
    } 
} 

class ControlThread { 
    Set<Scoket> clients; 
    SendDataThread sendDataThread; 

    public ControlThread() { 
     sendDataThread = new SendDataThread(); 
     sendDataThread.start();  
    } 

    public void addClient (Socket socket) { 
     clients.add(socket); 
     sendDataThread.addListener(socket); 
    } 

    public void run() { 
     ...... 
     for (Socket s : clients) { 
      if (s.getInputStream().available()) { 
       //read command from s 
      } 
     } 
     ......    
    } 
} 

class SendDataThread() { 
    Set<Scoket> listeners; 

    public void addListener (Socket s) { 
     listeners.add(s); 
    } 

    public void run() { 
     for (Socket s: listeners) { 
      // send data to each listener 
     } 
    } 
} 

Answer 1

является необходимым иметь резьбу для каждого сокета клиента?

Нет, по сути, я бы даже не рекомендовал его. Если это небольшой проект, и вы не хотите использовать какую-либо существующую библиотеку, я предлагаю вам использовать java.nio package и SelectableChannels. С помощью так называемого селектора вы можете легко контролировать клиентов для входящих данных неблокирующим способом.

Вот несколько полезных ссылок:

• NIO Examples (from the official tutorial)
• The Rox Java NIO Tutorial

Answer 2

Что об использовании технологии стандартов для решения этой проблемы?

JMS тема механизм распределения для публикации сообщений, которые доставляются несколько абонентов.

Tutorial

Answer 3

Спасибо BTW: извините за путаницу каждый, это небольшой проект, который включает только 5-10 классов.

В этом нет ничего страшного. Все абстракции верхнего уровня основаны на сокетах так или иначе. Если ваш проект достаточно велик, нет необходимости тянуть серию других рамок/инструментария для выполнения той же работы. Нитки дешевы (и могут даже выиграть от многоядерной архитектуры), хотя использование SelectableChannels в качестве предложенного @aioobe тоже неплохая идея.

Когда ваши проекты требуют этого, вы всегда можете узнать о других методах коммуникации между процессами (передача сообщений, удаленный метод invocaton и т. Д. И около 100 реализаций).

Однако вы можете ограничить количество потоков, используемых сервером одновременно. Это может быть легко достигнуто путем утверждения, например, семафора размера, равного количеству потоков, которые вы хотите обслуживать.Еще одна интересная вещь - использовать java thread pools, чтобы лучше использовать ресурсы.

Answer 4

Другие упомянули, что вы можете использовать библиотеку nio для уменьшения количества необходимых потоков. я просто хотел указать, что ваш текущий примерный код не будет работать. вы должны использовать при использовании стандартных потоков io. метод available() практически бесполезен (в общем) и не остановит ваш поток управления от блокировки.