PHP 混合 Go 協(xié)程并發(fā)

zhaofeihao 發(fā)布于2019-06-27 14:42 / 1211人閱讀

摘要：當(dāng)協(xié)程執(zhí)行權(quán)讓渡回來(lái)的時(shí)候，把原來(lái)的上下文恢復(fù)。說(shuō)明協(xié)程是并發(fā)的。實(shí)際的收益取決于后端的服務(wù)的延遲，如果耗時(shí)很長(zhǎng)，通過(guò)協(xié)程并發(fā)則可以收益明顯。

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

// 保存當(dāng)前協(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 這幾個(gè)函數(shù)是我加的，獲得的是php的（EG/SG/PG）這三個(gè)全局context（參見：http://www.cnblogs.com/chance...）。修改過(guò)的github.com/deuill/go-php的源代碼在：https://github.com/taowen/go-...

完整的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í)行結(jié)果是

1
2
2 enter
{0x2cf2930 {   0     0 0 0 [0 0 0 0 0]        0 0  1000 [0 0 0 0]} {{  0 16 0x7f682e819780 0 [0 0 0 0 0 0 0] } 0 1 [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} [0 0 0]} 0x2a00270 0x2a00f60  8388608 0 1 [0 0 0] 0 {8 7 2 [0 0 0 0] 0 0x29f4520 0x29f4520 0x29f4470 0x29f4420  1 0 0 [0 0 0 0 0]}  {0 [0 0 0 0 0 0 0]    } 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 [                               ] 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    0x7f682f016a00  0 0 1 [0 0 0 0 0]} 0x7ffd30bac590 22527 0 0 [0 0 0 0] 0x7f682f197640 0x29f4f80 0x29f4fd0 0x29f5070  0x2cf2950 0x7f682f1989c0 14 0 1 [0 0 0]   0 1 [0 0 0 0 0 0] {8 0 0 [0 0 0 0] 1    0x7f682f016a00 0x7f682e883140 0 0 1 [0 0 0 0 0]} {8 0 0 [0 0 0 0] 0    0x7f682f016a00 0x7f682e8831d0 1 0 0 [0 0 0 0 0]} 0x7f682f167088 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 0 0 0]  0 0 0x29fb2e0   {0x7f682f187030 2 1024 -1 [0 0 0 0]}    [{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  {0 [0 0 0 0]  0 [0 0 0 0] 0 0 [0 0 0 0]  0 [0 0 0 0] } 1 [0 0 0 0 0 0 0]  0x7f682f01bde8 895 [0 0 0 0 0 0] [   ]}
{1 [0 0 0 0 0 0 0] 0 0 0 [0 0 0 0 0 0]  0x29ff9a0 17 134217728 -1 0 0 0 1 [0 0 0 0] 1024 0 0 1 [0 0 0 0 0] 0x2a00870  0x2a010a0 0x7f682ecc58b0  0x7f682ecc5c23    2097152   0x2a00180 0x2a00230    {0x7f682ec91aa8 0x7f682ec91aa8} 0x2a00910 {0 0 0 [0 0 0 0] 0      0 0 0 [0 0 0 0 0]} 0 0 0 [0 0 0] {0x2b6dc10 0x2b6dc10 1 8  1 [0 0 0 0 0 0 0] } [0x7f682f197330 0x7f682f197040 0x7f682f197410   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]   0 [0 0 0 0] 0x2cf27c0  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]  0 [0 0 0 0 0 0 0]}
1 enter
{0x7f6818000aa0 {   0     0 0 0 [0 0 0 0 0]        0 0  1000 [0 0 0 0]} {{  0 16 0x7f682e819780 0 [0 0 0 0 0 0 0] } 0 1 [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} [0 0 0]} 0x2a00270 0x2a00f60  8388608 0 1 [0 0 0] 0 {8 7 2 [0 0 0 0] 0 0x29f4520 0x29f4520 0x29f4470 0x29f4420  1 0 0 [0 0 0 0 0]}  {0 [0 0 0 0 0 0 0]    } 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 [                               ] 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    0x7f682f016a00  0 0 1 [0 0 0 0 0]} 0x7f682a4ccce0 22527 0 0 [0 0 0 0] 0x7f682f197d28 0x29f4f80 0x29f4fd0 0x29f5070  0x2cf2950 0x7f682f1983e8 14 0 1 [0 0 0]   0 1 [0 0 0 0 0 0] {8 0 0 [0 0 0 0] 1    0x7f682f016a00 0x7f682e883140 0 0 1 [0 0 0 0 0]} {8 0 0 [0 0 0 0] 0    0x7f682f016a00 0x7f682e8831d0 1 0 0 [0 0 0 0 0]} 0x7f682802f030 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 0 0 0]  0 0 0x29fb2e0   {0x7f682804efd8 2 1024 -1 [0 0 0 0]}    [{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  {0 [0 0 0 0]  0 [0 0 0 0] 0 0 [0 0 0 0]  0 [0 0 0 0] } 1 [0 0 0 0 0 0 0]  0x7f682f01bde8 895 [0 0 0 0 0 0] [   ]}
{1 [0 0 0 0 0 0 0] 0 0 0 [0 0 0 0 0 0]  0x29ff9a0 17 134217728 -1 0 0 0 1 [0 0 0 0] 1024 0 0 1 [0 0 0 0 0] 0x2a00870  0x2a010a0 0x7f682ecc58b0  0x7f682ecc5c23    2097152   0x2a00180 0x2a00230    {0x7f682ec91aa8 0x7f682ec91aa8} 0x2a00910 {0 0 0 [0 0 0 0] 0      0 0 0 [0 0 0 0 0]} 0 0 0 [0 0 0] {0x2b6dc10 0x2b6dc10 1 8  1 [0 0 0 0 0 0 0] } [0x7f682f197a58 0x7f682f198ce0 0x7f682f197b38   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]   0 [0 0 0 0] 0x2cf27c0  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]  0 [0 0 0 0 0 0 0]}
sleep done
1 back
1 done
sleep done
2 back
2 done
1.00099211s

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

