hyperf配置jsonrpc

hyperf 实现 rpc 的相关步骤和配置

#一、首先下载hyperf,添加相关composer组件
```
	a.安装时，只需要在RPC时，选择 1【jsonrpc相关服务】，其他都回车就好
	b.安装必要的相关组件：
	composer require hyperf/json-rpc
	composer require hyperf/rpc-server
	composer require hyperf/rpc-client
	composer require hyperf/service-governance
	composer require hyperf/consul
	composer require hyperf/service-governance-consul
```

#二、定义 服务提供者 (server)
1、在app下新建 JsonRpc、JsonRpcInterface 两个目录
2、在 JsonRpcInterface 目录下新建接口类，如：IndexRpcServiceInterface.php
```
<?php
declare(strict_types=1);
namespace App\JsonRpcInterface;

/**
 * Desc:
 * Author: Spt <2864934511@qq.com>
 * Date: 2022-10-20 08:24
 * Version： 1
 */
interface IndexRpcServiceInterface
{
    public function datetime(): array;
}
```

3、在 JsonRpc 目录下新建接口实现类，如：IndexRpcService。php
```
<?php

namespace App\JsonRpc;

use App\JsonRpcInterface\IndexRpcServiceInterface;
use Hyperf\RpcServer\Annotation\RpcService;

/**
 * Desc:
 * Author: Spt <2864934511@qq.com>
 * Date: 2022-10-20 08:24
 * @RpcService 共有 4 个参数：
 *      name 属性为定义该服务的名称，这里定义一个全局唯一的名字即可，Hyperf 会根据该属性生成对应的 ID 注册到服务中心去；
 *      protocol 属性为定义该服务暴露的协议，目前仅支持 jsonrpc-http, jsonrpc, jsonrpc-tcp-length-check ，分别对应于 HTTP 协议和 TCP 协议下的两种协议，默认值为 jsonrpc-http，这里的值对应在 Hyperf\Rpc\ProtocolManager 里面注册的协议的 key，它们本质上都是 JSON RPC 协议，区别在于数据格式化、数据打包、数据传输器等不同。
 *      server 属性为绑定该服务类发布所要承载的 Server，默认值为 jsonrpc-http，该属性对应 config/autoload/server.php 文件内 servers 下所对应的 name，这里也就意味着我们需要定义一个对应的 Server，我们下一章节具体阐述这里应该怎样去处理；
 *      publishTo 属性为定义该服务所要发布的服务中心，目前仅支持 consul 或为空，为空时代表不发布该服务到服务中心去，但也就意味着您需要手动处理服务发现的问题，当值为 consul 时需要对应配置好 hyperf/consul 组件的相关配置，要使用此功能需安装 hyperf/service-governance 组件，具体可参考 服务注册 章节；

* 使用 @RpcService 注解需 use Hyperf\RpcServer\Annotation\RpcService; 命名空间。
 * @RpcService(name="IndexRpcService", protocol="jsonrpc", server="jsonrpc",publishTo="consul")
 */
class IndexRpcService implements IndexRpcServiceInterface
{

public function datetime(): array
    {
        return ['code' => 200, 'message' => 'success', 'data' => ['time' => date("Y-m-d H:i:s")]];
    }

}
```
4、在app/Listener/目录下新建 RegisterServiceListener类 实现 ListenerInterface 接口类。为了修改IP为正确的本机IP，避免因docker等服务器里获取不到主机IP造成无法访问的问题。
```
<?php

namespace App\Listener;

use Hyperf\Consul\Exception\ServerException;
use Hyperf\Contract\ConfigInterface;
use Hyperf\Contract\StdoutLoggerInterface;
use Hyperf\Event\Contract\ListenerInterface;
use Hyperf\Framework\Event\MainWorkerStart;
use Hyperf\Server\Event\MainCoroutineServerStart;
use Hyperf\ServiceGovernance\DriverManager;
use Hyperf\ServiceGovernance\IPReaderInterface;
use Hyperf\ServiceGovernance\ServiceManager;
use Psr\Container\ContainerInterface;

class RegisterServiceListener implements ListenerInterface
{
    /**
     * @var StdoutLoggerInterface
     */
    protected $logger;

/**
     * @var ServiceManager
     */
    protected $serviceManager;

/**
     * @var ConfigInterface
     */
    protected $config;

/**
     * @var IPReaderInterface
     */
    protected $ipReader;

/**
     * @var DriverManager
     */
    protected $governanceManager;

public function __construct(ContainerInterface $container)
    {
        $this->logger = $container->get(StdoutLoggerInterface::class);
        $this->serviceManager = $container->get(ServiceManager::class);
        $this->config = $container->get(ConfigInterface::class);
        $this->ipReader = $container->get(IPReaderInterface::class);
        $this->governanceManager = $container->get(DriverManager::class);
    }

public function listen(): array
    {
        return [
            MainWorkerStart::class,
            MainCoroutineServerStart::class,
        ];
    }

/**
     * @param MainCoroutineServerStart|MainWorkerStart $event
     */
    public function process(object $event)
    {
        $continue = true;
        while ($continue) {
            try {
                $services = $this->serviceManager->all();
                $servers = $this->getServers();
                foreach ($services as $serviceName => $serviceProtocols) {
                    foreach ($serviceProtocols as $paths) {
                        foreach ($paths as $service) {
                            if (! isset($service['publishTo'], $service['server'])) {
                                continue;
                            }
                            [$address, $port] = $servers[$service['server']];
                            if ($governance = $this->governanceManager->get($service['publishTo'])) {
                                if (! $governance->isRegistered($serviceName, $address, (int) $port, $service)) {
                                    $governance->register($serviceName, $address, (int) $port, $service);
                                }
                            }
                        }
                    }
                }
                $continue = false;
            } catch (ServerException $throwable) {
                if (strpos($throwable->getMessage(), 'Connection failed') !== false) {
                    $this->logger->warning('Cannot register service, connection of service center failed, re-register after 10 seconds.');
                    sleep(10);
                } else {
                    throw $throwable;
                }
            }
        }
    }

protected function getServers(): array
    {
        $result = [];
        $servers = $this->config->get('server.servers', []);
        foreach ($servers as $server) {
            if (! isset($server['name'], $server['host'], $server['port'])) {
                continue;
            }
            if (! $server['name']) {
                throw new \InvalidArgumentException('Invalid server name');
            }
            $host = $server['host'];
            if (in_array($host, ['0.0.0.0', 'localhost'])) {
                $host = $this->ipReader->read();
            }
            if (! filter_var($host, FILTER_VALIDATE_IP)) {
                throw new \InvalidArgumentException(sprintf('Invalid host %s', $host));
            }
            $port = $server['port'];
            if (! is_numeric($port) || ($port < 0 || $port > 65535)) {
                throw new \InvalidArgumentException(sprintf('Invalid port %s', $port));
            }
            $port = (int) $port;
            $result[$server['name']] = [env('MICRO_HOST',$host)?:$host, $port];//就是为了重新这句话，因为docker等获取的ip是虚拟IP不是宿主机本机的IP。
        }
        return $result;
    }
}
```

