循环发送信息的时候，出错send buffer full and drop package

h8h8 更新于2019-10-30

循环发送信息的时候，出错send buffer full and drop package，是不是缓冲区满了？

$socket->onConnect = function($socket) use($byname, $act_byname, $gdpay, $yestoday, $today, $Y, $bankcode, $appname)
    {
        //测试用
        $terminal_id = '44001555';
        for($i = 1; $i <= 10000; $i++)
        {
            $request = $gdpay->jk_datas($terminal_id, $byname, $act_byname, $yestoday, $today, $bankcode);
            if($request === TRUE)
            {
                continue;
            }
            else
            {
                log_message($appname, 'info', "{$today}缴款发送的数据：" . $request);
                $socket->send($request);   
            }
        }

        //正式生产                                             
        /*$gdpay_key  = $byname  . '.bankpay.terminals.' . $yestoday;
        $terminals  = \Uplott\Lib\Redis::instance('local_redis')->smembers($gdpay_key);

        if( ! empty($terminals))
        {
            log_message($appname, 'info', "{$today}要缴款的笔数：" . count($terminals) . "笔");
            try
            {
                foreach($terminals as $terminal_id)
                {
                    $request = $gdpay->jk_datas($terminal_id, $byname, $act_byname, $yestoday, $today, $bankcode);
                    if($request === TRUE)
                    {
                        continue;
                    }
                    else
                    {
                        log_message($appname, 'info', "{$today}缴款发送的数据：" . $request);
                        $socket->send($request);   
                    }                                    
                }                
            }
            catch(\Exception $e)
            {
                log_message($appname, 'error', $e->getMessage());
            }                   
        }*/                       
    };

    //服务器响应，接收返回结果
    $socket->onMessage = function($socket, $result) use($byname, $act_byname, $gdpay, $today, $appname)
    {
        try
        {
            log_message($appname, 'info', "{$today}缴款接收的数据：" . $result);
            $gdpay->save_jk_datas($result, $byname, $act_byname, $today);            
        }
        catch(\Exception $e)
        {
           //这里会出现send buffer full and drop package
            log_message($appname, 'error', $e->getMessage());
        }                                                    
    };

 6531  5 0

5个回答

walkor 2017-06-02

打赏

格式太乱了，看不清

暂无评论

h8h8 2017-06-02

不好意思，编辑了一下

$socket->onConnect = function($socket) use($byname)
{
    //测试用
    $terminal_id = '44001555';
    for($i = 1; $i <= 10000; $i++)
    {
        $request = $gdpay->jk_datas($terminal_id, $byname);
        if($request === TRUE)
        {
            continue;
        }
       else
       {
           log_message('info', "缴款发送的数据：" . $request);
          $socket->send($request);
       }
}

//服务器响应，接收返回结果
$socket->onMessage = function($socket, $result) use($byname)
{
    try
    {
        log_message('info', "缴款接收的数据：" . $result);
        $gdpay->save_jk_datas($result, $byname);
     }
    catch(\Exception $e)
    {        
        log_message( 'error', $e->getMessage());
    }
};

$socket->onError = function($socket, $err_code, $err_msg) use($appname)
{
        //这里会出现send buffer full and drop package
        log_message( 'error', "$err_code, $err_msg");        
};

发送10000条数据，大概出现3000-4000条 2 send buffer full and drop package 错误