学步园

set_time_limit
(
0
)
;


 
$host
 =
 "127.0.0.1"
;

$port
 =
 2046
;


 
$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
,
 "time"
)
 or die
(
"Write failed/n
"
)
;
 // 数据传送 向服务器发送消息


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

echo
(
"Data sent was: time/n
Response was:"
 .
 $buffer
 .
 "/n
"
)
;

}


 
socket_close
(
$socket
)
;

 
set_time_limit
(
0
)
;


 
$host
 =
 "127.0.0.1"
;

$port
 =
 2046
;


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


 
$result
 =
 socket_bind
(
$socket
,
 $host
,
 $port
)
 or die
(
"Could not bind tosocket/n
"
)
;
 //绑定Socket到端口


 
$result
 =
 socket_listen
(
$socket
,
 3
)
 or die
(
"Could not set up socket listener/n
"
)
;
 // 开始监听连接


 
$spawn
 =
 socket_accept
(
$socket
)
 or die
(
"Could not accept incoming connection/n
"
)
;
 // 处理通信


 
$input
 =
 socket_read
(
$spawn
,
 1024
)
 or die
(
"Could not read input/n
"
)
;
 // 数据传送 获得客户端的输入


 
$input
 =
 trim
(
$input
)
;

echo
 'input:'
,
 $input
,
 "/n
"
;


 
if
 (
$input
 ==
 'time'
)
 {

$output
 =
 date
(
"Y-m-d H:i:s"
)
.
 "/n
"
;
 //处理客户端输入并返回结果

}
else
{

$output
 =
 "input error /n
"
;
 //处理客户端输入并返回结果

}


 
echo
 "output:"
,
 $output
,
 "/n
"
;


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

socket_write
(
$spawn
,
 $output
,
 strlen
(
$output
)
)
 or die
(
"Could not write output/n
"
)
;
	

 
// 关闭sockets

socket_close
(
$spawn
)
;

socket_close
(
$socket
)
;

/* {{{ proto resource socket_create(int domain, int type, int protocol) U

   Creates an endpoint for communication in the domain specified by domain, of type specified by type */


PHP_FUNCTION(
socket_create)

{

long
            arg1,
 arg2,
 arg3;


        php_socket      *
php_sock =
 (
php_socket*
)
emalloc(
sizeof
(
php_socket)
)
;


 
if
 (
zend_parse_parameters(
ZEND_NUM_ARGS(
)
 TSRMLS_CC,
 "lll"
,
 &
arg1,
 &
arg2,
 &
arg3)
 ==
 FAILURE)
 {


                efree(
php_sock)
;

return
;

}


 
if
 (
arg1 !=
 AF_UNIX
#if HAVE_IPV6

&&
 arg1 !=
 AF_INET6
#endif

&&
 arg1 !=
 AF_INET)
 {


                php_error_docref(
NULL TSRMLS_CC,
 E_WARNING,
 "invalid socket domain [%ld] specified for argument 1, assuming AF_INET"
,
 arg1)
;


                arg1 =
 AF_INET;

}


 
if
 (
arg2 >
 10
)
 {


                php_error_docref(
NULL TSRMLS_CC,
 E_WARNING,
 "invalid socket type [%ld] specified for argument 2, assuming SOCK_STREAM"
,
 arg2)
;


                arg2 =
 SOCK_STREAM;

}


 

        php_sock->
bsd_socket =
 socket(
arg1,
 arg2,
 arg3)
;


        php_sock->
type =
 arg1;


 
if
 (
IS_INVALID_SOCKET(
php_sock)
)
 {


                SOCKETS_G(
last_error)
 =
 errno;


                php_error_docref(
NULL TSRMLS_CC,
 E_WARNING,
 "Unable to create socket [%d]: %s"
,
 errno,
 php_strerror(
errno TSRMLS_CC)
)
;


                efree(
php_sock)
;


                RETURN_FALSE;

}


 

        php_sock->
error =
 0
;


        php_sock->
blocking =
 1
;

1257
,
1
-
8
      61
%


        ZEND_REGISTER_RESOURCE(
return_value,
 php_sock,
 le_socket)
;

}

/* }}} */