這篇文章主要介紹“PHP混合Go協(xié)程并發(fā)分析”，在日常操作中，相信很多人在PHP混合Go協(xié)程并發(fā)分析問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”PHP混合Go協(xié)程并發(fā)分析”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

創(chuàng)新互聯(lián)建站是一家集網站建設,東洲企業(yè)網站建設,東洲品牌網站建設,網站定制,東洲網站建設報價,網絡營銷,網絡優(yōu)化,東洲網站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學習、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網站。

想法很簡單。通過設置 runtime.GOMAXPROCS(1) 讓 golang  的進程變成單線程執(zhí)行的。類似python用gevent的效果。然后通過調度多個協(xié)程實現(xiàn)異步I/O并發(fā)。php作為一個子函數(shù)跑在go的進程內，php需要yield到其他協(xié)程時，通過回調到golang函數(shù)來實現(xiàn)。從php里調用go提供的子函數(shù)時，go保證保存php的當前上下文。當協(xié)程執(zhí)行權讓渡回來的時候，把原來的php上下文恢復。關鍵的代碼在：

 // 保存當前協(xié)程上的php上下文        oldServerCtx := engine.ServerContextGet()     fmt.Println(oldServerCtx)     defer engine.ServerContextSet(oldServerCtx)     oldExecutorCtx := engine.ExecutorContextGet()     fmt.Println(oldExecutorCtx)     defer engine.ExecutorContextSet(oldExecutorCtx)     oldCoreCtx := engine.CoreContextGet()     fmt.Println(oldCoreCtx)     defer engine.CoreContextSet(oldCoreCtx)  // 放棄全局的鎖，使得其他的協(xié)程可以開始執(zhí)行php     engineLock.Unlock()     defer engineLock.Lock()

ServerContextGet  這幾個函數(shù)是我加的，獲得的是php的(EG/SG/PG)這三個全局context

完整的php/go混合協(xié)程的demo：

