This PR is adds prefix support to compatible with redis connection.

$sub = new \Mix\Redis\Subscriber\Subscriber('127.0.0.1', 6379, '', 5, 'my_prefix:');

如题： 如果用redis，sub/pub. 客户端主动断开。 但是redis的sub 还存在该连接客户端， 到时候pub 时候， 错误日志会 NOTICE swFactoryProcess_finish (ERROR 1005): connection[fd=2] does not exists。 or NOTICE swFactoryProcess_finish (ERROR 1004): send 70 byte failed, because connection[fd=31] is closed.

然后再redis-cli publish 返回的数量，也是发现这些关闭的还在订阅 频道

Server         Name:      mix-httpd
System         Name:      linux
PHP            Version:   7.2.17
Swoole         Version:   4.4.16
Framework      Version:   2.1.9
Listen         Addr:      0.0.0.0
Listen         Port:      7777

需求：json_decode能正确处理数据 实际：json_decode处理json中大量数据（大概20多条）时有可能会失败，导致报non-object错误，具体表现为前两次请求中运行成功，第三次开始失败，一旦失败过一次后续都无法成功

[notice] 2020-03-31 13:39:12.613 <3255> Trying to get property 'health_data' of non-object
[code] 8 [type] Mix\Console\Exception\ErrorException
[file] in /vagrant/mixtest/app/Http/Controllers/BandController.php on line 83
 #0 Mix\Console\Error->appError(8, 'Trying to get p...', '/vagrant/mixtes...', 83, Array) in /vagrant/mixtest/app/Http/Controllers/BandController.php on line 83
 #1 [internal function]: App\Http\Controllers\BandController->uploadData(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
 #2 call_user_func(Array, Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response)) in /vagrant/mixtest/app/Http/Commands/StartCommand.php on line 131
 #3 App\Http\Commands\StartCommand->handle(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response)) in /vagrant/mixtest/app/Http/Commands/StartCommand.php on line 85
 #4 [internal function]: App\Http\Commands\StartCommand->App\Http\Commands\{closure}(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
 #5 call_user_func(Object(Closure), Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response)) in /vagrant/mixtest/vendor/mix/http-server/src/Server.php on line 107
 #6 [internal function]: Mix\Http\Server\Server->Mix\Http\Server\{closure}(Object(Swoole\Http\Request), Object(Swoole\Http\Response))
 #7 {main}

无法确定是swoole还是框架或者是我使用上的问题，同样的请求、同样的代码换用slim框架后一切正常。

启动php swoolefor.phar -e "php /data/wwwroot/www.lua.qifeng/bin/mix-httpd start -c /data/wwwroot/www.lua.qifeng/http/config/httpd.php" --ext=php,json,ini 监控失败

查询某张表100条数据 版本2.1.9:

[vagrant@bogon ~]$ wrk -c 100 -d 10s -t 10 --latency http://localhost:7779/mixphp/test
Running 10s test @ http://localhost:7779/mixphp/test
  10 threads and 100 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency   571.52us   64.56us   3.82ms   95.05%
    Req/Sec     1.72k   244.30     1.80k    98.04%
  Latency Distribution
     50%  556.00us
     75%  561.00us
     90%  607.00us
     99%  800.00us
  17535 requests in 10.06s, 279.12MB read
  Socket errors: connect 0, read 0, write 0, timeout 1
Requests/sec:   1743.07
Transfer/sec:     27.75MB

版本2.2.5:

[vagrant@bogon /]$ wrk -c 100 -d 10s -t 10 --latency http://localhost:9501/test
Running 10s test @ http://localhost:9501/test
  10 threads and 100 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency    99.97ms    8.92ms 205.44ms   86.62%
    Req/Sec   100.33      9.62   148.00     71.21%
  Latency Distribution
     50%   99.06ms
     75%  102.44ms
     90%  106.69ms
     99%  135.73ms
  10029 requests in 10.09s, 159.32MB read
Requests/sec:    993.62
Transfer/sec:     15.78MB

可以看到性能严重下降，是什么原因？代码是复制过去的，基本没改。

• os: alpine3.9
• php_version: 7.3.13
• swoole_version: 4.5.2
• mix_version: 2.2.11

bug来源:

官方CoroutineCommand demo

bug描述:

并发使用连接池协程的数量大于8时，channel将提前被销毁导致无法写入

复现路径:

修改官方demo中的main，将并发数i增加到8以上

示例:

• 修改/mix/app/Console/Commands/CoroutineCommand.php

