집 > 기사 > 백엔드 개발 > PHP의 소켓 통신 원리에 대한 간략한 소개

PHP의 소켓 통신 원리에 대한 간략한 소개

WBOY원래의: 2016-08-08 09:23:28913검색

TCP/IP, UDP, 소켓용 프로그래밍이라는 단어가 낯설지 않으시죠? 네트워크 기술의 발달로 이런 말이 우리 귀에 넘쳐납니다. 그래서 묻고 싶습니다.
1. TCP/IP, UDP란 무엇인가요?
2. 소켓은 어디에 있나요?
3. 소켓이란 무엇인가요?
4. 사용하시겠습니까?
TCP/IP, UDP란 무엇인가요?

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

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

알고보니 소켓이 나왔네요.
소켓이란?
소켓은 애플리케이션 계층과 TCP/IP 프로토콜 제품군 간의 통신을 위한 중간 소프트웨어 추상화 계층입니다. 디자인 모드에서 소켓은 실제로 소켓 인터페이스 뒤에 복잡한 TCP/IP 프로토콜 제품군을 숨기는 파사드 모드입니다. 사용자에게는 소켓이 지정된 프로토콜을 준수하도록 데이터를 구성할 수 있는 간단한 인터페이스 세트가 전부입니다.
사용할 수 있나요?
이전 세대가 우리를 위해 많은 일을 해줬고, 네트워크 간의 통신도 훨씬 단순해졌지만, 결국 아직 해야 할 일이 많습니다. 이전에 소켓 프로그래밍에 대해 들었을 때 상대적으로 고급 프로그래밍 지식이라고 생각했습니다. 그러나 소켓 프로그래밍의 작동 원리를 이해하는 한 미스터리는 풀릴 것입니다.
인생의 한 장면. 친구에게 전화를 걸려면 먼저 해당 번호를 누르세요. 친구가 벨소리를 들으면 전화를 받습니다. 이때, 당신과 당신의 친구는 연결되어 통화할 수 있습니다. 통화가 끝나면 전화를 끊어 통화를 종료하세요. 삶의 장면은 이것이 어떻게 작동하는지 설명합니다. 아마도 TCP/IP 프로토콜 계열이 삶에서 탄생했을 수도 있지만 반드시 그런 것은 아닙니다.

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

소켓 관련 기능:
------------------------- --- ---------------------------------- --- -------
socket_accept()는 소켓 연결을 허용합니다
socket_bind()는 소켓을 IP 주소 및 포트에 바인딩합니다
socket_clear_error()는 소켓 오류 또는 마지막 오류 코드를 지웁니다
socket_close() 소켓 리소스 닫기
socket_connect() 소켓 연결 시작
socket_create_listen() 지정된 포트에서 수신 대기 중인 소켓 열기
socket_create_pair() 구별할 수 없는 소켓 쌍을 배열로 생성
socket_create()는 소켓 데이터 구조를 생성하는 것과 동일한 소켓을 생성합니다.
socket_get_option()은 소켓 옵션을 가져옵니다.
socket_getpeername()은 원격 유사한 호스트의 IP 주소를 가져옵니다.
socket_getsockname()은 소켓 옵션을 가져옵니다. 로컬 소켓 주소의 IP
socket_iovec_add() 분산/집계 배열에 새 벡터를 추가합니다.
socket_iovec_alloc() 이 함수는 전송, 수신, 읽기 및 쓰기가 가능한 iovec 데이터 구조를 생성합니다.
socket_iovec_delete() 이미 할당된 iovec 삭제
socket_iovec_fetch()는 지정된 iovec 리소스의 데이터를 반환
socket_iovec_free()는 iovec 리소스 해제
socket_iovec_set()는 iovec 데이터의 새 값 설정
socket_last_error()는 현재 소켓의 마지막 오류 코드
socket_listen()은 지정된 소켓의 모든 연결을 수신합니다
socket_read()는 지정된 길이의 데이터를 읽습니다
socket_readv()는 분산/집계 배열에서 데이터를 읽습니다
소켓_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() 지정된 오류 번호의 자세한 오류를 반환합니다.
소켓_write() 소켓 캐시에 데이터를 씁니다.
socket_writev() 분산/집계 배열에 데이터를 씁니다.

사례 1: 소켓 통신 데모

서버측:

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

$ip = '127.0.0.1';
$port = 1935;

