Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用

这篇文章主要介绍"Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用"，在日常操作中，相信很多人在Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

1.首先启动http跟rpc服务。

我这里是直接用docker-compose开启服务的。

大家也可以进入swoft容器用命令开启服务。

http命令：php bin/swoft http:start

rpc命令：php bin/swoft rpc:start

2.RPC Server 配置参数

RPC 服务启动有单独启动和集成其它服务(Http/Websocket)两种方式，无论那种方式都首先要在 bean.php 配置RPC。

'rpcServer'         => [    'class' => ServiceServer::class,    'port' => 18307,],

3.Http server 启动中集成 RPC 服务，其listener 单独监听一个RPC服务，且同时可以监听多个 RPC 服务中

'httpServer'        => [        'class'    => HttpServer::class,        'port'     => 18306,        'listener' => [            'rpc' => bean('rpcServer')        ],        'process'  => [//            'monitor' => bean(MonitorProcess::class)//            'crontab' => bean(CrontabProcess::class)        ],        'on'       => [//            SwooleEvent::TASK   => bean(SyncTaskListener::class),  // Enable sync task            SwooleEvent::TASK   => bean(TaskListener::class),  // Enable task must task and finish event            SwooleEvent::FINISH => bean(FinishListener::class)        ],        /* @see HttpServer::$setting */        'setting' => [            'task_worker_num'       => 12,            'task_enable_coroutine' => true,            'worker_num'            => 6        ]    ],

5.定义接口并实现接口，才能提供RPC服务。注意里面的版本号定制注解@Service()

6.定义接口

 ['list']];    }    /**     * @param int $id     *     * @return bool     */    public function delete(int $id): bool    {        return false;    }    /**     * @return void     */    public function returnNull(): void    {        return;    }    /**     * @return string     */    public function getBigContent(): string    {        $content = Co::readFile(__DIR__ . '/big.data');        return $content;    }    /**     * Exception     * @throws Exception     */    public function exception(): void    {        throw new Exception('exception version');    }    /**     * @param string $content     *     * @return int     */    public function sendBigContent(string $content): int    {        return strlen($content);    }}

7.按版本实现不同的接口需求

/** * Class UserService * * @since 2.0 * * @Service() */

/** * Class UserServiceV2 * * @since 2.0 * * @Service(version="1.2") */

不同的实现，需要定义不同的唯一版本号，如果存在相同，加载之后的服务会覆盖之前的服务

8.RPC Client配置参数

同样也是在bean.php中配置，如以下是一个user 服务

'user'              => [    'class'   => ServiceClient::class,    'host'    => '127.0.0.1',    'port'    => 18307,    'setting' => [        'timeout'         => 0.5,        'connect_timeout' => 1.0,        'write_timeout'   => 10.0,        'read_timeout'    => 0.5,    ],    'packet'  => bean('rpcClientPacket')],'user.pool'         => [    'class'  => ServicePool::class,    'client' => bean('user'),],

8.客户调用

userService->getList(12, 'type');        $result2 = $this->userService2->getList(12, 'type');        return [$result, $result2];    }    /**     * @RequestMapping("returnBool")     *     * @return array     */    public function returnBool(): array    {        $result = $this->userService->delete(12);        if (is_bool($result)) {            return ['bool'];        }        return ['notBool'];    }    /**     * @RequestMapping()     *     * @return array     */    public function bigString(): array    {        $string = $this->userService->getBigContent();        return ['string', strlen($string)];    }    /**     * @RequestMapping()     *     * @return array     * @throws SwoftException     */    public function sendBigString(): array    {        $content = Co::readFile(__DIR__ . '/../../Rpc/Service/big.data');        $len    = strlen($content);        $result = $this->userService->sendBigContent($content);        return [$len, $result];    }    /**     * @RequestMapping()     *     * @return array     */    public function returnNull(): array    {        $this->userService->returnNull();        return [null];    }    /**     * @RequestMapping()     *     * @return array     *     * @throws Exception     */    public function exception(): array    {        $this->userService->exception();        return ['exception'];    }}

9.地址栏访问效果。

我这里的ip是自己http服务的ip，大家根据自己的实际修改即可。

10.如何实现非Swoft框架调用

需要注意swoft框架的默认消息协议是json-rpc，而且默认消息协议是以 \r\n\r\n 结尾的。

其他框架代码例子如下，可以自行封装：

 '2.0',        "method" => sprintf("%s::%s::%s", $version, $class, $method),        'params' => $param,        'id' => '',        'ext' => $ext,    ];    $data = json_encode($req) . RPC_EOL;    fwrite($fp, $data);    $result = '';    while (!feof($fp)) {        $tmp = stream_socket_recvfrom($fp, 1024);        if ($pos = strpos($tmp, RPC_EOL)) {            $result .= substr($tmp, 0, $pos);            break;        } else {            $result .= $tmp;        }    }    fclose($fp);    return json_decode($result, true);}$ret = request('tcp://172.18.0.6:18307', \App\Rpc\Lib\UserInterface::class, 'getList',  [1, 2], "1.2");var_dump($ret);

11.需要格外注意是框架外调用的ip地址并非官方文档例子里的127.0.0.1，大家改为自己的实际ip即可。不然会连接报错。

到此，关于"Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！