public function main()
{
    $time = time();
    $chan = new Channel();
    xdefer(function () use ($chan) {
        $chan->close();
    });
    for ($i = 0; $i < 10; $i++) {
        xgo([$this, 'foo'], $chan);
    }
    for ($i = 0; $i < 10; $i++) {
        $result = $chan->pop();
        if(false===$result) {
            echo "i:".$i." chan_err_code:".$chan->errCode."\n";
        }

    }
    println(sprintf('Time: %ds', (time() - $time)));
}

• 执行php bin/mix.php co结果如下:

Hi everyone, a question can mix-php handle user sessions through multiple servers (front end ) connected to one database server ?

I am thinking of that laravel can handle it since one can store sessions in the database, is this possible to do the same with mix-php ?

Regards

Server         Name:      mix-httpd
System         Name:      linux
PHP            Version:   7.2.17
Swoole         Version:   4.4.16
Framework      Version:   2.1.9
Listen         Addr:      0.0.0.0
Listen         Port:      7777

需求：APP_DEBUG设为false时不显示错误，或不显示错误详情 实际：APP_DEBUG设为false依然会输出错误，相关数据库字段和框架信息遭到泄露

SQLSTATE[23000]: Integrity constraint violation: 1062 Duplicate entry '11' for key 'bands_mac_unique'
PDOException code 23000
/vagrant/mixtest/vendor/mix/database/src/AbstractConnection.php line 345

#0 /vagrant/mixtest/vendor/mix/database/src/AbstractConnection.php(345): PDOStatement->execute()
#1 [internal function]: Mix\Database\AbstractConnection->execute()
#2 /vagrant/mixtest/vendor/mix/database/src/Persistent/Connection.php(92): call_user_func_array('parent::execute', Array)
#3 /vagrant/mixtest/vendor/mix/database/src/Connection.php(30): Mix\Database\Persistent\Connection->call('execute', Array)
#4 /vagrant/mixtest/vendor/mix/database/src/Persistent/Connection.php(69): Mix\Database\Connection->call('execute')
#5 /vagrant/mixtest/app/Http/Models/BandModel.php(44): Mix\Database\Persistent\Connection->execute()
#6 /vagrant/mixtest/app/Http/Controllers/BandController.php(66): App\Http\Models\BandModel->add(Object(App\Http\Forms\BandForm))
#7 [internal function]: App\Http\Controllers\BandController->register(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
#8 /vagrant/mixtest/app/Http/Commands/StartCommand.php(123): call_user_func(Array, Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
#9 /vagrant/mixtest/app/Http/Commands/StartCommand.php(84): App\Http\Commands\StartCommand->handle(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
#10 [internal function]: App\Http\Commands\StartCommand->App\Http\Commands\{closure}(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
#11 /vagrant/mixtest/vendor/mix/http-server/src/Server.php(107): call_user_func(Object(Closure), Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
#12 [internal function]: Mix\Http\Server\Server->Mix\Http\Server\{closure}(Object(Swoole\Http\Request), Object(Swoole\Http\Response))
#13 {main}

MixPHP V2.1 —— Single-threaded coroutine PHP framework

看了下好像debug参数只在日志里用到了，是不是框架无法屏蔽错误，只能自己try...catch处理？

2.1.0-RC版本

$time = time();
$payload     = [
  "iss" => "http://example.org", // 签发人
  'iat' => $time, // 签发时间
  'exp' => $time + 7200, // 过期时间
  'uid' => $uid
 ];
$auth        = context()->get('auth');
$access_token= $auth->createToken($payload);

出现以下错误，这是什么原因造成的呢？如果解决？

> Too few arguments to function Mix\Auth\JWT::__construct(), 0 passed in ***//vendor/mix/bean/src/BeanDefinition.php on line 156 and exactly 1 expected
> [code] 0 [type] ArgumentCountError
> [file] ***/vendor/mix/auth/src/JWT.php [line] 53
> [trace] #0 ***/vendor/mix/bean/src/BeanDefinition.php(156): Mix\Auth\JWT->__construct()
> #1 ***/vendor/mix/bean/src/BeanFactoryTrait.php(79): Mix\Bean\BeanDefinition->newInstance(Array)
> #2 ***/vendor/mix/bean/src/BeanInjector.php(41): Mix\Bean\ApplicationContext->getBean('Mix\\Auth\\JWT')
> #3 ***/vendor/mix/bean/src/BeanDefinition.php(149): Mix\Bean\BeanInjector::build(Object(Mix\Bean\ApplicationContext), Array)
> #4 ***/vendor/mix/bean/src/BeanFactoryTrait.php(74): Mix\Bean\BeanDefinition->newInstance(Array)
> #5 ***/vendor/mix/bean/src/ApplicationContext.php(36): Mix\Bean\ApplicationContext-getBean('auth')
> #6***/app/src/Http/Controllers/LoginController.php(47): Mix\Bean\ApplicationContext->get('auth')
> #7 [internal function]: App\Http\Controllers\LoginController->passwd(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
> #8 ***/app/src/Http/Commands/StartCommand.php(130): call_user_func(Array, Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
> #9 ***/app/src/Http/Commands/StartCommand.php(91): App\Http\Commands\StartCommand->handle(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
> #10 [internal function]: App\Http\Commands\StartCommand->App\Http\Commands\{closure}(Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
> #11 ***/vendor/mix/http-server/src/HttpServer.php(95): call_user_func(Object(Closure), Object(Mix\Http\Message\ServerRequest), Object(Mix\Http\Message\Response))
> #12 [internal function]: Mix\Http\Server\HttpServer->Mix\Http\Server\{closure}(Object(Swoole\Http\Request), Object(Swoole\Http\Response))
> #13 {main}

