README

Hyperf 的另一个 jet 客户端

安装

Composer

composer require "friendsofhyperf/jet:^4.0"

快速入门

使用元数据注册

use FriendsOfHyperf\Jet\Metadata;
use FriendsOfHyperf\Jet\ServiceManager;
use FriendsOfHyperf\Jet\Registry\ConsulRegistry;
use FriendsOfHyperf\Jet\Transporter\GuzzleHttpTransporter;

$metadata = (new Metadata('CalculatorService'))
    ->withTransporter(new GuzzleHttpTransporter('127.0.0.1', 9502))
    // or
    ->setRegistry(new ConsulRegistry(['uri' => 'http://127.0.0.1:8500']))
    ;

ServiceManager::register('CalculatorService', $metadata);

注册默认仓库

use FriendsOfHyperf\Jet\RegistryManager;
use FriendsOfHyperf\Jet\Registry\ConsulRegistry;

RegistryManager::register(RegistryManager::DEFAULT, new ConsulRegistry(['uri' => $uri, 'timeout' => 1]));

在 Laravel 项目中，将以下代码添加到 boot() 方法中 App/Providers/AppServiceProvider.php

调用 RPC 方法

通过 ClientFactory 调用

use FriendsOfHyperf\Jet\ClientFactory;

$client = ClientFactory::create('CalculatorService');
var_dump($client->add(1, 20));

使用 Grpc 通过 ClientFactory 调用

use FriendsOfHyperf\Jet\ClientFactory;

return ClientFactory::create(function() {
    return (new Metadata('CalculatorService'))
        ->withPacker(new GrpcPacker())
        ->withPathGenerator(new GrpcPathGenerator())
        // If use consul next config is necessary
        ->withRegistry(RegistryManager::get(RegistryManager::DEFAULT))
        ->withTransporterConfig([
            'path' => 'calculator.CalCulator',
        ])
        ->withProtocol('grpc')
        ->withTimeout(10)
        // If not use consul,directly use GrpcTransporter 
        ->withTransporter(new GrpcTransporter('127.0.0.1', 9502, [
            'path' => 'calculator.CalCulator',
        ]));
});

通过自定义客户端调用

use FriendsOfHyperf\Jet\Client;
use FriendsOfHyperf\Jet\Transporter\GuzzleHttpTransporter;
use FriendsOfHyperf\Jet\Registry\ConsulRegistry;

/**
 * @method int add(int $a, int $b)
 */
class CalculatorService extends Client
{
    public function __construct($service = 'CalculatorService')
    {
        $metadata = (new Metadata($service))
            // Custom transporter
            ->withTransporter(new GuzzleHttpTransporter('127.0.0.1', 9502))
            // Custom registry
            ->withRegistry(new ConsulRegistry(['uri' => 'http://127.0.0.1:8500']));

        parent::__construct($metadata);
    }
}

$service = new CalculatorService;
var_dump($service->add(3, 10));

通过自定义外观调用

use FriendsOfHyperf\Jet\Facade;
use FriendsOfHyperf\Jet\ClientFactory;

/**
 * @method static int add(int $a, int $b)
 */
class Calculator extends Facade
{
    protected static function getFacadeAccessor()
    {
        // return ClientFactory::create('CalculatorService');
        return 'CalculatorService';
    }
}

var_dump(Calculator::add(rand(0, 100), rand(0, 100)));

Hyperf 中的协程支持

• 切面

<?php

namespace App\Aspect;

use Hyperf\Di\Aop\AbstractAspect;
use Hyperf\Di\Aop\ProceedingJoinPoint;
use Hyperf\Guzzle\ClientFactory;

class GuzzleHttpTransporterAspect extends AbstractAspect
{
    public array $classes = [
        'FriendsOfHyperf\Jet\Transporter\GuzzleHttpTransporter::getClient',
    ];

    protected ClientFactory $clientFactory;

    public function __construct(ClientFactory $clientFactory)
    {
        $this->clientFactory = $clientFactory;
    }

    public function process(ProceedingJoinPoint $proceedingJoinPoint)
    {
        $instance = $proceedingJoinPoint->getInstance();
        $config = (function () { return $this->config; })->call($instance);

        return $this->clientFactory->create($config);
    }
}

• 配置 config/autoload/aspects.php

<?php

return [
    'App\Aspect\GuzzleHttpTransporterAspect',
];