A. 姹侾HP SOCKET缂栫▼铡熺悊
浣犱简瑙ｄ粈涔堟槸socket涓?
濡傛灉涓崭简瑙ｅ缓璁铡讳简瑙ｄ笅,閮芥槸闇瑕佹帉鎻＄殑鐭ヨ瘑
鎴戝ぇ姒傝窡浣犳弿杩颁笅娴佺▼
链嶅姟鍣ㄧ鍏埚埯濮嫔寲Socket锛岀粦瀹氱鍙(bind)锛屽圭鍙ｈ繘琛岀洃钖(listen)锛岃皟鐢╝ccept阒诲烇纴绛夊緟瀹㈡埛绔杩炴帴銆
瀹㈡埛绔鍒濆嫔寲涓涓猄ocket锛岀劧钖庤繛鎺ユ湇锷″櫒(connect)锛屽傛灉杩炴帴鎴愬姛锛岃繖镞跺㈡埛绔涓庢湇锷″櫒绔镄勮繛鎺ュ氨寤虹珛浜嗐傚㈡埛绔鍙戦佹暟鎹璇锋眰锛屾湇锷″櫒绔鎺ユ敹璇锋眰骞跺勭悊璇锋眰锛岀劧钖庢妸锲炲簲鏁版嵁鍙戦佺粰瀹㈡埛绔锛屽㈡埛绔璇诲彇鏁版嵁锛屾渶钖庡叧闂杩炴帴锛屼竴娆′氦浜掔粨𨱒熴
鍏跺疄缃戜笂璧勬簮寰埚氢简, 澶氢简瑙ｅ氩姩镓嫔氢綘镊宸辩殑杩涙ユ湁寰埚ぇ镄勫府锷
B. php socket 如何实现非阻塞
关于socket的阻塞与非阻塞模式以及它们之间的优缺点，这已经没什么可言的；我打个很简单的比方，如果你调用socket send函数时；
如果是阻塞模式下：
send先比较待发送数据的长度len和套接字s的发送缓冲的长度，如果len大于s的发送缓冲区的长度，该函数返回SOCKET_ERROR；如果len小于或者等于s的发送缓冲区的长度，那么send先检查协议是否正在发送s的发送缓冲中的数据，如果是就等待协议把数据发送完，如果协议还没有开始发送s的发送缓冲中的数据或者s的发送缓冲中没有数据，那么 send就比较s的发送缓冲区的剩余空间和len，如果len大于剩余空间大小，send就一直等待协议把s的发送缓冲中的数据发送完，如果len小于剩余空间大小send就仅仅把buf中的数据到剩余空间里
如果是非阻塞模式下：
在调用socket send函数时，如果能写到socket缓冲区时，就写数据并返回实际写的字节数目，当然这个返回的实际值可能比你所要写的数据长度要小些（On nonblocking stream oriented sockets, the number of bytes written can be between 1 and the requested length, depending on buffer availability on both the client and server computers），如果不可写的话，就直接返回SOCKET_ERROR了，所以没有等待的过程。。
经过上面的介绍后，下面介绍如何设置socket的非阻塞模式：
当使用socket()函数和WSASocket()函数创建套接字时，默认都是阻塞的。在创建套接字之后，通过调用ioctlsocket()函数，将该套接字设置为非阻塞模式。
//-------------------------
// Set the socket I/O mode: In this case FIONBIO
// enables or disables the blocking mode for the
// socket based on the numerical value of iMode.
// If iMode = 0, blocking is enabled;
// If iMode != 0, non-blocking mode is enabled.
u_long iMode = 1; //non-blocking mode is enabled.
ioctlsocket(m_socket, FIONBIO, &iMode); //设置为非阻塞模式
套接字设置为非阻塞模式后，在调用Windows Sockets API函数时，调用函数会立即返回。大多数情况下，这些函数调用都会调用“失败”，并返回WSAEWOULDBLOCK错误代码。说明请求的操作在调用期间内没有时间完成。通常，应用程序需要重复调用该函数，直到获得成功返回代码。 不同的Windows Sockets API函数，在调用失败时返回的WSAEWOULDBLOCK错误代码具有不同的含义
需要说明的是并非所有的 Windows Sockets API 在非阻塞模式下调用，都会返回 WSAEWOULDBLOCK 错误。例如，以非阻塞模式的套接字为参数调用 bind() 函数时，就不会返回该错误代码。当然，在调用 WSAStartup() 函数时更不会返回该错误代码，因为该函数是应用程序第一调用的函数，当然不会返回这样的错误代码。
要将套接字设置为非阻塞模式，除了使用 ioctlsocket() 函数之外，还可以使用 WSAAsyncselect() 和 WSAEventselect() 函数。当调用该函数时，套接字会自动地设置为非阻塞方式:
C. socket在php主要是什么作用用在哪些方面
PHP 使用Berkley的socket库来创建它的连接。你可以知道socket只不过是一个数据结构。你使用这个socket数据结构去开始一个客户端和服务器之间的会话。这个服务器是一直在监听准备产生一个新的会话。当一个客户端连接服务器，它就打开服务器正在进行监听的一个端口进行会话。这时，服务器端接受客户端的连接请求，那么就进行一次循环。现在这个客户端就能够发送信息到服务器，服务器也能发送信息给客户端。
产生一个Socket，你需要三个变量：一个协议、一个socket类型和一个公共协议类型。产生一个socket有三种协议供选择，继续看下面的内容来获取详细的协议内容。
定义一个公共的协议类型是进行连接一个必不可少的元素。下面的表我们看看有那些公共的协议类型。
表一：协议
名字/常量 描述
AF_INET 这是大多数用来产生socket的协议，使用TCP或UDP来传输，用在IPv4的地址
AF_INET6 与上面类似，不过是来用在IPv6的地址
AF_UNIX 本地协议，使用在Unix和Linux系统上，它很少使用，一般都是当客户端和服务器在同一台及其上的时候使用
表二：Socket类型
名字/常量 描述
SOCK_STREAM 这个协议是按照顺序的、可靠的、数据完整的基于字节流的连接。这是一个使用最多的socket类型，这个socket是使用TCP来进行传输。
SOCK_DGRAM 这个协议是无连接的、固定长度的传输调用。该协议是不可靠的，使用UDP来进行它的连接。
SOCK_SEQPACKET 这个协议是双线路的、可靠的连接，发送固定长度的数据包进行传输。必须把这个包完整的接受才能进行读取。
SOCK_RAW 这个socket类型提供单一的网络访问，这个socket类型使用ICMP公共协议。（ping、traceroute使用该协议）
SOCK_RDM 这个类型是很少使用的，在大部分的操作系统上没有实现，它是提供给数据链路层使用，不保证数据包的顺序
表三：公共协议
名字/常量 描述
ICMP 互联网控制消息协议，主要使用在网关和主机上，用来检查网络状况和报告错误信息
UDP 用户数据报文协议，它是一个无连接，不可靠的传输协议
TCP 传输控制协议，这是一个使用最多的可靠的公共协议，它能保证数据包能够到达接受者那儿，如果在传输过程中发生错误，那么它将重新发送出错数据包。
现在你知道了产生一个socket的三个元素，那么我们就在php中使用socket_create()函数来产生一个socket。这个 socket_create()函数需要三个参数：一个协议、一个socket类型、一个公共协议。socket_create()函数运行成功返回一个包含socket的资源类型，如果没有成功则返回false。
Resourece socket_create(int protocol, int socketType, int commonProtocol);
现在你产生一个socket，然后呢？php提供了几个操纵socket的函数。你能够绑定socket到一个IP，监听一个socket的通信，接受一个socket；现在我们来看一个例子，了解函数是如何产生、接受和监听一个socket。
<?php
$commonProtocol = getprotobyname(“tcp”);
$socket = socket_create(AF_INET, SOCK_STREAM, $commonProtocol);
socket_bind($socket, ‘localhost’, 1337);
socket_listen($socket);
// More socket functionality to come
?>
上面这个例子产生一个你自己的服务器端。例子第一行，
$commonProtocol = getprotobyname(“tcp”);
使用公共协议名字来获取一个协议类型。在这里使用的是TCP公共协议，如果你想使用UDP或者ICMP协议，那么你应该把getprotobyname() 函数的参数改为“udp”或“icmp”。还有一个可选的办法是不使用getprotobyname()函数而是指定SOL_TCP或SOL_UDP在 socket_create()函数中。
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
例子的第二行是产生一个socket并且返回一个socket资源的实例。在你有了一个socket资源的实例以后，你就必须把socket绑定到一个IP地址和某一个端口上。
socket_bind($socket, ‘localhost’, 1337);
在这里你绑定socket到本地计算机（127.0.0.1）和绑定socket到你的1337端口。然后你就需要监听所有进来的socket连接。
socket_listen($socket);
在第四行以后，你就需要了解所有的socket函数和他们的使用。
表四：Socket函数
函数名 描述
socket_accept() 接受一个Socket连接
socket_bind() 把socket绑定在一个IP地址和端口上
socket_clear_error() 清除socket的错误或者最后的错误代码
socket_close() 关闭一个socket资源
socket_connect() 开始一个socket连接
socket_create_listen() 在指定端口打开一个socket监听
socket_create_pair() 产生一对没有区别的socket到一个数组里
socket_create() 产生一个socket，相当于产生一个socket的数据结构
socket_get_option() 获取socket选项
socket_getpeername() 获取远程类似主机的ip地址
socket_getsockname() 获取本地socket的ip地址
socket_iovec_add() 添加一个新的向量到一个分散/聚合的数组
socket_iovec_alloc() 这个函数创建一个能够发送接收读写的iovec数据结构
socket_iovec_delete() 删除一个已经分配的iovec
socket_iovec_fetch() 返回指定的iovec资源的数据
socket_iovec_free() 释放一个iovec资源
socket_iovec_set() 设置iovec的数据新值
socket_last_error() 获取当前socket的最后错误代码
socket_listen() 监听由指定socket的所有连接
socket_read() 读取指定长度的数据
socket_readv() 读取从分散/聚合数组过来的数据
socket_recv() 从socket里结束数据到缓存
socket_recvfrom() 接受数据从指定的socket，如果没有指定则默认当前socket
socket_recvmsg() 从iovec里接受消息
socket_select() 多路选择
socket_send() 这个函数发送数据到已连接的socket
socket_sendmsg() 发送消息到socket
socket_sendto() 发送消息到指定地址的socket
socket_set_block() 在socket里设置为块模式
socket_set_nonblock() socket里设置为非块模式
socket_set_option() 设置socket选项
socket_shutdown() 这个函数允许你关闭读、写、或者指定的socket
socket_strerror() 返回指定错误号的详细错误
socket_write() 写数据到socket缓存
socket_writev() 写数据到分散/聚合数组
(注: 函数介绍删减了部分原文内容，函数详细使用建议参考英文原文，或者参考PHP手册)
以上所有的函数都是PHP中关于socket的，使用这些函数，你必须把你的socket打开，如果你没有打开，请编辑你的php.ini文件，去掉下面这行前面的注释：
extension=php_sockets.dll
如果你无法去掉注释，那么请使用下面的代码来加载扩展库：
<?php
if(!extension_loaded(‘sockets’))
{
if(strtoupper(substr(PHP_OS, 3)) == “WIN”)
{
dl(‘php_sockets.dll’);
}
else
{
dl(‘sockets.so’);
}
}
?>
如果你不知道你的socket是否打开，那么你可以使用phpinfo()函数来确定socket是否打开。你通过查看phpinfo信息了解socket是否打开。如下图：
查看phpinfo()关于socket的信息
◆产生一个服务器
现在我们把第一个例子进行完善。你需要监听一个指定的socket并且处理用户的连接。
<?php
$commonProtocol = getprotobyname("tcp");
$socket = socket_create(AF_INET, SOCK_STREAM, $commonProtocol);
socket_bind($socket, 'localhost', 1337);
socket_listen($socket);
// Accept any incoming connections to the server
$connection = socket_accept($socket);
if($connection)
{
socket_write($connection, "You have connected to the socket.../n/r");
}
?>
你应该使用你的命令提示符来运行这个例子。理由是因为这里将产生一个服务器，而不是一个Web页面。如果你尝试使用Web浏览器来运行这个脚本，那么很有可能它会超过30秒的限时。你可以使用下面的代码来设置一个无限的运行时间，但是还是建议使用命令提示符来运行。
set_time_limit(0);
在你的命令提示符中对这个脚本进行简单测试：
Php.exe example01_server.php
如果你没有在系统的环境变量中设置php解释器的路径，那么你将需要给php.exe指定详细的路径。当你运行这个服务器端的时候，你能够通过远程登陆（telnet）的方式连接到端口1337来测试这个服务器。如下图：
上面的服务器端有三个问题：1. 它不能接受多个连接。2. 它只完成唯一的一个命令。3. 你不能通过Web浏览器连接这个服务器。
这个第一个问题比较容易解决，你可以使用一个应用程序去每次都连接到服务器。但是后面的问题是你需要使用一个Web页面去连接这个服务器，这个比较困难。你可以让你的服务器接受连接，然后些数据到客户端（如果它一定要写的话），关闭连接并且等待下一个连接。
在上一个代码的基础上再改进，产生下面的代码来做你的新服务器端：
<?php
// Set up our socket
$commonProtocol = getprotobyname("tcp");
$socket = socket_create(AF_INET, SOCK_STREAM, $commonProtocol);
socket_bind($socket, 'localhost', 1337);
socket_listen($socket);
// Initialize the buffer
$buffer = "NO DATA";
while(true)
{
// Accept any connections coming in on this socket
$connection = socket_accept($socket);
printf("Socket connected/r/n");
// Check to see if there is anything in the buffer
if($buffer != "")
{
printf("Something is in the buffer...sending data.../r/n");
socket_write($connection, $buffer . "/r/n");
printf("Wrote to socket/r/n");
}
else
{
printf("No Data in the buffer/r/n");
}
// Get the input
while($data = socket_read($connection, 1024, PHP_NORMAL_READ))
{
$buffer = $data;
socket_write($connection, "Information Received/r/n");
printf("Buffer: " . $buffer . "/r/n");
}
socket_close($connection);
printf("Closed the socket/r/n/r/n");
}
?>
这个服务器端要做什么呢？它初始化一个socket并且打开一个缓存收发数据。它等待连接，一旦产生一个连接，它将打印“Socket connected”在服务器端的屏幕上。这个服务器检查缓冲区，如果缓冲区里有数据，它将把数据发送到连接过来的计算机。然后它发送这个数据的接受信息，一旦它接受了信息，就把信息保存到数据里，并且让连接的计算机知道这些信息，最后关闭连接。当连接关闭后，服务器又开始处理下一次连接。(翻译的烂，附上原文)
This is what the server does. It initializes the socket and the buffer that you use to receive
and send data. Then it waits for a connection. Once a connection is created it prints
“Socket connected” to the screen the server is running on. The server then checks to see if
there is anything in the buffer; if there is, it sends the data to the connected computer.
After it sends the data it waits to receive information. Once it receives information it stores
it in the data, lets the connected computer know that it has received the information, and
then closes the connection. After the connection is closed, the server starts the whole
process again.
◆产生一个客户端
处理第二个问题是很容易的。你需要产生一个php页连接一个socket，发送一些数据进它的缓存并处理它。然后你又个处理后的数据在还顿，你能够发送你的数据到服务器。在另外一台客户端连接，它将处理那些数据。
To solve the second problem is very easy. You need to create a PHP page that connects to
a socket, receive any data that is in the buffer, and process it. After you have processed the
data in the buffer you can send your data to the server. When another client connects, it
will process the data you sent and the client will send more data back to the server.
下面的例子示范了使用socket：
<?php
// Create the socket and connect
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
$connection = socket_connect($socket,’localhost’, 1337);
while($buffer = socket_read($socket, 1024, PHP_NORMAL_READ))
{
if($buffer == “NO DATA”)
{
echo(“<p>NO DATA</p>”);
break;
}
else
{
// Do something with the data in the buffer
echo(“<p>Buffer Data: “ . $buffer . “</p>”);
}
}
echo(“<p>Writing to Socket</p>”);
// Write some test data to our socket
if(!socket_write($socket, “SOME DATA/r/n”))
{
echo(“<p>Write failed</p>”);
}
// Read any response from the socket
while($buffer = socket_read($socket, 1024, PHP_NORMAL_READ))
{
echo(“<p>Data sent was: SOME DATA<br> Response was:” . $buffer . “</p>”);
}
echo(“<p>Done Reading from Socket</p>”);
?>
这个例子的代码演示了客户端连接到服务器。客户端读取数据。如果这是第一时间到达这个循环的首次连接，这个服务器将发送“NO DATA”返回给客户端。如果情况发生了，这个客户端在连接之上。客户端发送它的数据到服务器，数据发送给服务器，客户端等待响应。一旦接受到响应，那么它将把响应写到屏幕上。
D. php涓轰粈涔堜笉阃傚悎socket
浣滀负涓钖嶉潪搴曞眰绋嫔簭锻桡纴瑕佹兂娣卞叆浜呜Вsocket镄勫唴閮ㄥ疄鐜版満鍒舵槸寰埚汹闅剧殑锛屾垜浠鍙闇鏄庣槠socket鏄涓濂楁搷浣灭郴缁熷皝瑁呭ソ镄勫疄鐜拌繘绋嬮氢俊镄勫嚱鏁帮纴浼氩垱寤哄拰璋幂敤灏卞熶简銆
PHP镄勮瑷鐗规у拰镊韬瀹氢綅鍐冲畾浜嗗畠鍙阃傚悎锅歴ocket瀹㈡埛绔锛岃屼笉阃傚悎锅歴ocket链嶅姟鍣ㄧ銆
锲犱负socket涓昏侀溃钖戝簳灞傚拰缃戠粶链嶅姟寮鍙戯纴涓鑸链嶅姟鍣ㄧ閮芥槸鐢 C 鎴 Java 绛夎瑷瀹炵幇锛岃繖镙疯兘镟村ソ鍦版搷浣滃簳灞傦纴瀵圭绣缁沧湇锷″紑鍙戜腑阆囧埌镄勯梾棰桡纸濡傚苟鍙戙侀樆濉炵瓑锛変篃链夋垚镡熷畬锽勭殑瑙ｅ喅鏂规堬纴钥孭HP鏄剧劧涓嶉傚悎杩欑嶅簲鐢ㄥ満鏅銆 锛堟帹钻愬︿範锛歅HP瑙嗛戞暀绋嬶级
瀹为檯涓婏纴PHP镎崭綔MySQL鏁版嵁搴扑篃鏄阃氲繃socket杩涜岀殑锛岃繖姝ｆ槸鐢变簬socket灞忚斀浜嗗簳灞傜殑鍗忚锛屼娇寰楃绣缁沧湇锷′箣闂寸殑浜掕仈浜挜氩彉寰楃亩鍗曘
闄や简浼犵粺镄勬湇锷″櫒绔璇瑷瀹炵幇镄剆ocket澶栵纴闅忕潃HTML5镄勬祦琛岋纴娴忚埚櫒瀹㈡埛绔瀹炵幇镄刉ebSocket涔熼愭笎鍏磋捣锛屽逛簬杩欎竴镣瑰煎缑鍏虫敞锛孎lashSocket涔熸槸涓涓涓嶉敊镄勮В鍐虫柟妗堛
瑕佸湪瀹㈡埛绔镎崭綔socket锛屽彲浣跨敤fsockopen銆乻ocket_create 鎴 stream_socket_client 绛夊嚱鏁板疄鐜帮纴濡傛灉鏄疨HP5锛屾帹钻愪娇鐢╯tream_socket_client銆
socket浜や簰搴旂敤瀹炰緥锛氢娇鐢╯ocket鎻愪氦琛ㄥ崟
鏂板缓涓涓 test.php 鏂囦欢锛屽悜 http://demo.com/index.php?id=1 鎻愪氦琛ㄥ崟鏁版嵁锛屼唬镰佸备笅锛
<?php
$data = array('comment'=>'this is a robot comment');
$data = http_build_query($data);
$out = "POST http://demo.com/index.php?id=1 HTTP/1.1
"; // 阃氲繃POST鏂瑰纺鍙戦佹暟鎹
$out .= "Host: demo.com
";
$out .= "Content-type: application/x-www-form-urlencoded; charset=UTF-8
";
$out .= "Content-length: ".strlen($data)."
";
$out .= "User-Agent: Mozilla/5.0 (Windows NT 6.1; rv:48.0) Gecko/20100101 Firefox/48.0"."
";
$out .= "Connection: close"."
"."
"; // 娉ㄦ剰锛氭ゅ勬湁涓や釜
$out .= $data."
"; // 姝ｆ枃鏁版嵁
$fp = fsockopen("demo.com", 80, $errno, $errstr, 30); // 鍒涘缓socket瀹㈡埛绔杩炴帴
// $fp = stream_socket_client("tcp://demo.com:80", $errno, $errstr, 30); 鎺ㄨ崘杩欑嶅啓娉
fwrite($fp, $out); // 钖戞湇锷″櫒鍙戦佹暟鎹
while (!feof($fp)) {
echo fgets($fp, 1280); // 璇诲彇链嶅姟鍣ㄥ搷搴旂殑鏁版嵁
}
fclose($fp); // 鍏抽棴socket杩炴帴
?>闇瑕佹敞镒忎互涓嫔嚑镣癸细
fsockopen镄勭涓涓鍙傛暟锛屼篃鍙浠ヤ娇鐢↖P鍦板潃锛屼笉瑕佸甫 http:// 瀛楃︿覆锛岄櫎闱炰娇鐢⊿SL绛
璇锋眰澶达纸headers锛変笉涓瀹氲佸甫涓婃墍链夌殑澶村烟锛屼竴鑸鍙闇甯︿笂鍑犱釜镙稿绩镄删eader鍗冲彲
鍦ㄦ渶钖庝竴涓猦eader澶勶纴鍗 Connection 钖庢湁涓や釜鎹㈣
娉ㄦ剰缂栫爜闂棰
E. PHPSocket缂栫▼杩囩▼
PHP锛孲ocket缂栫▼杩囩▼寰埚氢汉杩树笉鐭ラ亾锛岀幇鍦ㄨ╂垜浠涓璧锋潵鐪嬬湅钖э紒
PHP Socket缂栫▼杩囩▼
銆銆Socket鐢ㄤ簬杩涚▼闂撮氢俊锛岃繘绋嬮棿阃氢俊阃氩父锘轰簬瀹㈡埛绔钬旀湇锷＄妯″瀷銆傛ゆ椂锛屽㈡埛绔钬旀湇锷＄鏄鍙浠ュ郊姝や氦浜掔殑搴旂敤绋嫔簭銆傚㈡埛绔鍜屾湇锷＄涔嬮棿镄勪氦浜挜渶瑕佽繛鎺ャ係ocket缂栫▼璐熻矗镄勫氨鏄涓哄簲鐢ㄧ▼搴忎箣闂村缓绔嫔彲杩涜屼氦浜掔殑杩炴帴銆备笅闱涓哄ぇ瀹朵粙缁崭竴涓婸HP Socket缂栫▼杩囩▼!
銆銆浣跨敤浠ｇ爜
銆銆鐩镄'锛氩紑鍙戜竴涓瀹㈡埛绔鐢ㄤ簬鍙戦乻tring娑堟伅鍒版湇锷＄锛屾湇锷＄灏嗙浉钖岀殑淇℃伅鍙嶈浆钖庤繑锲炵粰瀹㈡埛绔銆
銆銆PHP链嶅姟鍣
銆銆绗1姝ワ细璁剧疆鍙橀噺锛屽傗滀富链衡濆拰钬灭鍙ｂ
銆銆$host = "127.0.0.1";$port = 5353;// No Timeout set_time_limit(0);
銆銆绔鍙ｅ彿鍙浠ユ槸1024 -65535涔嬮棿镄勪换浣曟ｆ暣鏁般
銆銆绗2姝ワ细鍒涘缓socket
銆銆$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socketn");
銆銆绗3姝ワ细缁戝畾socket鍒扮鍙ｅ拰涓绘満
銆銆鍒涘缓镄剆ocket璧勬簮缁戝畾鍒癐P鍦板潃鍜岀鍙ｅ彿銆
銆銆$result = socket_bind($socket, $host, $port) or die("Could not bind to socketn");
銆銆绗4姝ワ细钖锷╯ocket鐩戝惉
銆銆鍦ㄧ粦瀹氩埌IP鍜岀鍙ｅ悗锛屾湇锷＄寮濮嬬瓑寰呭㈡埛绔镄勮繛鎺ャ傚湪娌℃湁杩炴帴涔嫔墠瀹冨氨涓鐩寸瓑涓嫔幓銆
銆銆$result = socket_listen($socket, 3) or die("Could not set up socket listenern");
銆銆绗5姝ワ细鎺ュ弹杩炴帴
銆銆杩欎釜鍑芥暟浼氭帴鍙楁墍寤虹殑socket浼犲叆镄勮繛鎺ヨ锋眰銆傚湪鎺ュ弹𨱒ヨ嚜瀹㈡埛绔痵ocket镄勮繛鎺ュ悗锛岃ュ嚱鏁拌繑锲炲彟涓涓狲ocket璧勬簮锛屽疄闄呬笂灏辨槸璐熻矗涓庣浉搴旂殑瀹㈡埛绔痵ocket阃氢俊銆傝繖閲岀殑钬$spawn钬濆氨鏄璐熻矗涓庡㈡埛绔痵ocket阃氢俊镄剆ocket璧勬簮銆
銆銆$spawn = socket_accept($socket) or die("Could not accept incoming connectionn");
銆銆鍒扮幇鍦ㄤ负姝锛屾垜浠宸茬粡鍑嗗囧ソ浜嗘湇锷＄痵ocket 锛屼絾瀹为檯涓婅繖涓鑴氭湰骞舵病链夊仛浠讳綍浜嬫儏銆傛墍浠ヤ负浜嗙户缁瀹屾垚涓婅堪鐩镙囷纴鎴戜滑灏呜诲彇瀹㈡埛绔痵ocket娑堟伅锛岀劧钖庡皢鎺ユ敹鍒扮殑娑堟伅鍙嶈浆钖庡彂锲炵粰瀹㈡埛绔痵ocket銆
銆銆绗6姝ワ细浠庡㈡埛绔痵ocket璇诲彇娑堟伅
銆銆$input = socket_read($spawn, 1024) or die("Could not read inputn");
銆銆绗7姝ワ细鍙嶈浆娑堟伅
銆銆$output = strrev($input) . "n";
銆銆绗8姝ワ细鍙戦佹秷鎭缁椤㈡埛绔痵ocket
銆銆socket_write($spawn, $output, strlen ($output)) or die("Could not write outputn");
銆銆鍏抽棴socket
銆銆socket_close($spawn);socket_close($socket);
銆銆杩椤氨瀹屾垚浜嗘湇锷＄銆傜幇鍦锛屾垜浠瀛︿範濡备綍鍒涘缓PHP瀹㈡埛绔銆
銆銆PHP瀹㈡埛绔
銆銆鍓崭袱涓姝ラや笌链嶅姟绔鐩稿悓銆
銆銆绗1姝ワ细璁剧疆鍙橀噺锛屽傗滀富链衡濆拰钬灭鍙ｂ
銆銆$host = "127.0.0.1";$port = 5353;// No Timeout set_time_limit(0);
銆銆娉锛氲繖閲岀殑绔鍙ｅ拰涓绘満搴旇ュ拰链嶅姟绔涓镄勫畾涔夋槸鐩稿悓镄勚
銆銆绗2姝ワ细鍒涘缓socket
銆銆$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socketn");
銆銆绗3姝ワ细杩炴帴鍒版湇锷＄
銆銆$result = socket_connect($socket, $host, $port) or die("Could not connect toservern");
銆銆姝ゆ椂鍜屾湇锷＄涓嶅悓锛屽㈡埛绔痵ocket涓岖粦瀹氱鍙ｅ拰涓绘満銆傜浉鍙嶏纴瀹冭繛鎺ュ埌链嶅姟绔痵ocket锛岀瓑寰呮帴鍙楁潵镊瀹㈡埛绔痵ocket镄勮繛鎺ャ傝繖涓姝ュ缓绔嬩简瀹㈡埛绔痵ocket鍒版湇锷＄痵ocket镄勮繛鎺ャ
銆銆绗4姝ワ细鍐椤叆链嶅姟绔痵ocket
銆銆socket_write($socket, $message, strlen($message)) or die("Could not send data to servern");
銆銆鍦ㄦゆラや腑锛屽㈡埛绔痵ocket镄勬暟鎹琚鍙戦佸埌链嶅姟绔痵ocket銆
銆銆绗5姝ワ细阒呰绘潵镊链嶅姟绔镄勫搷搴
銆銆$result = socket_read ($socket, 1024) or die("Could not read server responsen");echo "Reply From Server :".$result;
銆銆绗6姝ワ细鍏抽棴socket
銆銆socket_close($socket);
銆銆瀹屾暣镄勪唬镰
銆銆链嶅姟绔(server.php)
銆銆// set some variables$host = "127.0.0.1";$port = 25003;// don't timeout!set_time_limit(0);// create socket$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socketn");// bind socket to port$result = socket_bind($socket, $host, $port) or die("Could not bind to socketn");// start listening for connections$result = socket_listen($socket, 3) or die("Could not set up socket listenern");// accept incoming connections// spawn another socket to handle communication$spawn = socket_accept($socket) or die("Could not accept incoming connectionn");// read client input$input = socket_read($spawn, 1024) or die("Could not read inputn");// clean up input string$input = trim($input);echo "Client Message : ".$input;// reverse client input and send back$output = strrev($input) . "n";socket_write($spawn, $output, strlen ($output)) or die("Could not write outputn");// close socketssocket_close($spawn);socket_close($socket);
銆銆瀹㈡埛绔(client.php)
銆銆$host = "127.0.0.1";$port = 25003;$message = "Hello Server";echo "Message To server :".$message;// create socket$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socketn");// connect to server$result = socket_connect($socket, $host, $port) or die("Could not connect to servern"); // send string to serversocket_write($socket, $message, strlen($message)) or die("Could not send data to servern");// get server response$result = socket_read ($socket, 1024) or die("Could not read server responsen");echo "Reply From Server :".$result;// close socketsocket_close($socket);
銆銆寤虹珛涓婅堪鏂囦欢(server.php鍜宑lient.php)钖庯纴镓ц屽备笅镎崭綔锛
銆銆澶嶅埗www鐩褰曚腑镄勮繖浜涙枃浠(锅囱网AMP)锛屽畨缃浜嶤:wamp銆
銆銆镓揿紑Web娴忚埚櫒锛屽湪鍦板潃镙忎腑阌鍏localhost 銆
銆銆鍏堟祻瑙坰erver.php铹跺悗client.php銆
F. php鍗虫椂阃氲鏄镐庝箞鎼寤虹殑锛熸湁娌℃湁鐭ラ亾镄勶纻
鍗虫椂阃氲镄勬牳蹇冨湪浜嶹ebSocket锛屽畠鏄瀹炵幇鍗虫椂阃氲镄勫父鐢ㄥ岗璁涔嬩竴锛屽师鐞嗘槸鍦ㄥ崟涓猅CP杩炴帴涓婃彁渚涘弻钖戦氢俊镄勫岗璁锛岄氩父琚鐢ㄤ簬瀹炴椂阃氢俊銆佹父鎴忋佸湪绾夸氦鏄撶瓑鍦烘櫙銆
浼犵粺镄刉eb搴旂敤绋嫔簭鏄锘轰簬HTTP鍗忚镄勶纴HTTP鏄涓绉嶆棤鐘舵佸岗璁锛屾疮娆¤锋眰閮介渶瑕侀吨鏂板缓绔嬭繛鎺ワ纴锲犳ら毦浠ュ疄鐜板疄镞堕氢俊銆傝学ebSocket鍗忚阃氲繃鍦ㄥ缓绔嬭繛鎺ュ悗淇濇寔闀胯繛鎺ワ纴鍏佽告湇锷″櫒涓诲姩钖戝㈡埛绔鍙戦佹暟鎹锛屼粠钥屽疄鐜板弻钖戦氢俊銆
WebSocket鍗忚鍏佽稿湪链嶅姟鍣ㄧ鍜屽㈡埛绔涔嬮棿鍙戦佷换镒忔暟鎹锛屽寘𨰾鏂囨湰銆佷簩杩涘埗鏁版嵁銆丣SON绛夋牸寮忕殑鏁版嵁銆傚㈡埛绔鍜屾湇锷″櫒绔閮藉彲浠ュ彂阃佹暟鎹锛岃屼笖涓嶉渶瑕侀氲繃HTTP镄勪腑闂村眰杩涜岃浆鎹锛屼粠钥屽噺灏戜简缃戠粶寤惰繜鍜屽甫瀹界殑娑堣椼
瑕佹惌寤篜HP鍗虫椂阃氲绯荤粺锛屽彲浠ラ伒寰浠ヤ笅姝ラわ细
阃夋嫨WebSocket链嶅姟鍣锛氲佸疄鐜板嵆镞堕氲锛岄渶瑕佷娇鐢╓ebSocket鍗忚锛屾墍浠ラ渶瑕侀夋嫨涓涓鏀鎸乄ebSocket镄勬湇锷″櫒锛屼緥濡侼ode.js銆丼ocket.io銆丷atchet绛夈
瀹夎呮湇锷″櫒锛氭牴鎹镓阃夋湇锷″櫒镄勫畼鏂规枃妗ｏ纴瀹夎匴ebSocket链嶅姟鍣ㄣ
缂栧啓瀹㈡埛绔椤甸溃锛氩湪PHP涓锛屽彲浠ヤ娇鐢╓ebSocket瀹㈡埛绔搴揿俣atchet鍜宲hpws绛夋潵鍒涘缓瀹㈡埛绔椤甸溃銆傚彲浠ュ弬钥冨畼鏂规枃妗ｅ拰绀轰緥浠ｇ爜銆
瀹炵幇链嶅姟绔阃昏緫锛氩疄鐜痒ebSocket链嶅姟鍣ㄧ镄勯昏緫锛屼緥濡傚勭悊瀹㈡埛绔鍙戦佺殑娑堟伅銆佸皢娑堟伅鍙戦佺粰鍏朵粬瀹㈡埛绔绛夈傚叿浣揿疄鐜板彲浠ユ牴鎹镓阃夋湇锷″櫒镄勬枃妗ｅ拰绀轰緥浠ｇ爜𨱒ヨ繘琛屻
闆嗘垚鍓岖鍜屽悗绔锛氩皢瀹㈡埛绔鍜屾湇锷＄阃昏緫闆嗘垚鍒板悓涓涓搴旂敤绋嫔簭涓锛屽彲浠ヤ娇鐢ㄦ嗘灦濡侺aravel鎴朤hinkPHP绛夛纴鎴栬呰嚜琛岀紪鍐欎唬镰併
浠ヤ笅鏄涓浜涘︿範PHP鍗虫椂阃氲镄勮祫鏂欙纴杩欎簺璧勬枡鍙浠ュ府锷╀綘鍏ラ棬锛
Ratchet瀹樻柟鏂囨。锛歊atchet鏄涓涓狿HP WebSocket搴掳纴鍙浠ョ敤𨱒ユ瀯寤哄嵆镞堕氲搴旂敤绋嫔簭銆傚畼鏂规枃妗ｆ彁渚涗简璇︾粏镄勪娇鐢ㄨ存槑鍜岀ず渚嬩唬镰併
PHP WebSockets锛氲繖鏄涓涓浣跨敤PHP缂栧啓镄刉ebSocket链嶅姟鍣ㄦ嗘灦锛屽畠镄勭洰镙囨槸鎻愪緵涓涓绠鍗旷殑鏂规硶𨱒ユ瀯寤哄疄镞跺簲鐢ㄧ▼搴忋傚畠鎻愪緵浜嗗畬鏁寸殑绀轰緥浠ｇ爜鍜屾枃妗ｃ
WebSocket PHP镵婂ぉ瀹ゆ暀绋嬶细杩欐槸涓涓璇︾粏镄勬暀绋嬶纴浠嬬粛浜嗗备綍浣跨敤PHP鍜学ebSocket𨱒ユ瀯寤轰竴涓绠鍗旷殑镵婂ぉ瀹ゅ簲鐢ㄧ▼搴忋傚畠鎻愪緵浜嗗畬鏁寸殑绀轰緥浠ｇ爜鍜屾紨绀恒
PHP镵婂ぉ搴旂敤绋嫔簭鏁欑▼锛氲繖鏄涓涓杈冧负鍏ㄩ溃镄勬暀绋嬶纴浠嬬粛浜嗗备綍浣跨敤PHP鍜孧ySQL𨱒ユ瀯寤轰竴涓瀹屾暣镄勮亰澶╁簲鐢ㄧ▼搴忥纴鍖呮嫭锏诲綍銆佹敞鍐屻佽亰澶╁ょ瓑锷熻兘銆傚畠鎻愪緵浜嗗畬鏁寸殑绀轰緥浠ｇ爜鍜屾紨绀恒
Real-time Apps with PHP锛氲繖鏄涓链浠嬬粛濡备綍浣跨敤PHP鏋勫缓瀹炴椂搴旂敤绋嫔簭镄勪功绫嶏纴娑电洊浜哤ebSocket銆丼ocket.io銆丯ode.js銆丷edis绛夋妧链銆傝槠铹惰繖链涔︾殑涓昏佽瑷鏄鑻辫锛屼絾瀹冩彁渚涗简澶ч噺镄勭ず渚嬩唬镰佸拰鏂囨。锛屽彲浠ュ府锷╀綘蹇阃熷叆闂ㄣ
浠ヤ笂杩欎簺璧勬枡鍙浠ュ府锷╀綘蹇阃熷叆闂≒HP鍗虫椂阃氲镄勫紑鍙戯纴寤鸿浣犲厛阃夋嫨涓绉嶈缉涓虹亩鍗旷殑瀹炵幇鏂规硶寮濮嫔︿範锛岄愭ユ帉鎻＄浉鍏虫妧链鍜屽紑鍙戠粡楠屻
G. php本地用虚拟机怎么模拟socket
利用socket发送HTTP请求。
Socket的英文原义是“孔”或“插座”。通常也称作“套接字”，用于描述IP地址和端口，是一个通信链的句柄，可以用来实现不同虚拟机或不同计算机之间的通信。在Internet上的主机一般运行了多个服务软件，同时提供几种服务。每种服务都打开一个Socket，并绑定到一个端口上，不同的端口对应于不同的服务。如此看来，其实利用socket操作远程文件和读写本地的文件一样容易，把本地文件看成通过硬件传输，远程文件通过网线传输就行了。
因而可以将发送请求的考虑成建立连接->打开socket接口(fsockopen())->写入请求（fwrite()）->读出响应（fread()->关闭文件（fclose()）。话不多说，直接上代码：
conn($url);
$this->setHeader('Host:'.$this->url['host']);
}
//此方法负责写请求行
protectedfunctionsetLine($method){
$this->line[0]=$method.''.$this->url['path'].'?'.$this->url['query'].''.历乎$this->version;
}
//此方法负责写头信息
publicfunctionsetHeader($headerline){
$this->header[]=$headerline;
}
//此方法负责写主体信息
protectedfunctionsetBody($body){
$this->body[]=http_build_query($body);
}
//连接url
publicfunctionconn($url){
$this->url=parse_url($url);
//判断端口
if(!isset($this->url['port'])){
$this->url['port']=80;
}
//判断query
if(!isset($this->url['query'])){
$this->url['query']='';
}
$this->fh=fsockopen($this->url['host'],$this->url['port'],$this->errno,$this->errstr,3);
}
//构造get请求的肢配悉数据
publicfunctionget(){
$this->setLine('GET');
$this->request();
return$this->response;
}
//构造post查询的数据
publicfunctionpost($body=array()){
$this->setLine('POST');
//设计content-type
$this->setHeader('Content-type:application/x-www-form-urlencoded');
//设计主体信息,比GET不一样的地方
$this->setBody($body);
//计算content-length
$this->setHeader('Content-length:'.strlen($this->body[0]));
$this->request();
return$this->response;
}
//真正请求
publicfunctionrequest(){
//把请求行，头信息，实体信息放在一个数组里，便于拼接
$req=array_merge($this->line,$this->header,array(''),$this->body,array(''));
//print_r($req);
$req=implode(self::CRLF,$req);
//echo$req;exit;
fwrite($this->fh,$req);
while(!feof($this->fh)){
$this->response.=fread($this->fh,1024);
}
$this->close();//关闭连接
}
//关闭连接
publicfunctionclose(){
卖缺fclose($this->fh);
}
}