摘要：理論主要介紹下實(shí)現(xiàn)一個(gè)網(wǎng)絡(luò)服務(wù)器的基本步驟，代碼會在實(shí)踐環(huán)節(jié)復(fù)現(xiàn)一次。第一步我們需要?jiǎng)?chuàng)建一個(gè)，綁定服務(wù)器端口，監(jiān)聽端口，在中用一個(gè)函數(shù)就能完成上面?zhèn)€步驟。此時(shí)程序會進(jìn)入睡眠狀態(tài)，直到有新的客戶端發(fā)起到服務(wù)器，操作系統(tǒng)會喚醒此進(jìn)程。

想要更好的理解，網(wǎng)絡(luò)編程，寫出一個(gè)高性能的服務(wù)，我們需要花點(diǎn)時(shí)間來理解下對于服務(wù)器處理客戶端的整個(gè)流程并且理解一些關(guān)鍵的術(shù)語,本來想在本文中補(bǔ)充一些基礎(chǔ)理論知識，擔(dān)心篇幅過長不利于閱讀，所以以后補(bǔ)發(fā)一些基礎(chǔ)知識，接下來進(jìn)入正題。

主要介紹下實(shí)現(xiàn)一個(gè)網(wǎng)絡(luò)服務(wù)器的基本步驟，代碼會在實(shí)踐環(huán)節(jié)復(fù)現(xiàn)一次。

我們需要?jiǎng)?chuàng)建一個(gè)socket，綁定服務(wù)器端口（bind），監(jiān)聽端口（listen），在PHP中用stream_socket_server一個(gè)函數(shù)就能完成上面3個(gè)步驟。

進(jìn)入while循環(huán)，阻塞在accept操作上，等待客戶端連接進(jìn)入。此時(shí)程序會進(jìn)入睡眠狀態(tài)，直到有新的客戶端發(fā)起connect到服務(wù)器，操作系統(tǒng)會喚醒此進(jìn)程。accept函數(shù)返回客戶端連接的socket

利用fread讀取客戶端socket當(dāng)中的數(shù)據(jù)收到數(shù)據(jù)后服務(wù)器程序進(jìn)行處理然后使用fwrite向客戶端發(fā)送響應(yīng)。長連接的服務(wù)會持續(xù)與客戶端交互，而短連接服務(wù)一般收到響應(yīng)就會close。

在這里我們用代碼來實(shí)現(xiàn)下基本一個(gè)流程，在開始寫代碼之前介紹介幾個(gè)php函數(shù)，是我們代碼中可能會用到的，方便大家理解。

stream_socket_server
stream_socket_accept
call_user_func
is_callable
fread

點(diǎn)擊函數(shù)了解用法

廢話少說直接開擼~

onConnect = function ($data) {
    echo "新的連接來了", $data, PHP_EOL;
};
//提前注冊了一個(gè)接收消息事件回調(diào)
$worker->onMessage = function ($conn, $message) {
};
$worker->run();

按照之前的流程我們需要監(jiān)聽端口+地址

public function __construct($socket_address) {
         //監(jiān)聽地址+端口
         $this->socket=stream_socket_server($socket_address);
     }

下一步就需要阻塞在accept操作，等待客戶端連接進(jìn)入。此時(shí)程序會進(jìn)入睡眠狀態(tài)，直到有新的客戶端發(fā)起connect到服務(wù)器，操作系統(tǒng)會喚醒此進(jìn)程

public function run(){
        while (true) { //循環(huán)監(jiān)聽
         $client = stream_socket_accept($this->socket);//在服務(wù)端阻塞監(jiān)聽
        }
     }

當(dāng)新的連接進(jìn)入喚醒進(jìn)程并且觸發(fā)連接事件回調(diào)

 public function run(){
        while (true) { //循環(huán)監(jiān)聽
         $client = stream_socket_accept($this->socket);//在服務(wù)端阻塞監(jiān)聽
         if(!empty($client) && is_callable($this->onConnect)){//socket連接成功并且是我們的回調(diào)
             //觸發(fā)事件的連接的回調(diào)
             call_user_func($this->onConnect,$client);
         }
        }
     }

這里的連接回調(diào)實(shí)際上觸發(fā)的就是之前準(zhǔn)備好類庫的這里下面這段代碼

$worker->onConnect = function ($data) {
    echo "連接事件：", $data, PHP_EOL;
};

當(dāng)連接成功后利用fread獲取到客戶端的內(nèi)容，并觸發(fā)接收消息事件

     public function run(){
      while (true) { //循環(huán)監(jiān)聽
         $client = stream_socket_accept($this->socket);//在服務(wù)端阻塞監(jiān)聽
         if(!empty($client) && is_callable($this->onConnect)){//socket連接成功并且是我們的回調(diào)
             //觸發(fā)事件的連接的回調(diào)
             call_user_func($this->onConnect,$client);
         }
         //從連接中讀取客戶端內(nèi)容
         $buffer=fread($client,65535);//參數(shù)2：在緩沖區(qū)當(dāng)中讀取的最大字節(jié)數(shù)
         //正常讀取到數(shù)據(jù)。觸發(fā)消息接收事件，進(jìn)行響應(yīng)
         if(!empty($buffer) && is_callable($this->onMessage)){
             //觸發(fā)時(shí)間的消息接收事件
             call_user_func($this->onMessage,$this,$client,$buffer);//傳遞到接收消息事件》當(dāng)前對象、當(dāng)前連接、接收到的消息
         }
       }
     }

到此處基本的一個(gè)網(wǎng)絡(luò)服務(wù)接收基本完成，還需要對請求做出一個(gè)響應(yīng)，以HTTP請求為例，這里封裝了一個(gè)http響應(yīng)的方法(http://127.0.0.1:9810)

 class Worker{
    ...
    ...
    ...
     public function  send($conn,$content){
         $http_resonse = "HTTP/1.1 200 OK
";
         $http_resonse .= "Content-Type: text/html;charset=UTF-8
";
         $http_resonse .= "Connection: keep-alive
";
         $http_resonse .= "Server: php socket server
";
         $http_resonse .= "Content-length: ".strlen($content)."

";
         $http_resonse .= $content;
         fwrite($conn, $http_resonse);
     }
 }

當(dāng)觸發(fā)接收消息事件時(shí)對http請求做出響應(yīng)

$worker->onMessage = function ($server,$conn, $message) {
    echo "來自客戶端消息:",$message,PHP_EOL;
    $server->send($conn,"來自服務(wù)端消息");
};

到這就結(jié)束了~，完整代碼直通車

一次只能處理一個(gè)連接，不支持多個(gè)連接同時(shí)處理