찾다

집  >  기사  >  백엔드 개발  >  PHP의 소켓 통신에 대한 자세한 설명

PHP의 소켓 통신에 대한 자세한 설명

小云云
小云云원래의
2018-03-16 11:34:011875검색

우리의 PHP 프로그램이 다른 시스템과 통신해야 하는 경우가 있습니다. 예를 들어, 회사의 공식 웹사이트는 제품 추적성 정보 조회를 제공합니다. 이때 백엔드 웹사이트는 회사의 추적성 시스템 또는 ERP 시스템과 통신해야 합니다. PHP는 소켓 확장 기능을 제공하며, 공식 웹사이트 주소는 다음과 같습니다:

http://nl3.php.net/manual/zh/intro.sockets.php

이 확장 기능을 사용하면 소켓을 직접 조작할 수 있습니다. PHP를 통해 소켓에 연결하면 다른 시스템과 통신할 수 있습니다. 우리는 소켓을 사용하여 OSI 네트워크 모델의 전송 계층 위에서 작업하고 TCP 및 UDP에서 제공하는 서비스를 직접 사용하므로 다른 시스템의 클라이언트로 사용할 수 있습니다. 시뮬레이션, HTTP 클라이언트(브라우저), 일반 smtp, pop, ftp와 같은 애플리케이션 계층 프로토콜을 시뮬레이션할 수 있습니다. 더 흥미로운 점은 이를 사용하여 TELNET을 허용하는 서버와 상호 작용할 수 있다는 것입니다. 프로토콜을 사용하므로 모두 상호 작용하고 사용자 정의할 수 있습니다. 시스템 간 통신에는 사용자 정의 프로토콜이 필요합니다.

다음은 PHP를 사용하여 간단한 파일 수신 서버를 개발하는 예입니다. 또 다른 PHP 클라이언트 프로그램은 이 서버 프로그램과 통신하는 방법을 보여줍니다.

서버측 프로그램: 

<?php
/**
 * 本程序演示php网络编程：socket通讯 需要php开启php_sockets扩展
 * 这是一个简易的服务器程序，接收客户端发送的文件，保存后关闭
 * 通讯协议约定为：文件大小::文件扩展名::有效数据
 * 通讯结束标识符为：“-end-”
 * 在命令行或浏览器中执行均可，推荐命令行
 * 作者：云客【云游天下，作客四方】
 */

/****配置****/
//要绑定监听的本机ip地址和端口
$address = &#39;127.0.0.1&#39;;
$port = 81;

error_reporting(E_ALL);

//防止超时
set_time_limit(0);

//开启绝对刷送，禁止缓冲内容
ob_implicit_flush();

//创建套接字资源
if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
}
//绑定套接字到端口
if (socket_bind($sock, $address, $port) === false) {
    echo "socket_bind() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
}
//开始监听端口，参数5表示可以让5个连接请求在缓冲中排队
//排队的链接请求会在前一个连接断掉后才开始执行，该处缓冲排队数满五个后，后面的链接请求将直接忽略，客户端显示无法链接
//注意这个5并不是指可以并发进行5个链接，而是允许让5个后续链接进入排队
if (socket_listen($sock, 5) === false) {
    echo "socket_listen() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
}

do {
    //程序运行到此处进行阻塞，就像暂停执行一样，一旦有请求进入，该函数停止阻塞，返回链接资源
    if (($client_sock = socket_accept($sock)) === false) {
        echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
        break;
    }
    echo "[client connect start]\n";
    $data = ""; //接收的数据
    $data_size = -1; //接收的数据大小
    $received_size = 0; //实际接收的数据
    $ext_name = "txt"; //默认文件扩展名

    //开始与客户端交互
    do {
        //运行到该处产生阻塞，一旦有内容则停止阻塞状态，返回内容
        if (false === ($buf = socket_read($client_sock, 2048))) {
            echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($client_sock)) . "\n";
            break 2; //读取不了就返回失败，此处的2会让客户端断掉链接后停止本模拟服务器
        }
        if ($data_size === -1) {//第一次接受数据，解析通讯协议
            $arr = explode("::", $buf, 3);
            $data_size = (int)$arr[0];
            $ext_name = $arr[1];
            $data .= $arr[2];
            $received_size += strlen($data);
            continue;
        }
        $data .= $buf;
        $received_size += strlen($buf);
        if ($data_size <= $received_size) {
            if ($data_size < $received_size) {
                $data = substr($data, 0, $data_size);
            }

            echo "received:" . $received_size . "/" . "total:" . $data_size;
            $talkback = "-end-"; //发送通讯结束标志
            socket_write($client_sock, $talkback, strlen($talkback));
            file_put_contents("servertest." . $ext_name, $data);
            break 2; //关闭服务器
        }

        echo $talkback = "received:" . $received_size . "\n";
        socket_write($client_sock, $talkback, strlen($talkback));


    } while (true);
    socket_close($client_sock);

} while (true);

