PHP 소켓 통신 내용

이 글은 주로 PHP의 소켓 통신에 대해 소개하고 있는데, 이제 도움이 필요한 친구들이 참고할 수 있도록 공유하겠습니다.

TCP/IP와 UDP는 무엇인가요?

TCP/IP(전송 제어 프로토콜/인터넷 프로토콜)는 WAN(광역 네트워크)용으로 설계된 산업 표준 프로토콜 세트입니다.
UDP(User Data Protocol)는 TCP에 해당하는 프로토콜입니다. 이는 TCP/IP 프로토콜 제품군의 구성원입니다.
다음은 이러한 프로토콜 간의 관계를 보여주는 다이어그램입니다.

TCP/IP 프로토콜 제품군에는 전송 계층, 네트워크 계층 및 링크 계층이 포함됩니다. 이제 TCP/IP와 UDP의 관계를 알았습니다.
소켓은 어디에 있나요?
그림 1에서는 소켓의 그림자가 보이지 않는데 소켓은 어디에 있나요? 사진이 스스로 말하도록 합시다.

소켓이란 무엇인가요?

Socket은 애플리케이션 계층과 TCP/IP 프로토콜 제품군 간의 통신을 위한 중간 소프트웨어 추상화 계층입니다. 디자인 모드에서 소켓은 실제로 소켓 인터페이스 뒤에 복잡한 TCP/IP 프로토콜 제품군을 숨기는 파사드 모드입니다. 사용자에게는 소켓이 지정된 요구 사항을 충족하도록 데이터를 구성할 수 있는 간단한 인터페이스 집합이 있습니다.
작동 방식

서버 측부터 시작해 보겠습니다. 서버는 먼저 소켓을 초기화한 다음 포트에 바인드하고 포트를 수신하며 차단을 위해 승인을 호출하고 클라이언트가 연결될 때까지 기다립니다. 이때 클라이언트가 Socket을 초기화한 후 서버에 연결(connect)하면, 연결에 성공하면 클라이언트와 서버 간의 연결이 성립된다. 클라이언트는 데이터 요청을 보내고, 서버는 요청을 받아 처리한 후, 응답 데이터를 클라이언트에 보내고, 클라이언트는 데이터를 읽고, 마지막으로 연결을 닫고 상호작용이 종료됩니다.

소켓 관련 함수:

socket_accept()는 소켓 연결을 허용합니다.
socket_bind()는 소켓을 IP 주소 및 포트에 바인딩합니다.
socket_clear_error()는 소켓 오류 또는 마지막 오류 코드를 지웁니다.
socket_close()는 소켓 리소스를 닫습니다
소켓 연결 시작
socket_create_listen() 지정된 포트에서 수신 대기하는 소켓 열기
socket_create_pair() 미분화된 소켓 쌍을 배열로 생성
socket_create() 소켓 생성, 이는 소켓 생성과 동일 데이터 구조
소켓_get_option() 소켓 옵션 가져오기
socket_getpeername() 원격 유사한 호스트의 IP 주소 가져오기
socket_getsockname() 로컬 소켓의 IP 주소 가져오기
socket_iovec_add() 분산/집계 배열에 새 벡터 추가
socket_iovec_alloc() 이 함수는 전송, 수신, 읽기 및 쓰기가 가능한 iovec 데이터 구조를 생성합니다.
socket_iovec_fetch()는 지정된 iovec 리소스의 데이터를 반환합니다.
socket_iovec_set. ()는 iovec 데이터를 설정합니다.
socket_last_error() 현재 소켓의 마지막 오류 코드를 가져옵니다.
socket_listen() 지정된 소켓의 모든 연결을 수신합니다.
socket_read() 지정된 길이의 데이터를 읽습니다.
socket_readv() 읽기 분산/집계 배열의 데이터
socket_recv() 소켓에서 캐시로 데이터 종료
socket_recvfrom() 지정된 소켓의 데이터 수락, 지정하지 않으면 현재 소켓이 기본값으로 설정됨
socket_recvmsg() iovec에서 메시지 수신
socket_select() 다중 선택
socket_send() 이 함수는 연결된 소켓으로 데이터를 보냅니다
socket_sendmsg() 소켓으로 메시지 보내기
socket_sendto() 지정된 주소의 소켓으로 메시지 보내기
socket_set_block() 소켓을 차단 모드로 설정
socket_set_nonblock() 소켓을 비블록 모드로 설정
socket_set_option( ) 소켓 옵션 설정
socket_shutdown() 이 함수를 사용하면 읽기, 쓰기 또는 지정된 소켓을 닫을 수 있습니다.
socket_strerror() 지정된 오류 번호와 함께 자세한 오류를 반환합니다.
socket_write() 소켓 캐시에 데이터 쓰기
socket_writev() 분산/집계 배열에 데이터 쓰기

