hyperf实现Rpc服务（docker+consul）
hyperf实现Rpc服务（docker+consul）
·
1、拉去docker镜像
（这里要注意自己实际用到的端口）
docker run --name self-rpc /
-v D:\Download\phpstudy_pro\WWW\self-rpc:/self-rpc /
-p 9501:9501 -p 9601:9601 -p 9503:9503 -p 9603:9603 /
-it --privileged -u root /
--entrypoint /bin/sh /
hyperf/hyperf:7.4-alpine-v3.11-swoole2、拉取并安装consul
docker pull consul
docker run --name=self-consul -p 8500:8500 -e CONSUL_BIND_INTERFACE=eth0 -d consul3、尝试访问
http://lcoalhost:8500
4、创建服务提供者项目（服务端）server-provider
先切换阿里云镜像
composer config -g repo.packagist composer https://mirrors.aliyun.com/composer
安装组件composer require hyperf/json-rpccomposer require hyperf/rpc-servercomposer require hyperf/rpc-clientcomposer require hyperf/service-governancecomposer require hyperf/service-governance-consulcomposer require hyperf/consul
发布组件（生成 autoload/services.php文件）php bin/hyperf.php vendor:publish hyperf/service-governance
编写服务提供者接口（先创建JsonRpc文件夹）【app/JsonRpc/CalculatorServiceInterface.php】
<?php declare(strict_types=1); namespace App\JsonRpc; interface CalculatorServiceInterface { public function list(); }实现接口【app/JsonRpc/CalculatorService.php】
<?php namespace App\JsonRpc; use Hyperf\RpcServer\Annotation\RpcService; /** * 服务提供者 * 注意，如希望通过服务中心来管理服务，需在注解内增加 publishTo 属性 * @RpcService(name="CalculatorService", protocol="jsonrpc", server="jsonrpc",publishTo="consul") */ class CalculatorService implements CalculatorServiceInterface { protected $list = [ ['id'=>1, 'name'=>'Mr.Li', 'age' => 20], ['id'=>2, 'name'=>'Mr.Zhang', 'age' => 30] ]; public function list() { return $this->list; } }server.php配置
<?php declare(strict_types=1); /** * This file is part of Hyperf. * * @link https://www.hyperf.io * @document https://hyperf.wiki * @contact group@hyperf.io * @license https://github.com/hyperf/hyperf/blob/master/LICENSE */ use Hyperf\Server\Event; use Hyperf\Server\Server; use Swoole\Constant; return [ 'mode' => SWOOLE_PROCESS, 'servers' => [ [ 'name' => 'jsonrpc', 'type' => Server::SERVER_BASE, 'host' => '0.0.0.0', 'port' => 9503, 'sock_type' => SWOOLE_SOCK_TCP, 'callbacks' => [ Event::ON_RECEIVE => [\Hyperf\JsonRpc\TcpServer::class, 'onReceive'], ], 'settings' => [ 'open_eof_split' => true, 'package_eof' => "\r\n", 'package_max_length' => 1024 * 1024 * 2, ], ], ], 'settings' => [ Constant::OPTION_ENABLE_COROUTINE => true, Constant::OPTION_WORKER_NUM => swoole_cpu_num(), Constant::OPTION_PID_FILE => BASE_PATH . '/runtime/hyperf.pid', Constant::OPTION_OPEN_TCP_NODELAY => true, Constant::OPTION_MAX_COROUTINE => 100000, Constant::OPTION_OPEN_HTTP2_PROTOCOL => true, Constant::OPTION_MAX_REQUEST => 100000, Constant::OPTION_SOCKET_BUFFER_SIZE => 2 * 1024 * 1024, Constant::OPTION_BUFFER_OUTPUT_SIZE => 2 * 1024 * 1024, ], 'callbacks' => [ Event::ON_WORKER_START => [Hyperf\Framework\Bootstrap\WorkerStartCallback::class, 'onWorkerStart'], Event::ON_PIPE_MESSAGE => [Hyperf\Framework\Bootstrap\PipeMessageCallback::class, 'onPipeMessage'], Event::ON_WORKER_EXIT => [Hyperf\Framework\Bootstrap\WorkerExitCallback::class, 'onWorkerExit'], ], ];services.php配置（前面发布生成的）
<?php declare(strict_types=1); /** * This file is part of Hyperf. * * @link https://www.hyperf.io * @document https://hyperf.wiki * @contact group@hyperf.io * @license https://github.com/hyperf/hyperf/blob/master/LICENSE */ return [ 'enable' => [ 'discovery' => true, 'register' => true, ], 'consumers' => [ [ // The service name, this name should as same as with the name of service provider. 'name' => 'CalculatorService', // The service registry, if `nodes` is missing below, then you should provide this configs. // 服务接口名，可选，默认值等于 name 配置的值，如果 name 直接定义为接口类则可忽略此行配置，如 name 为字符串则需要配置 service 对应到接口类 'service' => \App\JsonRpc\CalculatorServiceInterface::class, // 服务提供者的服务协议，可选，默认值为 jsonrpc-http 'protocol' => 'jsonrpc', // 负载均衡算法，可选，默认值为 random 'load_balancer' => 'random', // 对应容器对象 ID，可选，默认值等于 service 配置的值，用来定义依赖注入的 key 'id' => \App\JsonRpc\CalculatorServiceInterface::class, // If `registry` is missing, then you should provide the nodes configs. 'nodes' => [ // Provide the host and port of the service provider. ['host' => '127.0.0.1', 'port' => 9503] ], // 配置项，会影响到 Packer 和 Transporter 'options' => [ 'connect_timeout' => 5.0, 'recv_timeout' => 5.0, 'settings' => [ // 根据协议不同，区分配置 'open_eof_split' => true, 'package_eof' => "\r\n", // 'open_length_check' => true, // 'package_length_type' => 'N', // 'package_length_offset' => 0, // 'package_body_offset' => 4, ], // 当使用 JsonRpcPoolTransporter 时会用到以下配置 'pool' => [ 'min_connections' => 1, 'max_connections' => 32, 'connect_timeout' => 10.0, 'wait_timeout' => 3.0, 'heartbeat' => -1, 'max_idle_time' => 60.0, ], ] ], ], 'providers' => [], 'drivers' => [ 'consul' => [ 'uri' => 'http://172.17.0.2:8500', 'token' => '', 'check' => [ 'deregister_critical_service_after' => '90m', 'interval' => '1s', ], ] ], ];到此为止服务端配置完成
5、 创建服务消费者项目（客户端）server-consumer
把之前已经生成好的项目复制并修改文件名为server-consumer
注意：唯一不同的就是保留接口类，去掉实现类以及修改server.php、services.php
server.php配置
<?php declare(strict_types=1); /** * This file is part of Hyperf. * * @link https://www.hyperf.io * @document https://hyperf.wiki * @contact group@hyperf.io * @license https://github.com/hyperf/hyperf/blob/master/LICENSE */ use Hyperf\Server\Event; use Hyperf\Server\Server; use Swoole\Constant; return [ 'mode' => SWOOLE_PROCESS, 'servers' => [ [ 'name' => 'http', 'type' => Server::SERVER_HTTP, 'host' => '0.0.0.0', 'port' => 9601, 'sock_type' => SWOOLE_SOCK_TCP, 'callbacks' => [ Event::ON_REQUEST => [Hyperf\HttpServer\Server::class, 'onRequest'], ], ], [ // 这里和服务端的name是一样的 'name' => 'jsonrpc', 'type' => Server::SERVER_BASE, 'host' => '0.0.0.0', 'port' => 9603, 'sock_type' => SWOOLE_SOCK_TCP, 'callbacks' => [ Event::ON_RECEIVE => [\Hyperf\JsonRpc\TcpServer::class, 'onReceive'], ], 'settings' => [ 'open_eof_split' => true, 'package_eof' => "\r\n", 'package_max_length' => 1024 * 1024 * 2, ], ] ], 'settings' => [ Constant::OPTION_ENABLE_COROUTINE => true, Constant::OPTION_WORKER_NUM => swoole_cpu_num(), Constant::OPTION_PID_FILE => BASE_PATH . '/runtime/hyperf.pid', Constant::OPTION_OPEN_TCP_NODELAY => true, Constant::OPTION_MAX_COROUTINE => 100000, Constant::OPTION_OPEN_HTTP2_PROTOCOL => true, Constant::OPTION_MAX_REQUEST => 100000, Constant::OPTION_SOCKET_BUFFER_SIZE => 2 * 1024 * 1024, Constant::OPTION_BUFFER_OUTPUT_SIZE => 2 * 1024 * 1024, ], 'callbacks' => [ Event::ON_WORKER_START => [Hyperf\Framework\Bootstrap\WorkerStartCallback::class, 'onWorkerStart'], Event::ON_PIPE_MESSAGE => [Hyperf\Framework\Bootstrap\PipeMessageCallback::class, 'onPipeMessage'], Event::ON_WORKER_EXIT => [Hyperf\Framework\Bootstrap\WorkerExitCallback::class, 'onWorkerExit'], ], ];services.php配置
<?php declare(strict_types=1); /** * This file is part of Hyperf. * * @link https://www.hyperf.io * @document https://hyperf.wiki * @contact group@hyperf.io * @license https://github.com/hyperf/hyperf/blob/master/LICENSE */ return [ 'enable' => [ 'discovery' => true, 'register' => true, ], 'consumers' => [ // jsonrpc 通过consul中台进行请求 [ 'name' => 'CalculatorService', 'service' => \App\JsonRpc\CalculatorServiceInterface::class, 'protocol' => 'jsonrpc', // 默认为jsonrpc-http 所需必须进行指定 'registry' => [ 'protocol' => 'consul', 'address' => 'http://172.17.0.2:8500', // 这里需要自己的consul地址,我这里是docker容器内部的id ], ], ], 'providers' => [], 'drivers' => [ 'consul' => [ 'uri' => 'http://172.17.0.2:8500', 'token' => '', 'check' => [ 'deregister_critical_service_after' => '90m', 'interval' => '1s', ], ] ], ];到此客户端配置完成
6、启动服务端
如果没有报错则打开consul
可见服务已经注册成功
7、在客户端编写测试接口
【app/Controller/IndexController.php】
<?php declare(strict_types=1); /** * This file is part of Hyperf. * * @link https://www.hyperf.io * @document https://hyperf.wiki * @contact group@hyperf.io * @license https://github.com/hyperf/hyperf/blob/master/LICENSE */ namespace App\Controller; use App\JsonRpc\CalculatorServiceInterface; use Hyperf\Di\Annotation\Inject; class IndexController extends AbstractController { /** * @Inject() * @var CalculatorServiceInterface */ protected $calculator; public function index() { $res = $this->calculator->list(); return ['res' => $res, 'time' => date('Y-m-d H:i:s',time())]; } }并启动客户端服务
8、验证结果
访问接口：http://localhost:9601/
最终结果：
腾讯云面向开发者汇聚海量精品云计算使用和开发经验，营造开放的云计算技术生态圈。
更多推荐
5
0- 0
已为社区贡献2条内容
所有评论(0)