Platform For AI:Apêndice: Configure timeouts de gateway dedicado

import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.client.config.RequestConfig;
import java.util.concurrent.TimeUnit;

public class HttpClientIdleTimeout {
    public static void main(String[] args) throws InterruptedException {
        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
        // Example value: max connections per route
        cm.setDefaultMaxPerRoute(20);
         // Example value: max total connections
        cm.setMaxTotal(100);

        RequestConfig requestConfig = RequestConfig.custom()
                // Example value: connect timeout 5 seconds
                .setConnectTimeout(5000)
                // Example value: read timeout 10 seconds
                .setSocketTimeout(10000)
                .build();

        try (CloseableHttpClient httpClient = HttpClients.custom()
                .setConnectionManager(cm)
                .setDefaultRequestConfig(requestConfig)
                .build()) {

            // Start a background thread to clean up idle connections periodically
            Thread cleanerThread = new Thread(() -> {
                try {
                    while (!Thread.currentThread().isInterrupted()) {
                        // Example value: check every 5 seconds
                        Thread.sleep(5000);
                        // Close connections idle for more than 500 seconds (less than gateway idle timeout of 600 seconds)
                        cm.closeIdleConnections(500, TimeUnit.SECONDS);
                        // Close expired connections (e.g., connections closed by the server)
                        cm.closeExpiredConnections();
                    }
                } catch (InterruptedException e) {
                    // Restore interrupted status
                    Thread.currentThread().interrupt();
                }
            });
            // Set as daemon thread so it exits when the main thread exits
            cleanerThread.setDaemon(true);
            cleanerThread.start();

            // Execute HTTP requests...
            // Example: httpClient.execute(new HttpGet("http://your-gateway-url"));

            // Simulate the program running for a period. Example value: run for 1 minute
            Thread.sleep(60000);

            // Stop the cleaner thread (in production, gracefully shut it down during application shutdown)
            cleanerThread.interrupt();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

package main

import (
    "net/http"
    "time"
)

func main() {
    // Create a custom Transport
    tr := &http.Transport{
        MaxIdleConns:        100,              // Maximum number of idle connections
        IdleConnTimeout:     500 * time.Second, // Idle connection timeout, e.g. 500 seconds (less than 600 seconds)
        DisableKeepAlives:   false,            // Enable Keep-Alive
    }
}

import com.aliyun.openservices.eas.predict.http.HttpConfig;

public class EasSdkTimeoutJava {
    public static void main(String[] args) {
        // 1. Global client configuration
        HttpConfig httpConfig = new HttpConfig();
        // Enable idle connection cleanup, in milliseconds. Set based on your client requirements.
        httpConfig.setConnectionCleanupInterval(5000);
        // Set the idle connection timeout to 500 seconds, less than the fully managed gateway idle timeout of 600 seconds
        httpConfig.setIdleConnectionTimeout(500000);
        ...
    }
}

import org.apache.http.client.config.RequestConfig;

public class ApacheHttpClientTimeout {
    public static void main(String[] args) {
        // Set the client request timeout slightly above the gateway request timeout.
        // If the gateway default is 600 seconds, use 610 seconds here.
        RequestConfig requestConfig = RequestConfig.custom()
                // Example value: connection timeout in milliseconds
                .setConnectTimeout(5000)
                // Data transfer timeout (read timeout) in milliseconds (610 seconds)
                .setSocketTimeout(610000)
                .build();
    }
}

package main

import (
    "context"
    "fmt"
    "io"
    "net/http"
    "time"
)

func main() {
    // Recommended: set client request timeout slightly greater than or equal to the gateway request timeout (default 600 seconds). Use 610 seconds here.
    client := &http.Client{
        Timeout: 610 * time.Second, // Timeout for the entire request
    }

    req, err := http.NewRequest("GET", "http://your-gateway-url", nil)
    if err != nil {
        fmt.Println("Error creating request:", err)
        return
    }

    // You can also set a shorter timeout for individual requests
    ctx, cancel := context.WithTimeout(req.Context(), 610*time.Second) // 610 seconds
    defer cancel()
    req = req.WithContext(ctx)

    resp, err := client.Do(req)
    if err != nil {
            fmt.Println("Error sending request:", err)
            // Check if it is a timeout error
            if t, ok := err.(interface{ Timeout() bool }); ok && t.Timeout() {
                    fmt.Println("Request timed out!")
            }
            return
    }
    defer resp.Body.Close()

    body, err := io.ReadAll(resp.Body)
    if err != nil {
        fmt.Println("Error reading response body:", err)
        return
    }
    fmt.Printf("Response Status: %s\n", resp.Status)
    fmt.Printf("Response Body: %s\n", body)
}

import com.aliyun.openservices.eas.predict.http.HttpConfig;

public class EasSdkTimeoutJava {
    public static void main(String[] args) {
        // 1. Global client configuration
        HttpConfig httpConfig = new HttpConfig();
        // Connection timeout
        httpConfig.setConnectTimeout(5);
        // Read timeout. Set the client request timeout slightly above the gateway request timeout.
        // If the gateway default is 600 seconds, use 610 seconds here.
        httpConfig.setReadTimeout(610);

    }
}