前言
之前一直對(duì)Golang如何處理高并發(fā)http請(qǐng)求的一頭霧水,這幾天也查了很多相關(guān)博客,似懂非懂,不知道具體代碼怎么寫(xiě)
下午偶然在開(kāi)發(fā)者頭條APP上看到一篇國(guó)外技術(shù)人員的一篇文章用Golang處理每分鐘百萬(wàn)級(jí)請(qǐng)求,看完文章中的代碼,自己寫(xiě)了一遍代碼,下面自己寫(xiě)下自己的體會(huì)
核心要點(diǎn)
將請(qǐng)求放入隊(duì)列,通過(guò)一定數(shù)量(例如CPU核心數(shù))goroutine組成一個(gè)worker池(pool),workder池中的worker讀取隊(duì)列執(zhí)行任務(wù)
實(shí)例代碼
以下代碼筆者根據(jù)自己的理解進(jìn)行了簡(jiǎn)化,主要是表達(dá)出個(gè)人的思路,實(shí)際后端開(kāi)發(fā)中,根據(jù)實(shí)際場(chǎng)景修改
func doTask() {
//耗時(shí)炒作(模擬)
time.Sleep(200 * time.Millisecond)
wg.Done()
}
//這里模擬的http接口,每次請(qǐng)求抽象為一個(gè)job
func handle() {
//wg.Add(1)
job := Job{}
JobQueue - job
}
var (
MaxWorker = 1000
MaxQueue = 200000
wg sync.WaitGroup
)
type Worker struct {
quit chan bool
}
func NewWorker() Worker {
return Worker{
quit: make(chan bool)}
}
// Start method starts the run loop for the worker, listening for a quit channel in
// case we need to stop it
func (w Worker) Start() {
go func() {
for {
select {
case -JobQueue:
// we have received a work request.
doTask()
case -w.quit:
// we have received a signal to stop
return
}
}
}()
}
// Stop signals the worker to stop listening for work requests.
func (w Worker) Stop() {
go func() {
w.quit - true
}()
}
type Job struct {
}
var JobQueue chan Job = make(chan Job, MaxQueue)
type Dispatcher struct {
}
func NewDispatcher() *Dispatcher {
return Dispatcher{}
}
func (d *Dispatcher) Run() {
// starting n number of workers
for i := 0; i MaxWorker; i++ {
worker := NewWorker()
worker.Start()
}
}
測(cè)試
func Benchmark_handle(b *testing.B) {
runtime.GOMAXPROCS(runtime.NumCPU())
d := NewDispatcher()
d.Run()
for i:=0;i10000;i++ {
wg.Add(1)
handle()
}
wg.Wait()
}
測(cè)試結(jié)果
pkg: golang-study-demo/goroutine
1 2029931652 ns/op
PASS
1w個(gè)任務(wù)放到隊(duì)列中,1000個(gè)worker去執(zhí)行任務(wù),每個(gè)任務(wù)的耗時(shí)200ms,任務(wù)執(zhí)行完需要2s多
以上只是筆者的個(gè)人看法,不知道對(duì)Golang并發(fā)編程的理解是否正確,有錯(cuò)誤的地方,希望高手指點(diǎn)一二,在此謝過(guò)
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作能帶來(lái)一定的幫助，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
您可能感興趣的文章:- 基于Golang 高并發(fā)問(wèn)題的解決方案
- golang高并發(fā)限流操作 ping / telnet
- golang-gin-mgo高并發(fā)服務(wù)器搭建教程
- golang高并發(fā)的深入理解
- 關(guān)于golang高并發(fā)的實(shí)現(xiàn)與注意事項(xiàng)說(shuō)明
