java - клиент - сервер несколько сообщений от клиента

Question

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

Это мой код: Клиент: import java.io. ; импорт java.net.;

public class Klient 
    { 
     public static final int PORT=50007; 
     public static final String HOST = "127.0.0.1"; 

    public static void main(String[] args) throws IOException        
    {                     

     Socket sock;                  
     sock=new Socket(HOST,PORT);              
     System.out.println("communication works: "+sock);        


     BufferedReader klaw;                
     klaw=new BufferedReader(new InputStreamReader(System.in));      
     PrintWriter outp;                 
     outp=new PrintWriter(sock.getOutputStream());          


     System.out.print("<Sending:> ");             
     String str=klaw.readLine();              
     outp.println(str);                
     outp.flush();                  


     klaw.close();                  
     outp.close();                  
     sock.close();                  
    }                     
} 

и сервер:

import java.io.*; 
import java.net.*; 

public class Serwer 
{ 
    public static final int PORT=50007; 

    public static void main(String args[]) throws IOException     
    {                   

     ServerSocket serv;              
     serv=new ServerSocket(PORT);           


     System.out.println("listen for: "+serv);        
     Socket sock;               
     sock=serv.accept();              
     System.out.println("communication: "+sock);       


     BufferedReader inp;              
     inp=new BufferedReader(new InputStreamReader(sock.getInputStream())); 

     String str;                
     str=inp.readLine();              
     System.out.println("<it comes:> " + str);        


     inp.close();               
     sock.close();               
     serv.close();               
    }                   
} 

Answer 1

Вы должны добавить основной цикл для вашего кода и специальной команды для выхода

в примере:

// infinite loop 
while (true) { 

    // ..receive or send commands here.. 

    if (command.equals("exit") { 
    // exit from loop 
    } 

} 

также добавить обработку исключений (try-catch-finally) или приложение будет очень хрупким

Answer 2

Сокет TCP отправляет данные в поток. TCP не поддерживает отправку данных в «сообщения» или «блоки». То, что вы делаете в коде, отправляет и получает поток.

Чтобы отправить «сообщения» с использованием TCP, протокол TCP должен быть определен поверх TCP. Этот протокол должен иметь возможность отправлять «сообщения». (если вы не понимаете эту часть, вы должны прочитать о слоях протокола, 7-уровневой модели OSI и 5-уровневом пакете TCP/IP)

Способ сделать это, чтобы определить символ завершения сообщения. Поток будет выглядеть так:

<message><termination-character><message><termination-character> 

Символ окончания является символом символа сообщения или за его пределами. В последнем случае любое появление символа завершения в сообщении должно быть заменено escape-последовательностью.

Предположим, что мы используем символ «\ n» в качестве символа завершения, и мы предполагаем, что «\ n» не находится в кодировке сообщений. Ваш клиент должен выглядеть следующим образом:

import java.io.*; 
import java.net.*; 

    public class Klient 
    { 
    public static final int PORT=50007; 
    public static final String HOST = "127.0.0.1"; 
    public static final char TERMINATIONCHAR = '\n'; 

    public static void main(String[] args) throws IOException        
    {                     

     Socket sock;                  
     sock=new Socket(HOST,PORT);              
     System.out.println("communication works: "+sock);        


     BufferedReader klaw;                
     klaw=new BufferedReader(new InputStreamReader(System.in));      
     PrintWriter outp;                 
     outp=new PrintWriter(sock.getOutputStream());          

     //define the loop 
     while(true){ 
      System.out.print("<Sending:> ");             
      String str=klaw.readLine(); 
      outp.print(str+TERMINATIONCHAR);                
      outp.flush(); 
     } 

     /* uncomment if the loop can be exited 
     klaw.close();                  
     outp.close();                  
     sock.close();*/ 
    }                     
} 

и ваш сервер должен выглядеть следующим образом:

import java.io.*; 
import java.net.*; 

public class Server 
{ 
    public static final int PORT=50007; 
    public static final char TERMINATIONCHAR = '\n'; 

    public static void main(String args[]) throws IOException     
    {                   

     ServerSocket serv;              
     serv=new ServerSocket(PORT);           


     System.out.println("listen for: "+serv);        
     Socket sock;               
     sock=serv.accept();              
     System.out.println("communication: "+sock);       


     BufferedReader inp;              
     inp=new BufferedReader(new InputStreamReader(sock.getInputStream())); 

     //define the loop 
     while(true){ 
      String str;                
      str=inp.readLine();            
      System.out.println("<it comes:> " + str); 
     } 

     /* uncomment if the loop can be exited 
     inp.close();               
     sock.close();               
     serv.close();*/                 
    }                   
}