热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

请问一下,PHP下写socket的TCP通讯如何设定定时器?

在用PHP的socket函数写TCP的通讯时,不知道如何用PHP完成定时器的功能,在超时没有接收到需要的数据的时候,结束该TCP连接,并通知出错。我看到了,socket函数还有其他的封装函数如
在用PHP的socket函数写TCP的通讯时,不知道如何用PHP完成定时器的功能,在超时没有接收到需要的数据的时候,结束该TCP连接,并通知出错。

我看到了,socket函数还有其他的封装函数如:fsockopen()和stream_socket_client()等函数可以实现socket的TCP通信,但不知如何使用,进度紧迫,请各位达人指教。
如果有代码示例最好。

error_reporting (E_ALL); 

$service_port = 3456;
$address = "10.3.10.45";

$socket = socket_create (AF_INET, SOCK_STREAM, 0); 
if ($socket < 0)

    echo "socket_create() failed: reason: " . socket_strerror ($socket) . "
"; 
}
else
{         
        $Realsend = "GET / HTTP/1.1\r\n";
        $Realsend .= "Host: 10.3.10.45 \r\n";
        $Realsend .= "Connection: Close\r\n\r\n";*/
        
        socket_write ($socket, $Realsend, strlen($Realsend));
    }
}

$out ='';
$Ret = 1;
while ($out =socket_read($socket, $Ret, PHP_BINARY_READ))
{
echo htmlentities($out);
if("F" == $out)
{
echo "break";
break;
}
}
socket_close($socket);
?>

4 个解决方案

#1


这个问题也已经解决,现在也将解决方法贴出来,希望对大家能有帮助:



error_reporting (E_ALL); 

$service_port = 3456;
$address = "10.3.10.99";

$socket = socket_create (AF_INET, SOCK_STREAM, 0); 
if ($socket < 0)

    echo "socket_create() failed: reason: " . socket_strerror ($socket) . "\n"; 
    exit();
}
else

    echo "Attempting to connect to '$address' on port '$service_port'...". "\n"; 
    $result = socket_connect ($socket, $address, $service_port); 
    if ($result == FALSE ) 
    {
        echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n"; 
        exit();
    } 
    else 
    {        
        $send = '';
        //WORD wLength; // 数据区有效长度,从数据区aucData[0]开始
        $send = $send . pack("L",44);
        //UCHAR aucResv[TRANSFRAME_RESV_LENGTH]; // 保留
        $send = $send . pack("L",0);    
        //_UL     ulSIP;           源IP地址,业务不需要填写
        $send = $send . pack("L",0);
        //_UL     ulDIP;           // 目的IP地址,业务不需要填写
        $send = $send . pack("L",0);
        //_US     usDProcID;       // 目的进程ID
        $send = $send . pack("S",88);
        //_US     usDProcHandle;   // 目的进程Handle, 当一个进程启动多个实例时需要判断
        $send = $send . pack("S",89);
        //_UL     ulDCmdHandle;    // 目的命令句柄,标识一个模块内发送的命令标识
        $send = $send . pack("L",90);
        //_US     usSProcID;       // 源端进程ID
        $send = $send . pack("S",91);
        //_US     usSProcHandle;   // 源端进程Handle, 当一个进程启动多个实例时需要判断
        $send = $send . pack("S",92);
        //_UL     ulSCmdHandle;    // 源命令句柄,标识一个模块内发送的命令标识
        $send = $send . pack("L",93);
        //_US     usMsgVer;        // 消息版本号
        $send = $send . pack("S",94);
        //_US     usMsgType;       // 消息类型,具体类型附后
        $send = $send . pack("S",95);
        //_UL     ulCmdCode;       // 命令码
        $send = $send . pack("L",96);
        //_UC     ucReserve[8];    // 保留
        $send = $send . pack("L",0);
        //_UL     ulRetCode;       // 交互返回码, 应用使用, 通讯无关
        $send = $send . pack("L",0);
        //_UL     ulLength;        // 后附数据区长度
        $send = $send . pack("L",0);        
        
        $crc = 0xFFFF;
        for ($x = 0; $x < strlen ($send); $x++) 
        {
            $crc = $crc ^ ord($send[$x]);
            for ($y = 0; $y < 8; $y++) 
            {
                if (($crc & 0x0001) == 0x0001) 
                {
                    $crc = (($crc >> 1) ^ 0xA001);
                } 
                else 
                { $crc = $crc >> 1; }
            }
        }
        
        $Realsend = '';
        //DWORD dwHeaderFlag; // 帧的起始标志
        $Realsend = $Realsend . pack("L",0xDEADDEAD);
        //WORD wCrcCode; // CRC校验码,从长度字节wLength开始
        $Realsend = $Realsend . pack("L",$crc);
        $Realsend = $Realsend . $send;        
                
        echo "the length is";
        echo strlen($Realsend);
        echo "the message is";
        echo $Realsend;
        
        echo "Sending Msg..."; 
        socket_write ($socket, $Realsend, strlen ($Realsend));
        
        $out ='';
        
        echo "Reading response:\n\n";
        $time = time();
        $PP=TRUE;        
        
        socket_set_nonblock($socket);
        
        echo time(); 
        while($PP) 
        {
            $out =socket_read($socket,8);
            
            if ((time() - $time) >= 10 )
            {
                echo "Time out ,Closing socket...";
                $PP = FALSE;
                //socket_close($socket);  
            }
            else
            {
                sleep(1);
                continue;
            }
            
        }
        echo time();

        echo "Closing socket...";
        socket_close($socket);
    }
}

