定期发送客户端请求

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《定期发送客户端请求》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

我有一个简单的项目结构：

.../internal/app/api
 .../internal/app/middleware
 .../internal/app/service
 .../internal/app/server

所有传入请求处理程序都位于 ...api 中。但是现在我需要自己定期向另一个服务发送请求。 “....server”包含我的所有路由。我为此编写了一个函数。

func SendOrderNumber(orderNumber string, endpoint string) (*model.Answer, error) {
    //endpoint example: http://localhost:8080/api/orders/
    endpointWithOrderNumber := fmt.Sprintf("%s%s", endpoint, orderNumber)
    client := &http.Client{}

    request, err := http.NewRequest(http.MethodPost, endpointWithOrderNumber, strings.NewReader(""))
    if err != nil {
        return nil, err
    }

    response, err := client.Do(request)
    if err != nil {
        return nil, err
    }

    if response.StatusCode != http.StatusOK {
        return nil, errors.New(response.Status)
    }

    defer response.Body.Close()
    var accrualSystemAnswer model.AccrualSystemAnswer
    err = json.NewDecoder(response.Body).Decode(&accrualSystemAnswer)
    if err != nil {
        return nil, err
    }

    return &accrualSystemAnswer, nil
}

我不明白哪里是我调用发送请求函数的最佳位置。以及如何做到这一点。

正确答案

您只需将父上下文传递给我的 context.withtimeout 而不是 context.background()。 不清楚您的项目结构，但最好将此代码与端点放在一起。

ctx, cancel := context.withtimeout(context.background(), time.minute)
    defer cancel()
    
    var wg sync.waitgroup
    wg.add(1)
    go func() {
        defer wg.done()
        // defer func() {if e := recover(); e != nil {}}() // if need to recover panic
        t := time.newticker(time.hour * 1) // ticker, run 1 time per hour
        for {
            select {
            case <-ctx.done(): //if job works too long
                return
            case <-t.c: //implement logic here, that will be called by ticker
            }
        }
    }()

并修复你的函数来发出请求

func SendOrderNumber(ctx context.Context, orderNumber string, endpoint string) (*model.Answer, error) {
    //endpoint example: http://localhost:8080/api/orders/
    endpointWithOrderNumber := fmt.Sprintf("%s%s", endpoint, orderNumber)
    client := &http.Client{}

    request, err := http.NewRequestWithContext(ctx, http.MethodPost, endpointWithOrderNumber, strings.NewReader(""))
    if err != nil {
        return nil, err
    }

    response, err := client.Do(request)
    if err != nil {
        return nil, err
    }

    if response.StatusCode != http.StatusOK {
        return nil, errors.New(response.Status)
    }

    var accrualSystemAnswer model.AccrualSystemAnswer
    err = json.NewDecoder(response.Body).Decode(&accrualSystemAnswer)
    if err != nil {
        return nil, err
    }
    // body must be closed after error check, cos in case if body is empty u will get 
    // nil body. resp.Body.Close() for nil body -> panic
    defer response.Body.Close()

    return &accrualSystemAnswer, nil
}

本篇关于《定期发送客户端请求》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！