网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

phpsocket编程中客户端异常关闭导致服务端中断的问题怎么解决

这篇文章主要讲解了“php socket编程中客户端异常关闭导致服务端中断的问题怎么解决”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“php socket编程中客户端异常关闭导致服务端中断的问题怎么解决”吧!

创新互联建站的客户来自各行各业,为了共同目标,我们在工作上密切配合,从创业型小企业到企事业单位,感谢他们对我们的要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。专业领域包括网站建设、成都做网站、电商网站开发、微信营销、系统平台开发。


原因如下:
1.socket_recv支持多种flag,用于不同场景
2.socket_recv可以检测socket关闭的情况(例如对端关闭了socket)
返回值:$return_value=socket_recv(...)
含义: >0 表示接收到的字节数;
===0, 发生了错误,socket closed;
===false,无数据,socket not closed。

socket_read不能判断socket是否已经断开。
测试流程:
启动server端,再启动client端:可以正常通信。
kill掉client端,结果server端只能读取到空字符串。

测试代码如下:

file: bug1_server.php

 0, "usec" => 800000));
socket_set_option($accept_resource, SOL_SOCKET,         SO_SNDTIMEO, array("sec" => 0, "usec" => 800000));

// stream固定长度
$len = 100;

//让服务器不停获取客户端传过来的信息
while (true) {
    $string_read = socket_read($accept_resource, $len);
    if($string_read === false) {
        echo "socket error:" . socket_last_error() . ",error msg:" . socket_strerror(socket_last_error()) . PHP_EOL;
        break;
    }
    elseif($string_read == '') {
        if(in_array(socket_last_error(), [SOCKET_EPIPE, SOCKET_ECONNRESET])) {
            echo "socket error:".socket_last_error().",error msg:".socket_strerror(socket_last_error()).PHP_EOL;
            break;
        }
        if(in_array(socket_last_error(), [SOCKET_EAGAIN])) {
        // EAGAIN, retry later
        usleep(500);
        continue;
    }
    echo "server receive empty:" . socket_last_error() . ",error msg:" . socket_strerror(socket_last_error()) . PHP_EOL;
}
else {
    $string = trim($string_read);
    echo 'server receive success,msg:['.$string.'],time:' . microtime(true) . PHP_EOL;
    }
} ;

// 先shutdown,后close
@socket_shutdown($accept_resource);
socket_close($accept_resource);

@socket_shutdown($socket);
socket_close($socket);

/**
 * 生成php随机串
 * @param $length
 * @return string
 */
function randomkeys($length){
    $output='';
    for ($a = 0; $a<$length; $a++) {
        $output .= chr(mt_rand(33, 126));
    }
    return $output;
}
?>

file:bug1_client.php

 0, "usec" => 800000));
socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 0, "usec" => 800000));

$len = 100;

//连接服务端的套接流,这一步就是使客户端与服务器端的套接流建立联系
if (socket_connect($socket, '127.0.0.1', 8801) == false) {
    echo 'connect fail massege:' . socket_strerror(socket_last_error());
} else {
    while(1){
        $ori_msg = 'Hello, server!'.randomkeys(8);
        $message_write = str_pad($ori_msg, $len);

        //向服务端写入字符串信息
        $sent = @socket_write($socket, $message_write, $len);

        if ($sent === false) {
            if(in_array(socket_last_error(), [SOCKET_EPIPE, SOCKET_ECONNRESET])) {
                echo "socket error:".socket_last_error().",error msg:".socket_strerror(socket_last_error()).PHP_EOL;
                break;
            }
            echo "socket error:".socket_last_error().",error msg:".socket_strerror(socket_last_error()).PHP_EOL;
        }
        else{
            echo 'client write success,msg:['.$ori_msg.'],time:' . microtime(true).PHP_EOL;
        }
//        break;
    }
}
@socket_shutdown($socket);
socket_close($socket);

/**
 * 生成php随机串
 * @param $length
 * @return string
 */
function randomkeys($length){
    $output='';
    for ($a = 0; $a<$length; $a++) {
        $output .= chr(mt_rand(33, 126));
    }
    return $output;
}
?>

正确的代码是:(file: debug1_server.php)

 0, "usec" => 800000));
socket_set_option($accept_resource, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 0, "usec" => 800000));

// stream固定长度
$len = 100;

//让服务器不停获取客户端传过来的信息
while (true) {
    /* 使用socket_recv */
    $len_read = socket_recv($accept_resource, $string_read, $len, 0);
    
    if ($len_read === false) {
        // no data
        echo "no data".PHP_EOL;
        continue;
    }
    elseif($len_read === 0 ) {
        // socket closed
        echo "socket error:" . socket_last_error() . ",error msg:" . socket_strerror(socket_last_error()) . PHP_EOL;
        break;
    }
    else {
        $string = trim($string_read);
        echo 'server receive success,msg:['.$string.'],time:' . microtime(true) . PHP_EOL;
    }
} ;
// 先shutdown,后close
@socket_shutdown($accept_resource);
socket_close($accept_resource);

@socket_shutdown($socket);
socket_close($socket);

/**
 * 生成php随机串
 * @param $length
 * @return string
 */
function randomkeys($length){
    $output='';
    for ($a = 0; $a<$length; $a++) {
        $output .= chr(mt_rand(33, 126));
    }
    return $output;
}
?>

感谢各位的阅读,以上就是“php socket编程中客户端异常关闭导致服务端中断的问题怎么解决”的内容了,经过本文的学习后,相信大家对php socket编程中客户端异常关闭导致服务端中断的问题怎么解决这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!


当前题目:phpsocket编程中客户端异常关闭导致服务端中断的问题怎么解决
本文链接:http://bjjierui.cn/article/ipheio.html

其他资讯