?>



#2


不错

#3


不错,不过有时候自己查查手册也是有许多收获的

#4


看看下面的文章比较好
PHP套接字编程
1. 理解套接字
    Mail、ftp、telnet、name和finger这些服务都是在一个专用的公开的端口上提供的,通过连接到这些端口,客户程序就能够访问这些服务。这与现实生活是相似的——当需要干洗衣服的时候,找干洗店;当需要取钱的时候,去银行,等等。除了专用于特定服务器的端口外,计算机还有其它的端口让程序员创建他们自己的服务器。
端口一般是编号的,通过指定服务器的端口号,客户程序可以连接到该端口上。每种服务器或端口要有特定的协议,为了让客户的请求能够被理解和响应,客户必须以这种服务器特有的方式形成客户请求。
Socket是网络上运行的两个程序间双向通信连接的一端。Socket这个词的一般意义是自然的或人工的插口,如家用电器的电源插口等。
客户程序可以向Socket写请求,服务器将处理此请求,然后通过Socket把结果返回给客户。
Socket是一种底层连接。客户机和服务器通过写入到Socket的字节流进行通信。它们必须有共同的协议,也就是说,通过Socket相互传送信息时所用的语言必须是协定好的。

2. Socket建立连接的过程
建立过程如下:(connection-oriented)
server 方过程 client 方过程

socket() socket()
| |
bind() bind()
| |
listen() |
| |
accept()<------------------connect()
| |
recv()/send() <----------> send()/recv()

3. Php 基本套接字调用:
3.1. 基本套接字调用
创建套接字--socket();
绑定本机端口--bind();
建立连接--connect(),accept();
侦听端口--listen();
数据传输--send(),recv();
输入/输出多路复用--select();
关闭套接字--closesocket()
3.2. php提供的套接字调用:
接受连接-—accept connect() 
绑定端口—bind ()
关闭套接字—close()
初始化连接—connect()
侦听端口—listen()
读取套接字—read()
创建套接字—socket()
写套接字—write()

4. 基本应用
4.1. 一个简单的TCP服务器
1 #!/usr/local/bin/php -q

4 /*
5 * We don't want any time-limit for how the long can hang
6 * around, waiting for connections:
7 */
8 set_time_limit(0);

