我正在尝试创建一个PHP聊天，所以我server.php在终端上启动了服务器，它正在监听client连接：
<?php
function chat_leave( $sock, $chat_id = 0 )
{
if( $chat_room_id[ $chat_id ] )
{
unset( $chat_room_id[ $chat_id ] );
return true;
}
socket_close($sock);
return false;
}
function client( $input )
{
/*
Simple php udp socket client
*/
//Reduce errors
error_reporting(~E_WARNING);
$server = '127.0.0.1';
$port = 9999;
if(!($sock = socket_create(AF_INET, SOCK_DGRAM, 0)))
{
$errorcode = socket_last_error();
$errormsg = socket_strerror($errorcode);
die("Couldn't create socket: [$errorcode] $errormsg \n");
}
//Communication loop
while(1)
{
//Send the message to the server
if( ! socket_sendto($sock, $input , strlen($input) , 0 , $server , $port))
{
$errorcode = socket_last_error();
$errormsg = socket_strerror($errorcode);
die("Could not send data: [$errorcode] $errormsg \n");
}
//Now receive reply from server and print it
if(socket_recv ( $sock , $reply , 2045 , MSG_WAITALL ) === FALSE)
{
$errorcode = socket_last_error();
$errormsg = socket_strerror($errorcode);
die("Could not receive data: [$errorcode] $errormsg \n");
}
return $reply;
}
}
/*
* chat_join
* a new user joins the chat
* @username: String
* @password: String
*
* add a new listener to the server
*
*/
function chat_join( $username = "", $password = "" )
{
$users = array(
"batman" => "batman123",
"robin" => "robin123",
"joe" => "joe123"
);
if( $users[$username] == $password )
{
return true;
}
return false;
}
function main()
{
$chat_room_id = array();
$username = stripslashes( $_POST['username'] );
$password = stripslashes( $_POST['password'] );
$action = stripslashes( $_POST['action'] );
$port = intval( $_POST['port'] );
$domain = stripslashes( $_POST['domain'] );
$chat_id = intval( $_POST['chat_room_id'] );
if( strcmp( $action, "login" ) == 0 )
{
$status = chat_join( $username, $password );
if( $status )
{
$chat_room_id[] = $chat_id;
echo json_encode( $status );
}
}
else if( strcmp( $action, "chat" ) == 0 )
{
$msg = stripslashes( $_POST['message'] );
// take the message, send through the client
$reply = client( $msg );
echo json_encode( $reply );
}
else if( strcmp( $action, "logout") == 0 )
{
}
else
{
echo json_encode( false );
}
return;
}
main();
?>
该函数client()是我从client.php文件中获得的代码，当我在终端上执行时，它能够从server.php. 现在我想使用我的main.php文件，所以一旦用户登录，他就会向服务器发送消息，服务器会回复用户没有看到的消息。当我从两个不同的终端运行时server.php，client.php我可以发送和接收消息，但是我想使用main.php，将回复消息转换为一个JSON对象并发送回html页面，该页面将附加到一个textarea框。我的问题是：如何获取收到的回复client.php并将其发送回 html 页面？当我在终端上执行它时，我有：
Enter a message to send : hello
Reply : hello
我用来AJAX在聊天中发送用户输入，所以我希望能够接收该消息，并将其发送到服务器，我在终端上启动服务器，然后将回复返回并转发到网页并将其附加到文本框区域。我怎样才能做到这一点？我应该从client.php服务开始main.php吗？还是应该使用该client($input)函数发送消息，然后返回它发送的内容？但是，我希望它client一直运行到用户注销，因为其他客户端可能会连接到聊天。我怎么能做到这一点对我来说有点模糊。中的代码与client( $input )中相同client.php。