对接第三方接口--使用post请求发送json数据

对接第三方接口–使用post请求发送json数据

第三方接口字段构建成model

public class A{
private String sn;
private String host;
private String port;
......

public String getHost() {return host;}
public void setHost(String host) {this.host = host;}
......
}

Java对象

public class B{
private String id;
private String ip;
private String port;
......
......
}

发送请求

public class APITest {
//这里是日志
private static ....

/**
* api_url 请求路径 ，换成自己的路径
*/
private String apiUrl = MapCache.getConfigVal("api_url");

/**
* http客户端
*/
private HttpClient client = new HttpClient();

/**
* 将告警信息发送到百信API
*
* @param notice
*/
public void sendNotice(B b) {

//java对象封装成第三方类
if (b != null) {
A a = new A();
a.setHost(b.getIp);
...
send(a);
}
}

/**
* post请求发送json格式的数据至API
*
* @param A
*/
public void send(A a) {
if (this.apiUrl == null) {
this.apiUrl = "http://xxx...";
}

if (this.apiUrl != null) {
PostMethod postMethod = new PostMethod(this.apiUrl);
Gson gson = new Gson();
String data = gson.toJson(a);

try {
RequestEntity requestEntity = new StringRequestEntity(data.toString(), "application/json", "utf-8");
postMethod.setRequestEntity(requestEntity);
} catch (UnsupportedEncodingException e) {
log.error("Java Object To JSON Error: ", e);
}

try {
int httpCode = client.executeMethod(postMethod);
if (httpCode == 200) {
sendInfoLog.info("发送到api成功：" + data.toString());
} else {
sendInfoLog.info("发送到api失败：" + data.toString());
}
} catch (IOException e) {
this.log.error("发送api post请求失败：", e);
} finally {
postMethod.releaseConnection();
}
}
}
}