README

英文 | 中文

GoTask在Swoole旁边启动一个Go进程，并建立双向IPC以将重任务卸载到Go。可以将其视为Go中的Swoole Taskworker。

composer require hyperf/gotask

特性

高性能，占用小。
基于Swoole 4协程socket API。
支持Unix Socket、TCP和stdin/stdout管道。
支持PHP到Go和Go到PHP的调用。
自动管理边车生命周期。
正确处理远程错误。
支持结构化有效载荷和二进制有效载荷。
边车API与net/rpc兼容。
内置连接池。
可选集成Hyperf框架。

适用于

Swoole中的阻塞操作，如MongoDB查询。
CPU密集型操作，如编码和解码。
利用Go生态系统，如Kubernetes客户端。

要求

PHP 7.2+
Go 1.13+
Swoole 4.4LTS+
Hyperf 1.1+ (可选)

任务交付演示

package main

import (
    "github.com/hyperf/gotask/v2/pkg/gotask"
)

type App struct{}

func (a *App) Hi(name string, r *interface{}) error {
    *r = map[string]string{
        "hello": name,
    }
    return nil
}

func main() {
    gotask.SetAddress("127.0.0.1:6001")
    gotask.Register(new(App))
    gotask.Run()
}

<?php

use Hyperf\GoTask\IPC\SocketIPCSender;
use function Swoole\Coroutine\run;

require_once "../vendor/autoload.php";

run(function(){
    $task = new SocketIPCSender('127.0.0.1:6001');
    var_dump($task->call("App.Hi", "Hyperf"));
    // [ "hello" => "Hyperf" ]
});

资源

英文文档尚未完成！请先查看示例。

基准测试

https://github.com/reasno/gotask-benchmark

致谢

https://github.com/spiral/goridge 提供了IPC协议。
https://github.com/twose 帮助创建了此项目。

reasno / gotask

维护者

详细信息

README

特性

适用于

要求

任务交付演示

资源

基准测试

致谢