前言
之前一直對Golang如何處理高并發http請求的一頭霧水,這幾天也查了很多相關博客,似懂非懂,不知道具體代碼怎么寫
下午偶然在開發者頭條APP上看到一篇國外技術人員的一篇文章用Golang處理每分鐘百萬級請求,看完文章中的代碼,自己寫了一遍代碼,下面自己寫下自己的體會
核心要點
將請求放入隊列,通過一定數量(例如CPU核心數)goroutine組成一個worker池(pool),workder池中的worker讀取隊列執行任務
實例代碼
以下代碼筆者根據自己的理解進行了簡化,主要是表達出個人的思路,實際后端開發中,根據實際場景修改
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
func doTask() { //耗時炒作(模擬) time.Sleep(200 * time.Millisecond) wg.Done()}//這里模擬的http接口,每次請求抽象為一個jobfunc 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 itfunc (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() }} |
測試
|
1
2
3
4
5
6
7
8
9
10
|
func Benchmark_handle(b *testing.B) { runtime.GOMAXPROCS(runtime.NumCPU()) d := NewDispatcher() d.Run() for i:=0;i<10000;i++ { wg.Add(1) handle() } wg.Wait()} |
測試結果
|
1
2
3
|
pkg: golang-study-demo/goroutine1 2029931652 ns/opPASS |
1w個任務放到隊列中,1000個worker去執行任務,每個任務的耗時200ms,任務執行完需要2s多
以上只是筆者的個人看法,不知道對Golang并發編程的理解是否正確,有錯誤的地方,希望高手指點一二,在此謝過
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對服務器之家的支持。
原文鏈接：https://segmentfault.com/a/1190000011063451
