from flask import Flask,request,jsonify
import math

app = Flask(__name__)

#定義一個(gè)簡(jiǎn)單的API端點(diǎn)，計(jì)算平方根
@app.route('/calculate',methods=['POST'])
def calculate():
	data = request.get_json()
	number = data['number']
	result = math.sqrt(number)
	return jsonify({'result': result, 'python_version': '計(jì)算完成'})

#文本處理
@app.route('/process_text', methods=['POST'])
def process_text():
    data = request.get_json()
    text = data['text']
    processed_text = text.upper() + " - Processed by Python"
    return jsonify({'processed_text': processed_text})

if __name__ == '__main__':
    app.run(debug=True, host='0.0.0.0', port=5000)

public class PythonServiceClient {

    public static void main(String[] args) {
        RestTemplate restTemplate = new RestTemplate();
        String pythonServiceUrl = "http://localhost:5000/calculate";

        // 準(zhǔn)備請(qǐng)求數(shù)據(jù)
        Map<String, Object> requestMap = new HashMap<>();
        requestMap.put("number", 9.0);

        // 發(fā)送POST請(qǐng)求并獲取響應(yīng)
        ResponseEntity<Map> response = restTemplate.postForEntity(
                pythonServiceUrl,
                requestMap,
                Map.class
        );

        // 處理響應(yīng)
        if (response.getStatusCode().is2xxSuccessful()) {
            Map<String, Object> responseBody = response.getBody();
            System.out.println("計(jì)算結(jié)果: " + responseBody.get("result"));
            System.out.println("信息: " + responseBody.get("python_version"));
        } else {
            System.out.println("請(qǐng)求失敗: " + response.getStatusCode());
        }
    }
}

public class PythonServiceWebClient {

    public static void main(String[] args) throws InterruptedException {
        WebClient webClient = WebClient.create("http://localhost:5000");

        Mono<Map> responseMono = webClient.post()
                .uri("/process_text")
                .bodyValue(Collections.singletonMap("text", "hello from java"))
                .retrieve()
                .bodyToMono(Map.class);

        // 異步非阻塞地獲取結(jié)果
        responseMono.subscribe(response -> {
            System.out.println("處理后的文本: " + response.get("processed_text"));
        });

        // 等待異步操作完成（實(shí)際生產(chǎn)環(huán)境中不需要這樣）
        Thread.sleep(1000);
    }
}

# 這是一個(gè)簡(jiǎn)單的Python腳本，從標(biāo)準(zhǔn)輸入讀取JSON，計(jì)算后輸出JSON
import sys
import json
import math

def main():
    # 從標(biāo)準(zhǔn)輸入讀取數(shù)據(jù)
    data = sys.stdin.read()
    try:
        request_data = json.loads(data)
        number = request_data['number']
        # 執(zhí)行計(jì)算
        result = math.sqrt(number)
        # 輸出結(jié)果到標(biāo)準(zhǔn)輸出
        print(json.dumps({
            "result": result,
            "status": "success"
        }))
    except Exception as e:
        print(json.dumps({
            "status": "error",
            "message": str(e)
        }))

if __name__ == "__main__":
    main()

public class ProcessBuilderExample {

    public static void main(String[] args) throws IOException, InterruptedException {
        // 1. 定義Python解釋器和腳本路徑
        String pythonInterpreter = "python3"; // 或 "python"，取決于系統(tǒng)
        String pythonScriptPath = "/path/to/your/math_utils.py"; // 替換為你的腳本絕對(duì)路徑

        // 2. 構(gòu)建命令
        ProcessBuilder processBuilder = new ProcessBuilder(
                pythonInterpreter,
                "-u", // 強(qiáng)制標(biāo)準(zhǔn)輸出和錯(cuò)誤無(wú)緩沖，很重要！
                pythonScriptPath
        );
        processBuilder.redirectErrorStream(true); // 將錯(cuò)誤流合并到輸入流

        // 3. 啟動(dòng)進(jìn)程
        Process process = processBuilder.start();

        // 4. 準(zhǔn)備輸入數(shù)據(jù)并通過(guò)輸出流發(fā)送給Python腳本
        Map<String, Object> inputData = new HashMap<>();
        inputData.put("number", 16.0);
        String jsonInput = new com.fasterxml.jackson.databind.ObjectMapper().writeValueAsString(inputData); // 可以使用任何JSON庫(kù)

        try (BufferedWriter writer = new BufferedWriter(
                new OutputStreamWriter(process.getOutputStream(), StandardCharsets.UTF_8))) {
            writer.write(jsonInput);
            writer.flush();
        }

        // 5. 讀取Python腳本的輸出
        StringBuilder output = new StringBuilder();
        try (BufferedReader reader = new BufferedReader(
                new InputStreamReader(process.getInputStream(), StandardCharsets.UTF_8))) {
            String line;
            while ((line = reader.readLine()) != null) {
                output.append(line);
            }
        }

        // 6. 等待進(jìn)程結(jié)束并獲取返回值
        int exitCode = process.waitFor();
        if (exitCode == 0) {
            // 解析Python腳本的輸出
            Map<String, Object> result = new com.fasterxml.jackson.databind.ObjectMapper().readValue(
                    output.toString(), Map.class);
            System.out.println("成功: " + result.get("result"));
        } else {
            System.err.println("Python腳本執(zhí)行錯(cuò)誤: ");
            System.err.println(output);
        }
    }
}

public class JythonExample {
    public static void main(String[] args) {
        try (PythonInterpreter pyInterp = new PythonInterpreter()) {
            // 執(zhí)行簡(jiǎn)單的Python語(yǔ)句
            pyInterp.exec("print('Hello from Jython!)");
            pyInterp.exec("import math");

            // 在Python中設(shè)置變量，在Java中獲取
            pyInterp.set("a", 10);
            pyInterp.exec("b = math.sqrt(a)");
            Number b = (Number) pyInterp.get("b");
            System.out.println("Square root of 10 from Jython: " + b);
        }
    }
}