快递鸟海运查询接口全面解析：从入门到精通，助力跨境物流可视化

1 前言

在全球化的今天，海运作为国际贸易的主要运输方式，承担着超过80%的货物运输量。无论是跨境电商卖家、外贸企业，还是物流平台服务商，对海运物流的实时追踪需求都在快速增长。然而，海运物流的信息化程度长期落后于快递领域，货主往往面临“货物发出后如同石沉大海”的困境。

快递鸟（Kuaidiniao）作为国内知名的物流 API 服务商，近年推出了海运查询接口，将物流追踪能力从快递领域延伸至海运场景，为跨境物流可视化提供了强有力的技术支撑。本文将从技术原理、接口规格、集成方案和实战代码等多个维度，对快递鸟海运查询接口进行全面解析。

---

2 一、海运物流追踪的挑战与机遇

▎ 1.1 海运物流的特殊性

与国内快递不同，海运物流具有以下显著特点：

• 运输周期长：从中国港口到欧洲基本港通常需要25-35天，到美洲西海岸约15-20天，到非洲或南美洲则可能超过40天
• 节点信息少：相比快递的揽件、中转、派送等多达十几个节点，海运往往只有装船、离港、到港等少数关键节点
• 数据分散：船公司、货代、码头、海关等多方参与，数据分散在不同系统中
• 格式不统一：不同船公司和货代使用不同的数据格式和术语体系

这些特点使得海运物流追踪的技术实现远比快递复杂。

▎ 1.2 市场需求驱动

• 跨境电商爆发：亚马逊、FBA、Shopify等平台兴起，卖家需要精确掌握备货和到货时间
• 供应链透明化：品牌商和采购商要求全链路可视化
• 合规要求：海关预清关、危品监控等场景需要实时货物状态
• 竞争压力：物流服务商需要差异化能力，追踪服务成为标配

正是这些需求，推动了快递鸟等服务商在海运追踪领域的持续投入。

---

3 二、快递鸟海运查询接口概述

▎ 2.1 产品定位

快递鸟海运查询接口是快递鸟物流 API 矩阵的重要组成部分，与已有的快递查询接口、即时配送接口共同构成全场景物流追踪解决方案。其核心定位是：

为电商平台、物流系统、供应链管理系统提供统一、标准化的海运物流状态查询能力，屏蔽底层多家船公司和货代的数据差异。

▎ 2.2 核心能力

快递鸟海运查询接口提供以下核心能力：

能力项	说明
提单号查询	支持 Bill of Lading (B/L) 单号查询货物状态
船名航次查询	支持船名+航次号组合查询
多承运商覆盖	整合多家主流船公司和货代数据源
实时状态推送	支持物流状态变更的主动推送（需开通推送服务）
中文友好	返回数据支持中文，便于国内系统直接使用
历史轨迹	支持查询一定周期内的完整物流轨迹

▎ 2.3 支持的船公司和航线

根据官方文档，快递鸟海运查询接口覆盖了全球主流船公司，包括但不限于：

第一梯队（全球主要班轮公司）：

• 马士基（Maersk）
• MSC（地中海航运）
• CMA CGM（达飞轮船）
• 中远海运（COSCO Shipping）
• 长荣海运（Evergreen）
• 赫伯罗特（Hapag-Lloyd）
• ONE（Ocean Network Express）
• 阳明海运（Yang Ming）
• HMM
• 以星航运（ZIM）

覆盖航线：

• 亚欧航线（Asia-Europe）
• 跨太平洋航线（Trans-Pacific）
• 跨大西洋航线（Trans-Atlantic）
• 亚洲区域内航线（Intra-Asia）
• 中东印巴航线

注意：具体的承运商覆盖范围和数据更新频率可能随合作推进而变化，建议在实际对接前查阅最新的官方接口文档。

---

4 三、接口技术规格详解

▎ 3.1 请求地址与协议

快递鸟海运查询接口采用 HTTP/HTTPS 协议，JSON 数据格式，遵循 RESTful 设计风格。

正式环境请求地址：

POST https://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx

▎ 3.2 请求参数

以下是海运查询接口的核心请求字段：