10 /* Create a new socket: */
11 if( ($sock = socket( AF_INET, SOCK_STREAM, 0 )) < 0 )
12 {
13 print strerror( $sock ) . "n";
14 exit(1);
15 }
16 
17 /* Bind the socket to an address and a port: */
18 if( ($ret = bind( $sock, "10.31.172.77", 10000 )) < 0 )
19 {
20 print strerror( $ret ) . "n";
21 exit(1);
22 }
23 
24 /*
25 * Listen for incoming connections on $sock.
26 * The '5' means that we allow 5 queued connections.
27 */
28 if( ($ret = listen( $sock, 5 )) < 0 )
29 {
30 print strerror( $ret ) . "n";
31 }
32 
33 /* Accept incoming connections: */
34 if( ($msgsock = accept_connect( $sock )) < 0)
35 {
36 print strerror( $msgsock ) . "n";
37 exit(1); 
38 }
39 
40 /* Send the welcome-message: */
41 $message = "Welcome to my TCP-server!n";
42 if( ($ret = write( $msgsock, $message, strlen($message)) ) < 0 )
43 {
44 print strerror( $msgsock ) . "n";
45 exit(1);
46 }
47 
48 /* Read/Receive some data from the client: */ 
49 $buf = '';
50 if( ($ret = read( $msgsock, $buf, 128 )) < 0 )
51 {
52 print strerror( $ret ) . "n";
53 exit(1);
54 }
55 
56 /* Echo the received data back to the client: */
57 if( ($ret = write( $msgsock, "You said: $bufn", strlen("You said: $bufn")) ) < 0 )
58 {
59 print strerror( $ret ) . "n";
60 exit(1);
61 }
62 
63 /* Close the communication-socket: */ 
64 close( $msgsock );
65 
66 /* Close the global socket: */
67 close( $sock );
68 ?>

第8行:使用set_time_limit设定程序执行时间为无限以等待连接;
11-15: 创建一个套接字;
18-22: 把创建的套接字与IP及端口绑定;
28-31: 侦听端口;
34-38: 接受连接;
41-46: 显示欢迎信息;
49-54: 读取客户端信息;
57-61: 向客户端回显信息;
63-67: 关闭套接字
4.2. TCP服务器的运行
上边这个tcp服务器的运行要求php编译成cgi解释方式,并且编译时加入--enable-sockets。
如果你已经编译成cgi解释方式运行,但是使用命令php -m列出的项目没有sockets,则说明你需要重新编译php。当这些要求达到后你就可以运行这个服务器了
启动服务器:
./filename.php
然后就可以使用telnet登录了。
telnet 10.31.172.77 10000
你的终端上将显示:
Trying 10.31.172.77...
Connected to 10.31.172.77.
Escape character is '^]'.
Welcome to my TCP server!
然后输入一些东西,并回车:
Hello
You said: Hello
Connection closed by foreign host

你也可以修改一下这个程序,让它像phpmanual上的那个例子,只有当客户端输入“quit“的时候才关闭连接。

5. 其他应用
5.1. 聊天室应用
5.1.1. 常见的聊天室实现
一般的聊天室的实现常使用的方法是使用框架页面,然后对其中一个用于显示谈话内容的框架使用html的方式刷新,例如:

使用这种方式会导致浏览器端不断的向服务器端发出请求,当有大量的请求时就会使得服务器运行效率降低。这样的聊天室显然是有设计弊端的。
但是如果使用socket的方式实现聊天室,情况就不同了。
5.1.2. 使用socket实现聊天室
我们要讨论的聊天室非常简单,只是一个原理上的实现。
它是一个 client/server 结构的程序, 首先启动 server, 然后用户使用 client 进行连接. client/server 结构的优点是速度快, 缺点是当 server 进行更新时, client 也必需更新. 

初始化 server, 使server 进入监听状态: (以下只是实现原理,并不涉及具体程序) 

$socket = socket( AF_INET,SOCK_STREAM, 0); 
// 首先建立一个 socket, 族为 AF_INET, 类型为 SOCK_STREAM. 
// AF_INET = ARPA Internet protocols 即使用 TCP/IP 协议族 
// SOCK_STREAM 类型提供了顺序的, 可靠的, 基于字节流的全双工连接. 
// 由于该协议族中只有一个协议, 因此第三个参数为 0 

 
bind ($sock, $address, $port)
// 再将这个 socket 与某个地址进行绑定. 

listen( sockfd, MAX_CLIENT) 
// 地址绑定之后, server 进入监听状态. 
// MAX_CLIENT 是可以同时建立连接的 client 总数. 

server 进入 listen 状态后, 等待 client 建立连接。 

Client端要建立连接首先也需要初始化连接: 

$socket= socket( AF_INET,SOCK_STREAM,0))
// 同样的, client 也先建立一个 socket, 其参数与 server 相同. 

connect ($socket, $address, $service_port)
// client 使用 connect 建立一个连接. 

当 client 建立新连接的请求被送到Server端时, server 使用 accept 来接受该连接: 

accept_connect($sock)
// accept 返回一个新的文件描述符. 

在 server 进入 listen 状态之后, 由于可能有多个用户请求连接,所以程序需要同时对这些用户进行操作,并在它们之间实现信息交换。这在实现上称为I/O多路复用技术。
I/O多路复用技术的方法就不是本文所要叙述的内容了,如有兴趣请参考相关书籍。

5.2. 一个基于web的新闻组浏览器
在php中可以使用fsockopen打开一个tcp socket连接
int fsockopen (string hostname, int port [, int errno [, string errstr [, double timeout]]])
有关此函数的使用请参考php手册。
访问新闻组服务,需要使用一个协议叫NNTP,即Network News Transfer Protocol。
这个协议有一个专用的RFC描述,它位于 http://www.w3.org/Protocols/rfc977/rfc977.html。
该文档详细的说明了如何同一个nntp服务器对话及如何使用命令完成任务。
5.2.1. 连接一个服务器
$cfgServer = "news.php.net";
$cfgPort = 119;
$cfgTimeOut = 10;

// open a socket
if(!$cfgTimeOut)
// without timeout
$usenet_handle = fsockopen($cfgServer, $cfgPort);
else
// with timeout
$usenet_handle = fsockopen($cfgServer, $cfgPort, &$errno, &$errstr, $cfgTimeOut);

