gemini / rpc-multiplex
Rpc for multiplexing connection
v2.2.0
2021-07-18 06:50 UTC
Requires
- php: >=7.3
- hyperf/framework: ~2.2.0
- hyperf/http-message: ~2.2.0
- hyperf/load-balancer: ~2.2.0
- hyperf/rpc: ~2.2.0
- hyperf/rpc-client: ~2.2.0
- hyperf/rpc-server: ~2.2.0
- hyperf/server: ~2.2.0
- hyperf/utils: ~2.2.0
- multiplex/socket: ^0.4
This package is auto-updated.
Last update: 2024-10-12 23:25:52 UTC
README
安装
composer require hyperf/rpc-multiplex
Server 配置
修改 config/autoload/server.php
配置文件
删除不相干配置
<?php declare(strict_types=1); use Hyperf\Server\Event; use Hyperf\Server\Server; return [ 'servers' => [ [ 'name' => 'rpc', 'type' => Server::SERVER_BASE, 'host' => '0.0.0.0', 'port' => 9502, 'sock_type' => SWOOLE_SOCK_TCP, 'callbacks' => [ Event::ON_RECEIVE => [Hyperf\RpcMultiplex\TcpServer::class, 'onReceive'], ], 'settings' => [ 'open_length_check' => true, 'package_length_type' => 'N', 'package_length_offset' => 0, 'package_body_offset' => 4, 'package_max_length' => 1024 * 1024 * 2, ], ], ], ];
创建 RpcService
<?php namespace App\RPC; use App\JsonRpc\CalculatorServiceInterface; use Hyperf\RpcMultiplex\Constant; use Hyperf\RpcServer\Annotation\RpcService; /** * @RpcService(name="CalculatorService", server="rpc", protocol=Constant::PROTOCOL_DEFAULT) */ class CalculatorService implements CalculatorServiceInterface { }
客户端配置
修改 config/autoload/services.php
配置文件
<?php declare(strict_types=1); return [ 'consumers' => [ [ 'name' => 'CalculatorService', 'service' => App\JsonRpc\CalculatorServiceInterface::class, 'id' => App\JsonRpc\CalculatorServiceInterface::class, 'protocol' => Hyperf\RpcMultiplex\Constant::PROTOCOL_DEFAULT, 'load_balancer' => 'random', 'nodes' => [ ['host' => '127.0.0.1', 'port' => 9502], ], 'options' => [ 'connect_timeout' => 5.0, 'recv_timeout' => 5.0, 'settings' => [ // 包体最大值,若小于 Server 返回的数据大小,则会抛出异常,故尽量控制包体大小 'package_max_length' => 1024 * 1024 * 2, ], // 重试次数,默认值为 2 'retry_count' => 2, // 重试间隔,毫秒 'retry_interval' => 100, // 多路复用客户端数量 'client_count' => 4, // 心跳间隔 非 numeric 表示不开启心跳 'heartbeat' => 30, ], ], ], ];