這篇文章主要介紹了php使用websocket示例,需要的朋友可以參考下

下面我畫了一個(gè)圖演示 client 和 server 之間建立 websocket 連接時(shí)握手部分，這個(gè)部分在 node 中可以十分輕松的完成，因?yàn)?node 提供的 net 模塊已經(jīng)對(duì) socket 套接字做了封裝處理，開發(fā)者使用的時(shí)候只需要考慮數(shù)據(jù)的交互而不用處理連接的建立。而 php 沒有，從 socket 的連接、建立、綁定、監(jiān)聽等，這些都需要我們自己去操作，所以有必要拿出來再說一說。

① 和 ② 實(shí)際上就是一個(gè) HTTP 的請(qǐng)求和響應(yīng)，只不過我們?cè)谔幚淼倪^程中我們拿到的是沒有經(jīng)過解析的字符串。如：

復(fù)制代碼 代碼如下:

GET /chat HTTP/1.1
Host: server.example.com
Origin:

我們往?？吹降恼?qǐng)求是這個(gè)樣子，當(dāng)這東西到了服務(wù)器端，我們可以通過一些代碼庫(kù)直接拿到這些信息。

一、php 中處理 websocket

WebSocket 連接是由客戶端主動(dòng)發(fā)起的，所以一切要從客戶端出發(fā)。第一步是要解析拿到客戶端發(fā)過來的 Sec-WebSocket-Key 字符串。

復(fù)制代碼 代碼如下:

GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
Origin:
Sec-WebSocket-Protocol: chat, superchat
Sec-WebSocket-Version: 13

client 請(qǐng)求的格式

首先 php 建立一個(gè) socket 連接，監(jiān)聽端口的信息。

1. socket 連接的建立

關(guān)于 socket 套接字的建立，相信很多大學(xué)修過計(jì)算機(jī)網(wǎng)絡(luò)的人都知道了，下面是一張連接建立的過程：

復(fù)制代碼 代碼如下:

// 建立一個(gè) socket 套接字
$master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($master, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($master, $address, $port);
socket_listen($master);

相比 node，這個(gè)地方的處理實(shí)在是太麻煩了，上面幾行代碼并未建立連接，只不過這些代碼是建立一個(gè) socket 套接字必須要寫的東西。由于處理過程稍微有復(fù)雜，所以我把各種處理寫進(jìn)了一個(gè)類中，方便管理和調(diào)用。

復(fù)制代碼 代碼如下:

//demo.php
Class WS {
??? var $master;? // 連接 server 的 client
??? var $sockets = array(); // 不同狀態(tài)的 socket 管理
??? var $handshake = false; // 判斷是否握手

??? function __construct($address, $port){
??????? // 建立一個(gè) socket 套接字
??????? $this->master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)??
??????????? or die("socket_create() failed");
??????? socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)?
??????????? or die("socket_option() failed");
??????? socket_bind($this->master, $address, $port)???????????????????
??????????? or die("socket_bind() failed");
??????? socket_listen($this->master, 2)??????????????????????????????
??????????? or die("socket_listen() failed");

??????? $this->sockets[] = $this->master;

??????? // debug
??????? echo("Master socket? : ".$this->master."\n");

??????? while(true) {
??????????? //自動(dòng)選擇來消息的 socket 如果是握手 自動(dòng)選擇主機(jī)
??????????? $write = NULL;
??????????? $except = NULL;
??????????? socket_select($this->sockets, $write, $except, NULL);

??????????? foreach ($this->sockets as $socket) {
??????????????? //連接主機(jī)的 client
??????????????? if ($socket == $this->master){
??????????????????? $client = socket_accept($this->master);
??????????????????? if ($client < 0) {
// debug
echo "socket_accept() failed";
continue;
} else {
//connect($client);
array_push($this->sockets, $client);
??????????????????????? echo "connect client\n";
??????????????????? }
??????????????? } else {
??????????????????? $bytes = @socket_recv($socket,$buffer,2048,0);
??????????????????? if($bytes == 0) return;
??????????????????? if (!$this->handshake) {
??????????????????????? // 如果沒有握手，先握手回應(yīng)
??????????????????????? //doHandShake($socket, $buffer);
??????????????????????? echo "shakeHands\n";
??????????????????? } else {
??????????????????????? // 如果已經(jīng)握手，直接接受數(shù)據(jù)，并處理
??????????????????????? $buffer = decode($buffer);
??????????????????????? //process($socket, $buffer);
??????????????????????? echo "send file\n";
??????????????????? }
??????????????? }
??????????? }
??????? }
??? }
}

上面這段代碼是經(jīng)過我調(diào)試了的，沒太大的問題，如果想測(cè)試的話，可以在 cmd 命令行中鍵入 php /path/to/demo.php;當(dāng)然，上面只是一個(gè)類，如果要測(cè)試的話，還得新建一個(gè)實(shí)例。

復(fù)制代碼 代碼如下:

$ws = new WS('localhost', 4000);

客戶端代碼可以稍微簡(jiǎn)單點(diǎn)：

復(fù)制代碼 代碼如下: