2

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

Загвоздка в том, что он является последовательным, иными словами сокет занят одним клиентом и остальные должны дождаться окончания. На форумах нет примеров с обработкой нескольких клиентов одновременно, использующих библиотеку concurrent.

Привожу код клиента и сервера:

Server:

public class Server {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        int port = 6666; //мой некий порт
        try {
            ServerSocket ss = new ServerSocket(port); // создаем сокет сервера и привязываем его к вышеуказанному порту
            System.out.println("Ожидание клиента");

            Socket socket = ss.accept(); // заставляем сервер ждать подключений и выводим сообщение когда кто-то связался с сервером
            System.out.println("Клиент подключился");
            System.out.println();

            // Берем входной и выходной потоки сокета, теперь можем получать и отсылать данные клиенту. 
            InputStream sin = socket.getInputStream();
            OutputStream sout = socket.getOutputStream();

            // Конвертируем потоки в другой тип, чтоб легче обрабатывать текстовые сообщения.
            DataInputStream in = new DataInputStream(sin);
            DataOutputStream out = new DataOutputStream(sout) {
            };

            String line = null;
            while (true) {
                line = in.readUTF(); // ожидаем пока клиент пришлет строку текста.
                System.out.println("От клиента я получил следующую строку : " + line);
                System.out.println("Отправляю обратно...");
                out.writeUTF(line); // отсылаем клиенту обратно ту самую строку текста.
                out.flush(); // заставляем поток закончить передачу данных.
                System.out.println("Жду следующую строку...");
                System.out.println();
            }
        } catch (Exception x) {
            x.printStackTrace();
        }
    }
}

Client:

public class Client {


    public static void main(String[] args) {
       int serverPort = 6666; // порт к серверу, которому хотим присоединиться
        String address = "127.0.0.1"; // это IP-адрес компьютера, где исполняется наша серверная программа. 
                                      // Здесь указан адрес того самого компьютера где будет исполняться и клиент.

        try {
            InetAddress ipAddress = InetAddress.getByName(address); // создаем объект который отображает вышеописанный IP-адрес.
            System.out.println("Если ли кто-то, подключенный по этому адресу " + address + " и порту " + serverPort + "?");
            Socket socket = new Socket(ipAddress, serverPort); // создаем сокет используя IP-адрес и порт сервера.
            System.out.println("Соединение установлено.");

            // Берем входной и выходной потоки сокета, теперь можем получать и отсылать данные клиентом. 
            InputStream sin = socket.getInputStream();
            OutputStream sout = socket.getOutputStream();

            // Конвертируем потоки в другой тип, чтоб легче обрабатывать текстовые сообщения.
            DataInputStream in = new DataInputStream(sin);
            DataOutputStream out = new DataOutputStream(sout);

            // Создаем поток для чтения с клавиатуры.
            BufferedReader keyboard = new BufferedReader(new InputStreamReader(System.in));
            String line = null;
            System.out.println("Введите что-нибудь, это будет отправлено на сервер и возвращено им.");
            System.out.println();

            while (true) {
                line = keyboard.readLine(); // ждем пока пользователь введет что-то и нажмет кнопку Enter.
                System.out.println("Отправляем строку на сервер...");
                out.writeUTF(line); // отсылаем введенную строку текста серверу.
                out.flush(); // заставляем поток закончить передачу данных.
                line = in.readUTF(); // ждем пока сервер отошлет строку текста.
                System.out.println("Сервер прислал ответ : " + line);
                System.out.println("Введите следующую строку...");
                System.out.println();
            }
        } catch (Exception x) {
            x.printStackTrace();
        }    }

}

Каким образом сделать асинхронную обработку каждого клиента?И как вообще запустить несколько клиентов, по сути это просто 2 разных проекта в нетбинсе, и запуская сначала сервер, затем клиент - я запускаю два проекта, еще раз запустить клиент не получается. Кнопка серая.

2
  • 1
    пример сервера на сокетах есть в документации на j.u.c.ExecutorService
    – zRrr
    9 июн 2016 в 17:54
  • благодарю, совершенно не знаком с темой клиент-серверных приложений и тем более как им устраивать многопоточность, в библиотеке concurrent множество способов, и на какой смотреть я совершенно не представлял.
    – Silento
    9 июн 2016 в 18:03

1 ответ 1

1

Получив сообщение от клиента, создавайте новый поток на новом сокете. Номер сокета отсылайте клиенту и закрывайте соединение. Далее клиент общается с новым потоком.

2
  • А как создать несколько клиентов единовременно?
    – Silento
    9 июн 2016 в 13:42
  • 1
    Если нужно создать несколько клиентов - так же попробуйте запустить их в разных потоках. Только не забудьте сделать им механизм повторения запросов (habrahabr.ru/post/227225) на случай неуспешной попытки соединиться со стартовым сокетом сервера.
    – DimXenon
    9 июн 2016 в 15:56

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.