java對(duì)接第三方接口的三種實(shí)現(xiàn)方式

更新時(shí)間：2025年05月28日 09:39:00 作者：酷愛(ài)碼

這篇文章主要為大家詳細(xì)介紹了java對(duì)接第三方接口的三種實(shí)現(xiàn)方式,文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,感興趣的小伙伴可以參考一下

1. 使用 HttpURLConnection（JDK原生）
2. 使用 Apache HttpClient
3. 使用 Spring RestTemplate 或 WebClient
4. 使用 OkHttp
5. 使用 Feign Client（聲明式HTTP客戶(hù)端）
6. 使用 JAX-RS Client（Jersey或RESTEasy）
7. 使用第三方工具（如Unirest）
8. 使用WebService客戶(hù)端（如JAX-WS或Apache CXF）

方式一：同步HTTP調(diào)用

實(shí)現(xiàn)原理

通過(guò)阻塞式HTTP請(qǐng)求直接獲取響應(yīng)結(jié)果，適用于實(shí)時(shí)性要求高的場(chǎng)景。

代碼示例（使用HttpClient）

// 創(chuàng)建HTTP客戶(hù)端
CloseableHttpClient client = HttpClients.createDefault();

// 構(gòu)建GET請(qǐng)求
HttpGet request = new HttpGet("https://api.example.com/data?param=value");
request.setHeader("Content-Type", "application/json");

// 執(zhí)行請(qǐng)求并處理響應(yīng)
try (CloseableHttpResponse response = client.execute(request)) {
    String result = EntityUtils.toString(response.getEntity());
    System.out.println("響應(yīng)結(jié)果：" + result);
} catch (IOException e) {
    e.printStackTrace();
}

關(guān)鍵點(diǎn)

設(shè)置連接超時(shí)（建議5-10秒）
處理HTTP狀態(tài)碼（如200/401/500等）
使用try-with-resources自動(dòng)釋放資源

方式二：異步回調(diào)模式

實(shí)現(xiàn)原理

發(fā)起請(qǐng)求后立即返回
第三方服務(wù)處理完成后回調(diào)指定接口

代碼結(jié)構(gòu)

// 創(chuàng)建HTTP客戶(hù)端
CloseableHttpClient client = HttpClients.createDefault();

// 構(gòu)建GET請(qǐng)求
HttpGet request = new HttpGet("https://api.example.com/data?param=value");
request.setHeader("Content-Type", "application/json");

// 執(zhí)行請(qǐng)求并處理響應(yīng)
try (CloseableHttpResponse response = client.execute(request)) {
    String result = EntityUtils.toString(response.getEntity());
    System.out.println("響應(yīng)結(jié)果：" + result);
} catch (IOException e) {
    e.printStackTrace();
}

注意事項(xiàng)

保證接口冪等性（防止重復(fù)回調(diào)）
添加簽名驗(yàn)證機(jī)制
設(shè)置回調(diào)超時(shí)時(shí)間（如30分鐘）

方式三：消息隊(duì)列中間件

實(shí)現(xiàn)原理

通過(guò)消息隊(duì)列實(shí)現(xiàn)解耦，適用于高并發(fā)場(chǎng)景。

RabbitMQ實(shí)現(xiàn)示例

// 消息生產(chǎn)者
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
     Channel channel = connection.createChannel()) {
    channel.queueDeclare("API_QUEUE", true, false, false, null);
    channel.basicPublish("", "API_QUEUE", null, message.getBytes());
}

// 消息消費(fèi)者
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
    String message = new String(delivery.getBody(), "UTF-8");
    // 調(diào)用第三方接口
    callThirdPartyAPI(message);
};
channel.basicConsume("API_QUEUE", true, deliverCallback, consumerTag -> {});

優(yōu)勢(shì)分析

流量削峰：緩沖突發(fā)請(qǐng)求
失敗重試：自動(dòng)重試機(jī)制
系統(tǒng)解耦：生產(chǎn)消費(fèi)分離

