PHP 基于 SW-X 框架,搭建RPC微服务支持

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
云原生网关 MSE Higress,422元/月
简介: SW-X的微服务也可用于优化FPM业务,底层使用了TCP通讯协议,支持基于AES的数据加解密支持,官方提供了Swoole/FPM下的RPC客户端,并提供了纯基于Redis存储管理的RPC服务中心。

前言

官网地址:SW-X框架-专注高性能便捷开发而生的PHP-SwooleX框架

希望各大佬举起小手,GitHub - swoolex/swoolex: SwooleX一款专注于高性能、便捷开发的PHP协程框架

场景一

在FPM项目中,很多业务情况下是挺无奈的,例如某个业务需要用到发送短信。

通常这类业务不管短信是否发送成功,都不应该应该影响该接口的执行结果,又或者是执行效率(CURL堵塞到了下面的业务代码)。

以往,这种情况一般会把发送短信当作一个任务,投递到某种消息队列中,然后在php-cli下使用多进程的方式另起一个独立的进程进行后台消耗执行。

由于受到PHP进程模型的影响,如果FPM的进程被堵塞,该队列就有可能被直接挂掉。

同时,这种方法的性能消耗严重,也不便于日常维护。

场景二

如果是允许异步执行的逻辑,在FPM下还有优化的空间,那如果是需要同步执行的代码呢。

例如需要调用百度地图的经纬度解析接口,这种同时需要等待获得请求结果,才能往下执行。

假设我们有一个项目,7个接口需要用到该接口,通常情况下都会基于框架,封装成一个扩展类,又或者是一个公共的函数进行调用。

但当公司业务扩张,可能会产生不同的业务线,但不同的业务所使用的语言,框架都不一定一致(不是所有公司都喜欢一个框架,启用多应用架构的)。

这时候扩展封装的方式就没办法使用了,因为我们可能会copy无数份相同的代码到各个应用下,当百度地图接口升级时,我们还有可能会遗漏某一个应用下的代码没有升级完成,从而导致业务错误,发生不可估量的损失。

场景三

如果说第三方接口还可以允许COPY封装的扩展到多个应用下,那公共的业务逻辑组件化封装就没办法了。

例如会员注册,当项目刚起步时,可能我们需要会员注册才能下单,忽然某天公司业务做大了,需要开发出渠道API,让渠道商部署平台,其中又有会员注册的功能。

之后,公司发现如果使用二维码直接下单,又会更加方便市场推广,就变成需要支持下单时直接注册用户。

再之后,又一堆后台创建会员、电话下单创建会员、积分兑换商城创建会员等等。

从一个会员注册的Model,忽然变成了N个应用的会员注册,这时候使用单个应用的Model封装已经无法承载业务了。

SW-X的微服务

SW-X的微服务都是为了应对以上这些场景所诞生,底层使用了TCP通讯协议,支持基于AES的数据加解密支持,官方提供了Swoole/FPM下的RPC客户端,并提供了纯基于Redis存储管理的RPC服务中心,可进行WEB界面化的服务日常管理。

微服务的部署条件

1、需要先安装Redis服务,与PHP-Redis扩展
2、需要准备2个端口,与2份SW-X框架源码,因为服务中心(http)与微服务服务端(rpc)是需要分别启动不同的服务端口。

资料准备

先将Redis改成6379端口(默认),密码改成123456

安全组开放一个9501端口,用于搭建微服务-服务中心。

安全组开放一个9502端口,用于搭建微服务-服务端。

部署微服务-服务中心

1、将SW-X框架源码解压(拉取)到swoole_web/目录下,具体地址也可以改成自己测试的。

2、修改/config/server.php文件下的port端口为9501

3、修改/config/rpc.php文件下的http_rpc_is参数为true,表示当前HTTP服务为RPC服务中心应用。同时,该文件下的http_rpc_user_list参数为服务中心的账号配置,默认的超级账号密码是:swoolex

4、打开shell界面,执行以下代码:

# 进入目录
cd /www/wwwroot/swoole_web/
# 安装服务中心-web组件
php sw-x rpc start

安装成功会输出服务中心对应的路由地址,然后在shell界面,继续输入:

# 启动HTTP服务后台运行
php sw-x start http -d

完成后,就可以在浏览器打开IP地址:9501/HttpRpc/login访问到微服务-服务中心登陆地址了。

具体UI如下图:

部署微服务-服务端

1、将SW-X框架源码解压(拉取)到swoole_rpc/目录下,具体地址也可以改成自己测试的。

