学习如何通过通道来实现功能

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《学习如何通过通道来实现功能》，聊聊，我们一起来看看吧！

goroutine 中有一个正在运行的函数：

func (c *controlUC) WebhookPool() {
    for {
        if len(c.webhookPool) == 0 {
            continue
        }
        for i := 0; i < len(c.webhookPool); i++ {
            if !c.webhookPool[i].LastSentTime.IsZero() && time.Now().Before(c.webhookPool[i].LastSentTime.Add(GetDelayBySentCount(c.webhookPool[i].SendCount))) {
                continue
            }
            var headers = make(map[string]string)
            headers["Content-type"] = "application/json"
            _, statusCode, err := c.fhttpClient.Request("POST", c.webhookPool[i].Path, c.webhookPool[i].Body, nil, headers)
            if err != nil {
                c.logger.Error(err)
                return
            }
            if statusCode != 200 {
                if c.webhookPool[i].SendCount >= 2 {
                    c.webhookPool = append(c.webhookPool[:i], c.webhookPool[i+1:]...)
                    i--
                    continue
                }
                c.webhookPool[i].SendCount++
            } else {
                c.webhookPool = append(c.webhookPool[:i], c.webhookPool[i+1:]...)
                i--
                continue
            }
            c.webhookPool[i].LastSentTime = time.Now()
        }
    }
}
// webhookPool []models.WebhookPoolElem
type WebhookPoolElem struct {
    SendCount    int
    LastSentTime time.Time
    Path         string
    Body         []byte
}

将 webhookpoolelem 元素添加到 c.webhookpool 中，之后将请求发送到服务器（路径取自 webhookpoolelem.path）。如果服务器返回非 - 200 200，那么我需要在 x 秒后再次发送请求（取自 getdelaybysentcount()，具体取决于 sendcount 返回不同的时间）。尝试次数有限（c.webhookpool[i].sendcount >= 2）

但也许这个功能需要通过通道来完成？如果是这样，怎么办？

正确答案

假设 controluc 接收器有一个字段 webhookpool chan webhookpoolelem 并初始化为 webhookpool： make(chan webhookpoolelem, n) 以 n 作为缓冲区。

您可以接收元素并或多或少地将 c.webhookpool[i] 替换为 elem。像这样重写：

func (c *controluc) webhookpool() {
    for {
        elem, open := <-c.webhookpool
        if !open {
            return
        }

        if !elem.lastsenttime.iszero() && time.now().before(elem.lastsenttime.add(getdelaybysentcount(elem.sendcount))) {
            continue
        }
        // i omit http request
        if statuscode != 200 {
            if elem.sendcount >= 2 {
                // drop message from channel, no need to do anything
                continue
            }
            elem.sendcount++
            elem.lastsenttime = time.now()
            c.webhookpool <- elem // enqueue again
        }
}

我建议使用缓冲通道，这样最后一个发送 c.webhookpool <- elem 就不会阻塞，但最好将发送放在 select 中，这样如果无论缓冲区如何，发送都无法继续，则 goroutine 不会阻塞：

select {
    case c.webhookPool <- elem:
        // success
    default:
        // can not send 
}

到这里，我们也就讲完了《学习如何通过通道来实现功能》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！