phpSocket 程式設計的過程
導語:Socket用於程序間通訊。程序間通訊通常基於客戶端—服務端模型。此時,客戶端—服務端是可以彼此互動的應用程式。客戶端和服務端之間的互動需要連線。Socket程式設計負責的就是為應用程式之間建立可進行互動的連線。下面是phpSocket 程式設計的過程,一起來學習下吧:
使用程式碼
目的:開發一個客戶端用於傳送string訊息到服務端,服務端將相同的資訊反轉後返回給客戶端。
PHP伺服器
第1步:設定變數,如“主機”和“埠”
$host = "";$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到埠和主機
建立的socket資源繫結到IP地址和埠號。
$result = socket_bind($socket, $host, $port) or die("Could not bind to socketn");
第4步:啟動socket監聽
在繫結到IP和埠後,服務端開始等待客戶端的連線。在沒有連線之前它就一直等下去。
$result = socket_listen($socket, 3) or die("Could not set up socket listenern");
第5步:接受連線
這個函式會接受所建的socket傳入的連線請求。在接受來自客戶端socket的連線後,該函式返回另一個socket資源,實際上就是負責與相應的客戶端socket通訊。這裡的“$spawn”就是負責與客戶端socket通訊的socket資源。
$spawn = socket_accept($socket) or die("Could not accept incoming connectionn");
到現在為止,我們已經準備好了服務端socket ,但實際上這個指令碼並沒有做任何事情。所以為了繼續完成上述目標,我們將讀取客戶端socket訊息,然後將接收到的`訊息反轉後發回給客戶端socket。
第6步:從客戶端socket讀取消息
$input = socket_read($spawn, 1024) or die("Could not read inputn");
第7步:反轉訊息
$output = strrev($input) . "n";
第8步:傳送訊息給客戶端socket
socket_write($spawn, $output, strlen ($output)) or die("Could not write outputn");
關閉socket
socket_close($spawn);socket_close($socket);
這就完成了服務端。現在,我們學習如何建立PHP客戶端。
PHP客戶端
前兩個步驟與服務端相同。
第1步:設定變數,如“主機”和“埠”
$host = "";$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");
此時和服務端不同,客戶端socket不繫結埠和主機。相反,它連線到服務端socket,等待接受來自客戶端socket的連線。這一步建立了客戶端socket到服務端socket的連線。
第4步:寫入服務端socket
socket_write($socket, $message, strlen($message)) or die("Could not send data to servern");
在此步驟中,客戶端socket的資料被髮送到服務端socket。
第5步:閱讀來自服務端的響應
$result = socket_read ($socket, 1024) or die("Could not read server responsen");echo "Reply From Server :".$result;
第6步:關閉socket
socket_close($socket);
完整的程式碼
服務端()
// set some variables$host = "";$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);
客戶端()
$host = "";$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);
建立上述檔案(和)後,執行如下操作:
複製www目錄中的這些檔案(假設WAMP),安置於C:wamp。
開啟Web瀏覽器,在位址列中鍵入localhost 。
先瀏覽然後。