• 技术文章 >后端开发 >php教程

    PHP socket 发到指定的地址,该如何解决

    2016-06-13 13:28:07原创444
    PHP socket 发到指定的地址
    有3个用户通过socket登录到了服务端,通过mysql记录下了三个用户的IP与端口分别为:
    A: 192.168.1.100:13564 B:192.168.1.100:13565 C:192.168.1.100:13566

    现在我想在客户A发一个指今(包含客户B的端口),服务端接受分析后从数据库取出客户B对应的地址发个TEST字符给B

    我在服务端加入如下代码,出现错误,
    PHP Warning: socket_connect(): unable to connect [0]: 提供了一个无效的参数。

    PHP code
    
    $conn = socket_connect ($socket, '192.168.1.100', 13565);  
    $buffer = "ok";
    $command = socket_sendto($socket,$buffer,strlen($buffer),0,'192.168.1.100','192.168.1.100');
    
    


    可以在服务端用socket_sendto吗?这个怎么实现啊?



    服务端:
    PHP code
    
    $addr = "192.168.1.121";
    $port = 1338;
    
    $remoteIP = "";
    $remotePort = "";
    
    $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
    if($socket < 0) {
            echo "Socket create:".$socket_strerror($socket)."\n";
            exit;
    }
    if ( ($ret = socket_bind($socket, $addr, $port)) < 0 ) {
        echo "socket bind:".socket_strerror()."\n";
        exit;
    }
    if ( ($ret = socket_listen($socket, 5)) < 0 ) {
        echo "socket listen:".socket_strerror()."\n";
        exit;
    }
    
    socket_set_nonblock($socket);
    
    echo "Wainting for a connection:\n";
    
    $clients = array($socket);
    while(true) {
        $read = $clients;
        if(socket_select($read, $writes=NULL, $execs=NULL, 3) < 1){
            //echo ".";
            continue;
        }
    
        if(in_array($socket,$read)) {
            $clients[] = $newsock = socket_accept($socket);
            socket_set_nonblock($newsock);
            socket_getpeername($newsock,&$remoteIP,&$remotePort);        
            $key = array_search($socket,$read);
            unset($read[$key]);
            $msg = "Server: $addr\r\n".
                    "Notice:Welcome the user from ".$remoteIP.":".$remotePort.".\r\n";
            echo $remoteIP.":".$remotePort." conected in.\r\n";
            socket_write($newsock,$msg);
        }
    
        foreach($read as $read_sock) {
            $data = @socket_read($read_sock,1024,PHP_BINARY_READ);
            if($data == false) {
                $key = array_search($read_sock,$clients);
                print_r($clients[$key]);
                unset($clients[$key]);
                socket_close($read_sock);
                echo "Client disconnected.\n";
                continue;
            }
            
            $command = strtoupper ($data);
            
            switch ($command)
            {
                case "LIST":
                    $writer = print_r($clients,1);
                    break;
                case "HELLO":
                    $writer = "Hello Everybody!";
                    break;
                case "QUIT":
                    $writer = "Bye-Bye";
                    break;
                case "SLEEP":
                    sleep(30);
                    $writer = "sleeped 10 seconds!";
                    break;
                case "HELP":
                    $writer = "HELLO\tQUIT\tHELP";
                    break;
                default:
                    $writer = "Error Command!\r\nType help for help message!";
            }
    
            socket_write($read_sock, $writer);
            //exit;
        }
    }
    socket_close($socket);
    
    


    客户端:
    PHP code
    
    // Client  
     // 设置错误处理 
     error_reporting (E_ALL); 
     // 设置处理时间 
     set_time_limit (0); 
      
     $ip = "192.168.1.121";       // IP 地址 
     $port = 1338;            // 端口号 
      
     $socket = socket_create (AF_INET, SOCK_STREAM, SOL_TCP);   // 创建一个SOCKET 
     if ($socket) 
         echo "socket_create() successed!\n"; 
     else 
         echo "socket_create() failed:".socket_strerror ($socket)."\n"; 
      
     $conn = socket_connect ($socket, $ip, $port);       // 建立SOCKET的连接 
     if ($conn) 
         echo "Success to connection![".$ip.":".$port."]\n"; 
     else 
         echo "socket_connect() failed:".socket_strerror ($conn)."\n"; 
      
     echo socket_read ($socket, 1024);    
      
     $stdin = fopen ('php://stdin', 'r'); 
     while (true) 
     { 
         $command = trim (fgets ($stdin, 1024)); 
         socket_write ($socket, $command, strlen ($command)); 
         $msg = trim (socket_read ($socket, 1024)); 
         echo $msg."\n"; 
         if ($msg == "Bye-Bye") 
             break; 
     } 
     fclose ($stdin); 
     socket_close ($socket);
    
     
    声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn核实处理。
    专题推荐:quot socket read echo 192.168
    php培训_php实战培训【立即报名】-php中文网第20期

    相关文章推荐

    • 【活动】充值PHP中文网VIP即送云服务器• 分享一个有趣的php版本的扫雷!• php输出乱码有关问题 • 50分~哪位高手有mysql5.0的windows下的安装包?上传一下~ • 关于字符串的操作,可能需要用到正则,觉得很复杂解决思路 • 大家帮忙分析下这段函数输出?该如何解决
    1/1

    PHP中文网