Expliquez en termes simples : le principe de communication du socket PHP

Connaissez-vous les termes de programmation TCP/IP, UDP et Socket ? Avec le développement de la technologie des réseaux, ces mots inondent nos oreilles. Je veux donc demander :

1. Que sont TCP/IP et UDP ?

2. Où est la prise ?

3. Qu'est-ce que Socket ?

4. Pouvez-vous les utiliser ?

Que sont TCP/IP et UDP ?

TCP/IP (Transmission Control Protocol/Internet Protocol) est un ensemble de protocoles standards industriels conçus pour les réseaux étendus (WAN).

UDP (User Data Protocol) est un protocole correspondant à TCP. Il fait partie de la suite de protocoles TCP/IP.

Voici un schéma montrant la relation entre ces protocoles.

La suite de protocoles TCP/IP comprend la couche transport, la couche réseau et la couche liaison. Vous connaissez maintenant la relation entre TCP/IP et UDP.

Où est la prise ?

Sur la figure 1, nous ne voyons pas l’ombre de Socket, alors où est-elle ? Laissons les images parler d’elles-mêmes.

Il s'avère que le Socket est ici.

Qu'est-ce que Socket ?

Socket est une couche d'abstraction logicielle intermédiaire qui communique entre la couche application et la suite de protocoles TCP/IP. En mode conception, Socket est en fait un mode façade, qui cache la famille complexe de protocoles TCP/IP derrière l'interface Socket. Pour les utilisateurs, un ensemble d'interfaces simples permet à Socket d'organiser les données pour se conformer au protocole spécifié.

Pouvez-vous les utiliser ?

Les prédécesseurs ont fait beaucoup pour nous et la communication entre les réseaux est devenue beaucoup plus simple, mais après tout, il reste encore beaucoup de travail à faire. Quand j'ai entendu parler de la programmation Socket auparavant, je pensais qu'il s'agissait de connaissances en programmation relativement avancées, mais tant que nous comprendrons le principe de fonctionnement de la programmation Socket, le mystère sera levé.

Une scène de la vie. Si vous souhaitez appeler un ami, composez d'abord le numéro. Lorsque l'ami entend la sonnerie, il décroche le téléphone. Vous et votre ami êtes alors connectés et vous pouvez parler. Une fois la communication terminée, raccrochez pour mettre fin à la conversation. Des scènes de la vie expliquent comment cela fonctionne. Peut-être que la famille des protocoles TCP/IP est née dans la vie, mais ce n'est pas nécessairement le cas.

Commençons par le côté serveur. Le serveur initialise d'abord le Socket, puis se lie au port, écoute le port, appelle accepter pour bloquer et attend que le client se connecte. A ce moment, si un client initialise un Socket puis se connecte au serveur, si la connexion réussit, la connexion entre le client et le serveur est établie. Le client envoie une demande de données, le serveur reçoit la demande et traite la demande, puis envoie les données de réponse au client, le client lit les données et ferme enfin la connexion, et l'interaction se termine.

Fonctions liées à la prise :

------------------------------- -- ------------------------------------------------ -- -------------

socket_accept() accepte une connexion Socket

socket_bind() lie le socket à une adresse IP et un port

socket_clear_error() Effacer l'erreur de socket ou le dernier code d'erreur

socket_close() Fermer une ressource socket

socket_connect() Démarrer une connexion socket

socket_create_listen () Ouvrir une socket en écoute sur le port spécifié

socket_create_pair() Générer une paire de sockets indifférenciées dans un tableau

socket_create() Générer une socket, ce qui équivaut à générer une structure de données de socket

socket_get_option() Obtenez l'option socket

socket_getpeername() Obtenez l'adresse IP d'un hôte similaire distant

socket_getsockname() Obtenez l'adresse IP de la socket locale

socket_iovec_add () Ajouter un nouveau vecteur à un tableau scatter/agrégat

