发表新帖

WARN http_onReceive:connection[9658643] is closed.read error on connection

swoole 1.7.21 stable版本

{{{
<?php
error_reporting(E_ALL^E_NOTICE);
require __DIR__.'/../lib/str.php';
require __DIR__ . '/../lib/getconf.php';

class sessionService
{
    private $http;
    private $config;
    private $redis;
    private $redis_host;
    private $redis_port;

public function __construct() {
        $this->config = new getconf();

$this->redis_host = substr($this->config->config['redisserver']['redis_host'],0,strpos($this->config->config['redisserver']['redis_host'],':'));
        $this->redis_port = substr($this->config->config['redisserver']['redis_host'],strpos($this->config->config['redisserver']['redis_host'],':')+1);
        //$redis_pool[] = new Swoole\Async\RedisClient($host,$port);

$this->http = new swoole_http_server(
            $this->config->config['reqserver']['swoole_http_server_host'],
            $this->config->config['reqserver']['swoole_http_server_port']
        );
        $this->http->set(
            array(
                'worker_num' => 8,
                'daemonize' => false,
                'max_conn' => 1000000,
                'max_request' => 1000000,
                'heartbeat_idle_time' => 600,
                'heartbeat_check_interval' => 60,
                'pipe_buffer_size' => 128 * 1024 * 1024,
                'log_file' => '/Library/WebServer/Documents/session.api/api/log/session_err.log',
                //'log_file' => '/data/log/session_err.log',
                //'dispatch_mode' => 1
            )
        );
        $this->http->on('Start', array($this, 'onStart'));
        $this->http->on('WorkerStart', array($this, 'onWorkerStart'));
        $this->http->on('request' , array( $this , 'onRequest')); 
        $this->http->start();
    }
 
    public function onWorkerStart( $serv , $worker_id) {

$redis = new redis;
        $redis->connect($this->redis_host, $this->redis_port);
        $serv->redis = $redis;

}

public function onStart( $serv ) {
        echo "Start\n";
    }

public function onRequest($request, $response) {

$redis = $this->http->redis;

try{
            $ret = $redis->get("aaaa");

}catch (Exception $e){ 
           /*这个查redis数据接口，在跑了一段(几天)时间后报以下错
            WARN http_onReceive:connection[9658643] is closed. 然后redis开始报 read error on           
             connection 
           */
            echo $e->getMessage();
            $this->http->reload(); //哥，这里reload有没用？
        }
        $response->end('[]');
        return;
 
    }
}
new sessionService();
}}}

发布于7年前 · 1 次浏览 · 来自提问

╰

╰末年在等谁一世温存つ