配置文件 'default' => [ 'host' => 'redis://127.0.0.1:6379', 'options' => [ 'auth' => '', // 密码,可选参数 'db' => 10, // 数据库 'max_attempts' ...
[ error ] [2]file_get_contents(/www/wwwroot/beita.niukekj.top/vendor/workerman/workerman/../_www_wwwroot_beita.niukekj.top_think.pid): failed to open stream: No such file or directory[/www/wwwroot/beita.niukekj...
下面这段代码是基于laravel框架的,主要监听SQL查询,并记录下整条sql日志; 在webman中应该放到哪里呢? 请大佬帮忙看下哈。 DB::listen(function ($query) { $sql = $query->sql; $bindings = []; if ($query->bindings) { foreach ($query->bin...
$start = microtime(true); $num = 1000; $step = 10000; $count = $step * $num; for ($i = 0; $i < $num; $i++) { $items = []; for ($j = 0; $j < ...
最近要和大数据部门合作,处理下他们的kafka-topic的数据,打算用webman的自定义进程实现,找了几个包, nmred/kafka-php // 这个包里面有amphp ,在start的时候会多启动一个进程去消费,担心在webman的自定义进程中没法很好的管理, 所以打算放弃。 longlang/phpkafka // 这个包可在fpm和swoole下使用,但是还没出正式版,放弃了。 目前是这两个包 下载量比...
实时告警采用消息方式,采用socket/tcp协议,OMC为socket的server端,NMS为socket的client端。 5.3.1 消息格式 消息数据由消息头和消息体组成。消息头由9个字节(byte)表示,消息体长度不固定,各类消息不同。消息头的9个字节不能当做字符处理,需要按整型数处理。 上面是文档,下面是我的代码部分,代码是有问题的。 $con->onConnect = function(As...