看了一下BeanDefinition.php文件156行代码

$object or $object = new $class();  

JWT.php文件的代码是

public function __construct(array $config)

当数组大小为1时,不会出打印出错误 如果数组大小为2是或者更多,会出现错误 备注:数组内部为对象: 打印错误为: [2019-02-11 23:48:39 @19603.0] ERROR swMsgQueue_push(:104): msgsnd(65536, 2468, 1) failed. Error: Invalid argument[22].

打印位置BaseQueue.php push方法 当数组长度为1时,序列化的内容为

a:1:{i:0;O:16:"MQ\Model\Message":9:{s:16:"*receiptHandle";s:93:"2F630CC85E5C3D4EAC69389B9775013B-OSAxNTQ5OTAwMTIwOTU5IDMwMDAwMCA3IDAgaHotc2hhcmUyLTAzIDEgOQ==";s:14:"*publishTime";s:13:"1549900120949";s:18:"*nextConsumeTime";s:13
:"1549900420959";s:19:"*firstConsumeTime";s:13:"1549900120959";s:16:"*consumedTimes";s:1:"1";s:9:"messageId";s:32:"2F630CC85E5C3D4EAC69389B9775013B";s:14:"messageBodyMD5";s:32:"8D7B3DF974943E802F6C4D70D2293D3B";s:11:"messageBody";s:738:"{"db"
:{"uid":"100033","app_id":"100270","url":"http:\/\/www.kancloud.cn\/manual\/thinkphp5_1\/354102","title":"\u4eca\u5929\u8fd8\u6ca1\u6709\u7b7e\u5230\u54e6\uff0c\u4e0d\u8981\u5fd8\u8bb0\u4e86\u554a","description":"\u6cd5\u5e08\u6253\u53d1\u65a
f\u8482\u82ac","tid":"100028","push_description":"\u8fd9\u91cc\u63a8\u9001\u63cf\u8ff0"},"push":{"uid":"100033","app_id":"100270","url":"http:\/\/www.kancloud.cn\/manual\/thinkphp5_1\/354102","title":"\u5de5\u4f5c\u901a\u77e5:\u6cb3\u5357\u77
01\u7b2c\u4e00\u4eba\u6c11\u533b\u9662","description":"[\u7b7e\u5230]\u4eca\u5929\u8fd8\u6ca1\u6709\u7b7e\u5230\u54e6\uff0c\u4e0d\u8981\u5fd8\u8bb0\u4e86\u554a","tid":"100028","push_description":"\u8fd9\u91cc\u63a8\u9001\u63cf\u8ff0"},"versio
n":"1"}";s:10:"messageTag";N;}}

当数组长度为2时,序列化的内容为

string(2468) "a:2:{i:0;O:16:"MQ\Model\Message":9:{s:16:"*receiptHandle";s:93:"2F630B0D5D5C3D4EAC69389B8EFC009F-MTAgMTU0OTkwMDEyMDA4NyAzMDAwMDAgMyAwIGh6LXNoYXJlMi0wNCAzIDEw";s:14:"*publishTime";s:13:"1549900118780";s:18:"*nextConsumeTime";s:13
:"1549900420087";s:19:"*firstConsumeTime";s:13:"1549900120087";s:16:"*consumedTimes";s:1:"1";s:9:"messageId";s:32:"2F630B0D5D5C3D4EAC69389B8EFC009F";s:14:"messageBodyMD5";s:32:"8D7B3DF974943E802F6C4D70D2293D3B";s:11:"messageBody";s:738:"{"db"
:{"uid":"100033","app_id":"100270","url":"http:\/\/www.kancloud.cn\/manual\/thinkphp5_1\/354102","title":"\u4eca\u5929\u8fd8\u6ca1\u6709\u7b7e\u5230\u54e6\uff0c\u4e0d\u8981\u5fd8\u8bb0\u4e86\u554a","description":"\u6cd5\u5e08\u6253\u53d1\u65a
f\u8482\u82ac","tid":"100028","push_description":"\u8fd9\u91cc\u63a8\u9001\u63cf\u8ff0"},"push":{"uid":"100033","app_id":"100270","url":"http:\/\/www.kancloud.cn\/manual\/thinkphp5_1\/354102","title":"\u5de5\u4f5c\u901a\u77e5:\u6cb3\u5357\u77
01\u7b2c\u4e00\u4eba\u6c11\u533b\u9662","description":"[\u7b7e\u5230]\u4eca\u5929\u8fd8\u6ca1\u6709\u7b7e\u5230\u54e6\uff0c\u4e0d\u8981\u5fd8\u8bb0\u4e86\u554a","tid":"100028","push_description":"\u8fd9\u91cc\u63a8\u9001\u63cf\u8ff0"},"versio
n":"1"}";s:10:"messageTag";N;}i:1;O:16:"MQ\Model\Message":9:{s:16:"*receiptHandle";s:93:"792BCECC6D5A3D4EAC69389B92570138-MTAgMTU0OTkwMDEyMDA4NyAzMDAwMDAgMyAwIGh6LXNoYXJlMi0wNCAwIDEw";s:14:"*publishTime";s:13:"1549900119639";s:18:"*nextConsum
eTime";s:13:"1549900420087";s:19:"*firstConsumeTime";s:13:"1549900120087";s:16:"*consumedTimes";s:1:"1";s:9:"messageId";s:32:"792BCECC6D5A3D4EAC69389B92570138";s:14:"messageBodyMD5";s:32:"8D7B3DF974943E802F6C4D70D2293D3B";s:11:"messageBody";s
:738:"{"db":{"uid":"100033","app_id":"100270","url":"http:\/\/www.kancloud.cn\/manual\/thinkphp5_1\/354102","title":"\u4eca\u5929\u8fd8\u6ca1\u6709\u7b7e\u5230\u54e6\uff0c\u4e0d\u8981\u5fd8\u8bb0\u4e86\u554a","description":"\u6cd5\u5e08\u6253
\u53d1\u65af\u8482\u82ac","tid":"100028","push_description":"\u8fd9\u91cc\u63a8\u9001\u63cf\u8ff0"},"push":{"uid":"100033","app_id":"100270","url":"http:\/\/www.kancloud.cn\/manual\/thinkphp5_1\/354102","title":"\u5de5\u4f5c\u901a\u77e5:\u6cb
3\u5357\u7701\u7b2c\u4e00\u4eba\u6c11\u533b\u9662","description":"[\u7b7e\u5230]\u4eca\u5929\u8fd8\u6ca1\u6709\u7b7e\u5230\u54e6\uff0c\u4e0d\u8981\u5fd8\u8bb0\u4e86\u554a","tid":"100028","push_description":"\u8fd9\u91cc\u63a8\u9001\u63cf\u8ff
0"},"version":"1"}";s:10:"messageTag";N;}}"

