◆ ソケットの基本
phpは、Berkleyのソケットライブラリを使用して接続を作成します。ソケットは単なるデータ構造にすぎません。このソケット データ構造を使用して、クライアントとサーバー間のセッションを開始します。このサーバーは常にリッスンし、新しいセッションを生成する準備をしています。クライアントがサーバーに接続すると、サーバーがセッションを待機しているポートが開きます。このとき、サーバーはクライアントの接続要求を受け入れ、サイクルを実行します。これで、クライアントはサーバーに情報を送信できるようになり、サーバーもクライアントに情報を送信できるようになります。
ソケットを生成するには、プロトコル、ソケット タイプ、パブリック プロトコル タイプの 3 つの変数が必要です。ソケットを生成するときに選択できるプロトコルは 3 つあります。詳細なプロトコルの内容については、以下を読み続けてください。
パブリック プロトコル タイプの定義は、接続に不可欠な要素です。以下の表では、一般的なプロトコルの種類を示します。
表 1: プロトコル
名前/定数の説明
AF_INET これは、送信に TCP または UDP を使用してソケットを生成するために使用されるほとんどのプロトコルであり、IPv4 アドレスで使用されます
AF_INET6 上記と似ていますが、IPv6 アドレスで使用されます
AF_UNIX local Unix および Linux システムで使用されるプロトコルですが、めったに使用されず、通常はクライアントとサーバーが同じマシン上にある場合に使用されます
表 2: ソケットの種類
名前/定数の説明
SOCK_STREAM このプロトコルは、シーケンシャルで信頼性の高いデータに基づいています。統合されたバイトストリームベースの接続。これは最も一般的に使用されるソケットのタイプです。このソケットは送信に TCP を使用します。
SOCK_DGRAM このプロトコルは、コネクションレス型の固定長の転送呼び出しです。このプロトコルは信頼性が低く、接続に UDP を使用します。
SOCK_SEQPACKET このプロトコルは、固定長のデータ パケットを送信して送信するデュアルラインの信頼性の高い接続です。このパッケージを読み取る前に、完全に受け入れる必要があります。
SOCK_RAW このソケット タイプは、ICMP パブリック プロトコルを使用して単一のネットワーク アクセスを提供します。 (ping とtraceroute はこのプロトコルを使用します)
SOCK_RDM このタイプはめったに使用されず、ほとんどのオペレーティング システムでは実装されていません。これはデータ リンク層に提供され、データ パケットの順序を保証しません。
表 3: パブリック プロトコル
名前/定数の説明
ICMP インターネット制御メッセージ プロトコル、主にゲートウェイとホストでネットワーク状態を確認し、エラー メッセージを報告するために使用されます
UDP ユーザー データグラム プロトコル、コネクションレスで信頼性の低い伝送プロトコルです
TCP 伝送制御プロトコル、最も一般的に使用され信頼性の高いプロトコルですパブリック プロトコルを使用すると、送信プロセス中にエラーが発生した場合に、データ パケットが受信者に確実に到達できるようになり、エラー パケットが再送信されます。
ソケットを生成する 3 つの要素がわかったので、PHP のsocket_create() 関数を使用してソケットを生成します。このsocket_create()関数には、プロトコル、ソケットタイプ、パブリックプロトコルの3つのパラメータが必要です。 socket_create() 関数は、成功した場合はソケットを含むリソース タイプを返し、失敗した場合は false を返します。
Resourcesocket_create(int PROtocol, intソケットType, int commonProtocol);
それではソケットを生成します。その後は何をするのでしょうか? PHP には、ソケットを操作するための関数がいくつか用意されています。ソケットを IP にバインドし、ソケットの通信をリッスンし、ソケットを受け入れることができます。次に、関数がソケットを生成、受け入れ、リッスンする方法を理解するための例を見てみましょう。
$commonProtocol = getprotobyname("tcp");//パブリック プロトコル名を使用してプロトコル タイプを取得します
$socket =ソケット_create(AF_INET, SOCK_STREAM, $commonProtocol);//ソケットを生成し、ソケット リソース インスタンス
socket_bind($socket, 'localhost', 1337);//ソケットをローカル コンピューターにバインドします
socket_listen($socket);//すべての受信ソケット接続をリッスンします
// ソケット機能はさらに追加されます
? > ;
上記の例では、独自のサーバー側を生成します。例の最初の行、
$commonProtocol = getprotobyname("tcp");
パブリック プロトコル名を使用してプロトコル タイプを取得します。ここでは TCP パブリック プロトコルが使用されます。UDP または ICMP プロトコルを使用する場合は、getprotobyname() 関数のパラメータを「udp」または「icmp」に変更する必要があります。もう 1 つの方法は、getprotobyname() 関数を使用する代わりに、socket_create() 関数で SOL_TCP または SOL_UDP を指定することです。
$socket =ソケット_create(AF_INET, SOCK_STREAM, SOL_TCP);
例の 2 行目はソケットを生成し、ソケット リソースのインスタンスを返します。ソケット リソースのインスタンスを取得したら、ソケットを IP アドレスとポートにバインドする必要があります。
socket_bind($socket, ‘localhost’, 1337);
ここでは、ソケットをローカル コンピューター (127.0.0.1) にバインドし、ソケットを 1337 ポートにバインドします。次に、すべての受信ソケット接続をリッスンする必要があります。
socket_listen($socket);
4 行目以降は、すべてのソケット関数とその使用法を理解する必要があります。
表 4: ソケット関数
関数名 説明
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() 散布/集約配列からデータを読み取ります
socket_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() 指定されたエラー番号で詳細なエラーを返します
socket_write()ソケットキャッシュにデータを書き込む
socket_writev() 散布/集計配列にデータを書き込む
上記の関数はすべて PHP のソケットに関して、これらの関数を使用するには、ソケットを開く必要があります。開いていない場合は、ソケットを開く必要があります。 php.ini ファイルを編集し、次の行の前にあるコメントを削除します:
extension=php_sockets.dll
コメントを削除できない場合は、次のコードを使用して拡張ライブラリをロードしてください:
if (!extension_loaded('sockets')) {
if(strtoupper(substr(PHP_OS, 3)) == "WIN") {
dl('php_sockets.dll');
}else{
dl('sockets.so ');
}
}
?>
ソケットが開いているかどうかがわからない場合は、phpinfo() 関数を使用してソケットが開いているかどうかを判断できます。ソケットが開いているかどうかは、phpinfo 情報を確認することで確認できます。
phpinfo()のsocketに関する情報を表示する
◆ サーバーを生成する
次に、最初の例を改良していきます。特定のソケットをリッスンし、ユーザー接続を処理する必要があります。
$commonProtocol = getprotobyname("tcp");
$socket =ソケット_create(AF_INET, SOCK_STREAM, $commonProtocol);
socket_bind($socket, 'localhost', 1337);
socket_listen($socket);
// サーバーへの受信接続を受け入れます
$connection =ソケット_accept($socket);
if($connection){
socket_write($connection, "ソケットに接続しました...nr");
}
?>
この例を実行するには、コマンド プロンプトを使用する必要があります。その理由は、ここでは Web ページではなくサーバーが生成されるためです。 Web ブラウザを使用してこのスクリプトを実行しようとすると、30 秒の制限を超える可能性が高くなります。以下のコードを使用して無限の実行時間を設定できますが、コマンド プロンプトを使用して実行することをお勧めします。
set_time_limit(0);
コマンド プロンプトでのこのスクリプトの簡単なテスト:
Php.exe example01_server.php
システムの環境変数に php インタープリターへのパスを設定していない場合は、php を指定する必要があります。 .exeには詳細なパスを指定します。サーバーを実行するときは、Telnet 経由でポート 1337 に接続してサーバーをテストできます。
上記のサーバー側には 3 つの問題があります: 1. 複数の接続を受け入れることができません。 2. 1 つのコマンドのみを完了します。 3. Web ブラウザからこのサーバーに接続することはできません。
この最初の問題は解決するのが簡単です。アプリケーションを使用して毎回サーバーに接続できます。しかし、次の問題は、Web ページを使用してサーバーに接続する必要があることですが、これはさらに困難です。サーバーに接続を受け入れさせ、クライアントにデータを書き込み (書き込む必要がある場合)、接続を閉じて次の接続を待つことができます。
前のコードを改良し、次のコードを生成して新しいサーバーを作成します:
// ソケットを設定します
$commonProtocol = getprotobyname("tcp");
$socket =ソケット_create(AF_INET, SOCK_STREAM, $commonProtocol);
socket_bind($socket, 'localhost', 1337); //socket_bind() ソケットを IP アドレスとポートにバインドします
socket_listen($socket);
// バッファを初期化します
$buffer = "NO DATA";
while(true) {
//このソケットで受信するすべての接続を受け入れます
$connection =socket_accept($socket);//socket_accept() ソケット接続を受け入れます
printf( "Socket Connectedrn");
/ / バッファーに何かがあるかどうかを確認します
if($buffer != ""){
printf("バッファーに何かあります...データを送信中...rn") ;
socket_write($connection, $バッファ . "rn"); //socket_write() ソケットキャッシュにデータを書き込みます
printf("ソケットrnに書き込みます");
}else {
printf("バッファrnにデータがありません") ;
}
// input
while($data =ソケット_read($connection, 1024, PHP_NORMAL_READ))//socket_read() 指定された長さのデータを読み取ります
{
$buffer = $data;
socket_write($connection , "Information Receivedrn");
printf("Buffer: " . $buffer . "rn");
}
socket_close($connection); //socket_close() ソケットリソースを閉じる
printf("Closed theソケットrnrn") ;
}
?>
このサーバーは何をすべきでしょうか?ソケットを初期化し、データを送受信するためにキャッシュを開きます。接続を待機し、接続が確立されると、サーバー側の画面に「ソケットが接続されました」と表示されます。このサーバーはバッファをチェックし、バッファ内にデータがある場合は、接続されているコンピュータにデータを送信します。次に、このデータに対する受け入れメッセージを送信し、メッセージを受け入れると、メッセージをデータに保存し、接続されているコンピュータにメッセージを認識させ、最後に接続を閉じます。接続が閉じられると、サーバーは次の接続の処理を開始します。
◆ 2番目の問題に対処するクライアント
を生成するのは簡単です。 PHP ページを生成し、ソケットに接続し、データをそのキャッシュに送信して処理する必要があります。その後、処理されたデータが待機しているので、データをサーバーに送信できます。別のクライアント接続では、そのデータが処理されます。
次の例は、ソケットの使用方法を示しています:
// ソケットを作成して接続します
$socket =ソケット_create(AF_INET, SOCK_STREAM, SOL_TCP);
$connection =ソケット_connect($socket,'localhost', 1337 ) ;
while($buffer =socket_read($socket, 1024, PHP_NORMAL_READ)) {
if($buffer == “データなし”) {
echo(“
データなし
”);バッファ データ: “ . $buffer . “
”);書き込み失敗< ; /p>”);
}
// ソケットからの応答を読み取ります
while($buffer =socket_read($socket, 1024, PHP_NORMAL_READ)){
echo(“
送信されたデータ: SOME DATA< br> ; 応答は次のとおりです:" . $buffer . "
");Done Reading from Socket
"); 上記は php Socket の基本的な内容です。その他の関連記事については、PHP 中国語 Web サイト (www.php.cn) をご覧ください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
