异步任务队列

<?php
$ch = curl_init('https://api.ynlskj.com.cn/gateway/queue');
curl_setopt_array($ch, [
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_CUSTOMREQUEST => 'POST',
    CURLOPT_HTTPHEADER => ['X-API-Key: 你的密钥', 'Content-Type: application/json'],
    CURLOPT_POSTFIELDS => '{
    "action": "delay",
    "callback_url": "https://你的域名/api/order/webhook",
    "delay": 60,
    "payload": {
        "order_id": "ORDER123",
        "event": "timeout_cancel"
    }
}',
]);
echo curl_exec($ch);

import requests

url = 'https://api.ynlskj.com.cn/gateway/queue'
headers = {'X-API-Key': '你的密钥'}
resp = requests.post(url, headers=headers, json={
    "action": "delay",
    "callback_url": "https://你的域名/api/order/webhook",
    "delay": 60,
    "payload": {
        "order_id": "ORDER123",
        "event": "timeout_cancel"
    }
}, timeout=15)
print(resp.text)

package main

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

func main() {
	body := strings.NewReader(`{
    "action": "delay",
    "callback_url": "https://你的域名/api/order/webhook",
    "delay": 60,
    "payload": {
        "order_id": "ORDER123",
        "event": "timeout_cancel"
    }
}`)
	req, _ := http.NewRequest("POST", "https://api.ynlskj.com.cn/gateway/queue", 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/queue', {
  method: 'POST',
  headers: {
    'X-API-Key': '你的密钥',
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    "action": "delay",
    "callback_url": "https://你的域名/api/order/webhook",
    "delay": 60,
    "payload": {
        "order_id": "ORDER123",
        "event": "timeout_cancel"
    }
})
})
  .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/queue"))
    .header("X-API-Key", "你的密钥")
    .header("Content-Type", "application/json")
    .POST(HttpRequest.BodyPublishers.ofString("{\n    \"action\": \"delay\",\n    \"callback_url\": \"https://你的域名/api/order/webhook\",\n    \"delay\": 60,\n    \"payload\": {\n        \"order_id\": \"ORDER123\",\n        \"event\": \"timeout_cancel\"\n    }\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\": \"delay\",\n    \"callback_url\": \"https://你的域名/api/order/webhook\",\n    \"delay\": 60,\n    \"payload\": {\n        \"order_id\": \"ORDER123\",\n        \"event\": \"timeout_cancel\"\n    }\n}", Encoding.UTF8, "application/json");
var result = await client.PostAsync("https://api.ynlskj.com.cn/gateway/queue", content);
Console.WriteLine(await result.Content.ReadAsStringAsync());

curl -X POST "https://api.ynlskj.com.cn/gateway/queue" \
  -H "X-API-Key: 你的密钥" \
  -H "Content-Type: application/json" \
  -d '{
    "action": "delay",
    "callback_url": "https://你的域名/api/order/webhook",
    "delay": 60,
    "payload": {
        "order_id": "ORDER123",
        "event": "timeout_cancel"
    }
}'