PHP code example of friendsofhyperf / jet

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

friendsofhyperf / jet example snippets

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]));

use FriendsOfHyperf\Jet\ClientFactory;

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

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)));

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);
    }
}

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