socket_iovec_alloc() Cette fonction crée une structure de données iovec capable d'envoyer, de recevoir, de lire et d'écrire

socket_iovec_delete( ) Supprimer un iovec déjà alloué

socket_iovec_fetch() renvoie les données de la ressource iovec spécifiée

socket_iovec_free() libère une ressource iovec

socket_iovec_set() définit la nouvelle valeur de iovec data

socket_last_error() Obtenez le dernier code d'erreur de la socket actuelle

socket_listen() Écoutez toutes les connexions de la socket spécifiée

socket_read() Lisez les données de la longueur spécifiée

socket_readv() Lire les données du tableau dispersé/agrégé

socket_recv() Terminer les données du socket vers le cache

socket_recvfrom() Accepter le les données du socket spécifié, si elles ne sont pas spécifiées, le socket actuel sera par défaut

socket_recvmsg() reçoit les messages d'iovec

socket_select() sélection multiple

socket_send() Cette fonction envoie des données au socket connecté

socket_sendmsg() envoie un message au socket

socket_sendto() envoie un message au socket de l'adresse spécifiée

socket_set_block() Définir le socket en mode bloc

socket_set_nonblock() Définir le socket en mode non bloqué

socket_set_option() Définir l'option du socket

socket_shutdown () Cette fonction vous permet de fermer la lecture, l'écriture ou le socket spécifié

socket_strerror() renvoie l'erreur détaillée avec le numéro d'erreur spécifié

socket_write() écrit les données dans le cache du socket

socket_writev() écrit les données dans un tableau dispersé/agrégé

Cas 1 : démonstration de communication par socket

Côté serveur :

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

Il s'agit du côté serveur code de la prise. Ensuite, exécutez cmd, faites attention au chemin de stockage de votre propre programme.

Aucune réponse Le programme serveur a commencé à s'exécuter et le port a commencé à écouter. Exécutez netstat -ano pour vérifier l'état du port. Le mien est le port 1935

Regardez, le port est déjà dans l'état d'écoute. Ensuite, il nous suffit d'exécuter le programme client pour nous connecter. Téléchargez le code

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

Maintenant, le client est connecté au serveur.

Cas 2 : Explication détaillée du code

// 设置一些基本的变量
$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);

Ce qui suit est une description détaillée de chaque étape :

1. Fonctionnement du socket L'adresse IP et le port du serveur. Vous pouvez le définir sur votre propre serveur et votre port (ce port peut être un nombre compris entre 1 et 65535), à condition que ce port ne soit pas utilisé

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

// 超时时间
set_time_limit(0);

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

Le premier Le paramètre "AF_INET" permet de préciser le nom de domaine ;

Le deuxième paramètre "SOCK_STREM" indique à la fonction quel type de Socket sera créé (dans cet exemple, type TCP)

Par conséquent, si vous souhaitez créer un Socket UDP, vous pouvez utiliser le code suivant :

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

4. handle est créé, l'étape suivante consiste à le spécifier ou à le lier à l'adresse et au port spécifiés. Cela peut être fait via la fonction socket_bind()

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

5. est créé et lié à un port, vous pouvez commencer à écouter. Connexion externe. PHP vous permet de démarrer une fonction d'écoute avec la fonction socket_listen(), et vous pouvez spécifier un nombre (dans ce cas le deuxième paramètre : 3)

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

6. Jusqu'à présent, votre serveur n'a pratiquement rien fait à part attendre une demande de connexion du client. Une fois la connexion client reçue, la fonction socket_accept() entre en jeu. reçoit la demande de connexion et appelle un autre sous-socket pour gérer la communication client-serveur.

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

Ce sous-socket peut désormais être utilisé pour une communication client-serveur ultérieure.

7. Lorsqu'une connexion est établie, le serveur attendra que le client envoie des informations d'entrée. Ces informations peuvent être obtenues par la fonction socket_read() et affectées à la variable $input de PHP

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