| | |
| | | import org.springframework.web.context.request.ServletRequestAttributes; |
| | | |
| | | import java.io.*; |
| | | import java.nio.charset.Charset; |
| | | import java.nio.charset.StandardCharsets; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | |
| | |
| | | // 设定参数:客户端的总连接数 |
| | | manager.getParams().setMaxTotalConnections(400); |
| | | // 设置连接超时时间,单位:毫秒 |
| | | manager.getParams().setConnectionTimeout(8000); |
| | | manager.getParams().setConnectionTimeout(30000); |
| | | // 设置请求读取超时时间,单位:毫秒 |
| | | manager.getParams().setSoTimeout(8000); |
| | | manager.getParams().setSoTimeout(30000); |
| | | // 设置从连接池中获取链接时间, 单位:毫秒 |
| | | manager.getParams().setParameter(HttpClientParams.CONNECTION_MANAGER_TIMEOUT, 8000); |
| | | // 使用连接池技术创建HttpClient对象 |
| | |
| | | if (inputStream == null) { |
| | | throw new HttpRequestException(RESPONSE_NULL_ERROR_CODE, "响应为null"); |
| | | } |
| | | BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream)); |
| | | BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, Charset.forName("GB2312"))); |
| | | StringBuffer stringBuffer = new StringBuffer(); |
| | | String str = ""; |
| | | while ((str = reader.readLine()) != null) { |
| | |
| | | HttpEntity<RESPBODY> rep = null; |
| | | if (isNullOrEmpty(respStr) || null == respBodyClass) { |
| | | rep = new HttpEntity<RESPBODY>(respHeaders, null); |
| | | ;// 无响应 |
| | | // 无响应 |
| | | } else { |
| | | if (respBodyClass != String.class) { |
| | | RESPBODY respBody = JSON.parseObject(respStr, respBodyClass); |
| | | rep = new HttpEntity<RESPBODY>(respHeaders, respBody); |
| | | } else { |
| | | rep = new HttpEntity<RESPBODY>(respHeaders, (RESPBODY) respStr); |
| | | rep = new HttpEntity<RESPBODY>(respHeaders, (RESPBODY) new String(respStr.getBytes("ISO8859-1"), StandardCharsets.UTF_8)); |
| | | } |
| | | } |
| | | return rep; |
| | |
| | | } |
| | | return false; |
| | | } |
| | | } |
| | | } |