Java - распознавание отправленных сообщений и отправленных сообщений с сервера на стороне клиента

Question

Я работаю над серверным/клиентским приложением, которое позволяет подключать несколько клиентов к серверу в любой момент времени. Для каждого клиента сервер устанавливает объект ClientHandler, который имеет входной и выходной поток для клиента, подключенного к этому сокету. Благодаря этому соединению клиент может отправлять несколько сообщений на сервер в любой момент на протяжении всей программы, и сервер будет отвечать в соответствии с сообщением.

Что мне нужно реализовать - это механизм, который отправляет в определенные моменты сообщения всем клиентам, подключенным в настоящее время. Я сделал это, сохранив все выходные потоки для клиентов в ArrayList<PrintWriter>, которые позволят отправлять одно и то же сообщение всем клиентам.

То, что я борюсь с таким:

Когда сообщение получено, что является индивидуальным для клиента, GUI клиента обновляются соответствующим образом (только определенное число сообщений может быть отправлено, так что только избранной количество возможных ответов от сервера, которые рассматриваются с помощью клиентских инструкций if). Однако, когда сообщение получено клиентом, который был отправлен всем клиентам, я хотел бы, чтобы клиент обновил GUI совершенно по-другому.

Учитывая, что обе формы ввода поступают из одного входного потока, я вижу, что это трудно, и я ожидаю, что мне придется объявлять любые методы, которые вызывают вывод с использованием , должны быть сделаны . Однако есть ли способ обработки разных входов при использовании того же PrintWriter? Должно ли это быть сделано с использованием дополнительных операторов if или это можно сделать с помощью отдельного Thread на стороне клиента, который обрабатывает сообщения, отправленные всем клиентам?

Спасибо за любой совет, если вы считаете, что можете помочь, не стесняйтесь просить части моего существующего кода!

Марк

Answer 1

 When your clients connect to the server, your server creates a Socket for it, here it is Socket socket = ss.accept();, your socket variable will be holding that client. 

теперь, если вы просто держать добавление клиентского сокета к ArrayList в ваше время цикл, вы будете иметь список клиентов, активно связанных с вашим сервером, как:

после акцепта:

clients = new ArrayList<DataOutputStream>(); 
    Socket socket = ss.accept(); 
    os = new DataOutputStream(socket.getOutputStream()); 
    clients.add(os); 

Теперь, когда у вас есть все клиенты в том, что клиенты ArrayList, вы можете цикл через него, или с некоторым протоколом определите, с каким клиентом я должен отправить d ata после чтения.

Answer 2

Вы в первую очередь не хватает протокола между сервером и вашим клиентам!

Очевидно, что сервер может отправлять два типа сообщений «ответ» и «трансляция». Довольно простой подход - это пометка ваших сообщений: например. префикс ваших сообщений с помощью «R», если это ответ на запрос и с «B», если это сообщение автоматической трансляции. (Это все зависит от того, как должна выполняться связь между сервером и клиентами.)

Независимо от того, нужен ли вашему клиенту разные темы для обработки сообщений, это совершенно другая история. Наличие разных потоков полезно, если активность обработки внутри вашего клиента будет препятствовать своевременному считыванию сокета. Тогда вы можете подумать о том, что поток ввода-вывода, который выполняет связь, и отправляет сообщения различным «обработчикам» (может быть другим потокам) для обработки. (Этот поток ввода-вывода также может удалить тег таким образом, что существующий код обработки не должен знать о нижнем протоколе с сервером.)

Аналогичная аргументация может быть применима к вашей стороне сервера. В зависимости от динамики взаимодействия и обработки запросов вы можете использовать несколько потоков.Тогда вы должны иметь один, который делает ввод/вывод с клиентами и другими, которые делают работу (генерирующие ответы или широковещательные сообщения)