if(!$usenet_handle) {
echo "Connexion failedn";
exit();

else {
echo "Connectedn";
$tmp = fgets($usenet_handle, 1024);
}
?> 

5.2.2. 同服务器进行对话
在前面,我们已经同服务器连接上了,假如我们要从某一新闻组中选取10条最近的新闻,该怎么办呢?
RFC977指出,选择一个新闻组使用group命令:
GROUP ggg

//$cfgUser = "xxxxxx";
//$cfgPasswd = "yyyyyy";
$cfgNewsGroup = "alt.php";

// identification required on private server
if($cfgUser) {
fputs($usenet_handle, "AUTHINFO USER ".$cfgUser."n");
$tmp = fgets($usenet_handle, 1024);

fputs($usenet_handle, "AUTHINFO PASS ".$cfgPasswd."n");
$tmp = fgets($usenet_handle, 1024);

// check error

if($tmp != "281 Okrn") {
echo "502 Authentication errorn";
exit();

}

// select newsgroup

fputs($usenet_handle, "GROUP ".$cfgNewsGroup."n");
$tmp = fgets($usenet_handle, 1024);

if($tmp == "480 Authentication required for commandrn") {
echo "$tmpn";
exit();


$info = split(" ", $tmp);
$first = $info[2];
$last = $info[3];

print "First : $firstn";
print "Last : $lastn";
?> 
 

推荐阅读
  • 如何自行分析定位SAP BSP错误
    The“BSPtag”Imentionedintheblogtitlemeansforexamplethetagchtmlb:configCelleratorbelowwhichi ... [详细]
  • Nginx使用(server参数配置)
    本文介绍了Nginx的使用,重点讲解了server参数配置,包括端口号、主机名、根目录等内容。同时,还介绍了Nginx的反向代理功能。 ... [详细]
  • ASP.NET2.0数据教程之十四:使用FormView的模板
    本文介绍了在ASP.NET 2.0中使用FormView控件来实现自定义的显示外观,与GridView和DetailsView不同,FormView使用模板来呈现,可以实现不规则的外观呈现。同时还介绍了TemplateField的用法和FormView与DetailsView的区别。 ... [详细]
  • 本文介绍了计算机网络的定义和通信流程,包括客户端编译文件、二进制转换、三层路由设备等。同时,还介绍了计算机网络中常用的关键词,如MAC地址和IP地址。 ... [详细]
  • Python瓦片图下载、合并、绘图、标记的代码示例
    本文提供了Python瓦片图下载、合并、绘图、标记的代码示例,包括下载代码、多线程下载、图像处理等功能。通过参考geoserver,使用PIL、cv2、numpy、gdal、osr等库实现了瓦片图的下载、合并、绘图和标记功能。代码示例详细介绍了各个功能的实现方法,供读者参考使用。 ... [详细]
  • 本文介绍了Python爬虫技术基础篇面向对象高级编程(中)中的多重继承概念。通过继承,子类可以扩展父类的功能。文章以动物类层次的设计为例,讨论了按照不同分类方式设计类层次的复杂性和多重继承的优势。最后给出了哺乳动物和鸟类的设计示例,以及能跑、能飞、宠物类和非宠物类的增加对类数量的影响。 ... [详细]
  • 在Kubernetes上部署JupyterHub的步骤和实验依赖
    本文介绍了在Kubernetes上部署JupyterHub的步骤和实验所需的依赖,包括安装Docker和K8s,使用kubeadm进行安装,以及更新下载的镜像等。 ... [详细]
  • 目录实现效果:实现环境实现方法一:基本思路主要代码JavaScript代码总结方法二主要代码总结方法三基本思路主要代码JavaScriptHTML总结实 ... [详细]
  • CSS3选择器的使用方法详解,提高Web开发效率和精准度
    本文详细介绍了CSS3新增的选择器方法,包括属性选择器的使用。通过CSS3选择器,可以提高Web开发的效率和精准度,使得查找元素更加方便和快捷。同时,本文还对属性选择器的各种用法进行了详细解释,并给出了相应的代码示例。通过学习本文,读者可以更好地掌握CSS3选择器的使用方法,提升自己的Web开发能力。 ... [详细]
  • android listview OnItemClickListener失效原因
    最近在做listview时发现OnItemClickListener失效的问题,经过查找发现是因为button的原因。不仅listitem中存在button会影响OnItemClickListener事件的失效,还会导致单击后listview每个item的背景改变,使得item中的所有有关焦点的事件都失效。本文给出了一个范例来说明这种情况,并提供了解决方法。 ... [详细]
  • 本文介绍了Redis的基础数据结构string的应用场景,并以面试的形式进行问答讲解,帮助读者更好地理解和应用Redis。同时,描述了一位面试者的心理状态和面试官的行为。 ... [详细]
  • 计算机存储系统的层次结构及其优势
    本文介绍了计算机存储系统的层次结构,包括高速缓存、主存储器和辅助存储器三个层次。通过分层存储数据可以提高程序的执行效率。计算机存储系统的层次结构将各种不同存储容量、存取速度和价格的存储器有机组合成整体,形成可寻址存储空间比主存储器空间大得多的存储整体。由于辅助存储器容量大、价格低,使得整体存储系统的平均价格降低。同时,高速缓存的存取速度可以和CPU的工作速度相匹配,进一步提高程序执行效率。 ... [详细]
  • 本文介绍了在Windows环境下如何配置php+apache环境,包括下载php7和apache2.4、安装vc2015运行时环境、启动php7和apache2.4等步骤。希望对需要搭建php7环境的读者有一定的参考价值。摘要长度为169字。 ... [详细]
  • 本文介绍了在mac环境下使用nginx配置nodejs代理服务器的步骤,包括安装nginx、创建目录和文件、配置代理的域名和日志记录等。 ... [详细]
  • 本文介绍了如何使用C#制作Java+Mysql+Tomcat环境安装程序,实现一键式安装。通过将JDK、Mysql、Tomcat三者制作成一个安装包,解决了客户在安装软件时的复杂配置和繁琐问题,便于管理软件版本和系统集成。具体步骤包括配置JDK环境变量和安装Mysql服务,其中使用了MySQL Server 5.5社区版和my.ini文件。安装方法为通过命令行将目录转到mysql的bin目录下,执行mysqld --install MySQL5命令。 ... [详细]
author-avatar
缘zhi韵_297
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有