private static final String HTTP = "http";
private static final Logger logger = LoggerFactory.getLogger(RestClient.class);
- enum HttpMethod {
+ public enum HttpMethod {
GET, POST, PUT, DELETE
}
}
HttpHost target = new HttpHost(ip, port, HTTP);
HttpRequest request = getRequest(method, url, body);
- logger.info("deployfile method send ip"+ip);
+ logger.info("deployfile method send ip" + ip);
request.addHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
httpResponse = httpclient.execute(target, request);
HttpEntity entity = httpResponse.getEntity();
logger.info("deployfile method send");
- if (entity != null) {
+ if (entity != null && httpResponse.getStatusLine()!=null) {
result.setStatusCode(httpResponse.getStatusLine().getStatusCode());
logger.info("reply status code deploy"+httpResponse.getStatusLine().getStatusCode());
result.setResult(EntityUtils.toString(entity));
return result;
}
- private static HttpRequest getRequest(HttpMethod method, String url, HttpEntity body) {
+ public static HttpRequest getRequest(HttpMethod method, String url, HttpEntity body) {
HttpRequest request = null;
switch (method) {
case GET:
if (ip == null) {
ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
}
- port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+ if(port==null) {
+ port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+ }
RestResponse result = new RestResponse();
CloseableHttpClient httpClient = HttpClients.createDefault();
try {
httpDeteTest.setEntity(new StringEntity(jsonStr));
// returnValue = httpClient.execute(httpDeteTest, responseHandler); // 调接口获取返回值时,必须用此方法
CloseableHttpResponse httpResonse = httpClient.execute(httpDeteTest);
- int statusCode = httpResonse.getStatusLine().getStatusCode();
- result.setStatusCode(statusCode);
+ if(httpResonse!=null && httpResonse.getStatusLine()!=null) {
+ int statusCode = httpResonse.getStatusLine().getStatusCode();
+ result.setStatusCode(statusCode);
+ }
// result.setResult(EntityUtils.toString(httpResonse.getEntity()));
} catch (Exception e) {
e.printStackTrace();
if (ip == null) {
ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
}
- port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
-
+ if(ip==null) {
+ port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
+ }
HttpPost httpPost = new HttpPost(Constants.HTTP_HEADER + ip + ":" + port + url);
Gson gson = new Gson();
String jsonStr = gson.toJson(object, ActivitiStartProcessRequest.class);
httpPost.setEntity(requestEntity);
returnValue = httpClient.execute(httpPost, responseHandler); // 调接口获取返回值时,必须用此方法
CloseableHttpResponse httpResonse = httpClient.execute(httpPost);
- int statusCode = httpResonse.getStatusLine().getStatusCode();
- returnValue = EntityUtils.toString(httpResonse.getEntity(),"UTF-8");
- result.setStatusCode(statusCode);
- result.setResult(returnValue);
+ if(httpResonse!=null && httpResonse.getStatusLine()!=null) {
+ int statusCode = httpResonse.getStatusLine().getStatusCode();
+ returnValue = EntityUtils.toString(httpResonse.getEntity(), "UTF-8");
+ result.setStatusCode(statusCode);
+ result.setResult(returnValue);
+ }
} catch (Exception e) {
e.printStackTrace();
}