Explication détaillée du flux PHP Streams

Cet article présente principalement l'introduction détaillée et l'utilisation de PHP Streams (stream). PHP Streams est une opération de base intégrée et peut être rarement utilisé par les développeurs ordinaires. Il est utilisé pour unifier les opérations de fichiers, de réseaux, de compression de données et d'autres opérations de type fichier, et fournit un ensemble d'interfaces de fonctions communes pour ces opérations de type fichier. J'espère que cela aide tout le monde.

PHP Streams est une opération de base intégrée qui peut être rarement utilisée par les développeurs ordinaires. Elle est utilisée pour unifier les opérations de fichiers, de réseau, de compression de données et d'autres opérations de type fichier, et fournit un ensemble de fonctions communes pour. ces opérations de type fichier.

Un flux est un objet ressource avec un comportement de streaming. Chaque objet flux a une classe wrapper. Le flux peut être référencé via ://. Parmi eux, est le nom de la classe d'empaquetage, et le contenu de est spécifié par la syntaxe de la classe d'empaquetage. La syntaxe des différentes classes d'empaquetage sera différente.
Jetons un coup d'œil aux classes d'empaquetage intégrées que PHP a par défaut :

print_r(stream_get_wrappers());
/*
Array
(
  [0] => php
  [1] => file
  [2] => glob
  [3] => data
  [4] => http
  [5] => ftp
  [6] => zip
  [7] => compress.zlib
  [8] => https
  [9] => ftps
  [10] => phar
)
*/

Regardez le Manuel PHP sur le support PHP. Protocoles et classes wrapper.
Regardez le code suivant qui utilise file_get_contents() pour obtenir des données :

/* Read local file from /home/bar */
 $localfile = file_get_contents ( "/home/bar/foo.txt" );
 
 /* Identical to above, explicitly naming FILE scheme */
 $localfile = file_get_contents ( "file:///home/bar/foo.txt" );
 
 /* Read remote file from www.example.com using HTTP */
 $httpfile  = file_get_contents ( "http://www.example.com/foo.txt" );
 
 /* Read remote file from www.example.com using HTTPS */
 $httpsfile = file_get_contents ( "https://www.example.com/foo.txt" );
 
 /* Read remote file from ftp.example.com using FTP */
 $ftpfile  = file_get_contents ( "ftp://user:pass@ftp.example.com/foo.txt" );
 
 /* Read remote file from ftp.example.com using FTPS */
 $ftpsfile  = file_get_contents ( "ftps://user:pass@ftp.example.com/foo.txt" );

En fait readfile('/ path/ to/somefile.txt') ou readfile('file:///path/to/somefile.txt'), ces deux méthodes sont équivalentes. Parce que la classe d'empaquetage par défaut de PHP est file://.

Le manuel indique clairement que vous pouvez enregistrer votre propre wrapper via stream_register_wrapper(). Vous pouvez consulter les exemples dans le manuel.
OK, voici une brève introduction à PHP://, qui est une classe wrapper utilisée par PHP pour gérer les flux IO (cliquez ici pour voir un exemple). Des flux d'entrée et de sortie plus puissants sont accessibles via PHP:// :

php://stdin : accédez au flux d'entrée correspondant du processus PHP, tel que celui utilisé pour obtenir une saisie au clavier lorsque cli exécute des scripts.
php://stdout : accédez au flux de sortie correspondant du processus PHP.
php://stderr : accédez à la sortie d'erreur correspondante du processus PHP.
php://input : Un flux en lecture seule qui accède aux données brutes demandées.
php://output : flux de données en écriture seule, écrit dans la zone de sortie de la même manière que print et echo.
php://fd : permet un accès direct au descripteur de fichier spécifié. L'exemple php://fd/3 fait référence au descripteur de fichier 3.
php://memory : permet de lire et d'écrire des données temporaires. Stocker les données en mémoire.
php://temp : Comme ci-dessus, il sera stocké dans un fichier temporaire une fois que la mémoire aura atteint la limite prédéfinie (la valeur par défaut est de 2 Mo).
php://filter : filtre.

PHP peut également modifier et améliorer les classes d'empaquetage via le contexte et le filtre.
(1) Concernant le contexte, par exemple, PHP utilise stream_context_create() pour définir le délai d'attente pour l'obtention des fichiers. Vous devez avoir utilisé ce code :

$opts = array(
  'http'=>array(
    'method'=>"GET",
    'timeout'=>60,
  )
);
$context = stream_context_create($opts);
$html =file_get_contents('http://www.jb51.net', false, $context);