/*
 &#43;-------------------------------
 *    @socket通信整个过程
 &#43;-------------------------------
 *    @socket_create
 *    @socket_bind
 *    @socket_listen
 *    @socket_accept
 *    @socket_read
 *    @socket_write
 *    @socket_close
 &#43;--------------------------------
 */

/*----------------    以下操作都是手册上的    -------------------*/
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(&#43;&#43;$count >= 5){
            break;
        };
        
    
    }
    //echo $buf;
    socket_close($msgsock);

} while (true);

socket_close($sock);
?></span>

소켓의 서버측 코드입니다. 그런 다음 cmd를 실행하고 프로그램의 저장 경로에 주의하세요.

반영 없음, 서버 프로그램이 실행되기 시작했고 포트가 수신 대기를 시작했습니다. netstat -ano를 실행하여 포트 상태를 확인하세요.

보세요, 포트가 이미 LISTENING 상태입니다. 다음으로 연결을 위해 클라이언트 프로그램만 실행하면 됩니다. 코드는

<span><?php
error_reporting(E_ALL);
set_time_limit(0);
echo "<h2>TCP/IP Connection</h2>\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 < 0) {
    echo "socket_create() failed: reason: " . socket_strerror($socket) . "\n";
}else {
    echo "OK.\n";
}

echo "试图连接 '$ip' 端口 '$port'...\n";
$result = socket_connect($socket, $ip, $port);
if ($result < 0) {
    echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n";
}else {
    echo "连接OK\n";
}

$in = "Ho\r\n";
$in .= "first blood\r\n";
$out = '';

if(!socket_write($socket, $in, strlen($in))) {
    echo "socket_write() failed: reason: " . socket_strerror($socket) . "\n";
}else {
    echo "发送到服务器信息成功！\n";
    echo "发送的内容为:<font color='red'>$in</font> <br>";
}

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


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

클라이언트가 연결되었습니다 서버 측에서.

사례 2: 코드 상세 설명

// 기본 변수 설정
$host = "192.168.1.99" ;
$포트 = 1234;
//시간 초과 설정
set_time_limit(0);
//소켓 생성
$socket = socket_create( AF_INET, SOCK_STREAM, 0) 또는 사망("소켓을 생성할 수 없습니다." );
//포트
$result = socket_bind($socket, $host, $port ) 또는 die("소켓에 바인딩할 수 없습니다.");
// 링크 모니터링 시작
$result = socket_listen($socket, 3) 또는 사망("소켓 수신기를 설정할 수 없습니다.");
/ / 들어오는 연결 수락// 통신을 처리할 다른 소켓

$spawn = socket_accept($socket) 또는 사망("들어오는 연결을 수락할 수 없습니다.");
/ / 클라이언트에서 입력 받기
$input = socket_read($spawn , 1024) 또는 사망("입력을 읽을 수 없습니다.");
// 입력 문자열 지우기
$input = trim( $ input);
//클라이언트 입력 처리 및 결과 반환
$output = strrev($input) "n" ;
socket_write($spawn, $output , strlen ($output)) 또는 die("쓸 수 없습니다 출력n"
);
// 소켓 닫기
socket_close($spawn);
socket_close($socket);각 단계에 대한 자세한 설명은 다음과 같습니다.예:
웹사이트 디자인 회사,디자인 회사,인터넷 마케팅,인터넷 홍보,인터넷 최적화 웹사이트 홍보, 웹사이트 최적화, 웹사이트 운영 등 모두 비슷한 단계입니다. 1. 첫 번째 단계는 소켓이 실행되는 서버의 IP 주소와 포트를 저장하는 두 개의 변수를 만드는 것입니다.
웹사이트 디자인 서버 및 웹 사이트 구축 포트(이 포트는 1~65535 사이의 숫자일 수 있음)(이 포트가 사용되지 않는 경우) .

[클립보드에 복사]

PHP 코드:

// 변수 두 개 설정 <code>// 设置两个变量 $host = "192.168.1.99"; $port = 1234; 

$host

= "192.168.1.99";$포트 = 1234;

2. 서버 측에서는 set_time_out() 함수 를 사용하여 클라이언트 연결을 기다리는 동안 PHP가 시간 초과되지 않도록 할 수 있습니다. .

웹사이트 구축

// 超时时间 set_time_limit(0); 

[클립보드에 복사]PHP 코드:

// 시간 초과

