PHP websocket을 사용하여 간단한 채팅방을 만드는 방법

소켓은 애플리케이션 계층과 TCP/IP 프로토콜 제품군 간에 통신하는 중간 소프트웨어 추상화 계층입니다. 디자인 모드에서 소켓은 실제로 소켓 인터페이스 뒤에 복잡한 TCP/IP 프로토콜 제품군을 숨기는 파사드 모드입니다. 사용자에게는 소켓이 지정된 프로토콜을 준수하도록 데이터를 구성할 수 있는 간단한 인터페이스 세트가 전부입니다. 이전 장에서는 소켓과 http의 차이점에 대해 이야기했습니다. 소켓을 이해하려면 먼저 http와 tcp의 차이점을 이해해야 합니다. 간단히 말해서 하나는 짧은 체인이고 다른 하나는 긴 체인입니다. 체인이고 다른 하나는 서버에서 데이터를 가져오는 것입니다. 하나는 서버가 적극적으로 데이터를 푸시할 수 있다는 것입니다. HTTP 연결은 짧은 연결과 긴 연결로 구분됩니다. 짧은 연결은 일반적으로 ajax를 사용하여 구현할 수 있으며 긴 연결은 웹소켓입니다. 짧은 연결은 비교적 구현이 간단하지만 너무 많은 리소스를 소비합니다. Websocket은 효율적이지만 호환성에 몇 가지 문제가 있습니다. Websocket은 html5의 리소스입니다.

PHP 웹소켓으로 간단한 채팅방을 만드는 과정을 소개합니다

현재 PHP 채팅방은 ajax와 PHP를 통해 구현되었습니다. PHP 채팅방에서 WebSocket 기술의 실제 사례를 살펴보겠습니다.

1. 프론트엔드 클라이언트

프론트엔드 파일은 어떻게 작동합니까? 나중에 연구에 따르면 js WebSocket 기술을 사용하면 다음과 같은 일반적인 js WebSocket 작업이 가능합니다.

코드는 다음과 같습니다.

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!”);};

설명: 첫 번째 줄은 지정된 서버에 핸드셰이크 요청을 보냅니다. 서버가 올바른 http 헤더를 반환하면 핸드셰이크가 성공한 것이며, 서버에서 보낸 메시지는 onmessage 이벤트를 수신하여 처리될 수 있습니다. 모니터링할 수 있는 다른 이벤트도 많이 있습니다. 이전 URL을 참조하세요.

2. 백그라운드 서버

서버에서 수행하는 프로세스는 대략 다음과 같습니다.

a 소켓 프로세스를 일시 중지합니다.

b.소켓 연결이 이루어진 후 소켓 배열을 순회

c.핸드셰이크가 없으면 데이터를 받아 구문 분석합니다. 출력용 버퍼에 기록합니다

샘플 코드는 다음과 같습니다.

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;
  }
}

설명: 몇 가지 핵심 사항이 있습니다. 하나는 while(true)이 프로세스를 일시 중지한다는 것입니다. 그렇지 않으면 프로세스가 중단됩니다. 한번 실행 후 종료합니다. 두 번째는 소켓_select 및 소켓_accept 함수를 사용하는 것입니다. 세 번째는 클라이언트가 첫 번째 요청을 할 때의 핸드셰이크입니다.

다음 프로세스는 매우 명확합니다. 새 클라이언트 요청이 도착하면 소켓_accept를 사용하여 리소스를 생성하고 이를 $this->accept 연결 풀에 추가합니다. 그리고 레이블 isHand를 false로 설정한 다음 다음에 순환할 때($this->cycle[] = $this->socket;$this->cycle이 변경되었으므로 소켓_select가 반환되므로) 업그레이드 핸드셰이크를 수행합니다. 그런 다음 새 메시지를 기다리세요.

【관련 튜토리얼 추천】

1. "php.cn Dugu Jiujian (4) - PHP 비디오 튜토리얼 "

2. PHP 프로그래밍 입문부터 숙달까지 튜토리얼 세트

위 내용은 PHP websocket을 사용하여 간단한 채팅방을 만드는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!