package main  import (     "fmt"     "github.com/deuill/go-php/engine"     "os"     "runtime"     "time"     "sync" )  type TestObj struct{}  func newTestObj(args []interface{}) interface{} {     return &TestObj{} } var engineLock *sync.Mutex  func (self *TestObj) Hello() {     oldServerCtx := engine.ServerContextGet()     fmt.Println(oldServerCtx)     defer engine.ServerContextSet(oldServerCtx)     oldExecutorCtx := engine.ExecutorContextGet()     fmt.Println(oldExecutorCtx)     defer engine.ExecutorContextSet(oldExecutorCtx)     oldCoreCtx := engine.CoreContextGet()     fmt.Println(oldCoreCtx)     defer engine.CoreContextSet(oldCoreCtx)     engineLock.Unlock()     defer engineLock.Lock()     time.Sleep(time.Second)     fmt.Println("sleep done") }  func main() {     runtime.GOMAXPROCS(1)     theEngine, err := engine.New()     engineLock = &sync.Mutex{}     if err != nil {         fmt.Println(err)     }     _, err = theEngine.Define("TestObj", newTestObj)     wg := &sync.WaitGroup{}     wg.Add(2)     before := time.Now()     fmt.Println("1")     go func() {         engineLock.Lock()         defer engineLock.Unlock()         context1, err := theEngine.NewContext()         if err != nil {             fmt.Println(err)         }         context1.Output = os.Stdout         if err != nil {             fmt.Println(err)         }         fmt.Println("1 enter")         _, err = context1.Eval("$testObj = new TestObj(); $testObj->Hello();")         fmt.Println("1 back")         if err != nil {             fmt.Println(err)         }         //theEngine.DestroyContext(context1)         fmt.Println("1 done")         wg.Done()     }()     fmt.Println("2")     go func() {         engineLock.Lock()         defer engineLock.Unlock()         context2, err := theEngine.NewContext()         if err != nil {             fmt.Println(err)         }         if err != nil {             fmt.Println(err)         }         context2.Output = os.Stdout         fmt.Println("2 enter")         _, err = context2.Eval("$testObj = new TestObj(); $testObj->Hello();")         fmt.Println("2 back")         if err != nil {             fmt.Println(err)         }         //theEngine.DestroyContext(context2)         fmt.Println("2 done")         wg.Done()     }()     wg.Wait()     after := time.Now()     fmt.Println(after.Sub(before)) }

執(zhí)行結果是

1 2 2 enter {0x2cf2930 {<nil> <nil> <nil> 0 <nil> <nil> <nil> <nil> 0 0 0 [0 0 0 0 0] <nil> <nil> <nil> <nil> <nil> <nil> <nil> 0 0 <nil> 1000 [0 0 0 0]} {{<nil> <nil> 0 16 0x7f682e819780 0 [0 0 0 0 0 0 0] <nil>} 0 1 [0 0 0] <nil> <nil>} 0 0 0 [0 0 0 0 0 0] {0 0 0 0 0 0 0 0 0 0 0 {0 0} {0 0} {0 0} [0 0 0]} 0x2a00270 0x2a00f60 <nil> 8388608 0 1 [0 0 0] 0 {8 7 2 [0 0 0 0] 0 0x29f4520 0x29f4520 0x29f4470 0x29f4420 <nil> 1 0 0 [0 0 0 0 0]} <nil> {0 [0 0 0 0 0 0 0] <nil> <nil> <nil> <nil>} 0 [0 0 0 0 0 0 0]} {0x7ffd30bac588 {[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0] 2 0 0 [0 0]} 0x7f682f01b928 {[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0] 1 0 0 [0 0]} 0x7f682f01b948 [<nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil>] 0x7f682f01ba60 0x7f682f01b960 0x7f682f167168 0x7f682f01ba88 {64 63 5 [0 0 0 0] 0 0x7f682f1972d8 0x7f682f1972d8 0x7f682f1993f8 0x7f682f1970c8 0x7f682e862d10 0 0 1 [0 0 0 0 0]} {8 0 0 [0 0 0 0] 0 <nil> <nil> <nil> 0x7f682f016a00 <nil> 0 0 1 [0 0 0 0 0]} 0x7ffd30bac590 22527 0 0 [0 0 0 0] 0x7f682f197640 0x29f4f80 0x29f4fd0 0x29f5070 <nil> 0x2cf2950 0x7f682f1989c0 14 0 1 [0 0 0] <nil> <nil> 0 1 [0 0 0 0 0 0] {8 0 0 [0 0 0 0] 1 <nil> <nil> <nil> 0x7f682f016a00 0x7f682e883140 0 0 1 [0 0 0 0 0]} {8 0 0 [0 0 0 0] 0 <nil> <nil> <nil> 0x7f682f016a00 0x7f682e8831d0 1 0 0 [0 0 0 0 0]} 0x7f682f167088 0 [0 0 0 0] <nil> <nil> {0 0 <nil>} {0 0 <nil> <nil> 0 [0 0 0 0 0 0 0]} {0 0 <nil> <nil> 0 [0 0 0 0 0 0 0]} 0 [0 0 0 0] <nil> 0 0 0x29fb2e0 <nil> <nil> {0x7f682f187030 2 1024 -1 [0 0 0 0]} <nil> <nil> <nil> [{0x7f682e915050 [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] 0 0 149 8 8 8} {0x7f682e915050 [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] 0 0 149 8 8 8} {0x7f682e915050 [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] 0 0 149 8 8 8}] 0x7f682f167168 <nil> {0 [0 0 0 0] <nil> 0 [0 0 0 0] 0 0 [0 0 0 0] <nil> 0 [0 0 0 0] <nil>} 1 [0 0 0 0 0 0 0] <nil> 0x7f682f01bde8 895 [0 0 0 0 0 0] [<nil> <nil> <nil> <nil>]} {1 [0 0 0 0 0 0 0] 0 0 0 [0 0 0 0 0 0] <nil> 0x29ff9a0 17 134217728 -1 0 0 0 1 [0 0 0 0] 1024 0 0 1 [0 0 0 0 0] 0x2a00870 <nil> 0x2a010a0 0x7f682ecc58b0 <nil> 0x7f682ecc5c23 <nil> <nil> <nil> 2097152 <nil> <nil> 0x2a00180 0x2a00230 <nil> <nil> <nil> {0x7f682ec91aa8 0x7f682ec91aa8} 0x2a00910 {0 0 0 [0 0 0 0] 0 <nil> <nil> <nil> <nil> <nil> 0 0 0 [0 0 0 0 0]} 0 0 0 [0 0 0] {0x2b6dc10 0x2b6dc10 1 8 <nil> 1 [0 0 0 0 0 0 0] <nil>} [0x7f682f197330 0x7f682f197040 0x7f682f197410 <nil> <nil> 0x7f682f1974f0] 0 1 1 [0 0 0 0 0] 0x7f682ec9544b 0x7f682ec9544b 0 0 [0 0 0 0 0 0] 0 [0 0 0 0 0 0 0 0] 1 1 1 1 1 0 1 [0] 0 [0 0 0 0] <nil> <nil> 0 [0 0 0 0] 0x2cf27c0 <nil> 0 0 [0 0 0 0 0 0] 64 1000 0 [0 0 0 0 0 0 0] 0x7f682ecc6270 300 0x2a009b0 1 [0 0 0 0 0 0 0] <nil> 0 [0 0 0 0 0 0 0]} 1 enter {0x7f6818000aa0 {<nil> <nil> <nil> 0 <nil> <nil> <nil> <nil> 0 0 0 [0 0 0 0 0] <nil> <nil> <nil> <nil> <nil> <nil> <nil> 0 0 <nil> 1000 [0 0 0 0]} {{<nil> <nil> 0 16 0x7f682e819780 0 [0 0 0 0 0 0 0] <nil>} 0 1 [0 0 0] <nil> <nil>} 0 0 0 [0 0 0 0 0 0] {0 0 0 0 0 0 0 0 0 0 0 {0 0} {0 0} {0 0} [0 0 0]} 0x2a00270 0x2a00f60 <nil> 8388608 0 1 [0 0 0] 0 {8 7 2 [0 0 0 0] 0 0x29f4520 0x29f4520 0x29f4470 0x29f4420 <nil> 1 0 0 [0 0 0 0 0]} <nil> {0 [0 0 0 0 0 0 0] <nil> <nil> <nil> <nil>} 0 [0 0 0 0 0 0 0]} {0x7f682a4cccd8 {[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0] 2 0 0 [0 0]} 0x7f682f01b928 {[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0] 1 0 0 [0 0]} 0x7f682f01b948 [<nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil> <nil>] 0x7f682f01ba60 0x7f682f01b960 0x7f682802f110 0x7f682f01ba88 {64 63 5 [0 0 0 0] 0 0x7f682f197a00 0x7f682f197a00 0x7f682f198368 0x7f682f198fa0 0x7f682e862d10 0 0 1 [0 0 0 0 0]} {8 0 0 [0 0 0 0] 0 <nil> <nil> <nil> 0x7f682f016a00 <nil> 0 0 1 [0 0 0 0 0]} 0x7f682a4ccce0 22527 0 0 [0 0 0 0] 0x7f682f197d28 0x29f4f80 0x29f4fd0 0x29f5070 <nil> 0x2cf2950 0x7f682f1983e8 14 0 1 [0 0 0] <nil> <nil> 0 1 [0 0 0 0 0 0] {8 0 0 [0 0 0 0] 1 <nil> <nil> <nil> 0x7f682f016a00 0x7f682e883140 0 0 1 [0 0 0 0 0]} {8 0 0 [0 0 0 0] 0 <nil> <nil> <nil> 0x7f682f016a00 0x7f682e8831d0 1 0 0 [0 0 0 0 0]} 0x7f682802f030 0 [0 0 0 0] <nil> <nil> {0 0 <nil>} {0 0 <nil> <nil> 0 [0 0 0 0 0 0 0]} {0 0 <nil> <nil> 0 [0 0 0 0 0 0 0]} 0 [0 0 0 0] <nil> 0 0 0x29fb2e0 <nil> <nil> {0x7f682804efd8 2 1024 -1 [0 0 0 0]} <nil> <nil> <nil> [{0x7f682e915050 [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] 0 0 149 8 8 8} {0x7f682e915050 [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] 0 0 149 8 8 8} {0x7f682e915050 [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0] 0 0 149 8 8 8}] 0x7f682802f110 <nil> {0 [0 0 0 0] <nil> 0 [0 0 0 0] 0 0 [0 0 0 0] <nil> 0 [0 0 0 0] <nil>} 1 [0 0 0 0 0 0 0] <nil> 0x7f682f01bde8 895 [0 0 0 0 0 0] [<nil> <nil> <nil> <nil>]} {1 [0 0 0 0 0 0 0] 0 0 0 [0 0 0 0 0 0] <nil> 0x29ff9a0 17 134217728 -1 0 0 0 1 [0 0 0 0] 1024 0 0 1 [0 0 0 0 0] 0x2a00870 <nil> 0x2a010a0 0x7f682ecc58b0 <nil> 0x7f682ecc5c23 <nil> <nil> <nil> 2097152 <nil> <nil> 0x2a00180 0x2a00230 <nil> <nil> <nil> {0x7f682ec91aa8 0x7f682ec91aa8} 0x2a00910 {0 0 0 [0 0 0 0] 0 <nil> <nil> <nil> <nil> <nil> 0 0 0 [0 0 0 0 0]} 0 0 0 [0 0 0] {0x2b6dc10 0x2b6dc10 1 8 <nil> 1 [0 0 0 0 0 0 0] <nil>} [0x7f682f197a58 0x7f682f198ce0 0x7f682f197b38 <nil> <nil> 0x7f682f197c18] 0 1 1 [0 0 0 0 0] 0x7f682ec9544b 0x7f682ec9544b 0 0 [0 0 0 0 0 0] 0 [0 0 0 0 0 0 0 0] 1 1 1 1 1 0 1 [0] 0 [0 0 0 0] <nil> <nil> 0 [0 0 0 0] 0x2cf27c0 <nil> 0 0 [0 0 0 0 0 0] 64 1000 0 [0 0 0 0 0 0 0] 0x7f682ecc6270 300 0x2a009b0 1 [0 0 0 0 0 0 0] <nil> 0 [0 0 0 0 0 0 0]} sleep done 1 back 1 done sleep done 2 back 2 done 1.00099211s

可以看到兩個sleep 1s，最終只用了1.00099211s。說明協(xié)程是并發(fā)的。

一些性能指標。走http調用后端，在i7-6700k上，用ab -n 100 -c 4 可以跑出這樣的結果

Requests per second:    3183.70 [#/sec] (mean) Time per request:       1.256 [ms] (mean) Time per request:       0.314 [ms] (mean, across all concurrent requests)

如果不用http調用后端，直接php=>go返回"hello"，則可以達到

Requests per second: 10073.54 [#/sec] (mean)  Time per request: 0.397 [ms] (mean)  Time per request: 0.099 [ms] (mean, across all concurrent requests)

這些指標只說明了協(xié)程切換的成本。實際的收益取決于后端的http服務的延遲，如果耗時很長，通過協(xié)程并發(fā)則可以收益明顯。

這個實驗說明了可以用golang實現(xiàn)一個代替nginx+php-fpm的應用服務器。并且提供了一條從php向golang遷移的平滑遷移路徑。在一個應用里混合PHP和Go兩種語言。

并且可以通過提供golang函數(shù)給php調用的方式實現(xiàn)I/O的異步化。像libcurl這樣的擴展自身是支持異步回調的，只是php是同步的所以只給php暴露了同步的execute。有了Golang之后，可以把execute變成對異步execute+callback的包裝，從而實現(xiàn)基于協(xié)程的調度。

到此，關于“PHP混合Go協(xié)程并發(fā)分析”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注創(chuàng)新互聯(lián)網站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

新聞標題：PHP混合Go協(xié)程并發(fā)分析
鏈接地址：http://aaarwkj.com/article22/pjcojc.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供移動網站建設、虛擬主機、外貿網站建設、用戶體驗、網站營銷、品牌網站制作

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)