强制 Gitlab 在 Go 失败时重试 webhook

正如评论中所写，webhook 只是一个事件发生的通知，并且可能会发送一些数据，通常作为 JSON 数据。您有责任保留事件本身以及您想要/需要处理的随它发送的数据。您将在下面找到一个注释示例。请注意，这不包括增量退避，但这应该很容易添加：package mainimport (    "encoding/json"    "flag"    "io"    "log"    "net/http"    "os"    "path/filepath"    "github.com/joncrlsn/dque")var (    bind        string    queueDir    string    segmentSize int)// You might want to add request headers and stufftype webhookContent struct {    Foo string    Bar int}func init() {    flag.StringVar(&bind, "bind", ":8080", "The address to bind to")    flag.StringVar(&queueDir, "path", "./queue", "path to store the queue in")    flag.IntVar(&segmentSize, "size", 50, "number of entries for the queue")}// The "webserver" componentfunc runserver(q *dque.DQue) {    http.HandleFunc("/webhook", func(w http.ResponseWriter, r *http.Request) {        // A new decoder for each call, as we want to have a new LimitReader        // for each call. This is a simple, albeit a bit crude method to prevent        // accidental or malicious overload of your server.        dec := json.NewDecoder(io.LimitReader(r.Body, 4096))        defer r.Body.Close()        c := &webhookContent{}        if err := dec.Decode(c); err != nil {            log.Printf("reading body: %s", err)            http.Error(w, "internal error", http.StatusInternalServerError)            return        }        // When the content is successfully decoded, we can persist it into        // our queue.        if err := q.Enqueue(c); err != nil {            log.Printf("enqueueing webhook data: %s", err)            // PROPER ERROR HANDLING IS MISSING HERE        }    })    http.ListenAndServe(bind, nil)}func main() {    flag.Parse()    var (        q   *dque.DQue        err error    )    if !dirExists(queueDir) {        if err = os.MkdirAll(queueDir, 0750); err != nil {            log.Fatalf("creating queue dir: %s", err)        }    }    if !dirExists(filepath.Join(queueDir, "webhooks")) {        q, err = dque.New("webhooks", queueDir, segmentSize, func() interface{} { return &webhookContent{} })    } else {        q, err = dque.Open("webhooks", queueDir, segmentSize, func() interface{} { return &webhookContent{} })    }    if err != nil {        log.Fatalf("setting up queue: %s", err)    }    defer q.Close()    go runserver(q)    var (        // Placeholder during event loop        i interface{}        // Payload        w *webhookContent        // Did the type assertion succeed        ok bool    )    for {        // We peek only. The semantic of this is that        // you can already access the next item in the queue        // without removing it from the queue and "mark" it as read.        // We use PeekBlock since we want to wait for an item in the        // queue to be available.        if i, err = q.PeekBlock(); err != nil {            // If we can not peek, something is SERIOUSLY wrong.            log.Fatalf("reading from queue: %s", err)        }        if w, ok = i.(*webhookContent); !ok {            // If the type assertion fails, something is seriously wrong, too.            log.Fatalf("reading from queue: %s", err)        }        if err = doSomethingUseful(w); err != nil {            log.Printf("Something went wrong: %s", err)            log.Println("I strongly suggest entering an incremental backoff!")            continue        }        // We did something useful, so we can dequeue the item we just processed from the queue.        q.Dequeue()    }}func doSomethingUseful(w *webhookContent) error {    log.Printf("Instead of this log message, you can do something useful with: %#v", w)    return nil}func dirExists(path string) bool {    fileInfo, err := os.Stat(path)    if err == nil {        return fileInfo.IsDir()    }    return false}现在，当您执行以下操作时：$ curl -X POST --data '{"Foo":"Baz","Bar":42}' http://localhost:8080/webhook你应该得到一个日志条目2020/04/18 11:34:23 Instead of this log message, you can do something useful with: &main.webhookContent{Foo:"Baz", Bar:42}

强制 Gitlab 在 Go 失败时重试 webhook

1回答