Explication détaillée du cas de communication du socket php

Cet article présente principalement l'explication détaillée des cas de communication par socket en PHP. Les amis intéressés peuvent s'y référer. J'espère qu'il sera utile à tout le monde.

Connaissez-vous les mots programmation TCP/IP, UDP et Socket ? Avec le développement de la technologie des réseaux, ces mots envahissent nos oreilles.

Alors, 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 ? Utilisons des images pour parler clairement.

Il s'avère que le Socket est ici.
Qu'est-ce que Socket ? Socket est une couche d'abstraction logicielle intermédiaire pour la communication entre la couche application et la suite de protocoles TCP/IP. Il s'agit d'un ensemble d'interfaces. 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 générations précédentes 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. Attendez la fin de la communication, raccrochez et mettez 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() efface l'erreur de socket ou le dernier code d'erreur
socket_close() Ferme une ressource socket
socket_connect() Démarre une connexion socket
socket_create_listen() Ouvre une socket en écoute sur le port spécifié
socket_create_pair() Génère une paire de sockets indiscernables dans un tableau
socket_create() génère un socket, ce qui équivaut à générer une structure de données de socket
socket_get_option() obtient les options du socket
socket_getpeername() obtient l'adresse IP d'un hôte similaire distant
socket_getsockname() obtient le IP de la socket locale Adresse
socket_iovec_add() Ajoute 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 des données iovec
socket_last_error() obtient le dernier code d'erreur du socket actuel
socket_listen() écoute toutes les connexions du socket spécifié
socket_read() lit les données de la longueur spécifiée
socket_readv() lit les données du tableau scatter/agrégat
socket_recv() termine les données du socket Vers le cache
socket_recvfrom() Accepte les données du socket spécifié, si non spécifié, le socket actuel sera par défaut
socket_recvmsg() Recevoir les messages d'iovec
socket_select() Sélection multiple
socket_send() Cette fonction Envoyer des données au socket connecté
socket_sendmsg() Envoyer un message au socket
socket_sendto() Envoyer un message au socket à l'adresse spécifiée
socket_set_block() Définir le socket en mode bloc
socket_set_nonblock() socket Définir en mode non-blocage
socket_set_option() Définir les options 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 du 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 : socket démonstration de communication

côté serveur :

 1 <?php 2 //确保在连接客户端时不会超时 3 set_time_limit(0); 4 5 $ip = &#39;127.0.0.1&#39;; 6 $port = 1935; 7 8 /* 9 +------------------------------- 10 *  @socket通信整个过程 11 +------------------------------- 12 *  @socket_create 13 *  @socket_bind 14 *  @socket_listen 15 *  @socket_accept 16 *  @socket_read 17 *  @socket_write 18 *  @socket_close 19 +-------------------------------- 20 */ 21 22 /*----------------  以下操作都是手册上的  -------------------*/ 23 if(($sock = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0) { 24 echo "socket_create() 失败的原因是:".socket_strerror($sock)."\n"; 25 } 26 27 if(($ret = socket_bind($sock,$ip,$port)) < 0) { 28 echo "socket_bind() 失败的原因是:".socket_strerror($ret)."\n"; 29 } 30 31 if(($ret = socket_listen($sock,4)) < 0) { 32 echo "socket_listen() 失败的原因是:".socket_strerror($ret)."\n"; 33 } 34 35 $count = 0; 36 37 do { 38 if (($msgsock = socket_accept($sock)) < 0) { 39 echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n"; 40 break; 41 } else { 42 43 //发到客户端 44 $msg ="测试成功！\n"; 45 socket_write($msgsock, $msg, strlen($msg)); 46 47 echo "测试成功了啊\n"; 48 $buf = socket_read($msgsock,8192); 49 50 51 $talkback = "收到的信息:$buf\n"; 52 echo $talkback; 53 54 if(++$count >= 5){ 55 break; 56 }; 57 58 59 } 60 //echo $buf; 61 socket_close($msgsock); 62 63 } while (true); 64 65 socket_close($sock); 66 ?>

