首页 > 其他分享 >go高并发之路——go语言如何解决并发问题

go高并发之路——go语言如何解决并发问题

时间:2024-07-12 22:51:37浏览次数:14  
标签:语言 err fmt 并发 func time go GO

一、选择GO的原因

作为一个后端开发,日常工作中接触最多的两门语言就是PHP和GO了。无可否认,PHP确实是最好的语言(手动狗头哈哈),写起来真的很舒爽,没有任何心智负担,字符串和整型压根就不用区分,开发速度真的是比GO快很多。现在工作中也还是有一些老项目在使用PHP,但21年之后的新项目基本上就都是用GO了。那为什么PHP那么香,还要转战使用GO呢,下面就给大家讲解一下我们新项目从PHP转GO的原因,有几个比较重要的点:

1、PHP不能满足我们的高并发业务,这是最主要的原因了,(PS:我这里所说的PHP是指官方的php-fpm模式下的开发,是一个请求一个进程的那种模式,而不是类似于swoole常驻进程的那种。那么为什么不去使用swoole呢,当然也是有的,但swoole毕竟太小众了,且之前有很多bug,使用起来心智负担太高了),而我们部门所负责的是直播业务,每天都和高并发打交道啊,所以只能将目光转向了并发小王子GO的怀抱。

2、GO语言当时在市面上很火,像腾讯、百度、滴滴、好未来这些大厂都在陆陆续续地从PHP转向GO,这也是一个讯号吧,跟着大佬们走总不会错。

3、GO语言的简单简洁,相比较于JAVA,上手是很快的(但真正学好还是没那么容易的),我当时就学了两个礼拜左右语法就跟着一起写项目了。

二、GO解决的并发问题

说到并发,是GO最基本的功能了,但是在传统的PHP中是比较困难的,如果不借助其它一些扩展的话,是做不到并发的。举个场景:每个用户进入直播间,都要获取很多信息,有版本服务信息、直播基础信息、用户信息、直播关联权益信息、直播间信息统计等等。如果是PHP的写法,就得按照下面串行的流程去做,这个接口耗时就是所有操作的时间之和,严重影响用户体验啊。

但如果换成GO去做这件事,那就非常清爽了,这个用户请求耗时就只需要时间最长的那个操作耗时,如下图:

那么我们如何用去实现这个并发逻辑呢?

方法1:使用sync.WaitGroup
//请求入口
func main() {
	var (
		VersionDetail, LiveDetail, UserDetail, EquityDetail, StatisticsDetail int
	)
	ctx := context.Background()
	GoNoErr(ctx, func() {
		VersionDetail = 1 //版本服务信息
		time.Sleep(1 * time.Second)
		fmt.Println("执行第一个任务")
	}, func() {
		LiveDetail = 2 //直播基础信息
		time.Sleep(2 * time.Second)
		fmt.Println("执行第二个任务")
	}, func() {
		UserDetail = 3 //用户信息
		time.Sleep(3 * time.Second)
		fmt.Println("执行第三个任务")
	}, func() {
		EquityDetail = 4 //直播关联权益信息
		time.Sleep(4 * time.Second)
		fmt.Println("执行第四个任务")
	}, func() {
		StatisticsDetail = 5 //直播间信息统计
		time.Sleep(5 * time.Second)
		fmt.Println("执行第五个任务")
	})
	fmt.Println(VersionDetail, LiveDetail, UserDetail, EquityDetail, StatisticsDetail)
}