参数名	类型	必填	说明
RequestType	String	是	接口指令码，海运查询固定为"2002"
EBusinessID	String	是	用户 ID，从快递鸟管理后台获取
RequestData	String	是	请求数据 JSON 字符串，需 URL 编码
DataSign	String	是	数据签名，用于接口鉴权
DataType	String	否	数据格式，默认"2"（JSON）

RequestData 内部结构：

{
  "ShipperCode": "COSCO",
  "BillNo": "COSU1234567890",
  "ShipName": "",
  "VoyageNo": ""
}

▎ 3.3 响应参数

接口返回物流追踪的详细状态信息：

{
  "EBusinessID": "1234567890",
  "UpdateTime": "2026-05-18 10:30:00",
  "ShipperCode": "COSCO",
  "Success": true,
  "BillNo": "COSU1234567890",
  "LogisticCode": "COSU1234567890",
  "State": "302",
  "StateLast": "已装船",
  "Traces": [
    {
      "AcceptTime": "2026-04-15 08:00:00",
      "AcceptStation": "货物已装船离开盐田港",
      "Location": "盐田港",
      "State": "301",
      "StateName": "已装船"
    },
    {
      "AcceptTime": "2026-04-10 14:30:00",
      "AcceptStation": "货物已进港等待装船",
      "Location": "盐田港",
      "State": "215",
      "StateName": "已进港"
    }
  ]
}

▎ 3.4 物流状态代码说明

海运物流状态采用状态码体系，关键状态码对照：

状态码	状态名称	说明
0	暂无轨迹	暂时无物流信息
101	揽收成功	货代已揽收货物
102	预报成功	货代已做预报
103	补料确认	补料（SI）已确认
104	放单确认	提单已放单
201	预报	已提交装船预报
202	运抵报告	货物运抵目的港报告
203	海关放行	海关已放行
204	等待装船	货物等待装船
205	装船中	正在装船作业
206	卸船中	正在卸船作业
207	到港	船舶已到港
208	提货	已安排提货
209	拆箱中	正在拆箱作业
210	还箱中	正在返还空箱
211	清关中	正在清关流程
212	已清关	清关已完成
213	派送中	货物派送中
214	已签收	收件人已签收
215	已进港	货物已进入港口
216	运输中	货物运输途中
217	已离港	船舶已离港
301	已装船	货物已装上船舶
302	航行中	船舶航行中
303	到港待卸	船舶到港等待卸货
401	异常	发生异常情况
402	退运	货物被退回
403	销毁	货物已销毁
404	扣留	货物被海关扣留

---

5 四、Java SDK 集成实战

▎ 4.1 环境准备

首先，在项目中引入快递鸟 Java SDK：

Maven 项目（在 pom.xml 中添加）：

<dependency>
    <groupId>com.kdniao</groupId>
    <artifactId>kdniao-sdk</artifactId>
    <version>1.0.0</version>
</dependency>

Gradle 项目：

implementation 'com.kdniao:kdniao-sdk:1.0.0'

如果 SDK 版本不可用，也可以直接使用 HttpClient 或 OkHttp 手写调用逻辑。

▎ 4.2 签名工具类

数据签名是接口鉴权的核心，以下是签名生成工具类：

import java.net.URLEncoder;
import java.security.MessageDigest;
import java.nio.charset.StandardCharsets;

public class KdNiaoSignUtil {

    private static final String APP_KEY = "your-app-key-here";

    public static String generateSign(String data) {
        try {
            String signStr = data + APP_KEY;
            MessageDigest md = MessageDigest.getInstance("MD5");
            byte[] digest = md.digest(signStr.getBytes(StandardCharsets.UTF_8));
            StringBuilder sb = new StringBuilder();
            for (byte b : digest) {
                sb.append(String.format("%02x", b));
            }
            return URLEncoder.encode(sb.toString().toUpperCase(), "UTF-8");
        } catch (Exception e) {
            throw new RuntimeException("签名生成失败", e);
        }
    }

    public static Map<String, String> buildRequest(String requestData) {
        Map<String, String> params = new HashMap<>();
        params.put("RequestType", "2002");
        params.put("EBusinessID", "your-ebusiness-id");
        params.put("RequestData", URLEncoder.encode(requestData, StandardCharsets.UTF_8));
        params.put("DataSign", generateSign(requestData));
        params.put("DataType", "2");
        return params;
    }
}

