Jet

Another jet client for Hyperf

Installation

Composer

composer require "friendsofhyperf/jet:^4.0"

QuickStart

Register with metadata

useFriendsOfHyperf\Jet\Metadata;
useFriendsOfHyperf\Jet\ServiceManager;
useFriendsOfHyperf\Jet\Registry\ConsulRegistry;
useFriendsOfHyperf\Jet\Transporter\GuzzleHttpTransporter;
$metadata = (newMetadata('CalculatorService'))
->withTransporter(newGuzzleHttpTransporter('127.0.0.1', 9502))
// or
->setRegistry(newConsulRegistry(['uri' => 'http://127.0.0.1:8500']))
;
ServiceManager::register('CalculatorService', $metadata);

Register default registry

useFriendsOfHyperf\Jet\RegistryManager;
useFriendsOfHyperf\Jet\Registry\ConsulRegistry;
RegistryManager::register(RegistryManager::DEFAULT, newConsulRegistry(['uri' => $uri, 'timeout' => 1]));

In Laravel project, Add to boot() in App/Providers/AppServiceProvider.php

Call RPC method

Call by ClientFactory

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

Call by ClientFactory Using Grpc

useFriendsOfHyperf\Jet\ClientFactory;
return ClientFactory::create(function() {
return (newMetadata('CalculatorService'))
->withPacker(newGrpcPacker())
->withPathGenerator(newGrpcPathGenerator())
// 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(newGrpcTransporter('127.0.0.1', 9502, [
'path' => 'calculator.CalCulator',
]));
});

Call by custom client

useFriendsOfHyperf\Jet\Client;
useFriendsOfHyperf\Jet\Transporter\GuzzleHttpTransporter;
useFriendsOfHyperf\Jet\Registry\ConsulRegistry;
/** * @method int add(int $a, int $b) */class CalculatorService extends Client
{
publicfunction__construct($service = 'CalculatorService')
{
$metadata = (newMetadata($service))
// Custom transporter
->withTransporter(newGuzzleHttpTransporter('127.0.0.1', 9502))
// Custom registry
->withRegistry(newConsulRegistry(['uri' => 'http://127.0.0.1:8500']));
parent::__construct($metadata);
}
}
$service = newCalculatorService;
var_dump($service->add(3, 10));

Call by custom facade

useFriendsOfHyperf\Jet\Facade;
useFriendsOfHyperf\Jet\ClientFactory;
/** * @method static int add(int $a, int $b) */class Calculator extends Facade
{
protectedstaticfunctiongetFacadeAccessor()
{
// return ClientFactory::create('CalculatorService');return'CalculatorService';
}
}
var_dump(Calculator::add(rand(0, 100), rand(0, 100)));

Coroutine support in Hyperf

• Aspect

<?phpnamespaceApp\Aspect;
useHyperf\Di\Aop\AbstractAspect;
useHyperf\Di\Aop\ProceedingJoinPoint;
useHyperf\Guzzle\ClientFactory;
class GuzzleHttpTransporterAspect extends AbstractAspect
{
publicarray$classes = [
'FriendsOfHyperf\Jet\Transporter\GuzzleHttpTransporter::getClient',
];
protectedClientFactory$clientFactory;
publicfunction__construct(ClientFactory$clientFactory)
{
$this->clientFactory = $clientFactory;
}
publicfunctionprocess(ProceedingJoinPoint$proceedingJoinPoint)
{
$instance = $proceedingJoinPoint->getInstance();
$config = (function () { return$this->config; })->call($instance);
return$this->clientFactory->create($config);
}
}

• Config config/autoload/aspects.php

<?phpreturn [
'App\Aspect\GuzzleHttpTransporterAspect',
];