3

以下のコードを含むphp cliソケットサーバーがあります。クライアントが接続してリクエストを送信する 

<?php
// PHP SOCKET SERVER
error_reporting(E_ERROR);
// Configuration variables
$host = "127.0.0.1";
$port = 5600;
$max = 500;
$client = array();

// No timeouts, flush content immediatly
set_time_limit(0);
ob_implicit_flush();

// Server functions
function rLog($msg){
             $msg = "[".date('Y-m-d H:i:s')."] ".$msg;
             echo($msg."\n");

}
// Create socket
$sock = socket_create(AF_INET,SOCK_STREAM,0) or die("[".date('Y-m-d H:i:s')."] Could not create socket\n");
// Bind to socket
socket_bind($sock,$host,$port) or die("[".date('Y-m-d H:i:s')."] Could not bind to socket\n");
// Start listening
socket_listen($sock) or die("[".date('Y-m-d H:i:s')."] Could not set up socket listener\n");

rLog("Server started at ".$host.":".$port);
// Server loop
while(true){
             socket_set_block($sock);
             // Setup clients listen socket for reading
             $read[0] = $sock;
             for($i = 0;$i<$max;$i++){
                          if($client[$i]['sock'] != null)
                                       $read[$i+1] = $client[$i]['sock'];
             }
             // Set up a blocking call to socket_select()
             $ready = socket_select($read,$write = NULL, $except = NULL, $tv_sec = NULL);
             // If a new connection is being made add it to the clients array
             if(in_array($sock,$read)){
                          for($i = 0;$i<$max;$i++){
                                       if($client[$i]['sock']==null){
                                                    if(($client[$i]['sock'] = socket_accept($sock))<0){
                                                                 rLog("socket_accept() failed: ".socket_strerror($client[$i]['sock']));
                                                    }else{
                                                                 rLog("Client #".$i." connected");
                                                    }
                                                    break;
                                       }elseif($i == $max - 1){
                                                    rLog("Too many clients");
                                       }
                          }
                          if(--$ready <= 0)
                          continue;
             }
             for($i=0;$i<$max;$i++){
                          if(in_array($client[$i]['sock'],$read)){
                                       $input = socket_read($client[$i]['sock'],1024);

                                        if($input){

                                                    rLog("Client ".$i." Call:".$input.")");

                                                    ## <<<<<<<<<<< Clients Request Show Here >>>>>>>>>>>> ##
                                                    ## <<<<<<<<<<< Clients Request Show Here >>>>>>>>>>>> ##
                                                    ## <<<<<<<<<<< Clients Request Show Here >>>>>>>>>>>> ##
                                                    ## <<<<<<<<<<< Clients Request Show Here >>>>>>>>>>>> ##
                                                    ## <<<<<<<<<<< Clients Request Show Here >>>>>>>>>>>> ##

                                        }
                          }
             }
}
// Close the master sockets
socket_close($sock);
?>

質問:
- php cli ソケット サーバーに接続されているクライアントの IP アドレスを検出するにはどうすればよいですか?

4

1 に答える 1

4

socket_accept()の呼び出しに成功した行の直後に、次のように呼び出しsocket_getpeername()ます。

if (($client[$i]['sock'] = socket_accept($sock)) < 0) {
    rLog("socket_accept() failed: ".socket_strerror($client[$i]['sock']));
} else {
    rLog("Client #".$i." connected");
    socket_getpeername($client[$i]['sock'], $address, $port);
}

$addressリモート ホストの IP アドレスと$portリモート ポートが含まれるようになりました。必要に応じてその情報を処理してください。

于 2012-07-18T13:39:39.433 に答える