對(duì)比總結(jié)

對(duì)比維度	同步調(diào)用	異步回調(diào)	消息隊(duì)列
響應(yīng)時(shí)效	實(shí)時(shí)（毫秒級(jí)）	延遲（秒級(jí)）	可變
系統(tǒng)耦合度	高	中	低
吞吐量	低（受限于連接數(shù)）	中	高
實(shí)現(xiàn)復(fù)雜度	簡(jiǎn)單	中等	較高

選型建議

支付結(jié)果通知等實(shí)時(shí)場(chǎng)景 → 同步調(diào)用
物流狀態(tài)更新等異步場(chǎng)景 → 回調(diào)模式
批量數(shù)據(jù)處理等高并發(fā)場(chǎng)景 → 消息隊(duì)列

通用注意事項(xiàng)

使用HTTPS保證傳輸安全

添加請(qǐng)求簽名防止篡改

記錄完整日志（建議包含請(qǐng)求/響應(yīng)報(bào)文）

實(shí)現(xiàn)熔斷機(jī)制（如Hystrix）

配置監(jiān)控報(bào)警（超時(shí)率/錯(cuò)誤率）

方法補(bǔ)充

1. 使用 HttpURLConnection（JDK原生）

Java標(biāo)準(zhǔn)庫(kù)提供的底層HTTP客戶(hù)端，適合簡(jiǎn)單的請(qǐng)求，無(wú)需第三方依賴(lài)。

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
 
