首先需要现有一个 tcp 服务,我们使用 php中的 socket 系列函数实现
1、tcp 服务
<?php
//创建socket套接字
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
//设置阻塞模式
socket_set_block($socket);
//为套接字绑定ip和端口
socket_bind($socket,'127.0.0.1',3046);
//监听socket
socket_listen($socket,4);
while(true)
{
//接收客户端请求
if(($msgsocket = socket_accept($socket)) !== false)
{
//读取请求内容
$buf = socket_read($msgsocket, 8192);
echo "Received msg: $buf \n";
$str = "this is a service message";
//向连接的客户端发送数据
socket_write($msgsocket, $str,strlen($str));
//操作完之后需要关闭该连接否则 feof() 函数无法正确识别打开的句柄是否读取完成
socket_close($msgsocket);
}
}2、tcp服务端
function tcp_server($tcp_server = '192.168.0.12',$port=80){
//创建服务端的socket套接流,net协议为IPv4,protocol协议为TCP
$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
$message = '';
/*绑定接收的套接流主机和端口,与客户端相对应*/
if(socket_bind($socket,$tcp_server,$port) == false){
$message = 'server bind fail:'.socket_strerror(socket_last_error());
/*这里的127.0.0.1是在本地主机测试,你如果有多台电脑,可以写IP地址*/
}
//监听套接流
if(socket_listen($socket)==false){
$message = 'server listen fail:'.socket_strerror(socket_last_error());
}
//让服务器无限获取客户端传过来的信息
do{
/*接收客户端传过来的信息*/
$accept_resource = socket_accept($socket);
/*socket_accept的作用就是接受socket_bind()所绑定的主机发过来的套接流*/
if($accept_resource !== false){
/*读取客户端传过来的资源,并转化为字符串*/
$string = socket_read($accept_resource,1024);
/*socket_read的作用就是读出socket_accept()的资源并把它转化为字符串*/
$message = 'server receive is : '.$string.PHP_EOL;//PHP_EOL为php的换行预定义常量
if($string != false){
$return_client = 'server receive is : '.$string.PHP_EOL;
/*向socket_accept的套接流写入信息,也就是回馈信息给socket_bind()所绑定的主机客户端*/
socket_write($accept_resource,$return_client,strlen($return_client));
/*socket_write的作用是向socket_create的套接流写入信息,或者向socket_accept的套接流写入信息*/
}else{
$message = 'socket_read is fail';
}
/*socket_close的作用是关闭socket_create()或者socket_accept()所建立的套接流*/
// socket_close($accept_resource);
}
}while(true);
socket_close($socket);
return $message;
}连接 tcp 服务:
使用 socket 系列函数连接
<?php $st="socket send message"; $length = strlen($st); //创建tcp套接字 $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP); //连接tcp socket_connect($socket, '127.0.0.1',3046); //向打开的套集字写入数据(发送数据) $s = socket_write($socket, $st, $length); //从套接字中获取服务器发送来的数据 $msg = socket_read($socket,8190); echo $msg; //关闭连接 socket_close($socket);
使用 fsockopen 连接
<?php
//使用 fsockopen 打开tcp连接句柄
$fp = fsockopen("tcp://127.0.0.1",3046);
$msg = "fsockopen send message";
//向句柄中写入数据
fwrite($fp,$msg);
$ret = "";
//循环遍历获取句柄中的数据,其中 feof() 判断文件指针是否指到文件末尾
while (!feof($fp)){
stream_set_timeout($fp, 2);
$ret .= fgets($fp, 128);
}
//关闭句柄
fclose($fp);
echo $ret;使用 stream_socket_client 连接
<?php
//使用 stream_socket_client 打开 tcp 连接
$fp = stream_socket_client("tcp://127.0.0.1:3046");
$msg = "fsockopen send message";
//向句柄中写入数据
fwrite($fp,$msg);
$ret = "";
//循环遍历获取句柄中的数据,其中 feof() 判断文件指针是否指到文件末尾
while (!feof($fp)){
stream_set_timeout($fp, 2);
$ret .= fgets($fp, 128);
}
//关闭句柄
fclose($fp);
echo $ret;
|
|---|