케이스: 소켓 통신 데모

서버측:

<?php //确保在连接客户端时不会超时
set_time_limit(0);

$ip = &#39;127.0.0.1&#39;;
$port = 1935;

/*
 +-------------------------------
 *    @socket通信整个过程
 +-------------------------------
 *    @socket_create
 *    @socket_bind
 *    @socket_listen
 *    @socket_accept
 *    @socket_read
 *    @socket_write
 *    @socket_close
 +--------------------------------
 */

/*----------------    以下操作都是手册上的    -------------------*/
if(($sock = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0) {
    echo "socket_create() 失败的原因是:".socket_strerror($sock)."\n";
}

if(($ret = socket_bind($sock,$ip,$port)) < 0) {
    echo "socket_bind() 失败的原因是:".socket_strerror($ret)."\n";
}

if(($ret = socket_listen($sock,4)) < 0) {
    echo "socket_listen() 失败的原因是:".socket_strerror($ret)."\n";
}

$count = 0;

do {
    if (($msgsock = socket_accept($sock)) < 0) {
        echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";
        break;
    } else {
        
        //发到客户端
        $msg ="测试成功！\n";
        socket_write($msgsock, $msg, strlen($msg));
        
        echo "测试成功了啊\n";
        $buf = socket_read($msgsock,8192);
        
        
        $talkback = "收到的信息:$buf\n";
        echo $talkback;
        
        if(++$count >= 5){
            break;
        };
        
    
    }
    //echo $buf;
    socket_close($msgsock);

} while (true);

socket_close($sock);
?>

이 파일을 저장하고 실행하세요. netstat -ano를 실행하여 포트 상태를 확인하십시오. 내 포트는 1935입니다. 포트가 LISTENING이면 수신 중임을 의미합니다. 다음으로 연결을 위해 클라이언트 프로그램만 실행하면 됩니다.

클라이언트:

<?php error_reporting(E_ALL);
set_time_limit(0);
echo "<h2>TCP/IP Connection\n";

$port = 1935;
$ip = "127.0.0.1";

/*
 +-------------------------------
 *    @socket连接整个过程
 +-------------------------------
 *    @socket_create
 *    @socket_connect
 *    @socket_write
 *    @socket_read
 *    @socket_close
 +--------------------------------
 */

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket $in <br>";
}

while($out = socket_read($socket, 8192)) {
    echo "接收服务器回传信息成功！\n";
    echo "接受的内容为:",$out;
}


echo "关闭SOCKET...\n";
socket_close($socket);
echo "关闭OK\n";
?>

서버와 클라이언트를 실행하여 정보를 반환합니다. 이때 클라이언트가 서버에 연결되었습니다

자세한 코드 설명

// 设置一些基本的变量
$host = "192.168.1.99";
$port = 1234;
// 设置超时时间
set_time_limit(0);
// 创建一个Socket
$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not createsocket\n");
//绑定Socket到端口
$result = socket_bind($socket, $host, $port) or die("Could not bind tosocket\n");
// 开始监听链接
$result = socket_listen($socket, 3) or die("Could not set up socketlistener\n");
// accept incoming connections
// 另一个Socket来处理通信
$spawn = socket_accept($socket) or die("Could not accept incomingconnection\n");
// 获得客户端的输入
$input = socket_read($spawn, 1024) or die("Could not read input\n");
// 清空输入字符串
$input = trim($input);
//处理客户端输入并返回结果
$output = strrev($input) . "\n";
socket_write($spawn, $output, strlen ($output)) or die("Could not write output\n");
// 关闭sockets
socket_close($spawn);
socket_close($socket);

다음은 각 단계에 대한 자세한 설명입니다.1 첫 번째 단계는 소켓이 실행 중인 서버의 IP 주소와 포트를 보유하는 두 개의 변수를 만드는 것입니다. 제공된 서버와 포트(포트는 1에서 65535 사이의 숫자일 수 있음)로 설정할 수 있습니다. 포트가 사용되지 않고 있다는 것입니다.

// 设置两个变量
$host = "192.168.1.99";
$port = 1234;

2.在服务器端可以使用set_time_out()函数来确保PHP在等待客户端连接时不会超时.

// 超时时间
set_time_limit(0);

3.在前面的基础上,现在该使用socket_creat()函数创建一个Socket了—这个函数返回一个Socket句柄,这个句柄将用在以后所有的函数中.

// 创建Socket
$socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socket\n");

第一个参数”AF_INET”用来指定域名;
第二个参数”SOCK_STREM”告诉函数将创建一个什么类型的Socket(在这个例子中是TCP类型)

因此,如果你想创建一个UDP Socket的话,你可以使用如下的代码:

// 创建 socket
$socket = socket_create(AF_INET, SOCK_DGRAM, 0) or die("Could not create socket\n");

4.一旦创建了一个Socket句柄,下一步就是指定或者绑定它到指定的地址和端口.这可以通过socket_bind()函数来完成.

// 绑定 socket to 指定地址和端口
$result = socket_bind($socket, $host, $port) or die("Could not bind to socket\n");

5.当Socket被创建好并绑定到一个端口后,就可以开始监听外部的连接了.PHP允许你由socket_listen()函数来开始一个监听,同时你可以指定一个数字(在这个例子中就是第二个参数:3)

// 开始监听连接
$result = socket_listen($socket, 3) or die("Could not set up socket listener\n");

6.到现在,你的服务器除了等待来自客户端的连接请求外基本上什么也没有做.一旦一个客户端的连接被收到,socket_accept()函数便开始起作用了,它接收连接请求并调用另一个子Socket来处理客户端–服务器间的信息.

//接受请求链接
// 调用子socket 处理信息
$spawn = socket_accept($socket) or die("Could not accept incoming connection\n");

这个子socket现在就可以被随后的客户端–服务器通信所用了.
7.当一个连接被建立后,服务器就会等待客户端发送一些输入信息,这写信息可以由socket_read()函数来获得,并把它赋值给PHP的$input变量.

// 读取客户端输入
$input = socket_read($spawn, 1024) or die("Could not read input\n");

socker_read的第而个参数用以指定读入的字节数,你可以通过它来限制从客户端获取数据的大小.
注意:socket_read函数会一直读取壳户端数据,直到遇见n,t或者0字符.PHP脚本把这写字符看做是输入的结束符.
8.现在服务器必须处理这些由客户端发来是数据(在这个例子中的处理仅仅包含数据的输入和回传到客户端).这部分可以由socket_write()函数来完成(使得由通信socket发回一个数据流到客户端成为可能)

// 处理客户端输入并返回数据
$output = strrev($input) . "\n";
socket_write($spawn, $output, strlen ($output)) or die("Could not write output\n");

9.一旦输出被返回到客户端,父/子socket都应通过socket_close()函数来终止

// 关闭 sockets
socket_close($spawn);
socket_close($socket);

相关推荐：

php实现socket的方法 

PHP之Socket服务器搭建和测试实例分享

위 내용은 PHP 소켓 통신 내용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!