public class HttpUrlConnectionExample {
    public static void main(String[] args) throws Exception {
        URL url = new URL("https://api.example.com/data");
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("GET");
        
        int responseCode = conn.getResponseCode();
        if (responseCode == 200) {
            BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            String inputLine;
            StringBuilder response = new StringBuilder();
            while ((inputLine = in.readLine()) != null) {
                response.append(inputLine);
            }
            in.close();
            System.out.println(response);
        }
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：無(wú)需第三方依賴(lài)。

缺點(diǎn)：代碼冗余，需手動(dòng)處理輸入輸出流、狀態(tài)碼等。

2. 使用 Apache HttpClient

Apache提供的功能強(qiáng)大的HTTP客戶(hù)端庫(kù)，支持連接池、重試、認(rèn)證等高級(jí)功能。

import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
 
public class ApacheHttpClientExample {
    public static void main(String[] args) throws Exception {
        try (CloseableHttpClient client = HttpClients.createDefault()) {
            HttpGet request = new HttpGet("https://api.example.com/data");
            try (CloseableHttpResponse response = client.execute(request)) {
                System.out.println(response.getStatusLine().getStatusCode());
                // 處理響應(yīng)內(nèi)容...
            }
        }
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：功能全面，社區(qū)支持好。

缺點(diǎn)：需引入org.apache.httpcomponents:httpclient依賴(lài)。

3. 使用 Spring RestTemplate 或 WebClient

適用于Spring項(xiàng)目，簡(jiǎn)化REST API調(diào)用。

RestTemplate（同步）

import org.springframework.web.client.RestTemplate;
 
public class RestTemplateExample {
    public static void main(String[] args) {
        RestTemplate restTemplate = new RestTemplate();
        String url = "https://api.example.com/data";
        String response = restTemplate.getForObject(url, String.class);
        System.out.println(response);
    }
}

WebClient（異步，響應(yīng)式）

import org.springframework.web.reactive.function.client.WebClient;
 
public class WebClientExample {
    public static void main(String[] args) {
        WebClient webClient = WebClient.create("https://api.example.com");
        String response = webClient.get()
                .uri("/data")
                .retrieve()
                .bodyToMono(String.class)
                .block(); // 同步阻塞獲取結(jié)果
        System.out.println(response);
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：與Spring生態(tài)集成，支持JSON序列化、異常處理。

缺點(diǎn)：需引入Spring框架依賴(lài)（如spring-boot-starter-web或spring-boot-starter-webflux）。

4. 使用 OkHttp

Square公司開(kāi)發(fā)的高效HTTP客戶(hù)端，適合移動(dòng)端或輕量級(jí)應(yīng)用。

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
 
public class OkHttpExample {
    public static void main(String[] args) throws Exception {
        OkHttpClient client = new OkHttpClient();
        Request request = new Request.Builder()
                .url("https://api.example.com/data")
                .build();
        try (Response response = client.newCall(request).execute()) {
            System.out.println(response.body().string());
        }
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：輕量高效，支持HTTP/2。

缺點(diǎn)：需引入com.squareup.okhttp3:okhttp依賴(lài)。

5. 使用 Feign Client（聲明式HTTP客戶(hù)端）

適用于微服務(wù)架構(gòu)，通過(guò)接口和注解定義HTTP請(qǐng)求。

// 定義Feign接口
@FeignClient(name = "exampleClient", url = "https://api.example.com")
public interface ExampleClient {
    @GetMapping("/data")
    String getData();
}
 
// 使用示例（需結(jié)合Spring Cloud）
@SpringBootApplication
@EnableFeignClients
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：代碼簡(jiǎn)潔，支持負(fù)載均衡（結(jié)合Ribbon）。

缺點(diǎn)：需依賴(lài)Spring Cloud生態(tài)。

6. 使用 JAX-RS Client（Jersey或RESTEasy）

基于JAX-RS標(biāo)準(zhǔn)的客戶(hù)端，適合JAX-RS兼容的API。

import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.core.Response;
 
public class JaxRsClientExample {
    public static void main(String[] args) {
        Client client = ClientBuilder.newClient();
        Response response = client.target("https://api.example.com/data")
                .request()
                .get();
        System.out.println(response.readEntity(String.class));
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：標(biāo)準(zhǔn)化，支持RESTful語(yǔ)義。

缺點(diǎn)：需引入JAX-RS實(shí)現(xiàn)庫(kù)（如org.glassfish.jersey.core:jersey-client）。

7. 使用第三方工具（如Unirest）

簡(jiǎn)化HTTP調(diào)用的工具庫(kù)，語(yǔ)法簡(jiǎn)潔。

import kong.unirest.Unirest;
 
public class UnirestExample {
    public static void main(String[] args) {
        String response = Unirest.get("https://api.example.com/data")
                .asString()
                .getBody();
        System.out.println(response);
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：API簡(jiǎn)潔，適合快速開(kāi)發(fā)。

缺點(diǎn)：需引入com.konghq:unirest-java依賴(lài)。

8. 使用WebService客戶(hù)端（如JAX-WS或Apache CXF）

針對(duì)SOAP協(xié)議的WebService接口調(diào)用。

// JAX-WS示例
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import java.net.URL;
 
public class JaxWsExample {
    public static void main(String[] args) throws Exception {
        URL wsdlUrl = new URL("http://example.com/service?wsdl");
        QName qname = new QName("http://example.com/", "ExampleService");
        Service service = Service.create(wsdlUrl, qname);
        ExampleService port = service.getPort(ExampleService.class);
        String result = port.getData();
        System.out.println(result);
    }
}

特點(diǎn)：

優(yōu)點(diǎn)：適合SOAP協(xié)議。

缺點(diǎn)：代碼復(fù)雜，需生成客戶(hù)端存根。

選擇建議

簡(jiǎn)單請(qǐng)求：優(yōu)先使用HttpURLConnection或OkHttp。

Spring項(xiàng)目：使用RestTemplate（傳統(tǒng)同步）或WebClient（響應(yīng)式異步）。

微服務(wù)架構(gòu)：使用Feign Client。

高性能需求：選擇OkHttp或Apache HttpClient。

SOAP協(xié)議：使用JAX-WS或Apache CXF。

到此這篇關(guān)于java對(duì)接第三方接口的三種實(shí)現(xiàn)方式的文章就介紹到這了,更多相關(guān)java對(duì)接第三方接口內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: