using System.Net.Http;
using System.Text;
using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;
namespace ConsoleApp9
{
    internal class Program
    {
        private static readonly JsonSerializerSettings serializerSettings = new JsonSerializerSettings
        {
            ContractResolver = new CamelCasePropertyNamesContractResolver(),
            NullValueHandling = NullValueHandling.Ignore
        };
        private static readonly HttpClient httpClient = new HttpClient(); // 復(fù)用HttpClient實例
        private static readonly SemaphoreSlim semaphore = new SemaphoreSlim(100); // 限制并發(fā)請求數(shù)量為100
        static async Task Main(string[] args)
        {
            List<Task> tasks = new List<Task>();
            int taskNoCounter = 1; // 用于跟蹤 taskno
            // 只使用一個HttpClient對象（全局共享）
            for (int i = 0; i < 50; i++)
            {
                tasks.Add(Task.Run(async () =>
                {
                    // 等待信號量，控制最大并發(fā)數(shù)
                    await semaphore.WaitAsync();
                    try
                    {
                        var postData = new
                        {
                            taskno = taskNoCounter++,
                            content = "等待翻譯的內(nèi)容"
                        };
                        var json = JsonConvert.SerializeObject(postData, serializerSettings);
                        var reqdata = new StringContent(json, Encoding.UTF8, "application/json");
                        // 設(shè)置請求頭語言
                        httpClient.DefaultRequestHeaders.Add("Accept-Language", "en-US");                      
                        // 發(fā)送請求
                        var result = await httpClient.PostAsync("http://localhost:5000/translate", reqdata);
                        // 讀取并反序列化 JSON 數(shù)據(jù)
                        var content = await result.Content.ReadAsStringAsync();
                        var jsonResponse = JsonConvert.DeserializeObject<Response>(content);
                        var response = jsonResponse.Data.Content;
                       
                        // 反序列化后，直接輸出解碼后的文本
                        Console.WriteLine($"結(jié)果為：{response}");
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine($"請求失敗: {ex.Message}");
                    }
                    finally
                    {
                        // 釋放信號量
                        semaphore.Release();
                    }
                }));
            }
            await Task.WhenAll(tasks);
        }
    }
    // 定義與響應(yīng)結(jié)構(gòu)匹配的類
    public class Response
    {
        public int Code { get; set; }
        public ResponseData Data { get; set; }
        public string Msg { get; set; }
    }
    public class ResponseData
    {
        public string Content { get; set; }
        public string Lang { get; set; }
        public int Taskno { get; set; }
    }
}

from flask import Flask, request, jsonify
from google.cloud import translate_v2 as translate
app = Flask(__name__)
# 初始化 Google Cloud Translate 客戶端
translator = translate.Client()
@app.route('/translate', methods=['POST'])
def translate_text():
    try:
        # 從請求中獲取 JSON 數(shù)據(jù)
        data = request.get_json()
        # 獲取請求的文本內(nèi)容
        text = data.get('content')
        taskno = data.get('taskno', 1)
        # 獲取請求頭中的 Accept-Language 信息，默認為 'zh-CN'
        accept_language = request.headers.get('Accept-Language', 'zh-CN')
        # 調(diào)用 Google Translate API 進行翻譯
        result = translator.translate(text, target_language=accept_language)
        # 構(gòu)造響應(yīng)數(shù)據(jù)
        response_data = {
            "code": 200,
            "msg": "OK",
            "data": {
                "taskno": taskno,
                "content": result['translatedText'],
                "lang": accept_language
            }
        }
        # 返回 JSON 響應(yīng)
        return jsonify(response_data), 200
    except Exception as e:
        return jsonify({"code": 500, "msg": str(e)}), 500
if __name__ == "__main__":
    app.run(debug=True, host="0.0.0.0", port=5000)