C, PHP, VB, .NET

В представеното приложение е реализирана възможно най-базовата комуникация между клиент и сървър, при която се разменят поредица от текстови съобщения. Обърнете внимание, че не се използват нишки, т.е. за една “сесия” сървърът може да комуникира само с един клиент.

Server.java:

import java.io.PrintWriter;
import java.net.Socket;
import java.net.ServerSocket;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.IOException;
import java.util.Scanner;

public class Server{
  public static void main(String args[]) {
    ServerSocket serverSocket = null;
    Socket connection = null;
    Scanner socketIn = null;
    PrintWriter socketOut = null;
    int port = 1234;

    // Безкраен цикъл - сървъра ще приема връзки
    // докато програмата не бъде спряна принудително
    while(true){
      try {
        serverSocket = new ServerSocket(port);
        System.out.println("Сървъра очаква свързване...");
        connection = serverSocket.accept();
        System.out.println("Свърза се клиент:"
              +connection.getInetAddress().getHostName()
        );

        System.out.println("Подавам съобщение на клиента...");
        socketOut = new PrintWriter(connection.getOutputStream(), true);
        socketOut.println("Възможните команди са \"hi\" и \"exit\"");

        System.out.println("Сървъра очаква подаване на команда...");
        socketIn = new Scanner(new BufferedReader(
                          new InputStreamReader(connection.getInputStream()))
                       );

        String command = null;
        loop: do{
          socketOut.flush();
          command = socketIn.nextLine();
          switch(command){
            case "hi":
              System.out.println("Клиентът подаде команда \"hi\"");
              socketOut.println("OK");
              break;
            case "exit":
              System.out.println("Клиентът подаде команда \"exit\"");
              socketOut.println("OK");
              break loop;
            default:
              System.out.println("Получих непозната команда");
              socketOut.println("Не познавам тази команда");
              break;
          }
        }
        while(!command.equalsIgnoreCase("exit"));
        System.out.println("Затварям връзката с "
                             +connection.getInetAddress().getHostName()
                          );
      }
      catch(IOException e) {
        e.printStackTrace();
      }
      finally{
        try{
          if (socketIn!=null) socketIn.close();
          if (socketOut!=null) socketOut.close();
          if (connection!=null) connection.close();
          if (serverSocket!=null) serverSocket.close();
        }
        catch(IOException e){
          System.err.println("Не може да бъде затворен сокет");
        }
      }
    }
  }
}

Client.java:

import java.io.PrintWriter;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Scanner;
import java.net.Socket;
import java.io.IOException;
import java.net.ConnectException;

public class Client{
   public static void main(String args[]){
     Socket connection = null;
     Scanner socketIn = null;
     PrintWriter socketOut = null;
     Scanner keyboardIn = new Scanner(System.in);
     int port = 1234;
     String host = "localhost";

     try{
       System.out.println("Очаквам свързване със сървъра");
       try{
         connection = new Socket(host, port);
       }
       catch(ConnectException e){
         System.err.println("Не мога да осъществя връзка със сървъра");
         return;
       }
       System.out.println("Свързването със сървъра беше успешно!");

       System.out.println("Приемам първоначално съобщение от сървъра...");
       socketIn = new Scanner(new BufferedReader(
                         new InputStreamReader(connection.getInputStream()))
                      );
       System.out.println("Съобщението е: "+socketIn.nextLine());

       String command = null;
       socketOut = new PrintWriter(connection.getOutputStream(), true);
       do{
         socketOut.flush();
         System.out.print("Въведете команда: ");
         command = keyboardIn.nextLine();
         socketOut.println(command.toLowerCase());

         System.out.println("Изчакване на отговор от сървъра...");
         String answer = socketIn.nextLine();
         System.out.println("Сървърът отговори: "+answer);
       }
       while (!command.equalsIgnoreCase("exit"));
       System.out.println("Затваряне на връзката...");

     }
     catch(IOException e) {
       e.printStackTrace();
     }
     finally{
       try{
         if(socketIn!=null) socketIn.close();
         if(socketOut!=null) socketOut.close();
         if(connection!=null) connection.close();
       }
       catch(IOException e){
         System.err.println("Не може да се затвори сокета");
       }
     }
   }
}