PHP編程實現(xiàn)的TCP服務(wù)端和客戶端功能示例

2024-05-04 21:50:02

字體：大中小

供稿：網(wǎng)友

本文實例講述了PHP編程實現(xiàn)的TCP服務(wù)端和客戶端功能。分享給大家供大家參考，具體如下：

1、修改php.ini，打開extension=php_sockets.dll

2、服務(wù)端程序SocketServer.php

<?php

//確保在連接客戶端時不會超時

set_time_limit(0);

//設(shè)置IP和端口號

$address = "127.0.0.1";

$port = 3046;

/**

* 創(chuàng)建一個SOCKET

* AF_INET=是ipv4 如果用ipv6，則參數(shù)為 AF_INET6

* SOCK_STREAM為socket的tcp類型，如果是UDP則使用SOCK_DGRAM

*/

$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() fail:" . socket_strerror(socket_last_error()) . "/n");

//阻塞模式

socket_set_block($sock) or die("socket_set_block() fail:" . socket_strerror(socket_last_error()) . "/n");

//綁定到socket端口

$result = socket_bind($sock, $address, $port) or die("socket_bind() fail:" . socket_strerror(socket_last_error()) . "/n");

//開始監(jiān)聽

$result = socket_listen($sock, 4) or die("socket_listen() fail:" . socket_strerror(socket_last_error()) . "/n");

echo "OK/nBinding the socket on $address:$port ... ";

echo "OK/nNow ready to accept connections./nListening on the socket ... /n";

do { // never stop the daemon

  //它接收連接請求并調(diào)用一個子連接Socket來處理客戶端和服務(wù)器間的信息

  $msgsock = socket_accept($sock) or die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n");

  while(1){

    //讀取客戶端數(shù)據(jù)

    echo "Read client data /n";

    //socket_read函數(shù)會一直讀取客戶端數(shù)據(jù),直到遇見/n,/t或者/0字符.PHP腳本把這寫字符看做是輸入的結(jié)束符.

    $buf = socket_read($msgsock, 8192);

    echo "Received msg: $buf  /n";

    if($buf == "bye"){

      //接收到結(jié)束消息，關(guān)閉連接，等待下一個連接

      socket_close($msgsock);

      continue;

    } //Vevb.com

    //數(shù)據(jù)傳送向客戶端寫入返回結(jié)果

    $msg = "welcome /n";

    socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n");

  }

} while (true);

socket_close($sock);

?>

3、客戶端程序SocketClient.php

<?php

set_time_limit(0);

$host = "127.0.0.1";

$port = 3046;

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create socket/n");

$connection = socket_connect($socket, $host, $port) or die("Could not connet server/n");

socket_write($socket, "hello socket") or die("Write failed/n");

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

  echo("Response was:" . $buff . "/n");

  echo("input what you want to say to the server:/n");

  $text = fgets(STDIN);

  socket_write($socket, $text);

}

socket_close($socket);

?>