如何设置定时触发 Api 调用

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《如何设置定时触发 Api 调用》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我正在构建一个简单的平台，允许 Twitter 用户按照自己选择的时间表向他们的 Twitter 帐户发帖。例如，某人可能想在午夜 12:00 准时向他/她的 Twitter 帐户发帖，但该平台允许他们在下午 4:00 之前创建帖子，并在预定时间自动发布到他们的时间线。我对如何实现这一点感到困惑，因为必须手动调用负责此操作的 Api 端点才能发生此事件，我想到使用 cron 作业每分钟运行一次并检查所有预定的帖子，调用端点（如果是时候创建帖子了），但我觉得这很麻烦并且容易出错。请问还有更多的编程方式来实现这一点吗？

Ps：我正在尝试在 golang 中执行此操作...

正确答案

您可以将 pub/consumer 模型与消息队列结合使用。它将使您的解决方案更加健壮和分布式。我总是尽量不在任何类型的分布式环境中使用睡眠。

您的系统将包含 3 个组件：
生产者：它将负责调度消息并将其写入消息队列。
消息队列：您可以使用rabbitmq（带有delaymessageexchange）或activemq（它具有内置调度）。您的消息队列将解决调度问题。因为消息只有在特定的时间延迟后才会传递给消费者。
消费者：消费者将从消息队列中读取数据并按照功能执行操作

hld 将如下所示：

您可以将https://pkg.go.dev/github.com/streadway/amqp这个包用于rabbitmq 和 https://pkg.go.dev/github.com/go-stomp/stomp 这个 activemq 包

这是一个简单的例子，我使用了aws activemq。

package main

import (
    "crypto/tls"
    "flag"
    "fmt"
    "github.com/go-stomp/stomp/v3"
    "os"
    "time"
)

const defaultPort = ":61613"

var serverAddr = flag.String("server", "b-50ad5529-0347-4308-af59-f6265d68d290-1.mq.us-east-1.amazonaws.com:61614", "STOMP server endpoint") 
var messageCount = flag.Int("count", 2, "Number of messages to send/receive")
var queueName = flag.String("queue", "/queue/client_test", "Destination queue")
var helpFlag = flag.Bool("help", false, "Print help text")
var stop = make(chan bool)

// these are the default options that work with RabbitMQ
var options []func(*stomp.Conn) error = []func(*stomp.Conn) error{
    stomp.ConnOpt.Login("activemquser", "activemqpassword"),
}

func main() {
    flag.Parse()
    if *helpFlag {
        fmt.Fprintf(os.Stderr, "Usage of %s\n", os.Args[0])
        flag.PrintDefaults()
        os.Exit(1)
    }

    subscribed := make(chan bool)
    go recvMessages(subscribed)

    // wait until we know the receiver has subscribed
    <-subscribed

    go sendMessages()

    <-stop
    <-stop

}

func sendMessages() {
    defer func() {
        stop <- true
    }()

    netConn, err := tls.Dial("tcp", *serverAddr, &tls.Config{})
    if err != nil {
        println("cannot connect to server", err.Error())
    }

    conn, err := stomp.Connect(netConn, options...)
    if err != nil {
        println("cannot connect to server", err.Error())
    }

    for i := 1; i <= *messageCount; i++ {
        text := fmt.Sprintf("Message #%d", i)
        fmt.Println("sending message ", text, " ", time.Now())
        // scheduling a message with 15 seconds delay
        err = conn.Send(*queueName, "text/plain",
            []byte(text), stomp.SendOpt.Header("AMQ_SCHEDULED_DELAY", "15000"))
        if err != nil {
            println("failed to send to server", err)
            return
        }
        // schedule each message after 3 secs
        time.Sleep(3 * time.Second)
    }
    println("sender finished")
}

func recvMessages(subscribed chan bool) {
    defer func() {
        stop <- true
    }()

    netConn, err := tls.Dial("tcp", *serverAddr, &tls.Config{})
    if err != nil {
        println("cannot connect to server", err.Error())
    }

    conn, err := stomp.Connect(netConn, options...)
    if err != nil {
        println("cannot connect to server", err.Error())
    }

    sub, err := conn.Subscribe(*queueName, stomp.AckAuto)
    if err != nil {
        println("cannot subscribe to", *queueName, err.Error())
        return
    }
    close(subscribed)

    for i := 1; i <= *messageCount; i++ {
        msg := <-sub.C
        expectedText := fmt.Sprintf("Message #%d", i)
        actualText := string(msg.Body)
        fmt.Println("got message", actualText, " ", time.Now())
        if expectedText != actualText {
            println("Expected:", expectedText)
            println("Actual:", actualText)
        }
    }
    println("receiver finished")

}

今天关于《如何设置定时触发 Api 调用》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！