2、修改/config/server.php文件下的`port`端口为9502

3、打开shell界面,执行以下代码:

# 进入目录
cd /www/wwwroot/swoole_rpc/
# 启动RPC服务[不退后台运行]
php sw-x start rpc

服务日常管理

登入服务中心,我们可以看到有一个框架默认的测试服务,如下:

1、服务调试

点击调试按钮,可以直接对该服务进行在线调试,如下图:

可以对调试参数进行在线设置和保存,点击调试后对应的结果会在右侧窗口滑出。

2、服务统计

同时,服务中心也支持统计单个服务在一小时内的请求量,需要在RPC服务端,修改/config/rpc.php的配置参数,如下:

[
    // +-----------------------------
    // | 服务请求统计相关
    // +-----------------------------
    // 是否开启统计
    'chat_status' => true,
    // 统计记录的Redis连接池标识
    'chat_redis_driver' => 'default',
    // 统计记录保留天数
    'chat_days' => 14,
];

chat_status参数改为true,由于微服务的统计是依赖Redis计数器实现,所有微服务服务端也需要配置好Redis连接池(连接数必须大于1),然后重启RPC服务端即可。

最后回到服务中心,多发送几次调试请求,再点击统计按钮,就可以查看到下图效果:

3、添加服务

下面,我们就来创建一个order/test->run的服务,该服务是表示,服务调用于/app/rpc/order/test.php控制器下的run()方法。

具体流程如下图:

然后在swoole_rpc/服务端,创建/app/rpc/order/test.php文件,并写入以下代码:

<?php
// 微服务-同步调用演示
namespace app\rpc\order;
use x\controller\Rpc;
class test extends Rpc{
    // 对应 order/test->run 服务
    public function run() {
        // 可以这样获取请求头
        $headers = $this->headers();
        // 可以这样获取请求参数
        $param = $this->param();
        // 可以return值就是调用结果值
        return $param;
    }
}

如果你没有开启热重载,就需要先重启服务端,才能进行调试,下面是在服务中心里的调试结果:

4、FPM安装微服务客户端

打开官网:组件 | SW-X框架

根据项目的PHP版本,下载对应的FPM客户端扩展包,解压到应用的/extend/自定义扩展应用目录下(不管是TP还是La都会有该支持)。

下面以一个ThinkPHP5.1的项目为例,下载PHP5.3+版本的客户端包。

