php socket多進程簡單服務器（一）

進程，線程  IO復用，協程都是處理完成並發的方式

socket分為  三步 服務器監聽，客戶端請求，連接確認，

每次連接都由當前進程來處理，可以通過IO復用來解決這個問題，

這次通過進程來完成並發請求，但是這種方式開銷大，消耗較多，頻繁的創建和銷毀也是耗時

線程並發  IO復用 等下次在貼代碼

進程並發代碼 服務端代碼

<?php
$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP) or die("error:".socket_strerror(socket_last_error()));
socket_bind($socket,"192.168.33.1","8000") or die("error:".socket_strerror(socket_last_error()));
socket_set_option($socket, SOL_SOCKET , SO_REUSEADDR , 1);#可以重復使用端口號
socket_listen($socket,5);
while(true){
    print("******等待新客戶端的到來*******\r\n");
    $clien = socket_accept($socket) or die("error:".socket_strerror(socket_last_error()));
    $pid = pcntl_fork();
    #posix_setsid();
    if ($pid == -1) {
        die('fork failed');
    } else if ($pid == 0) {
        hanld_seesion($clien);
    } else {
        #pcntl_wait($status);
    }
}

function hanld_seesion($clien){
    socket_getpeername($clien,$ip,$port);
    $id = posix_getpid();
    print("進程ID:$id == 客戶端:".$ip.":".$port."已連接\r\n");
    while(true){
        $data = socket_read($clien,1024);
        if(mb_strlen($data) == 0)
        {
            print("進程ID:$id == 客戶端:".$ip.":".$port."斷開連接\r\n");
            socket_close($clien);
            exit();
        }
        print($ip.":".$port.">>:".$data."\r\n");
    }
}

 

客戶端代碼

<?php
$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP) or die("error:".socket_strerror(socket_last_error()));
$msg = "Ping!";
$len = strlen($msg);
$server = socket_connect($socket,'192.168.33.1', 8000);
socket_write($socket, $msg);
sleep(30);
socket_close($socket);