socket_close($sock);
?>

클라이언트측 프로그램: 

<?php
/**
 * 本程序演示php网络编程：socket通讯 需要php开启php_sockets扩展
 * 这是一个简易的客户端程序，向服务器发送文件
 * 通讯协议约定为：文件大小::文件扩展名::有效数据
 * 通讯结束标识符为：“-end-”
 * 在命令行或浏览器中执行均可，推荐命令行，需先开启服务器端
 * 作者：云客【云游天下，作客四方】
 */

/****配置****/
$file = "yunke.jpg"; //待发送的文件
//服务器ip和端口号
$address = &#39;127.0.0.1&#39;;
$port = 81;


error_reporting(E_ALL);

// 防止超时 
set_time_limit(0);

// 开启绝对刷送，不要缓冲输出
ob_implicit_flush(true);

//创建套接字资源
if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
    exit();
}
//打开到远程主机的链接
if (socket_connect($sock, $address, $port) === false) {
    echo "socket_connect() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
    exit();
}

//构造一个很大的待发送数据 大约10MB
/*
$data = "";
for ($i = 1; $i <= 10000000; $i++) {
    $data .= "data:" . $i;
}
$data = $data . $data . $data;
*/

$data = file_get_contents($file);
$data_size = strlen($data);
$arr_temp = explode(&#39;.&#39;, $file);
$ext_name = end($arr_temp);
$sock_data = $data_size . "::" . $ext_name . "::" . $data;

//发送数据给远程主机
while (true) {
    $sock_data_size = strlen($sock_data);
    $send_size = socket_write($sock, $sock_data, $sock_data_size);
    if ($send_size === false) {
        echo "send false:" . socket_strerror(socket_last_error($sock)) . "\n";
        socket_close($sock);
        echo "[client shutdown]\n";
        exit();
    }
    if ($send_size == $sock_data_size) {
        break;
    }
    $sock_data = substr($sock_data, $send_size);
}

//读返回数据
while (true) {
    if (false === ($out = socket_read($sock, 2048))) {
        echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
        break 1;
    }

    echo "server: " . $out . "\n";
    if (substr($out, -5) == "-end-") { //约定结束标志
        break;
    }
}
//关闭套接字资源
socket_close($sock);
echo "[client shutdown]\nsend data:" . format($data_size);

function format($byte = 0)
{
    if ($byte > 1024 * 1024) {
        return ceil($byte / (1024 * 1024)) . "MB";
    } elseif ($byte > 1024) {
        return ceil($byte / 1024) . "KB";
    } else {
        return $byte . " Byte";
    }
}


이 예제는 실제 프로젝트에서 통신하기 위해 TCP 짧은 링크를 통해 서버로 파일을 전송하는 방법을 보여줍니다. 모듈은 그렇게 간단하지 않으며 더 많은 문제를 고려해야 합니다

예:

긴 연결 방법이 필요한지(데이터는 tcp 링크에서 여러 번 앞뒤로 전송됨), 데이터 검증 손상 방지, 서로 다른 시스템 간의 크기 엔디안 문제, 사용자 정의 통신 프로토콜, 패킷 고정 문제, 시간 초과 처리, 동시 액세스, 흐름 제어, TCP 패킷 압축 풀기 등

PHP 네트워크에 대해 깊이 이해하고 싶다면 프로그래밍, 위에서 언급한 모든 작업에는 체계적인 연구가 필요하므로 작업자의 구현을 살펴보는 것이 좋습니다

소켓 통신 문제를 해결하는 데 도움이 되도록 PHP로 작성된 소켓 서버 프레임워크를 구축하는 데 사용할 수 있습니다. custom server, etc.
workerman공식 웹사이트 주소는 다음과 같습니다: http://www.workerman.net/

다음은 서버 HTTP 헤더와 브라우저 헤더를 보기 위한 두 가지 추가 샘플 프로그램입니다:

다음 예는 서버에서 반환한 헤더 정보를 보고, 보려는 서버 주소를 수정한 후 브라우저에서 스크립트에 액세스하기만 하면 됩니다. 

<?php
error_reporting(E_ALL);

// 防止超时 
set_time_limit(0);

// 开启绝对刷送，不要缓冲输出
ob_implicit_flush(true);

$address = &#39;www.qq.com&#39;; //要查看的服务器
$port=80;

//创建套接字资源
if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
    exit();
}
//打开到远程主机的链接
if (socket_connect($sock, gethostbyname($address), $port) === false) {
    echo "socket_connect() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
    exit();
}

