1

dd

2025-12-26 cca0b258ffefd2ad478b9e5115200f5a223eb09f

 src/main/java/com/nq/utils/redis/RedisKeyUtil.java

@@ -21,6 +21,7 @@
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Map;
import java.util.concurrent.locks.ReentrantLock;


public class RedisKeyUtil {
@@ -89,43 +90,78 @@
        }
    }

    private static final ReentrantLock lock = new ReentrantLock();
    private static String lastResult = null;
    private static long lastExecuteTime = 0;
    private static final long MIN_INTERVAL_MS = 3000;

    public static String doPost(String pid) {
        // 从配置中获取 API URL，并拼接 key
        // 快速检查缓存
        long currentTime = System.currentTimeMillis();
        if (lastResult != null && (currentTime - lastExecuteTime) < MIN_INTERVAL_MS) {
            return lastResult;
        }

        // 需要获取锁执行新请求
        return executeWithLock(pid);
    }

    private static String executeWithLock(String pid) {
        String apiUrl = PropertiesUtil.getProperty("JS_IN_HTTP_URL") + "stock?key=" + PropertiesUtil.getProperty("JS_IN_KEY");

        lock.lock();
        try {
            // 双检锁：再次检查缓存
            long currentTime = System.currentTimeMillis();
            if (lastResult != null && (currentTime - lastExecuteTime) < MIN_INTERVAL_MS) {
                return lastResult;
            }

            // 执行POST请求
        String result = null;
        try {
            URL url = new URL(apiUrl);
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();

            // 设置请求方法为 POST
            connection.setRequestMethod("POST");
            // 设置请求头
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            connection.setDoOutput(true); // 允许向连接输出
                connection.setDoOutput(true);

            // 构建 POST 数据
            String postData = "pid=" + pid;

            // 发送 POST 请求
            try (OutputStream os = connection.getOutputStream()) {
                byte[] input = postData.getBytes("utf-8");
                os.write(input, 0, input.length);
            }

            // 读取响应
            BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            String inputLine;
            StringBuffer response = new StringBuffer();
                StringBuilder response = new StringBuilder();

            while ((inputLine = in.readLine()) != null) {
                response.append(inputLine);
            }
            in.close();

            result = response.toString();

                // 更新缓存
                lastResult = result;
                lastExecuteTime = System.currentTimeMillis();

        } catch (Exception e) {
            e.printStackTrace();
                // 请求失败时返回缓存
                if (lastResult != null) {
                    return lastResult;
        }
            }

        return result;

        } finally {
            lock.unlock();
        }
    }