| | |
|---|
| | | BufferedReader reader = new BufferedReader(new InputStreamReader(this.socket.getInputStream())); |
|---|
| | | // 读取服务器的响应 |
|---|
| | | StringBuffer sb = new StringBuffer(); |
|---|
| | | String response = null; |
|---|
| | | char[] chars = new char[2048];//缓冲区 |
|---|
| | | do { |
|---|
| | | while (true) { |
|---|
| | | reader.read(chars); |
|---|
| | | String trim = new String(chars).trim(); |
|---|
| | | String trim = new String(chars); |
|---|
| | | sb.append(trim); |
|---|
| | | if (sb.lastIndexOf("\r\n") != -1) { |
|---|
| | | if (trim.lastIndexOf("\r\n") != -1) { |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } while (response != null); |
|---|
| | | // System.out.println("Received response from server: " + sb); |
|---|
| | | } |
|---|
| | | |
|---|
| | | JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集 |
|---|
| | | if (!socketResults.isEmpty() && socketResults.size() >= 5) { |
|---|