C'est le code serveur de la socket. 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

 1 <?php 2 error_reporting(E_ALL); 3 set_time_limit(0); 4 echo "<h2>TCP/IP Connection</h2>\n"; 5 6 $port = 1935; 7 $ip = "127.0.0.1"; 8 9 /* 10 +------------------------------- 11 *  @socket连接整个过程 12 +------------------------------- 13 *  @socket_create 14 *  @socket_connect 15 *  @socket_write 16 *  @socket_read 17 *  @socket_close 18 +-------------------------------- 19 */ 20 21 $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 22 if ($socket < 0) { 23 echo "socket_create() failed: reason: " . socket_strerror($socket) . "\n"; 24 }else { 25 echo "OK.\n"; 26 } 27 28 echo "试图连接 &#39;$ip&#39; 端口 &#39;$port&#39;...\n"; 29 $result = socket_connect($socket, $ip, $port); 30 if ($result < 0) { 31 echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n"; 32 }else { 33 echo "连接OK\n"; 34 } 35 36 $in = "Ho\r\n"; 37 $in .= "first blood\r\n"; 38 $out = &#39;&#39;; 39 40 if(!socket_write($socket, $in, strlen($in))) { 41 echo "socket_write() failed: reason: " . socket_strerror($socket) . "\n"; 42 }else { 43 echo "发送到服务器信息成功！\n"; 44 echo "发送的内容为:<font color=&#39;red&#39;>$in</font> <br>"; 45 } 46 47 while($out = socket_read($socket, 8192)) { 48 echo "接收服务器回传信息成功！\n"; 49 echo "接受的内容为:",$out; 50 } 51 52 53 echo "关闭SOCKET...\n"; 54 socket_close($socket); 55 echo "关闭OK\n"; 56 ?>

À ce stade, le client s'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. établissez deux variables A pour enregistrer l'adresse IP et le port du serveur sur lequel le Socket est exécuté. Vous pouvez la définir sur votre propre serveur et votre propre port (le port peut être un nombre compris entre 1 et 65535), à condition que ce port ne soit pas présent. use.

[Copier dans le presse-papiers]
PHP CODE :

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

2 Vous pouvez utiliser la fonction set_time_out() côté serveur pour vous assurer que PHP n'expire pas. en attendant que le client se connecte.

[Copier dans le presse-papiers]
CODE PHP :

// 超时时间
set_time_limit ( 0 );

Sur la base des étapes précédentes, il est temps de créer un Socket en utilisant. la fonction socket_creat() - cette fonction renvoie un handle de Socket, ce handle sera utilisé dans toutes les fonctions futures.

[Copier dans le presse-papiers]
PHP CODE :

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

Le premier 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éé (type TCP dans cet exemple)

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

[Copier dans le presse-papiers]
CODE PHP :

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

Une fois un handle de Socket créé, le 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().

[Copier dans le presse-papiers]
PHP CODE :

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

5. Lorsque le Socket est créé et lié à un port, vous pouvez commencer à écouter les connexions externes. PHP vous permet de démarrer une fonction d'écoute via la fonction socket_listen(), et vous pouvez spécifier un nombre (dans cet exemple, le deuxième paramètre : 3)

[Copier dans le presse-papier]
PHP CODE :

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

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

[Copy to clipboard]
PHP CODE:

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

这个子socket现在就可以被随后的客户端–服务器通信所用了.

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

[Copy to clipboard]
PHP CODE:

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

socker_read的第而个参数用以指定读入的字节数,你可以通过它来限制从客户端获取数据的大小.

注意:socket_read函数会一直读取壳户端数据,直到遇见\n,\t或者\0字符.PHP脚本把这写字符看做是输入的结束符.

8.现在服务器必须处理这些由客户端发来是数据(在这个例子中的处理仅仅包含数据的输入和回传到客户端).这部分可以由socket_write()函数来完成(使得由通信socket发回一个数据流到客户端成为可能)

[Copy to clipboard]
PHP CODE:

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

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

[Copy to clipboard]
PHP CODE:

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

总结：以上就是本篇文的全部内容，希望能对大家的学习有所帮助。

相关推荐：

PHP 实现页面静态化的几种方法详解

PHP读取CSV大文件导入数据库的方法

PHP实现十六进制颜色随机生成器功能的方法

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!