bain2018 / gotask
A replacement for Swoole TaskWorker in Go,upgrade to hyperf3.1
v3.1.1
2023-12-15 04:18 UTC
Requires
- php: >=8.1
- ext-mongodb: *
- ext-sockets: *
- ext-swoole: >=5.0
- hyperf/pool: ^3.1
- hyperf/process: ^3.1
- spiral/goridge: ^2.4
- symfony/event-dispatcher: ^7.0.0
Requires (Dev)
- friendsofphp/php-cs-fixer: ^3.41
- hyperf/command: ^3.1
- hyperf/config: ^3.1
- hyperf/di: ^3.1
- hyperf/framework: ^3.1
- hyperf/testing: ^3.1
- mockery/mockery: ^1.6
- phpstan/phpstan: ^1.10
- swoole/ide-helper: ^5.0
This package is auto-updated.
Last update: 2024-11-15 06:37:28 UTC
README
English | 中文
GoTask spawns a go process as a Swoole sidecar and establishes a bi-directional IPC to offload heavy-duties to Go. Think of it as a Swoole Taskworker in Go.
composer require hyperf/gotask
Feature
- High performance with low footprint.
- Based on Swoole 4 coroutine socket API.
- Support Unix Socket, TCP and stdin/stdout pipes.
- Support both PHP-to-Go and Go-to-PHP calls.
- Automatic sidecar lifecycle management.
- Correctly handle remote error.
- Support both structural payload and binary payload.
- Sidecar API compatible with net/rpc.
- Baked-in connection pool.
- Optionally integrated with Hyperf framework.
Perfect For
- Blocking operations in Swoole, such as MongoDB queries.
- CPU Intensive operations, such as encoding and decoding.
- Leveraging Go eco-system, such as Kubernetes clients.
Requirement
- PHP 7.2+
- Go 1.13+
- Swoole 4.4LTS+
- Hyperf 1.1+ (optional)
Task Delivery Demo
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" ] });
Resources
English documentation is not yet complete! Please see examples first.
Benchmark
https://github.com/reasno/gotask-benchmark
Credit
- https://github.com/spiral/goridge provides the IPC protocol.
- https://github.com/twose helps the creation of this project.