0

データがデータベースに保存され、要求に応じて抽出されるマルチユーザー チャット システムを構築しようとしています。次のコードは単なる例であり、全体がうまく機能するようになったら変更する、優れた SQL インジェクションが多数含まれていることはわかっています。さらに、php サーバー コードを同じファイルに保持することは、コードを 1 か所にきちんと保持することです。ここで説明する問題は、サーバー コードが別の php ファイルにある場合にも存在していました。

コードは正常に動作しますが、しばらくするとデータベースが応答しなくなるという問題があります。より多くのユーザーが一度にチャットしている場合 (このスクリプトの複数のインスタンス)、データベースはすぐにしばらく応答を停止し、しばらくすると再び応答を開始します。私が間違っているところを親切に提案してください。

<?php
    if($_POST){
        $db=mysqli_connect("localhost","***","****","****");
        if ( isset($_POST['update']) ){
            $q = 0;
            $lasttime = isset($_POST['timestamp']) ? $_POST['timestamp'] : 0;
            while (1){
                sleep(3);
                $mresult = mysqli_query($db,"SELECT * FROM tblchat WHERE msg_datetime > $lasttime");
                $wresult = mysqli_query($db,"SELECT writer_alias FROM tblwriter WHERE writer_isactive=1 AND     (UNIX_TIMESTAMP(NOW())-last_activity)<10");
                if (mysqli_num_rows($mresult)){ $msgs = array(); while ($row = mysqli_fetch_object( $mresult )) { $msgs[] = $row; }     mysqli_free_result($mresult); echo json_encode(array("writers"=>$writers,"msgs"=>$msgs)); flush(); break; }
                if (mysqli_num_rows($wresult)){ $writers = array(); while ($row = mysqli_fetch_object( $wresult )) { $writers[] = $row; }   mysqli_free_result($wresult); echo json_encode(array("writers"=>$writers,"msgs"=>$msgs)); flush(); break; }
                ++$q;
                if ($q>15){ break; }
            }
        }elseif ( isset($_POST['save']) ){
            $msg = isset($_POST['msg']) ? $_POST['msg'] : '';
            if ($msg != ''){
                $from = $_POST["from"];
                $to = $_POST["to"];
                mysqli_query($db,"INSERT INTO tblchat VALUES('".$to."','".$from."','".$msg."','".time()."')");
                echo json_encode(array("success"=>"1"));
                flush();
            }
        }
        mysqli_close($db);
        exit();
    }
?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.1//EN" "http://www.w3.org/TR/xhtml11/DTD/xhtml11.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
  <head>
    <title>testing comet</title>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
    <script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.1/jquery.min.js"></script>
  </head>
  <body>
<p>
    <input type="text" name="word" id="word" value="" />
    <input type="button" name="send" value="Send" id="mybutton"/>
</p>
<div id="content"></div>

<script type="text/javascript">
var lastime = 0;
$("#mybutton").click(function(){
    $.post(location.href, {save:"1",from:"1",to:"5",msg:$("#word").val()}, function(data){
        console.log(data);
        $("#word").val("");
    }, "json");
});

$(document).ready( function(){ update(); } );

function update(){
    console.log("update called");
    $.ajax({ type: "POST", url: location.href, data: {update:"1",timestamp:lastime}, success: function(data1){
        console.log(data1);
        lastime = handleDATA(data1.msgs);
    }, dataType: "json", complete: update, timeout: 60000 });
}

function handleDATA (data){
    for(i=0;i<data.length;i++){
        $("#content").append(data[i].msg_from +": "+ data[i].msg+"</br>");
    }
    return data[data.length-1].msg_datetime;
}
</script>

</body>
</html>
4

1 に答える 1

0

これが絶対的な解決策である場合とそうでない場合がありますが、コードでいくつかのことを修正しましょう (また、よりわかりやすくするための書式設定もいくつか修正します)。

古いセクション (7 行目から 15 行目):

while (1){
    sleep(3);
    $mresult = mysqli_query($db,"SELECT * FROM tblchat WHERE msg_datetime > $lasttime");
    $wresult = mysqli_query($db,"SELECT writer_alias FROM tblwriter WHERE writer_isactive=1 AND     (UNIX_TIMESTAMP(NOW())-last_activity)<10");
    if (mysqli_num_rows($mresult)){ $msgs = array(); while ($row = mysqli_fetch_object( $mresult )) { $msgs[] = $row; }     mysqli_free_result($mresult); echo json_encode(array("writers"=>$writers,"msgs"=>$msgs)); flush(); break; }
    if (mysqli_num_rows($wresult)){ $writers = array(); while ($row = mysqli_fetch_object( $wresult )) { $writers[] = $row; }   mysqli_free_result($wresult); echo json_encode(array("writers"=>$writers,"msgs"=>$msgs)); flush(); break; }
    ++$q;
    if ($q>15){ break; }
}

上部の新しい機能:

// This is separate of the while below, put this
// function at top of your script (less code later)

function toArray( myqli_result $result )
{
    while( $row = mysqli_fetch_object( $result ) )
    {
        $array[] = $row;
    }
    mysqli_free_result( $result );

    return $array;
}

新しい While ステートメント:

//Replacement While Function
while( $q < 15 )
{
    sleep(3);

    $mresult = mysqli_query( $db, "SELECT * FROM tblchat WHERE msg_datetime > $lasttime" );
    $wresult = mysqli_query( $db, "SELECT writer_alias FROM tblwriter WHERE writer_isactive = 1 AND ( UNIX_TIMESTAMP( NOW() ) - last_activity ) < 10" );

    //If you need both results, you must check for both results
    //And do what you need to do, BEFORE break;
    if ( mysqli_num_rows( $mresult ) > 0 && mysqli_num_rows( $wresult ) > 0 )
    {
        $msgs = toArray( $mresult );
        $writers = toArray( $wresult );

        echo json_encode( array( "writers" => $writers, "msgs" => $msgs ) );

        flush();
        break;
    }
    ++$q;
}

きれいなコードはプログラマーを幸せにし、後でデバッグするのもずっと簡単になります。

両方の結果セットが必要な場合 (そうであるように思われます)、コードのように両方を取得することはできません。これにより、json_encode の前に両方のクエリを処理できます。

ここでtoArray( mysqli_result $result )は、オブジェクトの生成のみを受け入れmysqli_resultて配列を返し、結果を解放する関数があります。

同じコード行を異なる変数で何度も書いていることに気付いた場合は、代わりに関数を作成することをお勧めします。

于 2013-08-30T21:14:43.177 に答える