5、修改config/autoload/下server.php
```
...//其他配置

'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,
            ],
        ],
    ],
...//其他配置
```

6、修改config/autoload/下 services.php （如果不需要调用消耗别人的服务，则不需要定义这个，这个只存在于消费者中）
```
<?php
/**
 * 微服务配置文件
 * 修改时间：2022-10-18 10:00:00
 * 自动加载接口文件
 */
$consumerServices = [];
$interface  = BASE_PATH . '/app/JsonRpcInterface/';
if(is_dir($interface)){
    $file = scandir($interface);
    if($file) {
        foreach ($file as $path){
            if(strstr($path,'Interface.php')){
                $name = str_replace("Interface.php",'',$path);
                if($name){
                    $consumerServices[$name] = 'App\\JsonRpcInterface\\'.$name.'Interface';
                }
            }
        }
    }
}

$consumers = [];
if($consumerServices){
    foreach ($consumerServices as $name => $interface) {
        $consumers[] = [
            'name' => $name,
            'service' => $interface,
            'id' => $interface,
            'protocol' => 'jsonrpc',
            'load_balancer' => 'random',
            'registry' => [
                'protocol' => 'consul',
                'address' => env('CONSUL_URL'),
            ],
            'options' => [
                'connect_timeout' => 5.0,
                'recv_timeout' => 5.0,
                // 重试次数，默认值为 2，收包超时不进行重试。暂只支持 JsonRpcPoolTransporter
                'retry_count' => 2,
                // 重试间隔，毫秒
                'retry_interval' => 100,
                // 使用多路复用 RPC 时的心跳间隔，null 为不触发心跳
                'heartbeat' => 30,
                // 当使用 JsonRpcPoolTransporter 时会用到以下配置
                'pool' => [
                    'min_connections' => 1,
                    'max_connections' => 128,
                    'connect_timeout' => 10.0,
                    'wait_timeout' => 3.0,
                    'heartbeat' => -1,
                    'max_idle_time' => 60.0,
                ],
            ],
        ];
    }
}

return [
    'enable' => [
        // 开启服务发现
        'discovery' => true,
        // 开启服务注册
        'register' => true,
    ],
    // 服务消费者相关配置
    // 此处省略了其它同层级的配置
    'consumers' => $consumers,
    // 服务提供者相关配置
    'providers' => [],
    // 服务驱动相关配置
    'drivers' => [
        'consul' => [
            'uri' => env('CONSUL_URL'),
            'token' => '',
            'check' => [
                'deregister_critical_service_after' => '90m',
                'interval' => '1s',
            ],
        ]
    ],
];
```