PHP Fatal error: Uncaught Error: Class 'Swoole\Process' not found in /www/wwwroot/xxx.com/mixphp/vendor/mixstart/mixphp-framework/src/helpers/ProcessHelper.php:40 Stack trace: #0 /www/wwwroot/xxx.com/mixphp/vendor/mixstart/mixphp-framework/src/helpers/ProcessHelper.php(31): mix\helpers\ProcessHelper::kill('17120', 0) #1 /www/wwwroot/xxx.com/mixphp/vendor/mixstart/mixphp-framework/src/helpers/ProcessHelper.php(64): mix\helpers\ProcessHelper::isRunning('17120') #2 /www/wwwroot/xxx.com/mixphp/apps/httpd/commands/ServiceCommand.php(66): mix\helpers\ProcessHelper::readPidFile('/var/run/mix-ht...') #3 /www/wwwroot/xxx.com/mixphp/apps/httpd/commands/ServiceCommand.php(83): apps\httpd\commands\ServiceCommand->actionStop() #4 /www/wwwroot/xxx.com/mixphp/vendor/mixstart/mixphp-framework/src/console/Application.php(82): apps\httpd\commands\ServiceCommand->actionRestart() #5 /www/wwwroot/xxx.com/mixphp/vendor/mixstart/mixphp-framework/src/console/Application.php in /www/wwwroot/xxx.com/mixphp/vendor/mixstart/mixphp-framework/src/helpers/ProcessHelper.php on line 40

https://github.com/mix-php 的子仓库都是由 https://github.com/mix-php/mix 项目的 src 目录内的源码同步过去的，因此：

• 提交代码需要 fork https://github.com/mix-php/mix
• 然后修改 src 对应子目录的源码
• 然后提交 PR 到 https://github.com/mix-php/mix

这样你的贡献就会出现在 mix 主仓库中，同时也会出现在子仓库