▎ 4.3 海运查询服务实现

import com.fasterxml.jackson.databind.ObjectMapper;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.HttpResponse;
import java.net.URI;
import java.util.*;

public class SeaFreightTrackingService {

    private static final String API_URL = "https://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx";
    private static final ObjectMapper objectMapper = new ObjectMapper();

    public SeaFreightResponse queryTracking(String shipperCode, String billNo) {
        try {
            Map<String, Object> requestData = new HashMap<>();
            requestData.put("ShipperCode", shipperCode);
            requestData.put("BillNo", billNo);

            String jsonData = objectMapper.writeValueAsString(requestData);
            Map<String, String> params = KdNiaoSignUtil.buildRequest(jsonData);

            HttpClient client = HttpClient.newHttpClient();
            StringBuilder bodyBuilder = new StringBuilder();
            params.forEach((k, v) -> {
                if (bodyBuilder.length() > 0) bodyBuilder.append("&");
                bodyBuilder.append(k).append("=").append(v);
            });

            HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(API_URL))
                .header("Content-Type", "application/x-www-form-urlencoded")
                .POST(HttpRequest.BodyPublishers.ofString(bodyBuilder.toString()))
                .build();

            HttpResponse<String> response = client.send(request,
                HttpResponse.BodyHandlers.ofString());

            return objectMapper.readValue(response.body(), SeaFreightResponse.class);

        } catch (Exception e) {
            throw new RuntimeException("海运查询请求失败: " + e.getMessage(), e);
        }
    }

    public List<SeaFreightResponse> batchQuery(List<Map<String, String>> queries) {
        List<SeaFreightResponse> results = new ArrayList<>();
        for (Map<String, String> q : queries) {
            try {
                SeaFreightResponse resp = queryTracking(
                    q.get("shipperCode"),
                    q.get("billNo")
                );
                results.add(resp);
                Thread.sleep(500);
            } catch (Exception e) {
                SeaFreightResponse errResp = new SeaFreightResponse();
                errResp.setSuccess(false);
                errResp.setReason("查询失败: " + e.getMessage());
                errResp.setBillNo(q.get("billNo"));
                results.add(errResp);
            }
        }
        return results;
    }
}

▎ 4.4 响应数据模型

import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;

public class SeaFreightResponse {
    @JsonProperty("EBusinessID") private String eBusinessID;
    @JsonProperty("Success") private boolean success;
    @JsonProperty("Reason") private String reason;
    @JsonProperty("BillNo") private String billNo;
    @JsonProperty("ShipperCode") private String shipperCode;
    @JsonProperty("State") private String state;
    @JsonProperty("StateLast") private String stateLast;
    @JsonProperty("Traces") private List<TraceNode> traces;
}

public class TraceNode {
    @JsonProperty("AcceptTime") private String acceptTime;
    @JsonProperty("AcceptStation") private String acceptStation;
    @JsonProperty("Location") private String location;
    @JsonProperty("State") private String state;
    @JsonProperty("StateName") private String stateName;
}

---

6 五、Python 集成方案

对于使用 Python 技术栈的团队，以下是简洁的集成实现：

import requests
import hashlib
import urllib.parse
import json
from datetime import datetime