一些性能指標(biāo)。走h(yuǎn)ttp調(diào)用后端，在i7-6700k上，用ab -n 100 -c 4 可以跑出這樣的結(jié)果

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調(diào)用后端，直接php=>go返回"hello"，則可以達(dá)到

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)

這些指標(biāo)只說(shuō)明了協(xié)程切換的成本。實(shí)際的收益取決于后端的http服務(wù)的延遲，如果耗時(shí)很長(zhǎng)，通過(guò)協(xié)程并發(fā)則可以收益明顯。

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

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

參考資料：

https://wiki.php.net/internal...

http://www.cunmou.com/phpbook...

http://www.phpinternalsbook.c...

http://www.php-internals.com/...

GPU云服務(wù)器云服務(wù)器 php并發(fā)go php協(xié)程curl php協(xié)程擴(kuò)展 go攜程 php

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://www.ezyhdfw.cn/yun/21976.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

zhaofeihao

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

conda

閱讀 2344·2023-04-25 14:50
ZJI：中國(guó)香港4C多IP站群服務(wù)器(238IP)，8折優(yōu)惠，1600元/月，20MCN2+BGP帶

閱讀 1409·2021-10-13 09:50
前端網(wǎng)頁(yè)加載渲染鏈路優(yōu)化

閱讀 1933·2019-08-30 15:56
如何優(yōu)雅的使用vue+Dcloud（Hbuild）開發(fā)混合app

閱讀 1908·2019-08-29 15:29
CSS 水平居中

閱讀 2949·2019-08-29 15:27
用 margin 還是用 padding ？

閱讀 3632·2019-08-29 15:14
浮動(dòng)影響

閱讀 1253·2019-08-29 13:01
JavaScript數(shù)據(jù)結(jié)構(gòu)與算法（九）二叉樹和二叉搜索樹

閱讀 3350·2019-08-26 14:06

亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

PHP 混合 Go 協(xié)程并發(fā)

相關(guān)文章

PHP 協(xié)程：Go + Chan + Defer

聊聊 2018 年后端技術(shù)趨勢(shì)

Easyswoole 源碼學(xué)習(xí)和個(gè)人解析目錄

Swoole4.x探究之多進(jìn)程TCP協(xié)程服務(wù)實(shí)現(xiàn)

PHP下用Swoole實(shí)現(xiàn)Actor并發(fā)模型

發(fā)表評(píng)論

0條評(píng)論

zhaofeihao

男|高級(jí)講師

TA的文章

conda

ZJI：中國(guó)香港4C多IP站群服務(wù)器(238IP)，8折優(yōu)惠，1600元/月，20MCN2+BGP帶

前端網(wǎng)頁(yè)加載渲染鏈路優(yōu)化

如何優(yōu)雅的使用vue+Dcloud（Hbuild）開發(fā)混合app

CSS 水平居中

用 margin 還是用 padding ？

浮動(dòng)影響

JavaScript數(shù)據(jù)結(jié)構(gòu)與算法（九）二叉樹和二叉搜索樹

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

PHP 混合 Go 協(xié)程并發(fā)

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！