IOUtils.toString 花了很长时间
IOUtils.toString taking to long
我有这个 class 可以打开一个 HTTP-Server 并监听一个端口。回复是一个http-header加一个jsonobject。 class 从服务器获取输入流,将其转换为字符串,过滤 http header 并解析 json object.
问题是从输入流到字符串的转换大约需要 3 秒。有没有办法更快地读取输入流?
public class GamestateListener {
private static int PORT = 3001; // Port specified in your cfg
public static ServerSocket listenServer;
private static JSONObject MYJSONOBJ;
public GamestateListener() {
try {
listenServer = new ServerSocket(PORT); // open new Server Socket
System.out.println("Started Socket..."); // printing out started
// listening
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public JSONObject listenAndParseJSON() throws IOException {
System.out
.println("Listening for connection on port " + PORT + " ...."); // printing
// out
// started
// listening
try (Socket socket = listenServer.accept()) { // wait for connection
System.out.println("Start get From Socket "
+ System.currentTimeMillis());
InputStream mis = socket.getInputStream();
System.out.println("Stop get From Socket "
+ System.currentTimeMillis());
String responseString = IOUtils.toString(mis, "UTF-8");
System.out.println("Stop to String "
+ System.currentTimeMillis());
MYJSONOBJ = new JSONObject(responseString.substring(responseString
.indexOf("{")));// split the response string
return MYJSONOBJ;// return the json obj
} catch (Exception e) {
MYJSONOBJ = new JSONObject("{ERROR:True}");// create error obj
return MYJSONOBJ;// return it
}
}
}
你没有衡量你认为的自己。这里:
System.out.println("Start get From Socket "
+ System.currentTimeMillis());
InputStream mis = socket.getInputStream();
System.out.println("Stop get From Socket "
+ System.currentTimeMillis());
... getInputStream()
returns时你似乎认为你已经阅读了所有数据。你没有。您刚刚获得了可以读取的流。这意味着有联系,但仅此而已。
如果您想测量读取所有数据(而不是实际处理它)需要多长时间,您可以这样做:
System.out.println("Start get From Socket "
+ System.currentTimeMillis());
InputStream mis = socket.getInputStream();
byte[] buffer = new byte[8192];
// Read all the data (but ignore it)
while ((mis.read(buffer)) != -1) ;
System.out.println("Stop get From Socket "
+ System.currentTimeMillis());
当然,接下来的代码将不会读取任何数据,但是您会看到仅读取数据 需要多长时间。我的猜测是大约 3 秒...这可能是由于网络速度慢,或者客户端需要很长时间才能 发送 所有数据。 (它可以连接,休眠 2.9 秒,然后然后发送一堆数据。)
我有这个 class 可以打开一个 HTTP-Server 并监听一个端口。回复是一个http-header加一个jsonobject。 class 从服务器获取输入流,将其转换为字符串,过滤 http header 并解析 json object.
问题是从输入流到字符串的转换大约需要 3 秒。有没有办法更快地读取输入流?
public class GamestateListener {
private static int PORT = 3001; // Port specified in your cfg
public static ServerSocket listenServer;
private static JSONObject MYJSONOBJ;
public GamestateListener() {
try {
listenServer = new ServerSocket(PORT); // open new Server Socket
System.out.println("Started Socket..."); // printing out started
// listening
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public JSONObject listenAndParseJSON() throws IOException {
System.out
.println("Listening for connection on port " + PORT + " ...."); // printing
// out
// started
// listening
try (Socket socket = listenServer.accept()) { // wait for connection
System.out.println("Start get From Socket "
+ System.currentTimeMillis());
InputStream mis = socket.getInputStream();
System.out.println("Stop get From Socket "
+ System.currentTimeMillis());
String responseString = IOUtils.toString(mis, "UTF-8");
System.out.println("Stop to String "
+ System.currentTimeMillis());
MYJSONOBJ = new JSONObject(responseString.substring(responseString
.indexOf("{")));// split the response string
return MYJSONOBJ;// return the json obj
} catch (Exception e) {
MYJSONOBJ = new JSONObject("{ERROR:True}");// create error obj
return MYJSONOBJ;// return it
}
}
}
你没有衡量你认为的自己。这里:
System.out.println("Start get From Socket "
+ System.currentTimeMillis());
InputStream mis = socket.getInputStream();
System.out.println("Stop get From Socket "
+ System.currentTimeMillis());
... getInputStream()
returns时你似乎认为你已经阅读了所有数据。你没有。您刚刚获得了可以读取的流。这意味着有联系,但仅此而已。
如果您想测量读取所有数据(而不是实际处理它)需要多长时间,您可以这样做:
System.out.println("Start get From Socket "
+ System.currentTimeMillis());
InputStream mis = socket.getInputStream();
byte[] buffer = new byte[8192];
// Read all the data (but ignore it)
while ((mis.read(buffer)) != -1) ;
System.out.println("Stop get From Socket "
+ System.currentTimeMillis());
当然,接下来的代码将不会读取任何数据,但是您会看到仅读取数据 需要多长时间。我的猜测是大约 3 秒...这可能是由于网络速度慢,或者客户端需要很长时间才能 发送 所有数据。 (它可以连接,休眠 2.9 秒,然后然后发送一堆数据。)