【发布时间】：2012-12-03 20:54:56
【问题描述】：
我正在尝试创建一个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 发送聊天中的用户输入，所以我希望能够接收该消息，并将其发送到服务器，我在终端上启动并将回复返回并转发到网页并将其附加到文本框区域。
我怎样才能做到这一点？我应该通过main.php 将client.php 作为服务启动吗？还是应该使用client($input) 函数发送消息，然后返回它发送的内容？
但是，我希望 client 在用户注销之前一直运行，因为其他客户端可能会连接到聊天。我怎么能做到这一点对我来说有点模糊。 client( $input )中的代码与client.php中的代码相同。
【问题讨论】：
-
另外请记住，PHP 并非旨在运行超过一个请求。它可以运行更长时间（前一段时间做过聊天机器人），但如果你不是很小心，你很有可能会泄漏内存和崩溃。其他语言可能更适合常驻应用。