class KdNiaoSeaFreightAPI:
    """快递鸟海运查询接口 Python 封装"""

    API_URL = "https://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx"

    def __init__(self, ebusiness_id: str, app_key: str):
        self.ebusiness_id = ebusiness_id
        self.app_key = app_key

    def _generate_sign(self, request_data: str) -> str:
        """生成 MD5 签名"""
        sign_str = request_data + self.app_key
        md5_hash = hashlib.md5(sign_str.encode('utf-8')).hexdigest()
        return urllib.parse.quote(md5_hash.upper())

    def _build_params(self, request_data: dict) -> dict:
        """构建请求参数"""
        json_str = json.dumps(request_data, ensure_ascii=False)
        return {
            "RequestType": "2002",
            "EBusinessID": self.ebusiness_id,
            "RequestData": urllib.parse.quote(json_str),
            "DataSign": self._generate_sign(json_str),
            "DataType": "2"
        }

    def query(self, shipper_code: str, bill_no: str) -> dict:
        """查询单票海运货物"""
        request_data = {
            "ShipperCode": shipper_code,
            "BillNo": bill_no
        }
        params = self._build_params(request_data)
        try:
            response = requests.post(
                self.API_URL,
                data=params,
                headers={"Content-Type": "application/x-www-form-urlencoded"},
                timeout=30
            )
            response.raise_for_status()
            return response.json()
        except requests.RequestException as e:
            return {
                "Success": False,
                "Reason": f"请求失败: {str(e)}",
                "BillNo": bill_no
            }

    def format_tracking_info(self, response: dict) -> str:
        """格式化物流信息为可读文本"""
        if not response.get("Success"):
            return f"查询失败: {response.get('Reason', '未知原因')}"
        bill_no = response.get("BillNo", "")
        state_last = response.get("StateLast", "未知")
        traces = response.get("Traces", [])
        lines = [
            f"提单号: {bill_no}",
            f"当前状态: {state_last}",
            f"轨迹节点数: {len(traces)}",
            "-" * 40,
            "物流轨迹："
        ]
        for i, trace in enumerate(traces, 1):
            accept_time = trace.get("AcceptTime", "")
            station = trace.get("AcceptStation", "")
            location = trace.get("Location", "")
            state_name = trace.get("StateName", "")
            lines.append(f"{i}. [{accept_time}] {station}")
            if location:
                lines.append(f"   地点: {location} | 状态: {state_name}")
        return "\n".join(lines)


if __name__ == "__main__":
    api = KdNiaoSeaFreightAPI(
        ebusiness_id="your-ebusiness-id",
        app_key="your-app-key"
    )
    result = api.query("COSCO", "COSU0123456789")
    print(api.format_tracking_info(result))

---

7 六、Webhook 推送集成方案

▎ 6.1 为什么要用推送

轮询模式（定时调用查询接口）存在两个问题：

1. 资源浪费：即使货物状态未变化，也要反复请求
2. 实时性差：状态变化后需要等待下一次轮询才能感知

快递鸟支持 Webhook 推送模式，当物流状态发生变化时，服务端主动将状态推送到客户指定的回调地址。

▎ 6.2 推送配置

在快递鸟管理后台配置推送地址（通常是企业内网的 API 网关或公网可访问的 webhook 服务）：

推送地址格式: https://your-domain.com/api/kdniao/callback
推送协议: HTTP POST
数据格式: JSON

▎ 6.3 推送接收服务实现（Java Spring Boot）

@RestController
@RequestMapping("/api/kdniao")
public class KdNiaoCallbackController {

    private static final Logger logger = LoggerFactory.getLogger(
        KdNiaoCallbackController.class);

    @Autowired
    private SeaFreightTrackingService trackingService;

    @PostMapping("/callback")
    public Map<String, Object> receiveCallback(@RequestBody Map<String, Object> payload) {
        logger.info("收到快递鸟推送: {}", payload);

        String billNo = (String) payload.get("BillNo");
        String state = (String) payload.get("State");
        String stateName = (String) payload.get("StateName");
        String acceptTime = (String) payload.get("AcceptTime");
        String acceptStation = (String) payload.get("AcceptStation");

        try {
            trackingService.updateTrackingState(billNo, state, acceptTime, acceptStation);
            notificationService.notifyStateChange(billNo, stateName);
            return Map.of("Result", "true", "ReturnCode", "100", "Message", "成功");
        } catch (Exception e) {
            logger.error("处理推送失败", e);
            return Map.of("Result", "false", "ReturnCode", "101", "Message", e.getMessage());
        }
    }
}

▎ 6.4 推送数据格式

{
  "EBusinessID": "1234567890",
  "ShipperCode": "COSCO",
  "BillNo": "COSU0123456789",
  "LogisticCode": "COSU0123456789",
  "State": "303",
  "StateName": "到港待卸",
  "AcceptTime": "2026-05-18 08:30:00",
  "AcceptStation": "船舶已抵达洛杉矶港，等待泊位卸货",
  "Location": "洛杉矶港",
  "UpdateTime": "2026-05-18 08:30:00",
  "CallbackType": "2002"
}