解压后,修改/SwooleXRpc/config/rpc.php文件,主要是将里面的配置参数,改成与微服务服务中心的`/config/rpc.php和/config/redis.php配置一致即可。

然后修改TP默认控制器代码/app/index/controller/Index.php,为如下代码:

<?php
namespace app\index\controller;
use think\Controller;
class Index extends Controller{
    public function index() {
        // 调用微服务客户端
        $Rpc = new \SwooleXRpc\RpcClient();
        // 请求RPC服务
        $body = $Rpc->route('order/test') // 路由地址
        ->func('run') // 方法
        ->param([ // 请求参数
            'longitude' => '113.383523',
            'latitude' => '23.131044'
        ])
        ->header(array()) // 请求头
        ->max(3) // 当RPC请求失败时,最多递归几个服务节点直至成功为止,默认1
        // ->task() // 是否投递异步任务池
        // ->callback('http://baidu.com', 'post') // 异步任务可以设置回调通知
        ->send(); // 发送请求
        // 结果集
        dump($body);
        // 状态码 == 200 == 成功
        dump($Rpc->getStatus());
        // 错误原因
        dump($Rpc->getMsg());
    }
}

最后访问该控制器查看调用结果即可。

5、异步投递调用

SW-X的微服务在客户端调用时,可以把该次服务请求投递到异步任务池,当前请求会即可返回true,表示任务投递成功。

投递成功的任务会从Swoole的onReceive事件,转发到onTask事件进行处理。

在服务中心添加以下服务,用于测试异步调用:

然后在swoole_rpc/服务端,创建/app/rpc/order/task.php文件,并写入以下代码:

<?php
// 微服务-异步调用演示
namespace app\rpc\order;
use x\controller\Rpc;
class task extends Rpc{
  // 对应 order/task->run 服务
    public function run() {
        // 可以这样获取请求参数
        $param = $this->param();
        // 记录日志,看看服务是否调用成功
        error_log(json_encode($param).PHP_EOL, 3, ROOT_PATH.'/task_test.log');
        // 可以return值就是调用结果值,如果是设置了回调通知地址,就会发送过去
        return $param;
    }
}

如果你没有开启热重载,就需要先重启服务端,才能进行调试。

再然后,修改TP默认控制器代码/app/index/controller/Index.php,为如下代码:

<?php
namespace app\index\controller;
use think\Controller;
class Index extends Controller{
    public function index() {
        // 调用微服务客户端
        $Rpc = new \SwooleXRpc\RpcClient();
        // 请求RPC服务
        $body = $Rpc->route('order/task') // 路由地址
        ->func('run') // 方法
        ->param([ // 请求参数
            'longitude' => '113.383523',
            'latitude' => '23.131044'
        ])
        ->header(array()) // 请求头
        ->max(3) // 当RPC请求失败时,最多递归几个服务节点直至成功为止,默认1
        ->task() // 投递异步任务池
        ->callback('http://你的TP测试地址/index.php/callback/index', 'post') // 异步任务可以设置回调通知,如果不需要回调通知,可以不设置
        ->send(); // 发送请求
        // 结果集
        dump($body);
        // 状态码 == 200 == 成功
        dump($Rpc->getStatus());
        // 错误原因
        dump($Rpc->getMsg());
    }
}

创建一个/app/index/controller/Callback.php控制器,用于记录异步处理回调通知结果:

<?php
namespace app\index\controller;
use think\Controller;
class Callback extends Controller{
  // 测试-记录异步服务调用回调通知
    public function index() {
        $param = \think\facade\Request::param();
        error_log(json_encode($param).PHP_EOL, 3, 'task_test.log');
    }
}

之后,就可以在浏览器访问TP的index/index控制器进行测试了,调用完成后分别查看两个task_test.log文件的记录结果。


更多的客户端支持,可以在SW-X官网中进行查看:组件 | SW-X框架

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
4天前
|
网络协议 Dubbo Java
什么是RPC?RPC和HTTP对比?RPC有什么缺点?市面上常用的RPC框架?
选择合适的RPC框架和通信协议,对于构建高效、稳定的分布式系统至关重要。开发者需要根据自己的业务需求和系统架构,综合考虑各种因素,做出适宜的技术选型。
9 1
|
10天前
|
分布式计算 负载均衡 数据安全/隐私保护
什么是RPC?有哪些RPC框架?
RPC(Remote Procedure Call,远程过程调用)是一种允许运行在一台计算机上的程序调用另一台计算机上子程序的技术。这种技术屏蔽了底层的网络通信细节,使得程序间的远程通信如同本地调用一样简单。RPC机制使得开发者能够构建分布式计算系统,其中不同的组件可以分布在不同的计算机上,但它们之间可以像在同一台机器上一样相互调用。
27 8
|
10天前
|
前端开发 PHP 数据库
PHP框架的优缺点是什么?
【7月更文挑战第14天】PHP框架的优缺点是什么?
17 7
|
12天前
|
消息中间件 Java 开发者
Spring Cloud微服务框架:构建高可用、分布式系统的现代架构
Spring Cloud是一个开源的微服务框架,旨在帮助开发者快速构建在分布式系统环境中运行的服务。它提供了一系列工具,用于在分布式系统中配置、服务发现、断路器、智能路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式会话、集群状态等领域的支持。
53 5
|
10天前
|
缓存 安全 前端开发
php框架
【7月更文挑战第14天】php框架
13 2
|
10天前
|
测试技术 PHP 数据库
深入解析PHP框架:Symfony框架详解与应用
📚 Symfony框架深度解析:模块化设计提升开发效率,性能优越,灵活性高,支持MVC模式。探索控制器、路由、模板(如Twig)、服务容器、事件调度器等核心概念。还包括表单处理、数据库集成( Doctrine ORM)、安全组件、国际化支持及调试工具。使用Symfony CLI快速创建应用,内置PHPUnit测试支持。开始你的高质量Web开发之旅吧!
15 2
|
13天前
|
缓存 中间件 API
PHP框架详解 - Laravel 框架
PHP框架详解 - Laravel 框架
|
15天前
|
负载均衡 Java
使用Java实现RPC框架
使用Java实现RPC框架
|
13天前
|
设计模式 前端开发 PHP
PHP框架详解 - CodeIgniter 框架
PHP框架详解 - CodeIgniter 框架
|
14天前
|
存储 中间件 API
PHP框架详解 - Slim 框架
PHP框架详解 - Slim 框架

热门文章

最新文章