| | |
| | | |
| | | static HttpsClient() |
| | | { |
| | | // 设置定时器,每10分钟清理一次requestTracker的数据 |
| | | cleanupTimer = new Timer(10 * 60 * 1000); |
| | | // 设置定时器,每5分钟清理一次requestTracker的数据 |
| | | cleanupTimer = new Timer(2 * 60 * 1000); |
| | | cleanupTimer.Elapsed += CleanupRequestTracker; |
| | | cleanupTimer.AutoReset = true; |
| | | cleanupTimer.Enabled = true; |
| | |
| | | // 检查请求次数和时间限制 |
| | | if (requestTracker.TryGetValue(requestKey, out var requestInfo)) |
| | | { |
| | | if (requestInfo.Count >= 5 && DateTime.Now < requestInfo.LastRequestTime.AddMinutes(3)) |
| | | if (requestInfo.Count >= 10 && DateTime.Now < requestInfo.LastRequestTime.AddMinutes(2)) |
| | | { |
| | | // 如果请求次数超过限制且未超过10分钟,抛出异常 |
| | | Console.WriteLine("请求次数已达到限制,请稍后再试。"); |
| | |
| | | requestTracker[requestKey] = (1, DateTime.Now); |
| | | } |
| | | |
| | | |
| | | // 记录请求参数 |
| | | LogRequestParameters(parameters, url); |
| | | |
| | | // 创建HttpClient实例 |
| | | using (HttpClient client = new HttpClient()) |
| | | { |
| | | // 将参数转换为FormUrlEncodedContent |
| | | string content = JsonConvert.SerializeObject(parameters); |
| | | |
| | | //client.Timeout = TimeSpan.from; |
| | | |
| | | var request = new HttpRequestMessage(HttpMethod.Post, url); |
| | | |
| | | request.Content = new StringContent(content, Encoding.UTF8, "application/json"); |
| | | //var content = new FormUrlEncodedContent(ConvertToKeyValuePairs(parameters)); |
| | | //// 发送POST请求并获取响应 |
| | | //HttpResponseMessage response = await client.PostAsync(url, content); |
| | | HttpResponseMessage response = await client.SendAsync(request); |
| | | |
| | | // 确保响应成功 |
| | | response.EnsureSuccessStatusCode(); |
| | | |
| | | // 读取响应内容 |
| | | string responseBody = await response.Content.ReadAsStringAsync(); |
| | | |
| | | // 记录响应参数 |
| | | LogResponseParameters(responseBody, url); |
| | | |
| | | // 返回响应内容 |
| | | return responseBody; |
| | | } |
| | | } |
| | | |
| | | public static async Task<string> PostNotLimitAsync(string url, Dictionary<string, object> parameters) |
| | | { |
| | | |
| | | // 记录请求参数 |
| | | LogRequestParameters(parameters, url); |
| | | |
| | |
| | | DateTime now = DateTime.Now; |
| | | |
| | | // 遍历并清理requestTracker中超过10分钟的记录 |
| | | var keysToRemove = requestTracker.Keys.Where(key => now > requestTracker[key].LastRequestTime.AddMinutes(10)).ToList(); |
| | | var keysToRemove = requestTracker.Keys.Where(key => now > requestTracker[key].LastRequestTime.AddMinutes(2)).ToList(); |
| | | |
| | | foreach (var key in keysToRemove) |
| | | { |