《PHP實(shí)例:利用PHP如何實(shí)現(xiàn)Socket服務(wù)器》要點(diǎn):
本文介紹了PHP實(shí)例:利用PHP如何實(shí)現(xiàn)Socket服務(wù)器,希望對您有用。如果有疑問,可以聯(lián)系我們。
PHP編程socket服務(wù)器的工作方式是這樣的,不間斷地運(yùn)行以等待客戶端的連接.一旦客戶端連接上了,服務(wù)器就會將它添加到客戶名單中,然后開始等待來自客戶端的消息.
PHP編程
PHP編程不要走開,下面是完整的源代碼:
PHP編程
// Set time limit to indefinite execution
set_time_limit (0);
// Set the ip and port we will listen on
$address = 'localhost';
$port = 10000;
$max_clients = 10;
// Array that will hold client information
$client = Array();
// Create a TCP Stream socket
$sock = socket_create(AF_INET, SOCK_STREAM, 0);
// Bind the socket to an address/port
socket_bind($sock, $address, $port) or die('Could not bind to address');
// Start listening for connections
socket_listen($sock);
echo "Waiting for connections...\r\n";
// Loop continuously
while (true) {
// Setup clients listen socket for reading
$read[0] = $sock;
for ($i = 0; $i < $max_clients; $i++) {
if (isset($client[$i]['sock']))
$read[$i + 1] = $client[$i]['sock'];
}
// Set up a blocking call to socket_select()
if (socket_select($read, $write = NULL, $except = NULL, $tv_sec = 5) < 1)
continue;
/* if a new connection is being made add it to the client array */
if (in_array($sock, $read)) {
for ($i = 0; $i < $max_clients; $i++) {
if (empty($client[$i]['sock'])) {
$client[$i]['sock'] = socket_accept($sock);
echo "New client connected $i\r\n";
break;
}
elseif ($i == $max_clients - 1)
echo "Too many clients...\r\n";
}
} // end if in_array
// If a client is trying to write - handle it now
for ($i = 0; $i < $max_clients; $i++) { // for each client
if (isset($client[$i]['sock'])) {
if (in_array($client[$i]['sock'], $read)) {
$input = socket_read($client[$i]['sock'], 1024);
if ($input == null) {
echo "Client disconnecting $i\r\n";
// Zero length string meaning disconnected
unset($client[$i]);
} else {
echo "New input received $i\r\n";
// send it to the other clients
for ($j = 0; $j < $max_clients; $j++) {
if (isset($client[$j]['sock']) && $j != $i) {
echo "Writing '$input' to client $j\r\n";
socket_write($client[$j]['sock'], $input, strlen($input));
}
}
if ($input == 'exit') {
// requested disconnect
socket_close($client[$i]['sock']);
}
}
} else {
echo "Client disconnected $i\r\n";
// Close the socket
socket_close($client[$i]['sock']);
unset($client[$i]);
}
}
}
} // end while
// Close the master sockets
socket_close($sock);
PHP編程哎呀,乍一看這似乎是一個(gè)大工程,但是我們可以先將它分解為幾個(gè)較小的部分.
PHP編程第一部分是創(chuàng)建服務(wù)器.Lines:2至20.
PHP編程這部分代碼設(shè)置了變量、地址、端口、最大客戶端和客戶端數(shù)組.接下來創(chuàng)建socket并將其綁定到我們指定的地址和端口上.
PHP編程下面我們要做的事情就是執(zhí)行一個(gè)死循環(huán)(實(shí)際上我們是故意的!).Lines:22至32.
PHP編程在這部分代碼中我們做的第一步是設(shè)置 $read 數(shù)組.此數(shù) 組包括所有客戶端的套接字和我們主服務(wù)器的套接字.這個(gè)變量稍后會用于select語句:告訴PHP監(jiān)聽來自這些客戶端的每一條消息.
PHP編程socket_select()的最后一個(gè)參數(shù)告訴我們的服務(wù)器在返回值之前最多等待5秒鐘.如果它的返回值小于1,那么就表示沒有收到任何數(shù)據(jù),所以只需要返回循環(huán)頂部,繼續(xù)等待.
PHP編程腳本的下一個(gè)部分,是增加新的客戶端到數(shù)組中.Lines:33至44.
PHP編程將新的客戶端放置在列表的末尾.檢查以確保客戶端的數(shù)量沒有超過我們想要服務(wù)器處理的數(shù)量.
PHP編程下面要介紹的代碼塊相當(dāng)大,也是服務(wù)器的主要部分.當(dāng)客戶端將消息發(fā)送到服務(wù)器時(shí),就需要這塊代碼挺身而出來處理.消息可以是各種各樣的,斷開消息、實(shí)際斷開――只要是服務(wù)器需要處理的消息.Lines:46至末尾.
PHP編程代碼循環(huán)通過每個(gè)客戶端并檢查是否收到來自于它們的消息.如果是,獲取輸入的內(nèi)容.根據(jù)輸入來檢查這是否是一個(gè)斷開消息,如果是那就從數(shù)組中刪除它們,反之,那它就是一個(gè)正常的消息,那我們的服務(wù)器再次通過所有客戶端,并一個(gè)一個(gè)寫信息給他們,跳過發(fā)送者.
PHP編程好了,下面試試創(chuàng)造你本身的聊天服務(wù)器吧!
歡迎參與《PHP實(shí)例:利用PHP如何實(shí)現(xiàn)Socket服務(wù)器》討論,分享您的想法,維易PHP學(xué)院為您提供專業(yè)教程。
轉(zhuǎn)載請注明本頁網(wǎng)址:
http://www.snjht.com/jiaocheng/8713.html