Как сервер может знать, когда сообщение, которое оно получает, происходит на самом деле?

Question

Я пытаюсь реализовать сервер, и он делает что-то вроде этого, когда он получает сообщение:

try{ 
     ObjectInputStream is = new ObjectInputStream(clientSocket.getInputStream()); 
     String message = (String)is.readObject(); 
     ActivateCommand(message,clientSocket); 
     is.close(); 
    } 

и ActivateCommand:

private void ActivateEwolfCommand(String msg, Socket clientSocket) throws IOException 
{ 
    ObjectOutputStream os = new ObjectOutputStream(clientSocket.getOutputStream()); 
    Gson gsonObject = new Gson(); 
    . 
    //code which makes a Json string 
    . 
    os.writeObject(json); 
os.close(); 
} 

теперь, когда я тестировал его с отправкой сообщения к локальному хозяину с тестом junit он работал. Но когда вы попытались подключиться к серверу с помощью клиента C#, клиент подключился, но сервер выбрал исключение EOF при достижении точки clientSocket.getInputStream(). Я предполагаю, что это происходит потому, что сервер не знал, когда сообщение должно закончиться, но я не знаю, действительно ли это так, и если да, то как я могу его исправить?

Answer 1

Когда данных на InputStream нет, read() - это в основном то, что вызывает EOF. Сколько данных доступно клиенту - данные, которые он записывает на Socket's OutputStream со своей стороны, отображаются как таковые на InputStream сокета на стороне сервера. Вы можете позвонить InputStream.available(), чтобы получить оценку количества байтов, которое может быть еще read().

Однако ваш код пытается прочитать объект с использованием ObjectInputStream - этот класс имеет свой собственный протокол для чтения сериализованного потока байтов и преобразования его в объект - если он не находит байты для выполнения задачи, это может вызвать исключение EOF. Если ваш клиент находится в C# - формат байтов, который записывает для сериализованного объекта, определенно не будет таким же, как ожидалось, ObjectInputStream на стороне сервера.

Answer 2

Вот почему это плохая идея создать собственный клиент-серверный протокол с потоками сокетов и объектов. Многие люди потратили много лет приносит вам, о, хорошо:

• SOAP
• REST
• RMI
• Hessian
• CORBA
• Бережливость

и множество другие протоколы. Разумеется, один из них, если не 5 или 6, достаточно хорош для решения вашей проблемы, включая все вопросы кадрирования.

Answer 3

Если вы хотите отправить строки по сокету, то ObjectInputStream или ObjectOutputStream не является правильной реализацией потока. Эти потоковые реализации используют сериализацию объектов Java. Даже если вы сериализуете String экземпляров, результирующие байты не совпадают с простой строкой для преобразования байтов с соответствующей кодировкой символов.

И приложение C# вообще не понимает сериализацию Java.

Рассмотрите возможность использования строки PrintWriter для записи строк в поток и BufferedReader для чтения.

PrintWriter writer = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream(), "UTF-8")); 
writer.println(...); 


BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream(), "UTF-8")); 
String line = reader.readLine(); 

Затем вы можете читать и писать строки по строкам. Это только отправная точка. Если вы хотите реализовать свой собственный протокол, вы должны обратить внимание на несколько пунктов.В качестве примера вы можете прочитать спецификации для некоторых протоколов TCP, таких как POP3, FTP или HTTP 1.0.