---

8 七、高级应用场景

▎ 7.1 预计到港时间（ETA）计算

基于海运轨迹数据，可以估算货物的预计到港时间：

from datetime import datetime, timedelta

def calculate_eta(traces: list, dest_port: str = "LOS ANGELES") -> dict:
    """基于历史航行数据估算 ETA"""
    if not traces:
        return {"eta": None, "confidence": "low", "reason": "无轨迹数据"}

    latest_trace = traces[0]
    state = latest_trace.get("State", "")

    if state == "302":  # 航行中
        avg_speed_knots = 15
        remaining_distance_nm = 3500
        remaining_days = remaining_distance_nm / (avg_speed_knots * 24)
        eta_days = int(remaining_days)
        confidence = "medium"
    elif state == "207":  # 到港
        eta_days = 2
        confidence = "high"
    elif state == "301":  # 刚装船
        eta_days = 30
        confidence = "low"
    else:
        return {"eta": None, "confidence": "unknown", "reason": f"状态{state}无法估算"}

    eta_date = datetime.now() + timedelta(days=eta_days)
    return {
        "eta": eta_date.strftime("%Y-%m-%d"),
        "days_remaining": eta_days,
        "confidence": confidence,
        "current_state": latest_trace.get("StateName"),
        "last_update": latest_trace.get("AcceptTime")
    }

▎ 7.2 异常监控告警

通过定期扫描所有追踪中的货物，可以自动发现异常情况：

import time
from datetime import datetime, timedelta

class SeaFreightMonitor:
    """海运物流异常监控"""

    ABNORMAL_STATES = ["401", "402", "403", "404"]

    def __init__(self, api, alert_hook):
        self.api = api
        self.alert_hook = alert_hook

    def check_single(self, shipper_code: str, bill_no: str) -> list:
        """检查单票货物是否有异常"""
        alerts = []
        result = self.api.query(shipper_code, bill_no)

        if not result.get("Success"):
            alerts.append({"type": "query_failed", "bill_no": bill_no, "reason": result.get("Reason")})
            return alerts

        state = result.get("State", "")
        traces = result.get("Traces", [])

        if state in self.ABNORMAL_STATES:
            alerts.append({
                "type": "abnormal_state",
                "bill_no": bill_no,
                "state": state,
                "state_name": result.get("StateLast"),
                "station": traces[0].get("AcceptStation") if traces else ""
            })

        if traces:
            latest_time = traces[0].get("AcceptTime", "")
            if latest_time:
                days_since_update = (datetime.now() - parse_time(latest_time)).days
                if days_since_update > 7 and state not in ["208", "214"]:
                    alerts.append({
                        "type": "stale_status",
                        "bill_no": bill_no,
                        "days": days_since_update,
                        "current_state": result.get("StateLast")
                    })
        return alerts

    def monitor_all(self, shipment_list: list):
        """批量监控所有货物"""
        all_alerts = []
        for item in shipment_list:
            alerts = self.check_single(item["shipper_code"], item["bill_no"])
            all_alerts.extend(alerts)
            time.sleep(0.5)
        if all_alerts:
            self.alert_hook(all_alerts)
        return all_alerts

▎ 7.3 与 ERP/WMS 系统集成

在实际企业应用中，海运追踪数据通常需要与 ERP 或 WMS 系统打通：

企业业务系统 (ERP / WMS / 跨境电商平台)
                   |
             ① 查询请求
                   v
        物流追踪中间件
  (统一接口层 · 缓存 · 告警 · 数据持久化)
        |                        |
  ② 推送回调              ③ 轮询查询
        |                        |
   快递鸟海运 API          快递鸟海运 API
  (Webhook推送)            (主动轮询)
        |                        |
        +-----------+------------+
                    v
        快递鸟服务端 (整合多家船公司数据)

---

9 八、常见问题与解决方案

▎ Q1: 提单号查询无结果怎么办？

可能原因：

1. 提单号格式错误：检查是否为正确的 Master B/L 或 House B/L 号
2. 承运商代码错误：不同船公司的代码不同，建议查阅快递鸟官方承运商代码表
3. 数据尚未同步：货物出运后，船公司数据通常需要 1-3 天同步到快递鸟系统

