golang 写一个秒杀小程序

在Go语言中，实现一个简单的秒杀系统需要处理的主要问题包括并发控制（防止超卖）、数据库操作以及商品库存的实时更新。以下是一个基础版的秒杀服务模拟，使用了goroutine和channel进行并发控制：

package main

import (
	"fmt"
	"sync"
)

type Goods struct {
	Name string
	Stock int
}

func (g *Goods) Seckill() bool {
	if g.Stock > 0 {
		g.Stock--
		return true
	}
	return false
}

func main() {
	goods := &Goods{Name: "iPhone 13", Stock: 100}

	var wg sync.WaitGroup
	seckillChan := make(chan bool, goods.Stock) // channel容量设置为库存量，防止超卖

	for i := 0; i < goods.Stock*2; i++ { // 模拟多于库存两倍的请求
		wg.Add(1)
		go func() {
			defer wg.Done()

			success := goods.Seckill()
			if success {
				seckillChan <- true // 秒杀成功发送信号
				fmt.Printf("用户成功秒杀到%s\n", goods.Name)
			} else {
				fmt.Println("秒杀失败，商品已售罄")
			}
		}()
	}

	wg.Wait()
	close(seckillChan) // 确保所有goroutine执行完毕后关闭channel

	fmt.Println("秒杀结束，剩余库存：", goods.Stock)
}

例如，数据库操作部分通常会使用事务来保证原子性和一致性，可以参考如下伪代码：

tx := db.Begin()
// 查询库存
row := tx.QueryRow("SELECT stock FROM goods WHERE id = ? FOR UPDATE", goodsId)
var stock int
err := row.Scan(&stock)
if err != nil || stock <= 0 {
    tx.Rollback()
    return errors.New("秒杀失败")
}

// 更新库存
_, err = tx.Exec("UPDATE goods SET stock = stock - 1 WHERE id = ?", goodsId)
if err != nil {
    tx.Rollback()
    return errors.New("秒杀失败")
}

// 提交事务
err = tx.Commit()
if err != nil {
    return errors.New("秒杀失败")
}

// 秒杀成功逻辑...

原文链接: https://www.yukx.com/golang/article/details/2460.html 优科学习网golang 写一个秒杀小程序