Was ist ein PHP-Socket?

Dieser Artikel stellt hauptsächlich die PHP-Socket-Programmierung auf einfache Weise vor. In diesem Artikel werden die relevanten Kenntnisse über Sockets und den Verpackungsinhalt von PHP-Socket-Programmierbeispielen ausführlich erläutert

für TCP/. IP und UDP, Socket-Programmierung, diese Wörter sind Ihnen nicht fremd, oder? Mit der Entwicklung der Netzwerktechnologie dringen diese Worte in unsere Ohren. Ich möchte also fragen:

1. Was sind TCP/IP und UDP?
2. Wo ist die Steckdose?
3.Was ist Socket?
4. Können Sie sie verwenden?

Was sind TCP/IP und UDP?

TCP/IP (Transmission Control Protocol/Internet Protocol) ist ein industrieller Standardprotokollsatz, der für Weitverkehrsnetze (WANs) entwickelt wurde.

UDP (User Data Protocol) ist ein TCP entsprechendes Protokoll. Es ist Mitglied der TCP/IP-Protokollsuite.

Hier ist ein Diagramm, das die Beziehung zwischen diesen Protokollen zeigt.

Die TCP/IP-Protokollsuite umfasst die Transportschicht, die Netzwerkschicht und die Verbindungsschicht. Jetzt kennen Sie die Beziehung zwischen TCP/IP und UDP.

Wo ist die Steckdose?

In Abbildung 1 sehen wir den Schatten von Socket nicht. Wo ist er also? Lassen Sie uns Bilder verwenden, um klar zu sprechen.

Es stellt sich heraus, dass der Sockel hier ist.

Was ist Socket?

Socket ist eine zwischengeschaltete Software-Abstraktionsschicht, die zwischen der Anwendungsschicht und der TCP/IP-Protokollsuite kommuniziert. Es handelt sich um eine Reihe von Schnittstellen. Im Designmuster ist Socket eigentlich ein Fassadenmodus, der die komplexe TCP/IP-Protokollfamilie hinter der Socket-Schnittstelle verbirgt. Für Benutzer ist eine Reihe einfacher Schnittstellen alles und ermöglicht es Socket, Daten zu organisieren das vorgegebene Protokoll einhalten.

Können Sie sie verwenden?

Frühere Menschen haben viel für uns getan und die Kommunikation zwischen Netzwerken ist viel einfacher geworden, aber schließlich gibt es noch viel zu tun. Als ich zuvor von Socket-Programmierung hörte, dachte ich, es handele sich um relativ fortgeschrittene Programmierkenntnisse, aber solange wir das Funktionsprinzip der Socket-Programmierung verstehen, wird das Rätsel gelöst sein.
Eine Szene aus dem Leben. Wenn Sie einen Freund anrufen möchten, wählen Sie zuerst die Nummer. Wenn der Freund den Klingelton hört, nimmt er den Hörer ab. Zu diesem Zeitpunkt sind Sie und Ihr Freund verbunden und Sie können sprechen. Wenn die Kommunikation beendet ist, legen Sie den Hörer auf, um das Gespräch zu beenden. Szenen aus dem Leben erklären, wie das funktioniert. Vielleicht wurde die TCP/IP-Protokollfamilie im Leben geboren, aber das ist nicht unbedingt der Fall.

Beginnen wir mit der Serverseite. Der Server initialisiert zuerst den Socket, bindet dann an den Port, lauscht auf den Port, ruft „Accept“ zum „Blockieren“ auf und wartet darauf, dass der Client eine Verbindung herstellt. Wenn zu diesem Zeitpunkt ein Client einen Socket initialisiert und dann eine Verbindung zum Server herstellt und die Verbindung erfolgreich ist, wird die Verbindung zwischen dem Client und dem Server hergestellt. Der Client sendet eine Datenanforderung, der Server empfängt die Anforderung und verarbeitet sie, sendet dann die Antwortdaten an den Client, der Client liest die Daten und schließt schließlich die Verbindung und die Interaktion endet.

Sockelbezogene Funktionen:
------------------------------------------------ -------------------------------------------------- ----------
socket_accept() Akzeptieren Sie eine Socket-Verbindung
socket_bind() Binden Sie den Socket an eine IP-Adresse und einen Port
socket_clear_error() Löschen Sie den Socket-Fehler oder den letzten Fehler. Fehlercode
socket_close() Schließt eine Socket-Ressource
socket_connect() Startet eine Socket-Verbindung
socket_create_listen() Öffnet einen Socket, der den angegebenen Port überwacht
socket_create_pair() Erzeugt ein Paar nicht unterscheidbarer Sockets in einem Array,
socket_create() generiert einen Socket, was dem Generieren einer Socket-Datenstruktur entspricht.
socket_get_option() ruft die IP-Adresse eines entfernten ähnlichen Hosts ab 🎜>socket_getsockname() ruft die lokale IP-Adresse ab
socket_iovec_add() fügt einem Scatter/Aggregate-Array einen neuen Vektor hinzu
socket_iovec_alloc() Diese Funktion erstellt eine iovec-Datenstruktur, die senden und empfangen kann , Lesen und Schreiben
socket_iovec_delete() löscht einen vorhandenen zugewiesenen iovec
socket_iovec_fetch() Gibt die Daten der angegebenen iovec-Ressource zurück
socket_iovec_free() Gibt eine iovec-Ressource frei
socket_iovec_set() Setzt den neuen Wert von iovec-Daten
socket_last_error() Ruft den letzten Fehler des aktuellen Socket-Codes ab
socket_listen() hört auf alle Verbindungen vom angegebenen Socket
socket_read() liest Daten der angegebenen Länge
socket_readv() liest Daten aus dem Scatter/Aggregate-Array
socket_recv() from socket Daten im Cache beenden
socket_recvfrom() Akzeptiert Daten vom angegebenen Socket. Wenn nicht angegeben, wird der aktuelle Socket als Standard verwendet
socket_recvmsg() Empfangen Nachrichten von iovec
socket_select() Mehrfachauswahl
socket_send( ) Diese Funktion sendet Daten an den angeschlossenen Socket
socket_sendmsg()
Sendet eine Nachricht
an den Socketsocket_sendto() Sendet eine Nachricht an den Socket an der angegebenen Adressesocket_set_block() Setzt es im Socket auf Blockmodus
socket_set_nonblock() Setzt den Socket auf Nicht-Blockmodus
socket_set_option() Setzt die Socket-Option
socket_shutdown() Mit dieser Funktion können Sie das Lesen, Schreiben oder Schließen des angegebenen Sockets schließen
socket_strerror() Detaillierten Fehler der angegebenen Fehlernummer zurückgeben
socket_write() Daten in den Socket-Cache schreiben
socket_writev() Daten in schreiben Scatter/Aggregate-Array

Fall 1: Demonstration der Socket-Kommunikation

Serverseite:

Dies ist der Servercode des Sockets. Führen Sie dann cmd aus und achten Sie auf den Speicherpfad Ihres eigenen Programms.

<?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);
?>

Keine Antwort. Das Serverprogramm wurde gestartet und der Port hat mit dem Abhören begonnen. Führen Sie netstat -ano aus, um den Portstatus zu überprüfen.

Sehen Sie, der Port befindet sich bereits im LISTENING-Status. Als nächstes müssen wir nur noch das Client-Programm ausführen, um eine Verbindung herzustellen. Laden Sie den Code hoch

<?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 "试图连接 &#39;$ip&#39; 端口 &#39;$port&#39;...\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 = &#39;&#39;;

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

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


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

Der Client hat sich nun mit dem Server verbunden.

Fall 2: Detaillierte Codeerklärung

Im Folgenden finden Sie eine detaillierte Beschreibung jedes Schritts:

// 设置一些基本的变量
$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. Der erste Schritt besteht darin, zwei Variablen zum Speichern zu erstellen Socket-Betrieb Die IP-Adresse und der Port des Servers können auf Ihren eigenen Server und Port eingestellt werden (dieser Port kann eine Zahl zwischen 1 und 65535 sein), sofern dieser Port nicht verwendet wird 🎜> Code wie folgt:

2. Sie können die Funktion set_time_out() auf der Serverseite verwenden, um sicherzustellen, dass PHP nicht abläuft, während es auf die Verbindung des Clients wartet

Der Code lautet wie folgt:

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

3. Basierend auf den vorherigen ist es an der Zeit, einen Socket mit der Funktion socket_creat() zu erstellen – diese Funktion gibt zurück ein Socket-Handle, das in allen nachfolgenden Funktionen verwendet wird

Der Code lautet wie folgt:

// 超时时间
set_time_limit(0);

Der erste Parameter „AF_INET“ wird zur Angabe des Domänennamens verwendet ;

Der zweite Parameter „SOCK_STREM“ teilt der Funktion mit, welchen Typ sie erstellen wird (TCP-Typ in diesem Beispiel)

Wenn Sie also einen UDP-Socket erstellen möchten, können Sie den folgenden Code verwenden:

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

Der Code lautet wie folgt:

4. Sobald ein Socket-Handle erstellt wurde, besteht der nächste Schritt darin, ihn an die angegebene Adresse und den angegebenen Port zu binden über die socket_bind()-Funktion

Der Code lautet wie folgt:

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

5. Nachdem der Socket erstellt und an einen Port gebunden wurde, können Sie mit der Überwachung auf externe Verbindungen beginnen Ermöglicht Ihnen, einen Abhörvorgang über die Funktion socket_listen() zu starten, und Sie können eine Zahl angeben (in diesem Beispiel ist es der zweite Parameter: 3)

Der Code lautet wie folgt:

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

6. Bisher hat Ihr Server im Grunde nichts anderes übrig, als auf die Verbindungsanfrage vom Client zu warten. Sobald eine Client-Verbindung empfangen wird, kommt die Funktion socket_accept() ins Spiel ein weiterer Sub-Socket zur Verarbeitung der Client-Server-Informationen

代码如下:

//接受请求链接
// 调用子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);

Das obige ist der detaillierte Inhalt vonWas ist ein PHP-Socket?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!