시간 제한(0); 3. 앞에서 를 기반으로 이제 소켓_creat() 함수를 사용하여 소켓을 생성할 차례입니다. 이 함수는 앞으로 사용될 소켓 핸들을 반환합니다. 사이트의 기능으로.[클립보드에 복사]

PHP 코드:

<code>// 创建Socket $socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("Could not create socketn"); // 소켓 생성

$socket = socket_create
(AF_INET, SOCK_STREAM,
0) 또는 사망("소켓을 생성할 수 없습니다

);

첫 번째 매개변수 "AF_INET"은 도메인 이름을 지정하는 데 사용됩니다.

// 创建 socket $socket = socket_create(AF_INET, SOCK_DGRAM, 0) or die("Could not create socketn"); 두 번째 매개변수 "SOCK_STREM"은

클래스가 무엇을 할지 함수에 알려줍니다.

유형의 소켓을 생성합니다(이 예에서는 TCP 유형 ) 따라서 UDP 소켓을 생성하려면, 다음 코드를 사용할 수 있습니다:[클립보드에 복사]

PHP 코드 :

// 소켓 생성

$socket

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

(

AF_INET, SOCK_DGRAM, 0) 또는 사망(

"소켓을 생성할 수 없습니다

");

4 . 소켓 핸들이 생성되면 다음 단계는 이를 지정된

// 开始监听连接 $result = socket_listen($socket, 3) or die("Could not set up socket listenern"); 웹사이트 건설 회사

주소와 기업용 웹사이트 구축 port.

[ 클립보드에 복사]

PHP CODE:

// 지정된 주소와 포트에 소켓 바인딩

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

socket_bind($socket, $host, $port
) 또는 die("소켓에 바인딩할 수 없습니다.");5. 소켓이 생성되어 포트에 바인딩되면 외부 Connected 청취를 시작할 수 있습니다. PHP를 사용하면 소켓_listen() 함수를 통해 웹사이트 제작 회사

를 시작할 수 있으며, 숫자( 예를 들어 두 번째 매개변수입니다: 3)

[클립보드에 복사]

PHP 코드: // 读取客户端输入 $input = socket_read($spawn, 1024) or die("Could not read inputn"); ?&gt; 

// 연결 수신 시작 $result = socket_listen($socket, 3) 또는 die("소켓을 설정할 수 없습니다. listener");

6. 지금까지 서버에는 대기 외에는 아무것도 없습니다. 기본적으로 클라이언트의 연결 요청 외에는 아무 작업도 수행되지 않습니다. 클라이언트 연결이 수신되면 소켓_accept() 함수가 작동하게 되며, 연결 요청을 수신하고 클라이언트를 처리하기 위해 다른 하위 소켓을 호출합니다. 🎜>웹사이트 제작서버 간 정보.[클립보드에 복사 ]PHP 코드:

//요청 링크 수락// 서브소켓 프로세스 정보 호출$spawn = socket_accept($socket) 또는 사망("수신연결을 수락할 수 없습니다.");

이 하위 소켓은 이제 후속 웹 페이지 제작 클라이언트-서버 통신에 사용할 수 있습니다. 7. 연결이 되면 웹디자인서버는 클라이언트가 일부 입력 정보를 보낼 때까지 기다립니다. 이 정보는 소켓_read() 함수로 가져와서 PHP의 $input 변수에 할당할 수 있습니다.[클립보드에 복사]PHP 코드:

//클라이언트 입력 읽기$input = socket_read(  $spawn, 1024) 또는 die("입력을 읽을 수 없습니다." );? &gt;

socker_read의 두 번째 매개변수는 읽을 바이트 수를 지정하는 데 사용됩니다. 이를 사용하여 클라이언트에서 데이터 가져오기 size.
참고: 소켓_read 함수는 n, t 또는를 만날 때까지 항상 쉘 클라이언트 APPdevelopment 데이터를 읽습니다. 이상 내용의 측면을 포함하여 PHP의 소켓 통신 원리에 대해 간략하게 소개했습니다. PHP 튜토리얼에 관심이 있는 친구들에게 도움이 되기를 바랍니다.

성명：

이전 기사：제품 자동 연결 서버측 업데이트 아이디어다음 기사：제품 자동 연결 서버측 업데이트 아이디어

PHP의 소켓 통신 원리에 대한 간략한 소개

PHP 코드:

PHP 코드:

$socket

[클립보드에 복사]

관련 기사