.

(2) Concernant les filtres de filtrage, jetons d'abord un coup d'œil aux filtres intégrés que PHP possède :

print_r(stream_get_filters());
/*
Array
(
  [0] => convert.iconv.*
  [1] => mcrypt.*
  [2] => mdecrypt.*
  [3] => string.rot13
  [4] => string.toupper
  [5] => string.tolower
  [6] => string.strip_tags
  [7] => convert.*
  [8] => consumed
  [9] => dechunk
  [10] => zlib.*
)
*/

Des filtres personnalisés peuvent être créés via stream_filter_register() et le php_user_filter intégré, comme suit :

/* Define our filter class */
class strtoupper_filter extends php_user_filter {
  function filter ( $in , $out , & $consumed , $closing )
  {
    while ( $bucket = stream_bucket_make_writeable ( $in )) {
      $bucket -> data = strtoupper ( $bucket -> data );
      $consumed += $bucket -> datalen ;
      stream_bucket_append ( $out , $bucket );
    }
    return PSFS_PASS_ON ;
  }
}
 
/* Register our filter with PHP */
stream_filter_register ( "strtoupper" , "strtoupper_filter" )
or die( "Failed to register filter" );
 
$fp = fopen ( "foo-bar.txt" , "w" );
 
/* Attach the registered filter to the stream just opened */
stream_filter_append ( $fp , "strtoupper" );
 
fwrite ( $fp , "Line1\n" );
fwrite ( $fp , "Word - 2\n" );
fwrite ( $fp , "Easy As 123\n" );
 
fclose ( $fp );
 
 
readfile ( "foo-bar.txt" );
/*
结果如下：
LINE1
WORD - 2
EASY AS 123
*/

fournit la liste suivante de fonctions de flux en PHP :

stream_bucket_append函数：为队列添加数据　
stream_bucket_make_writeable函数：从操作的队列中返回一个数据对象
stream_bucket_new函数：为当前队列创建一个新的数据
stream_bucket_prepend函数：预备数据到队列　
stream_context_create函数：创建数据流上下文
stream_context_get_default函数：获取默认的数据流上下文
stream_context_get_options函数：获取数据流的设置
stream_context_set_option函数：对数据流、数据包或者上下文进行设置
stream_context_set_params函数：为数据流、数据包或者上下文设置参数
stream_copy_to_stream函数：在数据流之间进行复制操作
stream_filter_append函数：为数据流添加过滤器
stream_filter_prepend函数：为数据流预备添加过滤器
stream_filter_register函数：注册一个数据流的过滤器并作为PHP类执行
stream_filter_remove函数：从一个数据流中移除过滤器
stream_get_contents函数：读取数据流中的剩余数据到字符串
stream_get_filters函数：返回已经注册的数据流过滤器列表
stream_get_line函数：按照给定的定界符从数据流资源中获取行
stream_get_meta_data函数：从封装协议文件指针中获取报头/元数据
stream_get_transports函数：返回注册的Socket传输列表
stream_get_wrappers函数：返回注册的数据流列表
stream_register_wrapper函数：注册一个用PHP类实现的URL封装协议
stream_select函数：接收数据流数组并等待它们状态的改变
stream_set_blocking函数：将一个数据流设置为堵塞或者非堵塞状态
stream_set_timeout函数：对数据流进行超时设置
stream_set_write_buffer函数：为数据流设置缓冲区
stream_socket_accept函数：接受由函数stream_ socket_server()创建的Socket连接
stream_socket_client函数：打开网络或者UNIX主机的Socket连接
stream_socket_enable_crypto函数：为一个已经连接的Socket打开或者关闭数据加密
stream_socket_get_name函数：获取本地或者网络Socket的名称
stream_socket_pair函数：创建两个无区别的Socket数据流连接
stream_socket_recvfrom函数：从Socket获取数据，不管其连接与否
stream_socket_sendto函数：向Socket发送数据，不管其连接与否
stream_socket_server函数：创建一个网络或者UNIX Socket服务端
stream_wrapper_restore函数：恢复一个事先注销的数据包
stream_wrapper_unregister函数：注销一个URL地址包

Recommandations associées :

fractionnement et fusion de fichiers PHP (téléchargement avec reprise)

Utiliser nginx+ nginx-rtmp- Notes sur la création d'un serveur multimédia en streaming avec module+ffmpeg (5)

Lecture multimédia en streaming Xiaowan - Système de streaming multimédia à la demande HLS

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!