解决方案：

• 尝试使用船名+航次号组合查询
• 联系货代获取对应的承运商代码
• 使用备用查询方式：通过货代系统或船公司官网查询

▎ Q2: 数据更新频率如何？

海运追踪数据的更新频率取决于船公司和货代的数据推送速度：

• 实时节点（离港、到港等）：通常在事件发生后 2-4 小时内可见
• 一般节点（航行中每日报平安）：可能每天更新一次
• 特殊情况（恶劣天气、港口拥堵）：可能出现较长时间的静默期

建议在应用层面做好静默期处理，不要将“无更新”等同于“异常”。

▎ Q3: 如何申请接口权限？

1. 前往快递鸟官网注册账号
2. 完成企业实名认证
3. 在控制台申请海运查询 API 权限
4. 获取 EBusinessID 和 AppKey
5. 阅读接口文档，了解调用限制和计费规则

快递鸟海运 API 通常有免费调用额度，超出后按调用量计费。具体价格策略请以官网最新公告为准。

▎ Q4: 接口调用频率限制是多少？

根据快递鸟的服务条款：

• 免费用户：建议每秒不超过 5 次调用
• 付费用户：根据套餐等级有所不同，通常为 50-200 次/秒
• 批量查询：建议添加适当的延迟（500ms-1s），避免触发限流

▎ Q5: 如何处理承运商代码映射？

不同系统对同一承运商使用的代码可能不同，建议维护一个映射表：

SHIPPER_CODE_MAP = {
    "COSCO": ["COSCO", "COS", "COSU"],
    "MAERSK": ["MAERSK", "MAEU", "MSKU"],
    "MSC": ["MSC", "MSCU", "MSMU"],
    "EVERGREEN": ["EVERGREEN", "EGLV", "EVEU"],
    "CMA_CGM": ["CMA", "CMAU", "CMDU"],
    "HAPAG_LLOYD": ["HAPAG", "HLCU", "HLCMU"],
    "YANG_MING": ["YANGMING", "YMLU", "YMMU"],
}

---

10 九、最佳实践总结

▎ 9.1 技术层面

实践项	建议
缓存策略	将查询结果缓存 30 分钟至 2 小时，避免重复查询
重试机制	对网络异常和临时失败实现 3 次重试，使用指数退避
幂等设计	推送回调处理应设计为幂等的，支持重复消费
数据持久化	每次查询结果建议持久化到数据库，便于历史追溯
错误分级	将不同类型的错误（网络、超时、无数据、限流）分级处理

▎ 9.2 产品层面

实践项	建议
多数据源互补	将快递鸟与船公司官网、货代系统交叉验证，提高可靠性
用户预期管理	在 UI 上展示“数据更新时间”，避免用户对实时性期望过高
ETA 展示	ETA 估算应同时展示置信度，避免给出过于精确的承诺
异常可视化	对异常状态（如海关扣留、退运）使用醒目的视觉提示

▎ 9.3 合规与安全

• 数据安全：海运数据可能涉及商业敏感信息，务必做好传输加密（HTTPS）和访问控制
• 隐私合规：追踪数据中如涉及收件人个人信息，需符合《个人信息保护法》要求
• API 密钥管理：AppKey 等凭证不要硬编码在代码中，推荐使用环境变量或密钥管理服务

---

11 结语

快递鸟海运查询接口为跨境物流追踪提供了一条相对便捷的技术路径，尤其对于中小型跨境电商和物流平台来说，无需逐一对接各家船公司和货代，通过统一的 API 即可获取较为完整的海运物流信息。

当然，海运物流追踪领域仍有不少挑战：数据覆盖的完整性有待提升、部分航线的更新及时性仍不理想、ETA 估算精度有限等。这些问题的解决，既需要快递鸟等服务商持续拓展数据合作，也需要行业各方共同推动数据标准化进程。

随着数字化港口、智能航运的发展，海运物流信息的实时性和透明度正在逐步提升。掌握好海运 API 集成技术，将在未来的跨境供应链竞争中占据重要优势。

如果你在集成过程中遇到具体问题，欢迎在评论区留言交流！

---

参考资料：

• 快递鸟官方 API 文档：https://www.kdniao.com/doc