想把webman改成tcp协议(项目要求),做RPC服务有没有大佬提供思路或者帮助,可以有偿~

defence

想把webman改成tcp协议(项目要求),做RPC服务有没有大佬提供思路或者帮助,可以有偿~

10527 2 49
2个回答

walkor

webman支持自定义进程,做这个很容易。

1、新建文件 process/Rpc.php 编写rpc进程

<?php
namespace process;
use Workerman\Connection\TcpConnection;
class Rpc
{
    public function onMessage(TcpConnection $connection, $data)
    {
        static $instances = [];
        $data = json_decode($data, true);
        $class = 'service\\'.$data['class'];
        $method = $data['method'];
        $args = $data['args'];
        if (!isset($instances[$class])) {
            $instances[$class] = new $class; // 缓存类实例,避免重复初始化
        }
        $connection->send(call_user_func_array([$instances[$class], $method], $args));
    }
}

2、打开 config/process.php 增加配置启动rpc进程

return [
    // ... 这里省略了其它配置...

    'rpc'  => [
        'handler' => process\Rpc::class,
        'listen'  => 'text://0.0.0.0:8888', // 这里用了text协议,也可以用frame或其它协议
        'count'   => 8, // 可以设置多进程
    ]
];

3、新建 service/User.php 服务 (目录不存在自行创建)

<?php
namespace service;
class User
{
    public function get($uid)
    {
        return json_encode([
            'uid'  => $uid,
            'name' => 'tom'
        ]);
    }
}

4、重启webman php start.php restart

5、客户端调用

<?php
$client = stream_socket_client('tcp://127.0.0.1:8888');
$request = [
    'class'   => 'User',
    'method'  => 'get',
    'args'    => [100], // 100 是 $uid
];
fwrite($client, json_encode($request)."\n"); // text协议末尾有个换行符"\n"
$result = fgets($client, 10240000);
$result = json_decode($result, true);
var_export($result);

以上客户端代码自己可以封装成一个类

最终结果打印

array (
  'uid' => 100,
  'name' => 'tom',
)
tanhongbin

大佬就是大佬,我想了半个小时没想明白,他一句很简单就给解决了点赞了

  • wangmaomao 2021-12-25

    这个是不是在linux才有用,在win下是不是不能有两个worker

  • Tinywan 2021-12-25

    windows不支持多进程的

  • tanhongbin 2021-12-27

    windows服务区还是孩子用比较好,咱们做开发的,测试服务器和线上服务器必须linux呀,性能差太多了

年代过于久远,无法发表回答
🔝