Java. Создание простого клиент-сервера на основе сокетов

Создадим примитивнейший сервер, который будет запущен на локалхосте на порте 8888.

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

Конец общения между клиентом и сервером - строка "BYE", получив которую, сервер обрывает соединение.

И так, приступим. Вот код сервера:

package investigation.clientserver; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; public class Server { // Порт, на котором будем шлюхать 1-1024: public static final int PORT = 8888; public static void main(String[] args) throws IOException { ServerSocket s = new ServerSocket(PORT); System.out.println("Started: " + s); try { Socket socket = s.accept(); try { System.out.println("Connection accepted: " + socket); BufferedReader in = new BufferedReader(new InputStreamReader( socket.getInputStream())); PrintWriter out = new PrintWriter(new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())), true); while (true) { String str = in.readLine(); if (str.equals("BYE")) { System.out.println("Closing connection."); break; } System.out.println("Echoing: " + str); out.println(str); } } finally { System.out.println("closing..."); socket.close(); } } finally { s.close(); } } }

Вот код клиента:

package investigation.clientserver; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.InetAddress; import java.net.Socket; public class Client { public static void main(String[] args) throws IOException { InetAddress addr = InetAddress.getByName(null); System.out.println("addr = " + addr); Socket socket = new Socket(addr, Server.PORT); try { System.out.println("socket = " + socket); BufferedReader in = new BufferedReader(new InputStreamReader(socket .getInputStream())); PrintWriter out = new PrintWriter(new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())), true); for (int i = 0; i < 10; i++) { out.println("HELLO " + i); String str = in.readLine(); System.out.println(str); } out.println("BYE"); } finally { System.out.println("closing..."); socket.close(); } } }

Запустив сервер и клиент, можно увидеть, что после сообщения BYE сервер обрывает соединение. 

Клиент можно и не писать, а протестировать можно через telnet.  Под виндой запускаем телнет через windows+run -> telnet.

вводим localhost 8888 и попадаем в сессию. Тут можно вводить сообщения, которые будут тут же печататься сервером в консоль. 

Недостаток вышеприведенного примера в том, что сервер может принимать только одно соединение. 

Напишем новый сервер, который будет использовать потоки для приема множества соединений.

package investigation.clientserver; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; class ServeOneThread extends Thread { private Socket socket; private BufferedReader in; private PrintWriter out; public ServeOneThread(Socket s) throws IOException { socket = s; in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket .getOutputStream())), true); start(); } public void run() { try { while (true) { String str = in.readLine(); if (str.equals("END")) break; System.out.println("Echoing: " + str); out.println(str); } System.out.println("closing..."); } catch (IOException e) { System.err.println("IO Exception"); } finally { try { socket.close(); } catch (IOException e) { System.err.println("Socket not closed"); } } } } public class MultiThreadedServer { static final int PORT = 8888; public static void main(String[] args) throws IOException { ServerSocket s = new ServerSocket(PORT); System.out.println("Server Started"); try { while (true) { Socket socket = s.accept(); try { new ServeOneThread(socket); } catch (IOException e) { socket.close(); } } } finally { s.close(); } } }

Для каждого соединения создается новый поток.

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