Java实现调用接口API并返回数据
作者：rfos
这篇文章主要介绍了Java实现调用接口API并返回数据方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
Java调用接口API并返回数据
Get方法
import com.alibaba.fastjson.JSONObject;
import edu.zhku.fire_ant_project.config.WxConstant;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
public class HttpCallOtherInterfaceUtils {
public static void main(String args[]) {
HttpClient client = HttpClients.createDefault();
// 要调用的接口方法
String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+ WxConstant.appid +"&secret="+WxConstant.secret;
HttpGet httpGet=new HttpGet(url);
JSONObject jsonObject = null;
try {
HttpResponse res = client.execute(httpGet);
if (res.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
// 返回json格式：
jsonObject = JSONObject.parseObject(EntityUtils.toString(res.getEntity()));
System.out.println(jsonObject);
}
} catch (Exception e) {
System.out.println("服务间接口调用出错！");
e.printStackTrace();
}
}
}
post方法
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
public class HttpCallOtherInterfaceUtils {
public static String callOtherInterface(JSONObject jsonParam, String port, String postUrl) {
HttpClient client = HttpClients.createDefault();
// 要调用的接口方法
String url = "http://localhost:" + port + postUrl;
HttpPost post = new HttpPost(url);
JSONObject jsonObject = null;
try {
StringEntity s = new StringEntity(jsonParam.toString(), "UTF-8");
//s.setContentEncoding("UTF-8");//此处测试发现不能单独设置字符串实体的编码，否则出错！应该在创建对象时创建
s.setContentType("application/json");
post.setEntity(s);
post.addHeader("content-type", "application/json;charset=UTF-8");
HttpResponse res = client.execute(post);
if (res.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
// 返回json格式：
jsonObject = JSONObject.parseObject(EntityUtils.toString(res.getEntity()));
}
} catch (Exception e) {
System.out.println("服务间接口调用出错！");
e.printStackTrace();
//throw new RuntimeException(e);
}
return jsonObject.toString();
}
}
Java跨服务调用接口
Java程序跨服务调用接口，通常可以使用以下方式：
- RESTful API：通过HTTP协议进行通信，使用RESTful API调用其他服务的接口。
- RPC：使用远程过程调用（RPC）框架，如Dubbo、gRPC等，通过序列化和反序列化技术实现跨服务调用。
- 消息队列：使用消息队列，如Kafka、RabbitMQ等，服务之间通过消息队列进行异步通信。
- HTTP客户端：使用Java内置的HTTP客户端，如HttpURLConnection、Apache HttpClient等，通过HTTP协议调用其他服务的接口。
无论使用哪种方式，都需要了解其他服务的接口定义和调用方式，以及网络通信的安全性和稳定性等方面的考虑。同时，需要注意接口版本的兼容性和错误处理等问题。
这里提供一个使用Java内置的HttpURLConnection进行POST请求的示例代码：
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
public class HttpPostExample {
private static final String POST_URL = "http://engine-server-host:port/api/client/data/push";
private static final String USER_AGENT = "Mozilla/5.0";
public static void main(String[] args) throws IOException {
URL obj = new URL(POST_URL);
HttpURLConnection con = (HttpURLConnection) obj.openConnection();
// 添加请求头
con.setRequestMethod("POST");
con.setRequestProperty("User-Agent", USER_AGENT);
con.setRequestProperty("Accept-Language", "en-US,en;q=0.5");
// 设置POST请求体
String postBody = "your_post_body_here";
con.setDoOutput(true);
try (DataOutputStream wr = new DataOutputStream(con.getOutputStream())) {
wr.writeBytes(postBody);
wr.flush();
}
// 发送POST请求并获取响应
int responseCode = con.getResponseCode();
System.out.println("POST Response Code :: " + responseCode);
try (BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()))) {
String inputLine;
StringBuilder response = new StringBuilder();
while ((inputLine = in.readLine()) != null) {
response.append(inputLine);
}
System.out.println("POST Response :: " + response.toString());
}
}
}在代码中，需要将POST_URL替换为引擎端的API接口地址，将postBody替换为要发送的POST请求体。
需要注意的是，这里的POST请求体需要按照引擎端API接口的要求进行格式化。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。