簡単に説明します: PHP ソケット通信の原理

TCP/IP、UDP、ソケットプログラミングという言葉に馴染みがありませんね?ネットワーク技術の発展に伴い、こんな言葉が私たちの耳に溢れています。そこでお聞きしたいのは:

1. TCP/IP と UDP とは何ですか?

2. ソケットはどこですか?

3. ソケットとは何ですか?

4. 使えますか？

TCP/IP と UDP とは何ですか?

TCP/IP (伝送制御プロトコル/インターネット プロトコル) は、ワイド エリア ネットワーク (WAN) 用に設計された業界標準プロトコル セットです。

UDP(User Data Protocol)は、TCPに相当するプロトコルです。これは、TCP/IP プロトコル スイートのメンバーです。

これらのプロトコル間の関係を示す図は次のとおりです。

TCP/IP プロトコル スイートには、トランスポート層、ネットワーク層、リンク層が含まれます。これで、TCP/IP と UDP の関係がわかりました。

ソケットはどこですか?

図 1 では、Socket の影が見えませんが、それはどこにあるのでしょうか?写真そのものに語ってもらいましょう。

ソケットがここにあることが判明しました。

ソケットとは何ですか?

ソケットは、アプリケーション層と TCP/IP プロトコル ファミリ間の通信のための中間ソフトウェア抽象化層であり、インターフェイスのセットです。設計モードでは、Socket は実際にはファサード モードであり、複雑な TCP/IP プロトコル ファミリを Socket インターフェイスの背後に隠し、ユーザーにとっては一連の単純なインターフェイスだけで、指定されたプロトコルを満たすように Socket がデータを編成できます。

使えますか？

先人たちは私たちのために多くのことをしてくれ、ネットワーク間の通信ははるかに簡単になりましたが、結局のところ、やるべきことはまだたくさんあります。以前ソケットプログラミングについて聞いたとき、比較的高度なプログラミング知識だと思っていましたが、ソケットプログラミングの動作原理を理解すれば、その謎は解けます。

人生の一場面。友人に電話したい場合は、最初にその番号をダイヤルします。呼び出し音が聞こえたら、友人は電話に出ます。この時点で、あなたと友人は接続され、通話することができます。通話が終了したら電話を切って会話を終了します。 TCP/IP プロトコル ファミリは人生の中で誕生したのかもしれませんが、必ずしもそうではありません。

サーバー側から始めましょう。サーバーはまずソケットを初期化し、次にポートにバインドし、ポートをリッスンし、accept を呼び出してブロックし、クライアントが接続するのを待ちます。このとき、クライアントがSocketを初期化してからサーバーに接続(connect)すると、接続に成功するとクライアントとサーバー間の接続が確立されます。クライアントがデータ要求を送信し、サーバーが要求を受信して​​処理し、次に応答データをクライアントに送信し、クライアントがデータを読み取り、最後に接続を閉じて対話が終了します。

ソケット関連関数:

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

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() 新しいベクトルを散布 /集約Array

Socket_iovec_Alloc（）この関数は、送信、受信、読み取り、および書き込みできるIOVECデータ構造を作成します。 () 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() スキャッター/集約配列にデータを書き込みます

ケース 1: ソケット通信のデモ

サーバー側:

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

これはサーバー側のコードですソケットの。次に cmd を実行し、独自のプログラムのストレージ パスに注意してください。

反映はありません。サーバー プログラムが実行を開始し、ポートがリッスンを開始しました。 netstat -ano を実行してポートのステータスを確認します。私のポートは 1935 です

見てください、ポートはすでに LISTENING 状態になっています。次に、クライアント プログラムを実行して接続するだけです。コードをアップロードします

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

これで、クライアントがサーバーに接続されました。

ケース 2: コードの詳細説明

// 设置一些基本的变量
$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. 最初のステップは、ソケットが実行されているサーバーの IP アドレスとポートを保存するための 2 つの変数を作成することです。このポートが使用されていない場合は、独自のサーバーとポート (このポートは 1 ～ 65535 の数字にすることができます) に設定できます。

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

2 サーバー上で set_time_out() 関数を使用できます。 PHP がクライアントの接続を待機していることを確認します。タイムアウトは発生しません。

// 超时时间
set_time_limit(0);

3. 前の手順に基づいて、socket_creat() 関数を使用してソケットを作成します。この関数はソケットを返します。ハンドル。後続のすべての関数で使用されます。

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

最初のパラメータ「AF_INET」は、ドメイン名を指定するために使用されます

2 番目のパラメータ「SOCK_STREM」は、作成されるソケットのタイプを関数に示します。この例では TCP タイプです)

したがって、UDP ソケットを作成するには、次のコードを使用できます:

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

4. ソケット ハンドルが作成されたら、次のステップはそれを指定するかバインドすることです。これは、socket_bind() 関数を使用して実行できます。完了しました。

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

5. ソケットが作成され、ポートにバインドされたら、PHP で外部接続の待機を開始できます。これまで、サーバーは基本的にクライアントからの接続要求を 1 回待機するだけでした。クライアント接続が受信されると、socket_accept() 関数が動作し、接続要求を受信し、クライアントとサーバー間の情報を処理するために別のサブソケットを呼び出します。後続のクライアントとサーバーの通信により

7. 接続が確立されると、サーバーはクライアントが何らかの入力情報を送信するのを待ちます。この情報は、socket_read() 関数によって取得され、PHP の $input 変数に割り当てられます。

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

socker_read の 2 番目のパラメーターは、読み取られるバイト数を指定するために使用されます。

注: ソケット読み取り関数は引き続きシェルを読み取ります。 n、torまでのクライアントデータ