So erstellen Sie einen einfachen Chatroom mit PHP-Websocket

Socket ist die mittlere Software-Abstraktionsschicht, die zwischen der Anwendungsschicht und der TCP/IP-Protokollsuite kommuniziert. Es handelt sich um eine Reihe von Schnittstellen. Im Entwurfsmodus ist Socket eigentlich ein Fassadenmodus, der die komplexe TCP/IP-Protokollfamilie hinter der Socket-Schnittstelle verbirgt. Für Benutzer ist alles eine Reihe einfacher Schnittstellen, die es Socket ermöglichen, Daten so zu organisieren, dass sie dem angegebenen Protokoll entsprechen. Im vorherigen Kapitel haben wir über den Unterschied zwischen Socket und http gesprochen. Um Socket zu verstehen, müssen Sie zunächst den Unterschied zwischen http und TCP verstehen. Einfach ausgedrückt: Das eine ist eine kurze Kette, das andere ist eine lange Die andere besteht darin, Daten vom Server abzurufen. Die eine besteht darin, dass der Server Daten aktiv pushen kann. HTTP-Verbindungen werden in kurze und lange Verbindungen unterteilt. Kurze Verbindungen können im Allgemeinen mit Ajax implementiert werden, lange Verbindungen sind Websockets. Kurze Verbindungen sind relativ einfach zu implementieren, verbrauchen jedoch zu viele Ressourcen. Websocket ist effizient, weist jedoch einige Kompatibilitätsprobleme auf. Websocket ist eine Ressource von HTML5.

Einführung in den Prozess der Erstellung eines einfachen Chatrooms mit PHP-Websocket

PHP-Chatrooms wurden heute über Ajax und PHP implementiert Wir werfen einen Blick auf ein praktisches Beispiel der WebSocket-Technologie in einem PHP-Chatroom.

1. Der Front-End-Client

Wie funktioniert die Front-End-Datei? Informationen an den Back-End-Server senden? Spätere Untersuchungen ergaben, dass es sich um die Verwendung der js WebSocket-Technologie handelt. Die folgenden allgemeinen Vorgänge von js WebSocket lauten wie folgt:

Erläuterung: Die erste Zeile sendet eine Handshake-Anfrage an den angegebenen Server. Wenn der Server einen gültigen HTTP-Header zurückgibt, ist der Handshake erfolgreich und die vom Server gesendete Nachricht kann durch Abhören des Onmessage-Ereignisses verarbeitet werden. Es gibt viele andere Ereignisse, die überwacht werden können, siehe vorherige URL.

var socket = new WebSocket('ws://localhost:8080');     
    // 打开Socket     
    socket.onopen = function(event) {     
    }    
    // 发送一个初始化消息    
     socket.send('I am the client and I\'m listening!');     
    // 监听消息    
     socket.onmessage = function(event) {     
        console.log('Client received a message',event);     
      };  //phpfensi.com    
    // 监听Socket的关闭    
      socket.onclose = function(event) {     
        console.log('Client notified socket has closed',event);     
      };     
      // 关闭Socket....     
    socket.close()     
   socket.onerror = function(evt){console.log(“WebSocketError!”);};

2. Der Hintergrundserver

Der vom Server durchgeführte Prozess ist ungefähr:

A

b. Nachdem eine Socket-Verbindung besteht, durchlaufen Sie das Socket-Array.

c. Wenn kein Handshake erfolgt, führen Sie einen Handshake-Vorgang durch und analysieren Sie ihn Schreiben Sie es in den Puffer für die Ausgabe

Der Beispielcode lautet wie folgt:

Erklärung: Es gibt mehrere wichtige Punkte: Der eine besteht darin, den Prozess anzuhalten, andernfalls Der Prozess wird nach einmaliger Ausführung beendet. Die zweite Möglichkeit ist die Verwendung der Funktionen socket_select und socket_accept. Der dritte ist der Handshake, wenn der Client die erste Anfrage stellt.

public function start_server(){
  $this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  //允许使用本地地址
  socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, TRUE);
  socket_bind($this->socket, $this->host, $this->port);
  //最多10个人连接，超过的客户端连接会返回WSAECONNREFUSED错误
  socket_listen($this->socket, $this->maxuser);
  while(TRUE) {
    $this->cycle = $this->accept;
    $this->cycle[] = $this->socket;
    //阻塞用，有新连接时才会结束
    socket_select($this->cycle, $write, $except, null);
    foreach ($this->cycle as $k => $v) {
      if($v === $this->socket) {
        if (($accept = socket_accept($v)) < 0) {
          continue;
        }
        //如果请求来自监听端口那个套接字，则创建一个新的套接字用于通信
        $this->add_accept($accept);
        continue;
      }
      $index = array_search($v, $this->accept);
      if ($index === NULL) {
        continue;
      }
      //没消息的socket就跳过
      if (!@socket_recv($v, $data, 1024, 0) || !$data) {
        $this->close($v);
        continue;
      }
      if (!$this->isHand[$index]) {
        $this->upgrade($v, $data, $index);
        if(!empty($this->function[&#39;add&#39;])) {
          call_user_func_array($this->function[&#39;add&#39;], array($this));
        }
        continue;
      }
      $data = $this->decode($data);
      if(!empty($this->function[&#39;send&#39;])) {
        call_user_func_array($this->function[&#39;send&#39;], array($data, $index, $this));
      }
    }
    sleep(1);
  }
}
//增加一个初次连接的用户
public function add_accept($accept){
  $this->accept[] = $accept;
  $index = array_keys($this->accept);
  $index = end($index);
  $this->isHand[$index] = FALSE;
}
//关闭一个连接
public function close($accept) {
  $index = array_search($accept, $this->accept);
  socket_close($accept);
  unset($this->accept[$index]);
  unset($this->isHand[$index]);
  if(!empty($this->function[&#39;close&#39;])) {
    call_user_func_array($this->function[&#39;close&#39;], array($this));
  }
}
//响应升级协议
public function upgrade($accept, $data, $index) {
  if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$data,$match)) {
    $key = base64_encode(sha1($match[1] . &#39;258EAFA5-E914-47DA-95CA-C5AB0DC85B11&#39;, true));
    $upgrade  = "HTTP/1.1 101 Switching Protocol\r\n" .
      "Upgrade: websocket\r\n" .
      "Connection: Upgrade\r\n" .
      "Sec-WebSocket-Accept: " . $key . "\r\n\r\n";  //必须以两个回车结尾
    socket_write($accept, $upgrade, strlen($upgrade));
    $this->isHand[$index] = TRUE;
  }
}

Der folgende Prozess ist sehr klar. Wenn eine neue Client-Anfrage eintrifft, verwenden Sie socket_accept, um eine Ressource zu erstellen und sie dem Verbindungspool $this->accept hinzuzufügen. Und setzen Sie die Bezeichnung „isHand“ auf „false“. Führen Sie dann beim nächsten Zyklus einen Upgrade-Handshake durch (da $this->cycle[] = $this->socket;$this->cycle sich geändert hat, sodass socket_select zurückkehrt). Dann warten Sie einfach auf die neuen Nachrichten.

【Empfohlene verwandte Tutorials】

1. "

php.cn Dugu Jiujian (4) - PHP-Video-Tutorial

2 Reihe von Tutorials zur PHP-Programmierung vom Einstieg bis zur Beherrschung

Das obige ist der detaillierte Inhalt vonSo erstellen Sie einen einfachen Chatroom mit PHP-Websocket. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!