//构造http头
$msg = "GET / HTTP/1.1 \r\n";
$msg .= "Host: {$address}\r\n";
$msg .= "Connection: Close\r\n\r\n";  
//指示服务器发回完毕就断开，不必等等其他资源的链接
//如果没有该行会，服务器会一直等待我方继续发送数据，直到超时关闭
//而我方不会再发送，这个会让下面的socket_read函数互为等待，等很久

//发送给远程主机
socket_write($sock, $msg, strlen($msg));

$str="";
while ($out = @socket_read($sock, 2048*4)) {
    $str.=$out;
}
$str=explode("\r\n\r\n", $str);
$str=$str[0];
if($str)
{
    echo "<pre class="brush:php;toolbar:false">\r\n".$str."\r\n
"; }else{ echo "nothing"; } //关闭套接字资源 socket_close($sock);

다음은 보기 예입니다. 브라우저 헤더에서 브라우저가 보내는 세션 정보를 쉽게 볼 수 있습니다
먼저 포트 80이 닫혀 있는지 확인한 다음, 머신 호스트 파일을 수정하고, 접속하려는 URL을 로컬 127.0.0.1 주소로 지정하고, PHP를 사용하세요. 명령줄 모드로 이 스크립트를 시작한 다음 브라우저를 사용하여 설정된 URL에 액세스하십시오. 프로그램을 닫아야 하는 경우 콘솔에서 Ctrl+C 키 조합을 사용하십시오. 

<?php
error_reporting(E_ALL);

//防止超时
set_time_limit(0);

//开启绝对刷送，禁止缓冲内容
ob_implicit_flush();

$address = &#39;127.0.0.1&#39;;
$port = 80;

//创建套接字资源
if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
}
//绑定套接字到端口
if (socket_bind($sock, $address, $port) === false) {
    echo "socket_bind() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
}
//开始监听端口，参数5表示可以让5个连接请求在缓冲中排队
//排队的链接请求会在前一个连接断掉后才开始执行，该处缓冲排队数满五个后，后面的链接请求将显示无法链接
//注意这个5并不是指可以并发进行5个链接，而是允许让5个后续链接进入排队
if (socket_listen($sock, 5) === false) {
    echo "socket_listen() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
}

do {
    //程序运行到此处进行阻塞，就像暂停执行一样，一旦有请求进入，该函数停止阻塞，返回链接资源
    //可以使用socket_set_nonblock函数设置非阻塞模式
    if (($msgsock = socket_accept($sock)) === false) {
        echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\n";
        break;
    }
    
    //链接成功后在控制台显示提示
    echo "[client start ".date("Y-m-d H:i:s")."]\n\n";
    
    do {
        //运行到该处产生阻塞，一旦有内容则停止阻塞状态，返回内容
        if (false === ($buf = socket_read($msgsock, 2048*6))) {
            echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($msgsock)) . "\n";
            break 2; //读取不了就返回失败，此处的2会让客户端断掉链接后停止本模拟服务器
        }
        $talkback ="HTTP/1.1 200 OK\r\n\r\n";
        $talkback .= date("Y-m-d H:i:s")."\nBrowser HTTP Headers:\n\n".$buf."\n";
        //向客户端显示该内容
        socket_write($msgsock, $talkback, strlen($talkback));
        //向服务器控制台显示该内容
        echo "$buf\n";
        break ; //中断本次与浏览器的链接
    } while (true);
    socket_close($msgsock);
} while (true);

socket_close($sock);
?>

관련 권장 사항:

Linux

PHP 소켓 서버 빌드 및 테스트 예제 공유

Simple에서 소켓 통신을 위한 로컬 소스 포트 번호를 얻는 방법 PHP

에서 소켓을 사용하는 방법

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

성명：
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
이전 기사：PHP 글로벌 클래스 인스턴스 소개다음 기사：PHP 글로벌 클래스 인스턴스 소개

관련 기사

더보기