socket数据通讯

1、服务器监听

error_reporting(E_ALL);
//端口111
$service_port = 1234;
//本地
$address = '192.168.0.103';
//创建 TCP/IP socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
echo $socket;
var_dump($socket);
if ($socket < 0)
{
    echo "socket创建失败原因: " . socket_strerror($socket) . "
";
}
else
{
    echo "OK，HE HE.
";
}
$result = socket_connect($socket, $address, $service_port);
if ($result)
{
    echo "OK.
";
}
else
{
    echo "SOCKET连接失败原因: ($result) " . socket_strerror($result) . "
";
}

//发送命令
$in = "HEAD / HTTP/1.1
";
$in .= "Connection: Close

";
$out = '';
echo "Send Command..........";
$in = "sun
";
socket_write($socket, $in, strlen($in));
echo "OK.
";
echo "Reading Backinformatin:

";
while ($out = socket_read($socket, 2048)) {
    echo $out;
}
echo "Close socket........";
socket_close($socket);

2、客户端访问

$attr = array("id"=>"admin","pw"=>"admin","mark"=>"1");
$json = json_encode($attr);
set_time_limit(0);
//192.168.247.1
$host = "192.168.0.103";
$port = 12345;
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create    socket
"); // 创建一个Socket
$user = "admin";
$connection = socket_connect($socket, $host, $port) or die("Could not connet server
");    //  连接
socket_write($socket, $json) or die("Write failed
"); // 数据传送 向服务器发送消息
while ($buff = @socket_read($socket, 1024, PHP_NORMAL_READ)) {
    echo("Response was:" . $buff . "
");
}
socket_close($socket);