使用 php 在 android 中使用 websocket 实现聊天

Posted 2023-04-13

【中文标题】使用 php 在 android 中使用 websocket 实现聊天

【英文标题】：Implement chat using websocket in android with php

【发布时间】：2014-08-17 05:55:04

【问题描述】：

我想通过 php 在 android 中使用 websocket 实现聊天功能。

我需要同样的 php 代码。

场景是这样的。

android 开发者将从 android 设备发送消息到 php 应用程序，然后从 php 将消息发送到另一个用户的 android 手机。

之后，我还需要将所有聊天记录保存在数据库中。

我不知道该怎么做。

请帮助并提供代码。

我写的代码如下。

$address = "0.0.0.0";
$port = 5000;
$max_clients = 10;

if(!($sock = socket_create(AF_INET, SOCK_STREAM, 0)))

    $errorcode = socket_last_error();
    $errormsg = socket_strerror($errorcode);

    die("Couldn't create socket: [$errorcode] $errormsg \n");


echo "Socket created \n";

// Bind the source address
if( !socket_bind($sock, $address , 5000) )

    $errorcode = socket_last_error();
    $errormsg = socket_strerror($errorcode);

    die("Could not bind socket : [$errorcode] $errormsg \n");


echo "Socket bind OK \n";

if(!socket_listen ($sock , 10))

    $errorcode = socket_last_error();
    $errormsg = socket_strerror($errorcode);

    die("Could not listen on socket : [$errorcode] $errormsg \n");


echo "Socket listen OK \n";

echo "Waiting for incoming connections... \n";

//array of client sockets
$client_socks = array();

//array of sockets to read
$read = array();

//start loop to listen for incoming connections and process existing connections
while (true) 

    //prepare array of readable client sockets
    $read = array();

    //first socket is the master socket
    $read[0] = $sock;

    //now add the existing client sockets
    for ($i = 0; $i < $max_clients; $i++)
    
        if($client_socks[$i] != null)
        
            $read[$i+1] = $client_socks[$i];
        
    

    //now call select - blocking call
    if(socket_select($read , $write , $except , null) === false)
    
        $errorcode = socket_last_error();
        $errormsg = socket_strerror($errorcode);

        die("Could not listen on socket : [$errorcode] $errormsg \n");
    

    //if ready contains the master socket, then a new connection has come in
    if (in_array($sock, $read)) 
    
        for ($i = 0; $i < $max_clients; $i++)
        
            if ($client_socks[$i] == null) 
            
                $client_socks[$i] = socket_accept($sock);

                //display information about the client who is connected
                if(socket_getpeername($client_socks[$i], $address, $port))
                
                    echo "Client $address : $port is now connected to us. \n";
                

                //Send Welcome message to client
                $message = "Welcome to php socket server version 1.0 \n";
                $message .= "Enter a message and press enter, and i shall reply back \n";
                socket_write($client_socks[$i] , $message);
                break;
            
        
    

    //check each client if they send any data
    for ($i = 0; $i < $max_clients; $i++)
    
        if (in_array($client_socks[$i] , $read))
        
            $input = socket_read($client_socks[$i] , 1024);

            if ($input == null) 
            
                //zero length string meaning disconnected, remove and close the socket
                unset($client_socks[$i]);
                socket_close($client_socks[$i]);
            

            $n = trim($input);

            $output = "OK ... $input";

            //echo "Sending output to client \n";

            //send response to client
            //socket_write($client_socks[1] , $output);

            //send response to client
            socket_write($client_socks[$i] , $output);
        
    

【问题讨论】：

你有什么解决方案吗，请告诉我我们需要同样的解决方案。

【参考方案1】：

查看此链接http://socketo.me/docs/hello-world

Ratchet 是一个松散耦合的 PHP 库，为开发人员提供了通过 WebSockets 在客户端和服务器之间创建实时、双向应用程序的工具。