Swoft2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用
这篇文章主要介绍“Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用”,在日常操作中,相信很多人在Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Swoft 2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
成都创新互联公司是一家网站设计公司,集创意、互联网应用、软件技术为一体的创意网站建设服务商,主营产品:自适应网站建设、品牌网站设计、网络营销推广。我们专注企业品牌在网站中的整体树立,网络互动的体验,以及在手机等移动端的优质呈现。成都网站设计、成都网站制作、移动互联产品、网络运营、VI设计、云产品.运维为核心业务。为用户提供一站式解决方案,我们深知市场的竞争激烈,认真对待每位客户,为客户提供赏析悦目的作品,网站的价值服务。
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框架外部调用”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!
分享文章:Swoft2.0.6怎么实现Rpc服务客户端以及非Swoft框架外部调用
当前地址:http://myzitong.com/article/ggppsp.html