分布式速率限流

<?php
$ch = curl_init('https://api.ynlskj.com.cn/gateway/ratelimit');
curl_setopt_array($ch, [
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_CUSTOMREQUEST => 'POST',
    CURLOPT_HTTPHEADER => ['X-API-Key: 你的密钥', 'Content-Type: application/json'],
    CURLOPT_POSTFIELDS => '{
    "action": "check",
    "key": "login:user_10086",
    "limit": 10,
    "window": 60,
    "algorithm": "token_bucket"
}',
]);
echo curl_exec($ch);

import requests

url = 'https://api.ynlskj.com.cn/gateway/ratelimit'
headers = {'X-API-Key': '你的密钥'}
resp = requests.post(url, headers=headers, json={
    "action": "check",
    "key": "login:user_10086",
    "limit": 10,
    "window": 60,
    "algorithm": "token_bucket"
}, timeout=15)
print(resp.text)

package main

import (
	"fmt"
	"io"
	"net/http"
	"strings"
)

func main() {
	body := strings.NewReader(`{
    "action": "check",
    "key": "login:user_10086",
    "limit": 10,
    "window": 60,
    "algorithm": "token_bucket"
}`)
	req, _ := http.NewRequest("POST", "https://api.ynlskj.com.cn/gateway/ratelimit", body)
	req.Header.Set("X-API-Key", "你的密钥")
	req.Header.Set("Content-Type", "application/json")
	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		panic(err)
	}
	defer resp.Body.Close()
	out, _ := io.ReadAll(resp.Body)
	fmt.Println(string(out))
}

fetch('https://api.ynlskj.com.cn/gateway/ratelimit', {
  method: 'POST',
  headers: {
    'X-API-Key': '你的密钥',
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    "action": "check",
    "key": "login:user_10086",
    "limit": 10,
    "window": 60,
    "algorithm": "token_bucket"
})
})
  .then(res => res.json())
  .then(data => console.log(data));

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

HttpClient client = HttpClient.newHttpClient();
HttpRequest request = HttpRequest.newBuilder()
    .uri(URI.create("https://api.ynlskj.com.cn/gateway/ratelimit"))
    .header("X-API-Key", "你的密钥")
    .header("Content-Type", "application/json")
    .POST(HttpRequest.BodyPublishers.ofString("{\n    \"action\": \"check\",\n    \"key\": \"login:user_10086\",\n    \"limit\": 10,\n    \"window\": 60,\n    \"algorithm\": \"token_bucket\"\n}"))
    .build();
HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
System.out.println(response.body());

using System.Net.Http;
using System.Text;

var client = new HttpClient();
client.DefaultRequestHeaders.Add("X-API-Key", "你的密钥");
var content = new StringContent("{\n    \"action\": \"check\",\n    \"key\": \"login:user_10086\",\n    \"limit\": 10,\n    \"window\": 60,\n    \"algorithm\": \"token_bucket\"\n}", Encoding.UTF8, "application/json");
var result = await client.PostAsync("https://api.ynlskj.com.cn/gateway/ratelimit", content);
Console.WriteLine(await result.Content.ReadAsStringAsync());

curl -X POST "https://api.ynlskj.com.cn/gateway/ratelimit" \
  -H "X-API-Key: 你的密钥" \
  -H "Content-Type: application/json" \
  -d '{
    "action": "check",
    "key": "login:user_10086",
    "limit": 10,
    "window": 60,
    "algorithm": "token_bucket"
}'