socket_create_pair
(PHP 4 >= 4.1.0, PHP 5)
socket_create_pair — Creates a pair of indistinguishable sockets and stores them in an array
说明
$domain
, int $type
, int $protocol
, array &$fd
) socket_create_pair() creates two connected and
indistinguishable sockets, and stores them in fd.
This function is commonly used in IPC (InterProcess Communication).
参数
-
domain -
The
domainparameter specifies the protocol family to be used by the socket. See socket_create() for the full list. -
type -
The
typeparameter selects the type of communication to be used by the socket. See socket_create() for the full list. -
protocol -
The
protocolparameter sets the specific protocol within the specifieddomainto be used when communicating on the returned socket. The proper value can be retrieved by name by using getprotobyname() . If the desired protocol is TCP, or UDP the corresponding constantsSOL_TCP, andSOL_UDPcan also be used.See socket_create() for the full list of supported protocols.
-
fd -
Reference to an array in which the two socket resources will be inserted.
返回值
成功时返回 TRUE ， 或者在失败时返回 FALSE 。
更新日志
| 版本 | 说明 |
|---|---|
| 5.3.0 | This function is now re-enabled on Windows platforms. |
| 4.3.0 | This function was due to a bug made unavailable on Windows platforms. |
范例
Example #1 socket_create_pair() example
<?php
$sockets = array();
$domain = ( strtoupper ( substr ( PHP_OS , 0 , 3 )) == 'WIN' ? AF_INET : AF_UNIX );
if ( socket_create_pair ( $domain , SOCK_STREAM , 0 , $sockets ) === false ) {
echo "socket_create_pair failed. Reason: " . socket_strerror ( socket_last_error ());
}
if ( socket_write ( $sockets [ 0 ], "ABCdef123\n" , strlen ( "ABCdef123\n" )) === false ) {
echo "socket_write() failed. Reason: " . socket_strerror ( socket_last_error ( $sockets [ 0 ]));
}
if (( $data = socket_read ( $sockets [ 1 ], strlen ( "ABCdef123\n" ), PHP_BINARY_READ )) === false ) {
echo "socket_read() failed. Reason: " . socket_strerror ( socket_last_error ( $sockets [ 1 ]));
}
var_dump ( $data );
socket_close ( $sockets [ 0 ]);
socket_close ( $sockets [ 1 ]);
?>
Example #2 socket_create_pair() IPC example
<?php
$ary = array();
$strone = 'Message From Parent.' ;
$strtwo = 'Message From Child.' ;
if ( socket_create_pair ( AF_UNIX , SOCK_STREAM , 0 , $ary ) === false ) {
echo "socket_create_pair() failed. Reason: " . socket_strerror ( socket_last_error ());
}
$pid = pcntl_fork ();
if ( $pid == - 1 ) {
echo 'Could not fork Process.' ;
} elseif ( $pid ) {
socket_close ( $ary [ 0 ]);
if ( socket_write ( $ary [ 1 ], $strone , strlen ( $strone )) === false ) {
echo "socket_write() failed. Reason: " . socket_strerror ( socket_last_error ( $ary [ 1 ]));
}
if ( socket_read ( $ary [ 1 ], strlen ( $strtwo ), PHP_BINARY_READ ) == $strtwo ) {
echo "Recieved $strtwo \n" ;
}
socket_close ( $ary [ 1 ]);
} else {
socket_close ( $ary [ 1 ]);
if ( socket_write ( $ary [ 0 ], $strtwo , strlen ( $strtwo )) === false ) {
echo "socket_write() failed. Reason: " . socket_strerror ( socket_last_error ( $ary [ 0 ]));
}
if ( socket_read ( $ary [ 0 ], strlen ( $strone ), PHP_BINARY_READ ) == $strone ) {
echo "Recieved $strone \n" ;
}
socket_close ( $ary [ 0 ]);
}
?> 参见
- socket_create() - 创建一个套接字（通讯节点）
- socket_create_listen() - Opens a socket on port to accept connections
- socket_bind() - 给套接字绑定名字
- socket_listen() - Listens for a connection on a socket
- socket_last_error() - Returns the last error on the socket
- socket_strerror() - Return a string describing a socket error
用户评论:
[#1] cweiske at php dot net [2009-05-09 13:45:43]
The underlying sockpair() function does only support AF_UNIX at least on BSD and Linux.
[#2] thegreatall at gmail dot com [2007-07-13 11:24:20]
There is a syntax error in one of the code samples provided, it should look like this:
<?php
$sockets = array();
if (socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $sockets) === false) {
echo "socket_create_pair failed. Reason: ".socket_strerror(socket_last_error());
}
if (socket_write($sockets[0], "ABCdef123\n", strlen("ABCdef123\n")) === false) {
echo "socket_write() failed. Reason: ".socket_strerror(socket_last_error($sockets[0]));
}
if (($data = socket_read($sockets[1], strlen("ABCdef123\n"), PHP_BINARY_READ)) === false) {
echo "socket_read() failed. Reason: ".socket_strerror(socket_last_error($sockets[1]));
}
var_dump($data);
socket_close($sockets[0]);
socket_close($sockets[1]);
?>