Java对接Dify API接口完整指南

Java对接Dify API接口完整指南

一、Dify API简介

Dify是一款AI应用开发平台，提供多种自然语言处理能力。通过调用Dify开放API，开发者可以快速集成智能对话、文本生成等功能到自己的Java应用中。

二、准备工作

1. 获取API密钥

   • 登录Dify平台控制台
   • 在「API密钥」模块创建新的密钥

   • 添加依赖

    org.apache.httpcomponents
    httpclient
    4.5.13



    com.fasterxml.jackson.core
    jackson-databind
    2.13.3

三、基础对接实现

1. 封装HTTP工具类

import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
public class DifyApiClient {
    private static final String API_BASE_URL = "https://api.dify.ai/v1";
    private final String apiKey;
    
    public DifyApiClient(String apiKey) {
        this.apiKey = apiKey;
    }
    
    public String post(String endpoint, String requestBody) throws Exception {
        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
            HttpPost httpPost = new HttpPost(API_BASE_URL + endpoint);
            
            // 设置请求头
            httpPost.setHeader("Authorization", "Bearer " + apiKey);
            httpPost.setHeader("Content-Type", "application/json");
            
            // 设置请求体
            httpPost.setEntity(new StringEntity(requestBody));
            
            // 执行请求
            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {
                HttpEntity entity = response.getEntity();
                return EntityUtils.toString(entity);
            }
        }
    }
}

2. 调用文本生成接口

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
public class TextGenerationExample {
    public static void main(String[] args) {
        String apiKey = "your_api_key_here";
        DifyApiClient client = new DifyApiClient(apiKey);
        
        ObjectMapper mapper = new ObjectMapper();
        ObjectNode requestBody = mapper.createObjectNode();
        requestBody.put("prompt", "请用Java写一个快速排序算法");
        requestBody.put("max_tokens", 1000);
        
        try {
            String response = client.post("/completions", requestBody.toString());
            System.out.println("API响应: " + response);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

四、高级功能实现

1. 流式响应处理

// 使用WebSocket实现流式响应
import javax.websocket.*;
import java.net.URI;
@ClientEndpoint
public class DifyStreamClient {
    private Session session;
    
    public void connect(String wsUrl) throws Exception {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        container.connectToServer(this, new URI(wsUrl));
    }
    
    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        System.out.println("连接已建立");
    }
    
    @OnMessage
    public void onMessage(String message) {
        System.out.println("收到消息: " + message);
    }
    
    public void sendMessage(String message) throws Exception {
        session.getBasicRemote().sendText(message);
    }
}

2. 异常处理增强

public class DifyApiException extends RuntimeException {
    private final int statusCode;
    private final String errorResponse;
    
    public DifyApiException(int statusCode, String errorResponse) {
        super("API请求失败，状态码: " + statusCode);
        this.statusCode = statusCode;
        this.errorResponse = errorResponse;
    }
    
    // getter方法...
}
// 在DifyApiClient中修改post方法
if (response.getStatusLine().getStatusCode() != 200) {
    throw new DifyApiException(
        response.getStatusLine().getStatusCode(),
        EntityUtils.toString(entity)
    );
}

五、最佳实践建议

1. 连接池配置：使用连接池提高性能

   PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
   cm.setMaxTotal(200);
   cm.setDefaultMaxPerRoute(20);
   

2. 超时设置：避免长时间等待

   RequestConfig config = RequestConfig.custom()
       .setConnectTimeout(5000)
       .setSocketTimeout(15000)
       .build();
   

3. 重试机制：对临时性错误自动重试

   HttpRequestRetryHandler retryHandler = (exception, executionCount, context) -> {
       return executionCount