侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

在go语言中使用GoRoutines实现高性能并发批量调用api示例

Go  /  管理员 发布于 2个月前   69

go语言是一种非常高效的语言,特别是在并发调度上,go使用自己的goroutines调度器将其轻量级goroutines从操作系统线程中进一步抽象出来。

如果一个goroutine被阻塞了,Go的调度器会在它的位置上切换另一个goroutine,以尽可能地保持线程的忙碌。


那么,我们如何使用Golang来并发地进行多个http调用呢?


Go总是至少有一个goroutine在运行,它负责运行main()。

Go Scheduler允许开发者制作成千上万个这种轻量级的goroutines,并为我们管理每个goroutines所花费的CPU时间。

每当一个以go为前缀的函数被执行时,就会创建一个新的goroutine来运行该函数,主goroutine在生成一个新的goroutine后立即继续前进,

直到它遇到一个阻塞操作符。


高性能调用示例


第一:

我们需要添加一个叫做通道的东西。

由于在自己的goroutine中运行的Golang函数只是简单的函数,我们需要一种方法,通过它内部的goroutine可以把它们的结果告诉外部的goroutine;

这就是使用通道来实现的。

我们通过以下方式初始化它们: 

c := make(chan string) 

我们能够使用<- 箭头将结果值发送到我们的通道,我们也可以使用这个箭头将通道的值分配出去。


第二:

我们需要添加一个跟踪器,来跟踪我们应该期待多少个值从这个通道出来。

这可以通过使用

sync.WaitGroup.WaitGroup

的类型来完成。


代码如下:

import (
    "fmt"
    "net/http"
    "sync"
)

func checkUrls(urls []string) {
   c := make(chan string)
   var wg sync.WaitGroup

   for _, link := range urls {
       wg.Add(1)   // 这告诉wg,现在这里有一个待处理的操作。
       go checkUrl(link, c, &wg)
   }

   go func() {
       wg.Wait()   // 这将阻止Goroutine,直到WaitGroup计数器为零。
       close(c)    // 通道需要被关闭,否则下面的循环将永远持续下去
   }()

   // 这个简略的循环是一个无休止的循环的语法糖,它只是在等待结果通过'c'通道进入。
   for msg := range c {
       fmt.Println(msg)
   }
}

func checkUrl(url string, c chan string, wg *sync.WaitGroup) {
   defer (*wg).Done()
   _, err := http.Get(url)

   if err != nil {
       c <- "#janrs.com#We could not reach:" + url    // 将结果输入通道
   } else {
       c <- "Success reaching the website:" + url    // 将结果输入通道
   }
}

func main() {
    links := []string{
        "https://github.com/fabpot",
        "https://github.com/andrew",
        "https://github.com/taylorotwell",
        "https://github.com/egoist",
        "https://github.com/HugoGiraudel",
    }
   
    checkUrls(links)
}


有兴趣的可以自行测试一下


  • 上一条:
    Docker撤回受争议的收费方案,又可以继续使用docker了
    下一条:
    在Laravel项目中的实现无密码认证之:发送邮箱链接授权
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • 在go语言中以邮件标题中获取SPF和DMARC,来判断是否为垃圾邮件之垃圾邮件过滤器功能实现(0个评论)
    • 在go语言中使用attr字段标签提取XML属性数据示例(0个评论)
    • 在go语言中如何记录每个HTTP请求到你的Web服务器、日志记录器?(0个评论)
    • 在Go语言中如何查找一个IP地址的网络地址?(0个评论)
    • 在go语言中使用gin框架-中间件gin.BasicAuth()实现账号密码方式认证示例(0个评论)
    • 近期文章
    • 在go语言中以邮件标题中获取SPF和DMARC,来判断是否为垃圾邮件之垃圾邮件过滤器功能实现(0个评论)
    • 在go语言中使用attr字段标签提取XML属性数据示例(0个评论)
    • 在laravel中介绍一个生成假数据的PHP库:FakerPHP(0个评论)
    • 在laravel框架中对环境配置文件的加载过程步骤浅析(0个评论)
    • Laravel 10.12版本发布(0个评论)
    • 在go语言中如何记录每个HTTP请求到你的Web服务器、日志记录器?(0个评论)
    • 在Go语言中如何查找一个IP地址的网络地址?(0个评论)
    • ELK + Filebeat 搭建日志系统流程步骤(0个评论)
    • 在laravel中以curl的方式请求京东联盟api获取数据流程步骤(0个评论)
    • 在go语言中使用gin框架-中间件gin.BasicAuth()实现账号密码方式认证示例(0个评论)
    • 近期评论
    • 博主 在

      2023年国务院办公厅春节放假通知:1月21日起休7天中评论 @ xiaoB 你只管努力,剩下的叫给天意;天若有情天亦老,..
    • xiaoB 在

      2023年国务院办公厅春节放假通知:1月21日起休7天中评论 会不会春节放假后又阳一次?..
    • BUG4 在

      你翻墙过吗?国内使用vpn翻墙可能会被网警抓,你需了解的事中评论 不是吧?..
    • 博主 在

      go语言+beego框架中获取get,post请求的所有参数中评论 @ t1  直接在router.go文件中配就ok..
    • Jade 在

      如何在MySQL查询中获得当月记录中评论 Dear zongscan.com team, We can skyroc..
    • 2016-10
    • 2017-09
    • 2020-03
    • 2020-05
    • 2020-06
    • 2020-07
    • 2020-12
    • 2021-01
    • 2021-05
    • 2021-06
    • 2021-07
    • 2021-08
    • 2021-10
    • 2021-11
    • 2021-12
    • 2022-01
    • 2022-02
    • 2022-03
    • 2022-04
    • 2022-05
    • 2022-06
    • 2022-07
    • 2022-08
    • 2022-09
    • 2022-10
    • 2022-11
    • 2022-12
    • 2023-01
    • 2023-02
    • 2023-03
    • 2023-04
    • 2023-05
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客