//并发方法
func GoNoErr(ctx context.Context, functions ...func()) {
	var wg sync.WaitGroup
	for _, f := range functions {
		wg.Add(1)
		// 每个函数启动一个协程
		go func(function func()) {
			function()
			wg.Done()
		}(f)
	}
	// 等待执行完
	wg.Wait()
}
方法2:使用ErrGroup库
//请求入口
func main() {
	var (
		VersionDetail, LiveDetail, UserDetail, EquityDetail, StatisticsDetail int
		err                                                                   error
	)
	ctx := context.Background()
	err = GoErr(ctx, func() error {
		VersionDetail = 1 //版本服务信息
		time.Sleep(1 * time.Second)
		fmt.Println("执行第一个任务")
		return nil //返回实际执行的错误
	}, func() error {
		LiveDetail = 2 //直播基础信息
		time.Sleep(2 * time.Second)
		fmt.Println("执行第二个任务")
		return nil //返回实际执行的错误
	}, func() error {
		UserDetail = 3 //用户信息
		time.Sleep(3 * time.Second)
		fmt.Println("执行第三个任务")
		return nil //返回实际执行的错误
	}, func() error {
		EquityDetail = 4 //直播关联权益信息
		time.Sleep(4 * time.Second)
		fmt.Println("执行第四个任务")
		return nil //返回实际执行的错误
	}, func() error {
		StatisticsDetail = 5 //直播间信息统计
		time.Sleep(5 * time.Second)
		fmt.Println("执行第五个任务")
		return nil //返回实际执行的错误
	})
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println(VersionDetail, LiveDetail, UserDetail, EquityDetail, StatisticsDetail)

}

func GoErr(ctx context.Context, functions ...func() error) error {
	var eg errgroup.Group
	for i := range functions { 
		f := functions[i]  //请注意这里的写法,下面有讲解
		eg.Go(func() (err error) {
			err = f()
			if err != nil {
				//记日志
			}
			return err
		})
	}
	// 等待执行完
	return eg.Wait()
}

上面就是使用ErrGroup库的并发执行任务的方法,可以直接拿来使用,ErrGroup这是GO官方提供的一个同步扩展库可以很好地将⼀个通⽤的⽗任务拆成⼏个⼩任务并发执⾏

上面有一点需要特别注意的写法,就是下面这段代码的写法,写法1:

