Чтение данных из входного потока без клиентской стороны «flush()»

Question

Я реализовал программу Java, которая считывает данные с устройств GPS через ServerSocket.

ServerSocket serverSocket = new ServerSocket(13811); 
serverSocket.setReceiveBufferSize(receiveBufferSize); 
Socket incomingSocket = serverSocket.accept(); 
InputStream stream = incomingSocket.getInputStream(); 
byte[] buffer = new byte[1000]; 
      StringBuffer sb = new StringBuffer(); 
System.out.println("START getting message from TCP stream: " + dateFormat.format(Calendar.getInstance().getTime())); 

      while (stream.read(buffer) > 0) 
      { 
       sb.append(new String(buffer)); 
       System.out.println(sb.toString()); 
      } 
System.out.println("[incomingMessage]: " + incomingMessage); 

System.out.println("FINISHED getting message from TCP stream: " + dateFormat.format(Calendar.getInstance().getTime())); 

Тем не менее, мы обнаружили, что существует большая задержка (т.е. большое отклонение между Sys из «START ...» и «FINISHED ...» время выше). Время было потрачено на inputStream.read().

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

Socket socket = new Socket("localhost", 13811); 
DataOutputStream out = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream())); 
String tobesend = "testing message 1"; 
out.writeBytes(tobesend); 
out.flush(); 
out.close(); 

Однако, если добавить "Thread.Sleep (10 * 1000)" перед "out.flush()" и "out.close()", задержка на стороне сервера будет 10seconds .. Поэтому я подозреваю, что GPS-устройство не выполнило «флеш» и привело к задержке вводаstream.read() со стороны сервера ...

К сожалению, у нас нет контроля над TCP-устройствами GPS-устройств, поэтому я могу «внесите в него какие-либо изменения, чтобы принудительно применить его к сообщению« flush »для моего входного потока ... Пожалуйста, советьте, есть ли какие-либо средства, чтобы серверная сторона могла читать данные из входного потока без такой задержки, даже на стороне клиента (то есть на устройстве GPS) не выполнять «флеш»?

Answer 1

Приемник не может прочитать данные, которые не были отправлены. Он не может заставить другой конец отправлять данные, которые не были отправлены.

Answer 2

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

Но тогда мы выполняем некоторый нагрузочный тест с той же программой сервера, имея 4000 пробных GPS-устройств, которые подталкивают данные к ним каждые 5 минут, каждый из которых составляет около 300 байт.

Мы попытались изменить код сервера, представив Threadpool для обработки данных TCP и надеемся, что это даст нам лучшую производительность.

Мы включили TCPDump и обнаружили, что на этот раз было обнаружено временное отклонение между временной меткой TCPDump и меткой «START ...», записанной в программе Java. Отклонение составляло от нескольких секунд до менее 20 секунд ...

Любое предложение о том, как устранить проблему?

Инициализация Threadpool:

blockingQueueForRetriveTCPMsg = new LinkedBlockingQueue<Runnable>(50); 
threadPoolExecutorForRetriveTCPMsg = new ThreadPoolExecutor(
    50,1200, 0, TimeUnit.SECONDS, 
    blockingQueueForRetriveTCPMsg, 
    new ThreadPoolExecutor.CallerRunsPolicy()); 

ServerSocket.accept():

ServerSocket serverSocket = new ServerSocket(13811); 
serverSocket.setReceiveBufferSize(receiveBufferSize); 
Socket incomingSocket = serverSocket.accept(); 

RetrieveTcpMessage retrieveTcpMessage = new RetrieveTcpMessage(incomingSocket); 
Thread retrieveTcpMessageThread = new Thread(retrieveTcpMessage); 
threadPoolExecutorForRetriveTCPMsg.execute(retrieveTcpMessageThread); 

Внутри RetrieveTcpMessage.run(), simuilar раньше:

InputStream stream = incomingSocket.getInputStream(); 
byte[] buffer = new byte[1000]; 
     StringBuffer sb = new StringBuffer(); 
System.out.println("START getting message from TCP stream: " +  dateFormat.format(Calendar.getInstance().getTime())); 

     while (stream.read(buffer) > 0) 
     { 
      sb.append(new String(buffer)); 
      System.out.println(sb.toString()); 
     } 
System.out.println("[incomingMessage]: " + incomingMessage); 

System.out.println("FINISHED getting message from TCP stream: " + dateFormat.format(Calendar.getInstance().getTime()));