php socket

PHP 也可以使用socket，先开启socket扩展。

php.ini开启 socket

/**

 *File name server.php

 *服务器端代码

 */   

//确保在连接客户端时不会超时 

set_time_limit(0); 

//设置IP和端口号 

$address = "127.0.0.1"; 

$port = 2046; //调试的时候，可以多换端口来测试程序！ 

/**

 *创建一个SOCKET 

 *AF_INET=是ipv4    如果用ipv6，则参数为AF_INET6

 *SOCK_STREAM为socket的tcp类型，如果是UDP则使用SOCK_DGRAM

*/ 

$sock = socket_create(AF_INET, SOCK_STREAM,

SOL_TCP) or die("socket_create() 失败的原因是:" . socket_strerror(socket_last_error()) ."/n"); 

//阻塞模式 

socket_set_block($sock) or

die("socket_set_block() 失败的原因是:" . socket_strerror(socket_last_error()) ."/n"); 

//绑定到socket端口 

$result = socket_bind($sock, $address,

$port) or die("socket_bind() 失败的原因是:" . socket_strerror(socket_last_error()) ."/n"); 

//开始监听 

$result = socket_listen($sock, 4) or

die("socket_listen() 失败的原因是:" . socket_strerror(socket_last_error()) ."/n"); 

echo "OK\nBinding the socket on$address:$port ... "; 

echo "OK\nNow ready to accept connections.\nListeningon the socket ... \n"; 

do { // never stop the daemon 

   //它接收连接请求并调用一个子连接Socket来处理客户端和服务器间的信息 

   $msgsock = socket_accept($sock) or die("socket_accept() failed: reason: " .socket_strerror(socket_last_error()) . "/n");       

    //读取客户端数据 

   echo "Read client data \n"; 

   //socket_read函数会一直读取客户端数据,直到遇见\n,\t或者\0字符.PHP脚本把这写字符看做是输入的结束符. 

   $buf = socket_read($msgsock, 8192); 

   echo "Received msg: $buf  \n";       

   //数据传送向客户端写入返回结果 

   $msg = "welcome \n"; 

    socket_write($msgsock, $msg, strlen($msg)) ordie("socket_write() failed: reason: " .socket_strerror(socket_last_error()) ."/n"); 

   //一旦输出被返回到客户端,父/子socket都应通过socket_close($msgsock)函数来终止 

   socket_close($msgsock); 

} while (true); 

socket_close($sock);

/**

 *File name:client.php

 *客户端代码

 * 

 *@author guisu.huang

 *@since 2012-04-11

 */ 

set_time_limit(0); 

$host = "120.55.81.171"; 

$port = 7000; 

$socket = socket_create(AF_INET,SOCK_STREAM, SOL_TCP)or die("Could not create  socket\n"); //创建一个Socket 

$connection = socket_connect($socket,$host, $port) or die("Could not connet server\n");    //  连接 

socket_write($socket,

"SOS@@123456789012345@@1@@11403.6791@@2240.5644@@201701041319") or

die("Write failed\n"); // 数据传送向服务器发送消息 

while ($buff = socket_read($socket, 1024,PHP_NORMAL_READ)) { 

   echo("Response was:" . $buff . "\n"); 

} 

socket_close($socket);

实测

PHP服务端脚本

等待连接 连接成功 client

一旦连接发送消息成功后，立马断开连接。