首页 > 数据库 >gorm使用事务并发情况下切有最大mysql连接数限制的情况下的BUG,踩坑了

gorm使用事务并发情况下切有最大mysql连接数限制的情况下的BUG,踩坑了

时间:2024-03-14 18:14:01浏览次数:38  
标签:PID 连接数 gorm mynode mysql msg protoMsg BUG conn

现象

服务器pprof中的goroutines 很多,无法释放,肯定是异常.

代码


// 收到 请求上个赛季个人秘境赛季排行
func (this *MsgProc) MsgProc_PersonSecretLastRankReq(msg *protoMsg.PersonSecretLastRankReq) {
	global.GetSrvInst().GetThreadGo().Go(func(ctx context.Context) {
		global.GetSrvInst().GetMysqlConn().Transaction(func(tx *gorm.DB) error {
			// 拿到当前数据
			var mynode *protoMsg.PersonSecretRankMD
			global.GetSrvInst().GetMysqlConn().Where("seasonid=? and pid=?", msg.SeasonID, msg.PID).Find(&mynode)
			if mynode == nil || mynode.SeasonID == 0 || mynode.PID == 0 {
				// 空数据
				server.PostPlayerSrv(msg.PID, gcommon.ServerTypeLobby, &protoMsg.PersonSecretLastRankRet{
					LastSeasonID:   msg.SeasonID,
					PID:            msg.PID,
					LastSeasonRank: 0,
				})
				return nil
			}
			server.PostPlayerSrv(msg.PID, gcommon.ServerTypeLobby, &protoMsg.PersonSecretLastRankRet{
				LastSeasonID:      msg.SeasonID,
				PID:               msg.PID,
				LastSeasonRank:    mynode.SeasonRank,
				LastSeasonEndTime: mynode.UpdatedAt.Unix(),
			})
			return nil
		})
	})
}

结论

在gorm的transaction中, Begin会申请一个conn链接, 然后内部如果在获取新的Mysql Conn的话, 当conn达到maxNum的时候,就会卡住, transaction无法自动释放conn,进而导致雪崩,其他的代码想要调用mysql都会出现等待conn的死锁情况.

所以 在 transaction 的代码中, 要用 tx 对象,不要用新的对象.

ps: 这代码是同事写的,但是引以为戒. 顺便 get 到gorm事务的踩坑用法,知道为什么这么写更重要.

标签:PID,连接数,gorm,mynode,mysql,msg,protoMsg,BUG,conn
From: https://www.cnblogs.com/ayanmw/p/18073622

相关文章

  • Mysql学习
    1.5Mysql架构 1.6日志文件1)错误日志2)查询日志3)二进制文件记录了对mysql数据库执行的更改操作并且记录了语句发生的时间,执行时长;但是不记录select、showtables等不修改数据的SQL。主要用于数据库的恢复和主从复制4)慢查询日志超时查询日志,long_query  1.7数据文件......
  • 操作MySQL之mysql库
    目录一、快速使用1.下载2.快速链接3.最佳使用方案4.设置连接池二、查询数据1.单行查询db.QueryRow()2.多行查询db.Query()三、插入数据四、删除数据五、更新数据六、MySQL预处理1.什么是预处理?2.为什么要预处理?3.Go实现MySQL预处理4.SQL注入问题七、Go实现MySQL事务1.......
  • 操作MySQL之sqlx库
    目录一、介绍和使用1.安装和快速使用二、基本增删查改1.增加数据2.修改数据3.删除数据4.查询数据三、其他查询1.Get和Select查询四、其他方法1.sqlx的NamedExec2.sqlx的NamedQuery五、事务操作六、连接池一、介绍和使用上一篇我们用了go-sql-driver/mysql库来操作mysql......
  • MySQL 5.5和8.0.2 安装在一台电脑上
    情况说明:MySQL5.5已经安装,安装MySQL8方法一:InstallDirectory更改为C:\ProgramFiles\MySQLE\MySQLServer8.0;DataDirectory更改为C:\ProgramData\MySQLE\MySQLServer8(默认路径加E,也可以自定义)2.安装时更改端口号为3307、XProtocolPort为330703.添加环境变量path......
  • MYSQL 存储过程示例
    MySQL5.0版本开始支持存储过程。存储过程(StoredProcedure)是一种在数据库中存储复杂程序,以便外部程序调用的一种数据库对象。存储过程是为了完成特定功能的SQL语句集,经编译创建并保存在数据库中,用户可通过指定存储过程的名字并给定参数(需要时)来调用执行。存储过程思想上很......
  • MYSQL学习笔记26: 多表查询|子查询
    多表查询|子查询行子查询查询与张无忌工资相同,且直属领导相同的员工#写法1select*fromempwheresalary=(selectsalaryfromempwherename='张无忌')andmanagerId=(selectmanagerIdfromempwherename='张无忌');#可以合并起来,写入一个集合selec......
  • MySQL之运算符篇
    1.算术运算符算术运算符主要用于数学运算,其可以连接运算符前后的两个数值或表达式,对数值或表达式进行加(+)、减(-)、乘(*)、除(/)和取模(%)运算。1.1 加法与减法运算符由运算结果可以得出如下结论:一个整数类型的值对整数进行加法和减法操作,结果还是一个整数;一个整数类型的值......
  • Mysql 100个表嵌套查询 存储过程
    背景1. 业务销售订单会随机落在1~100表中,查询一个订单时需要1到100表依次去查询,增加手工重复操作和浪费时间。2.查询未解冻数据时,需要过滤部分解冻的数据,此时需要用到嵌套查询。 一、根据订单号,循环1~100个表,查询出订单数据CREATEDEFINER=`{数据库连接账号}`@`%`......
  • 数据库练习发生的error—— check the manual that corresponds to your MySQL server
    记录一下发生的错误。 checkthemanualthatcorrespondstoyourMySQLserverversionfortherightsyntaxtousenear''id'),参考链接:完美解决ERROR1064(42000):YouhaveanerrorinyourSQLsyntax...near…_responsecode:420001064r......
  • MYSQL 是如何保证binlog 和redo log同时提交的?
    MYSQL一个事务在提交的时候能够保证binlog和redolog是同时提交的,并且能在宕机恢复后保持binlog和redolog的一致性。先来看看什么是redolog和binlog,以及为什么要保持它们的一致性。什么是redolog,binlogredolog是innodb引擎层产生的日志,MYSQL从磁盘读取数据的单位是一......