7、修改config/autoload/下dependencies.php
```
<?php

declare(strict_types=1);

return [
    \Hyperf\JsonRpc\JsonRpcTransporter::class => \Hyperf\JsonRpc\JsonRpcPoolTransporter::class,
    \Hyperf\ServiceGovernance\Listener\RegisterServiceListener::class =>\App\Listener\RegisterServiceListener::class,
    \App\JsonRpcInterface\IndexRpcServiceInterface::class=>\App\JsonRpc\IndexRpcService::class
];
```

8、修改env配置
```
...//其他配置
#自己的consul地址
CONSUL_URL=http://1.0.1.26:8500
#自己的主机地址
MICRO_HOST=1.0.1.26
```
9、至此服务提供者配置完成，结构目录如下类似：
![hyperf服务提供者目录](http://qiniu.pengdayou.top/p0p0x1/image/902019437be99a99e9f2e02c30faab68.png "hyperf服务提供者目录")

#三、定义 服务消费者 (client) : 
####ps： 将上面的server项目复制一份出来修改最好。类似如下目录结构，client(服务消费者)和server(服务提供者)都在同一级 ：
![提供者和消费者目录](http://qiniu.pengdayou.top/p0p0x1/image/6488cf3fab27e4c81c5dc55a62e735e6.png "提供者和消费者目录")

-
####注意：以下是开始修改client(服务消费者)下文件
1、在app目录下新建 JsonRpcInterface 一个目录，将服务提供者定义的接口复制过来放在这里目录里。
2、在 app/Controller 目录下新建 服务消费类 ，如：TestController.php
```
<?php

declare(strict_types=1);

namespace App\Controller;

use App\JsonRpcInterface\IndexRpcServiceInterface;
use Hyperf\Utils\ApplicationContext;

class TestController extends AbstractController
{
    public function index()
    {
		//官方建议如此调用消费
        return ApplicationContext::getContainer()->get(IndexRpcServiceInterface::class)->datetime();
    }
}

```

3、修改config/autoload/下 services.php ，和上面 二.6 一模一样，复制过来就好。

4、修改 env ，和上面 二.7 一模一样，复制过来就好。

5、修改 路由，新增测试接口路由：config/routes.php
```
...其他配置
Router::addRoute(['GET', 'POST', 'HEAD'], '/test', 'App\Controller\TestController@index');
```

6、至此服务提供者配置完成，结构目录如下类似：
![hyperf消费者目录](http://qiniu.pengdayou.top/p0p0x1/image/dbb8c28002ad3531ac4de0398bc10589.png "hyperf消费者目录")

#四、启动步骤一：启动 consul
```
#安装百度就好
#以下是win10下子系统ubuntu中直接安装
[root@spt] sudo spt install consul
#直接启动
[root@spt] consul agent -dev -client=0.0.0.0 --datacenter=test
```
效果类似如下：
![consul启动](http://qiniu.pengdayou.top/p0p0x1/image/605285bfdeb3c98b32f25ae0c1328e0a.png "consul启动")

#五、启动步骤二：启动 服务提供者，server
效果类似如下：
![服务提供者](http://qiniu.pengdayou.top/p0p0x1/image/5601e0b7539a1b0e6d2ab11630c679fc.png "服务提供者")
红框内标识注册到consul成功

刷新consul，效果类似如下：
![注册成功的consul](http://qiniu.pengdayou.top/p0p0x1/image/b556de8703e609d95e9deeb0f2d5470d.png "注册成功的consul")

#六、启动步骤三：启动 服务消费者，client

![服务消费者](http://qiniu.pengdayou.top/p0p0x1/image/ebfd70aeec614360bbc4534c34613e79.png "服务消费者")

#七，测试访问接口。

访问路径：http://127.0.0.1:9502/test
结果类似：
```
{
	"code": 200,
	"message": "success",
	"data": {
		"time": "2022-10-20 16:12:26"
	}
}
```

<h1 id="h1--hyperf-composer-"><a name="一、首先下载hyperf,添加相关composer组件" class="reference-link"></a><span class="header-link octicon octicon-link"></span>一、首先下载hyperf,添加相关composer组件</h1><pre><code>    a.安装时，只需要在RPC时，选择 1【jsonrpc相关服务】，其他都回车就好
    b.安装必要的相关组件：
    composer require hyperf/json-rpc
    composer require hyperf/rpc-server
    composer require hyperf/rpc-client
    composer require hyperf/service-governance
    composer require hyperf/consul
    composer require hyperf/service-governance-consul
</code></pre><h1 id="h1--server-"><a name="二、定义 服务提供者 (server)" class="reference-link"></a><span class="header-link octicon octicon-link"></span>二、定义 服务提供者 (server)</h1><p>1、在app下新建 JsonRpc、JsonRpcInterface 两个目录<br>2、在 JsonRpcInterface 目录下新建接口类，如：IndexRpcServiceInterface.php
<pre><code>&lt;?php
declare(strict_types=1);
namespace App\JsonRpcInterface;

/**
 * Desc:
 * Author: Spt &lt;2864934511@qq.com&gt;
 * Date: 2022-10-20 08:24
 * Version： 1
 */
interface IndexRpcServiceInterface
{
    public function datetime(): array;
}
</code></pre><p>3、在 JsonRpc 目录下新建接口实现类，如：IndexRpcService。php</p>
<pre><code>&lt;?php

namespace App\JsonRpc;

use App\JsonRpcInterface\IndexRpcServiceInterface;
use Hyperf\RpcServer\Annotation\RpcService;

/**
 * Desc:
 * Author: Spt &lt;2864934511@qq.com&gt;
 * Date: 2022-10-20 08:24
 * @RpcService 共有 4 个参数：
 *      name 属性为定义该服务的名称，这里定义一个全局唯一的名字即可，Hyperf 会根据该属性生成对应的 ID 注册到服务中心去；
 *      protocol 属性为定义该服务暴露的协议，目前仅支持 jsonrpc-http, jsonrpc, jsonrpc-tcp-length-check ，分别对应于 HTTP 协议和 TCP 协议下的两种协议，默认值为 jsonrpc-http，这里的值对应在 Hyperf\Rpc\ProtocolManager 里面注册的协议的 key，它们本质上都是 JSON RPC 协议，区别在于数据格式化、数据打包、数据传输器等不同。
 *      server 属性为绑定该服务类发布所要承载的 Server，默认值为 jsonrpc-http，该属性对应 config/autoload/server.php 文件内 servers 下所对应的 name，这里也就意味着我们需要定义一个对应的 Server，我们下一章节具体阐述这里应该怎样去处理；
 *      publishTo 属性为定义该服务所要发布的服务中心，目前仅支持 consul 或为空，为空时代表不发布该服务到服务中心去，但也就意味着您需要手动处理服务发现的问题，当值为 consul 时需要对应配置好 hyperf/consul 组件的相关配置，要使用此功能需安装 hyperf/service-governance 组件，具体可参考 服务注册 章节；

public function datetime(): array
    {
        return ['code' =&gt; 200, 'message' =&gt; 'success', 'data' =&gt; ['time' =&gt; date("Y-m-d H:i:s")]];
    }

}
</code></pre><p>4、在app/Listener/目录下新建 RegisterServiceListener类 实现 ListenerInterface 接口类。为了修改IP为正确的本机IP，避免因docker等服务器里获取不到主机IP造成无法访问的问题。</p>
<pre><code>&lt;?php

namespace App\Listener;

class RegisterServiceListener implements ListenerInterface
{
    /**
     * @var StdoutLoggerInterface
     */
    protected $logger;

/**
     * @var ServiceManager
     */
    protected $serviceManager;

/**
     * @var ConfigInterface
     */
    protected $config;

/**
     * @var IPReaderInterface
     */
    protected $ipReader;

/**
     * @var DriverManager
     */
    protected $governanceManager;

public function __construct(ContainerInterface $container)
    {
        $this-&gt;logger = $container-&gt;get(StdoutLoggerInterface::class);
        $this-&gt;serviceManager = $container-&gt;get(ServiceManager::class);
        $this-&gt;config = $container-&gt;get(ConfigInterface::class);
        $this-&gt;ipReader = $container-&gt;get(IPReaderInterface::class);
        $this-&gt;governanceManager = $container-&gt;get(DriverManager::class);
    }

public function listen(): array
    {
        return [
            MainWorkerStart::class,
            MainCoroutineServerStart::class,
        ];
    }

/**
     * @param MainCoroutineServerStart|MainWorkerStart $event
     */
    public function process(object $event)
    {
        $continue = true;
        while ($continue) {
            try {
                $services = $this-&gt;serviceManager-&gt;all();
                $servers = $this-&gt;getServers();
                foreach ($services as $serviceName =&gt; $serviceProtocols) {
                    foreach ($serviceProtocols as $paths) {
                        foreach ($paths as $service) {
                            if (! isset($service['publishTo'], $service['server'])) {
                                continue;
                            }
                            [$address, $port] = $servers[$service['server']];
                            if ($governance = $this-&gt;governanceManager-&gt;get($service['publishTo'])) {
                                if (! $governance-&gt;isRegistered($serviceName, $address, (int) $port, $service)) {
                                    $governance-&gt;register($serviceName, $address, (int) $port, $service);
                                }
                            }
                        }
                    }
                }
                $continue = false;
            } catch (ServerException $throwable) {
                if (strpos($throwable-&gt;getMessage(), 'Connection failed') !== false) {
                    $this-&gt;logger-&gt;warning('Cannot register service, connection of service center failed, re-register after 10 seconds.');
                    sleep(10);
                } else {
                    throw $throwable;
                }
            }
        }
    }

protected function getServers(): array
    {
        $result = [];
        $servers = $this-&gt;config-&gt;get('server.servers', []);
        foreach ($servers as $server) {
            if (! isset($server['name'], $server['host'], $server['port'])) {
                continue;
            }
            if (! $server['name']) {
                throw new \InvalidArgumentException('Invalid server name');
            }
            $host = $server['host'];
            if (in_array($host, ['0.0.0.0', 'localhost'])) {
                $host = $this-&gt;ipReader-&gt;read();
            }
            if (! filter_var($host, FILTER_VALIDATE_IP)) {
                throw new \InvalidArgumentException(sprintf('Invalid host %s', $host));
            }
            $port = $server['port'];
            if (! is_numeric($port) || ($port &lt; 0 || $port &gt; 65535)) {
                throw new \InvalidArgumentException(sprintf('Invalid port %s', $port));
            }
            $port = (int) $port;
            $result[$server['name']] = [env('MICRO_HOST',$host)?:$host, $port];//就是为了重新这句话，因为docker等获取的ip是虚拟IP不是宿主机本机的IP。
        }
        return $result;
    }
}
</code></pre><p>5、修改config/autoload/下server.php</p>
<pre><code>...//其他配置

'servers' =&gt; [
       ...//其他配置
        [
            'name' =&gt; 'jsonrpc',
            'type' =&gt; Server::SERVER_BASE,
            'host' =&gt; '0.0.0.0',
            'port' =&gt; 9503,
            'sock_type' =&gt; SWOOLE_SOCK_TCP,
            'callbacks' =&gt; [
                Event::ON_RECEIVE =&gt; [\Hyperf\JsonRpc\TcpServer::class, 'onReceive'],
            ],
            'settings' =&gt; [
                'open_eof_split' =&gt; true,
                'package_eof' =&gt; "\r\n",
                'package_max_length' =&gt; 1024 * 1024 * 2,
            ],
        ],
    ],
...//其他配置
</code></pre><p>6、修改config/autoload/下 services.php （如果不需要调用消耗别人的服务，则不需要定义这个，这个只存在于消费者中）</p>
<pre><code>&lt;?php
/**
 * 微服务配置文件
 * 修改时间：2022-10-18 10:00:00
 * 自动加载接口文件
 */
$consumerServices = [];
$interface  = BASE_PATH . '/app/JsonRpcInterface/';
if(is_dir($interface)){
    $file = scandir($interface);
    if($file) {
        foreach ($file as $path){
            if(strstr($path,'Interface.php')){
                $name = str_replace("Interface.php",'',$path);
                if($name){
                    $consumerServices[$name] = 'App\\JsonRpcInterface\\'.$name.'Interface';
                }
            }
        }
    }
}

$consumers = [];
if($consumerServices){
    foreach ($consumerServices as $name =&gt; $interface) {
        $consumers[] = [
            'name' =&gt; $name,
            'service' =&gt; $interface,
            'id' =&gt; $interface,
            'protocol' =&gt; 'jsonrpc',
            'load_balancer' =&gt; 'random',
            'registry' =&gt; [
                'protocol' =&gt; 'consul',
                'address' =&gt; env('CONSUL_URL'),
            ],
            'options' =&gt; [
                'connect_timeout' =&gt; 5.0,
                'recv_timeout' =&gt; 5.0,
                // 重试次数，默认值为 2，收包超时不进行重试。暂只支持 JsonRpcPoolTransporter
                'retry_count' =&gt; 2,
                // 重试间隔，毫秒
                'retry_interval' =&gt; 100,
                // 使用多路复用 RPC 时的心跳间隔，null 为不触发心跳
                'heartbeat' =&gt; 30,
                // 当使用 JsonRpcPoolTransporter 时会用到以下配置
                'pool' =&gt; [
                    'min_connections' =&gt; 1,
                    'max_connections' =&gt; 128,
                    'connect_timeout' =&gt; 10.0,
                    'wait_timeout' =&gt; 3.0,
                    'heartbeat' =&gt; -1,
                    'max_idle_time' =&gt; 60.0,
                ],
            ],
        ];
    }
}

return [
    'enable' =&gt; [
        // 开启服务发现
        'discovery' =&gt; true,
        // 开启服务注册
        'register' =&gt; true,
    ],
    // 服务消费者相关配置
    // 此处省略了其它同层级的配置
    'consumers' =&gt; $consumers,
    // 服务提供者相关配置
    'providers' =&gt; [],
    // 服务驱动相关配置
    'drivers' =&gt; [
        'consul' =&gt; [
            'uri' =&gt; env('CONSUL_URL'),
            'token' =&gt; '',
            'check' =&gt; [
                'deregister_critical_service_after' =&gt; '90m',
                'interval' =&gt; '1s',
            ],
        ]
    ],
];
</code></pre><p>7、修改config/autoload/下dependencies.php</p>
<pre><code>&lt;?php

declare(strict_types=1);

return [
    \Hyperf\JsonRpc\JsonRpcTransporter::class =&gt; \Hyperf\JsonRpc\JsonRpcPoolTransporter::class,
    \Hyperf\ServiceGovernance\Listener\RegisterServiceListener::class =&gt;\App\Listener\RegisterServiceListener::class,
    \App\JsonRpcInterface\IndexRpcServiceInterface::class=&gt;\App\JsonRpc\IndexRpcService::class
];
</code></pre><p>8、修改env配置</p>
<pre><code>...//其他配置
#自己的consul地址
CONSUL_URL=http://1.0.1.26:8500
#自己的主机地址
MICRO_HOST=1.0.1.26
</code></pre><p>9、至此服务提供者配置完成，结构目录如下类似：<br><img src="http://qiniu.pengdayou.top/p0p0x1/image/902019437be99a99e9f2e02c30faab68.png" alt="hyperf服务提供者目录" title="hyperf服务提供者目录">
<h1 id="h1--client-"><a name="三、定义 服务消费者 (client) :" class="reference-link"></a><span class="header-link octicon octicon-link"></span>三、定义 服务消费者 (client) :</h1><h4 id="h4-ps-server-client-server-"><a name="ps： 将上面的server项目复制一份出来修改最好。类似如下目录结构，client(服务消费者)和server(服务提供者)都在同一级 ：" class="reference-link"></a><span class="header-link octicon octicon-link"></span>ps： 将上面的server项目复制一份出来修改最好。类似如下目录结构，client(服务消费者)和server(服务提供者)都在同一级 ：</h4><p><img src="http://qiniu.pengdayou.top/p0p0x1/image/6488cf3fab27e4c81c5dc55a62e735e6.png" alt="提供者和消费者目录" title="提供者和消费者目录">
<p>-</p>
<h4 id="h4--client-"><a name="注意：以下是开始修改client(服务消费者)下文件" class="reference-link"></a><span class="header-link octicon octicon-link"></span>注意：以下是开始修改client(服务消费者)下文件</h4><p>1、在app目录下新建 JsonRpcInterface 一个目录，将服务提供者定义的接口复制过来放在这里目录里。<br>2、在 app/Controller 目录下新建 服务消费类 ，如：TestController.php
<pre><code>&lt;?php

declare(strict_types=1);

namespace App\Controller;

use App\JsonRpcInterface\IndexRpcServiceInterface;
use Hyperf\Utils\ApplicationContext;

class TestController extends AbstractController
{
    public function index()
    {
        //官方建议如此调用消费
        return ApplicationContext::getContainer()-&gt;get(IndexRpcServiceInterface::class)-&gt;datetime();
    }
}
</code></pre><p>3、修改config/autoload/下 services.php ，和上面 二.6 一模一样，复制过来就好。</p>
<p>4、修改 env ，和上面 二.7 一模一样，复制过来就好。</p>
<p>5、修改 路由，新增测试接口路由：config/routes.php</p>
<pre><code>...其他配置
Router::addRoute(['GET', 'POST', 'HEAD'], '/test', 'App\Controller\TestController@index');
</code></pre><p>6、至此服务提供者配置完成，结构目录如下类似：<br><img src="http://qiniu.pengdayou.top/p0p0x1/image/dbb8c28002ad3531ac4de0398bc10589.png" alt="hyperf消费者目录" title="hyperf消费者目录">
<h1 id="h1--consul"><a name="四、启动步骤一：启动 consul" class="reference-link"></a><span class="header-link octicon octicon-link"></span>四、启动步骤一：启动 consul</h1><pre><code>#安装百度就好
#以下是win10下子系统ubuntu中直接安装
[root@spt] sudo spt install consul
#直接启动
[root@spt] consul agent -dev -client=0.0.0.0 --datacenter=test
</code></pre><p>效果类似如下：<br><img src="http://qiniu.pengdayou.top/p0p0x1/image/605285bfdeb3c98b32f25ae0c1328e0a.png" alt="consul启动" title="consul启动">
<h1 id="h1--server"><a name="五、启动步骤二：启动 服务提供者，server" class="reference-link"></a><span class="header-link octicon octicon-link"></span>五、启动步骤二：启动 服务提供者，server</h1><p>效果类似如下：<br><img src="http://qiniu.pengdayou.top/p0p0x1/image/5601e0b7539a1b0e6d2ab11630c679fc.png" alt="服务提供者" title="服务提供者"><br>红框内标识注册到consul成功
<p>刷新consul，效果类似如下：<br><img src="http://qiniu.pengdayou.top/p0p0x1/image/b556de8703e609d95e9deeb0f2d5470d.png" alt="注册成功的consul" title="注册成功的consul">
<h1 id="h1--client"><a name="六、启动步骤三：启动 服务消费者，client" class="reference-link"></a><span class="header-link octicon octicon-link"></span>六、启动步骤三：启动 服务消费者，client</h1><p><img src="http://qiniu.pengdayou.top/p0p0x1/image/ebfd70aeec614360bbc4534c34613e79.png" alt="服务消费者" title="服务消费者">
<h1 id="h1--"><a name="七，测试访问接口。" class="reference-link"></a><span class="header-link octicon octicon-link"></span>七，测试访问接口。</h1><p>访问路径：<a href="http://127.0.0.1:9502/test">http://127.0.0.1:9502/test</a><br>结果类似：
<pre><code>{
    "code": 200,
    "message": "success",
    "data": {
        "time": "2022-10-20 16:12:26"
    }
}
</code></pre>

hyperf配置jsonrpc

热门文章

置顶推荐

最近访客