for i := range functions { 
		f := functions[i]  
		eg.Go(func() (err error) {
			err = f()

也可以这样写,写法2:

for _, f := range functions { 
		fs := f  
		eg.Go(func() (err error) {
			err = fs()

但如果这样写就会有问题,写法3:

for _, f := range functions { 
		eg.Go(func() (err error) {
			err = f()

你们可以改一下,实际跑一下。会发现 (写法3) 会出现类似这样的错误结果

正确预期的结果(写法1、写法2)应该是这样的

这是因为在 Go 语言中,当使用闭包(匿名函数)时,如果闭包引用了外部的变量,闭包实际上会捕获这些变量的引用。在循环中创建闭包时,如果直接将循环变量作为闭包的参数或在闭包中引用该变量,会导致所有生成的闭包都引用相同的变量,即最后一次迭代的值。

为了避免这个问题,常见的做法是在循环内部创建一个新的变量,将循环变量的值赋给这个新变量,然后在闭包中引用该新变量。这样,每次循环迭代都会创建一个新的变量,闭包捕获的是不同的变量引用,而不是相同变量的引用。

在给定的代码中,fs := f 就是为了创建一个新的变量 f,并将循环变量 f 的值赋给它。这样,在闭包中就可以安全地引用这个新变量 f,而不会受到循环迭代的影响。这个技巧非常有用,可以在循环中创建多个独立的闭包,并确保它们捕获的是预期的变量值,而不会受到循环迭代的干扰

当然,还有一些第三方库也实现了上面的并发分组操作,大家感兴趣的可以去GitHub上看看,但功能和实现基本都大同小异。以上就是GO并发的基础,将一个父任务拆分成多个子任务去执行,提高程序的并发度,节省程序耗时。我们平时在工作中,两种方法都可以直接拿来使用,可以说这两个GO并发方法几乎贯穿了我的GO职业生涯,也是最基础最实用的并发操作方法

https://mp.weixin.qq.com/s/j1xq-o0DPpkXSlp2l6kAow

https://mp.weixin.qq.com/s/S-1oipJHX6U0yqU5koTgNA

https://mp.weixin.qq.com/s?__biz=Mzk0MDcyNjA2MA==&mid=2247483718&idx=1&sn=c28c6955e3945013ed3db3d56fe279be&chksm=c2dc0305f5ab8a138611899cf9451e4db4ad2d7100d0386d5ddb97328e5c7f762d98f8b1db84#rd

https://mp.weixin.qq.com/s?__biz=Mzk0MDcyNjA2MA==&mid=2247483755&idx=1&sn=14b0fd96e2f90f602a150452a90e3dd7&chksm=c2dc0328f5ab8a3e14e4f4ea9c219c329af17741042a5da7b77b99236e5630eb90aa8c7cf767#rd

标签:语言,err,fmt,并发,func,time,go,GO
From: https://www.cnblogs.com/YxzY/p/18299515

相关文章

  • 实现猜数字游戏(C语言)
    简单版本#include<stdio.h>#include<stdlib.h>#include<time.h>#include<Windows.h>#include<string.h>voidmenu(){ chararr[]="************************"; chararr1[]="--Welcometomygame!!--"; int......
  • 学习C语言第一天
    今天看了B站上的几节课,总结了以下几个要点:1.githud,码云两个网站实现代码托管,坚持上传代码。2.CSDN坚持写博客,善于总结包括xmind。3.不做伸手党,要学会自己解决问题。4.操作系统,计算机网络+网络编程,比较难,上课要认真,还需要看书补偿。5.数据结构要听懂。6.介绍了课程安排。7.了解......
  • c语言的简易教法—— 函数递归
    文章目录一、什么是递归?1.1递归的思想1.2递归的限制条件二、递归案例2.1案例1:求n的阶层2.1.1分析2.1.2递归函数(Fact)的代码实现2.1.3测试:main函数实现2.1.4运行结果和画图推演2.1.5扩展:迭代方法求解n的阶乘2.2案例2:顺序打印⼀个整数的每⼀位2.2.1分析2.2.2打印数(p......
  • MongoDB集群同步
    实现MongoDBCluster-to-Cluster即集群同步的工具是:mongosync详情可参考如下官方文档:https://www.mongodb.com/zh-cn/docs/cluster-to-cluster-sync/current/quickstart/以上这个地址的文档一看就是机器翻译的,可能有不恰当的地方,但基本可参考使用。以下是本次在某项目地配置......
  • BS-Python-061 基于Python+Django实现在线考试系统
    作者主页:编程千纸鹤作者简介:Java、前端、Python开发多年,做过高程,项目经理,架构师主要内容:Java项目开发、Python项目开发、大学数据和AI项目开发、单片机项目设计、面试技术整理、最新技术分享收藏点赞不迷路 关注作者有好处文末获得源码 项目编号:BS-Python-061一,环境......
  • Django静态文件系统之meida文件,Django配置文件介绍,RBAC权限系统
    ⅠDjango静态文件系统之meida文件【一】问题引入一般常用的静态文件:static但是,媒体文件:图片,视频,音频……会随着用户改变而改变,不应该作为静态文件来使用应该是媒体资源于是Django提供了另一种静态文件语法meida文件【二】配置使用在Django的settings里面DEBUG—>开......
  • Algorithm notes and references
    AlgorithmnotesandreferencesVersion:2024/02/03DataStructure1.SegmentTreeBeats(segb)from题解P4314【CPU监控】-He_Ren的博客-洛谷博客(luogu.com.cn)lazytag实际上可以看作是对于该节点表示的区间的操作序列,这也是线段树的精髓所在push_down操作就......
  • R语言广义加性混合模型(GAMM)分析长沙气象因子、空气污染、PM2.5浓度、显著性检验、逐
    全文链接:https://tecdat.cn/?p=32981原文出处:拓端数据部落公众号气候变化和空气污染对现代社会产生了越来越大的影响。在这种背景下,研究气象和空气污染之间的关系以及其对PM2.5浓度的影响变得非常重要。为了更好地理解和解释这些关系,广义加性混合模型(GAMM)成为一种强大的工具。......
  • R语言软件套保期限GARCH、VAR、OLS回归模型对沪深300金融数据可视化分析
    全文链接:https://tecdat.cn/?p=34670原文出处:拓端数据部落公众号金融市场的波动性一直是投资者和决策者关注的焦点之一。为了应对市场波动的风险,套保成为了一种重要的金融手段。在这个背景下,使用R语言软件中的GARCHVAR模型对沪深300金融数据进行分析,可以帮助我们更好地理解市......
  • 十天速通C语言基础(day01)
    目录一、前言二、大纲三、Linux命令快捷键新建查看切换 复制移动 删除 打开终端四、vi编辑器1、vi编辑器的使用2.vi模式切换命令3.vi拷贝与粘贴命令 4.vi保存和退出命令5.vi光标命令6.vi的查找命令7.vi替换命令8.vi复制和剪切命令一、前言    ......