DataInputStream.readInt () вызывает высокую задержку, я делаю это неправильно? - PullRequest
Новая
       29

DataInputStream.readInt () вызывает высокую задержку, я делаю это неправильно?

2 голосов
/ 28 октября 2011

Здесь вы найдете простое приложение сервер / клиент, которое отправляет целое число 5 от клиента на сервер, который читает его и отправляет обратно клиенту.На сервере я разместил измеритель задержки вокруг метода DataInputStream.readInt (), который показывает, что этот метод вызывает задержку 400 мс.

Код сервера: 

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

public class Server {
    public static void main(String args[]) {

// declaration section:
        ServerSocket echoServer = null;
        Socket clientSocket = null;
        int x;

// Try to open a server socket on port 4444
        try {
           echoServer = new ServerSocket(4444);
        }
        catch (IOException e) {
           System.out.println(e);
        }

//accept connection
        try {
           clientSocket = echoServer.accept();
//input
           DataInputStream input = new DataInputStream(clientSocket.getInputStream());
//output
           DataOutputStream output = new DataOutputStream(clientSocket.getOutputStream());
//loop
           while(true){
               long time = System.currentTimeMillis();
               output.writeInt(input.readInt());
               long dtime = System.currentTimeMillis();
               System.out.println(dtime-time);
           }
//close
//           output.close();
//           input.close();
//           clientSocket.close();
//           echoServer.close();
        }catch (IOException e) {
           System.out.println(e);
        }
    }
}

Код клиента: 

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

public class Client {
    public static void main(String[] args) {

// declaration section:
// clientClient: our client socket
// out: output stream
// in: input stream

        Socket clientSocket = null;
// Initialization section:
// Try to open a socket on port 4444
// Try to open input and output streams
        try{
            clientSocket = new Socket("YOUR-IP-HERE", 4444);

//output
            DataOutputStream output = new DataOutputStream(clientSocket.getOutputStream());
//input
            DataInputStream input = new DataInputStream(clientSocket.getInputStream());
//loop
        while(true) {
            output.writeInt(5);
            //System.out.println(input.readInt());
        }
//close
//            output.close();
//            input.close();
//            clientSocket.close();
        }catch(Exception e) {
            System.out.println("error");
        }
    }
}

Проблемная область: 

//latencymeter
long time = System.currentTimeMillis();
//problem code
output.writeInt(input.readInt());
//latencymeter
long dtime = System.currentTimeMillis();
System.out.println(dtime-time);

Я ошибаюсь в своем коде или неэффективно кодирую, пожалуйста, дайте мне знать.

Спасибо

1 Ответ

1 голос
/ 28 октября 2011

Решено: добавление clientSocket.setTcpNoDelay (true);как на сервере, так и на клиенте время ожидания снизилось до 10-20 мсек.

...