实时聊天,消息处理 – Socket.io,PHP,MySQL,Apache

在Web开发方面,我是初学者.最近我一直在开发一个完全基于PHP和JS / jQuery的实时聊天网站(我没有使用任何框架).目前,我的设置只是简单的AJAX轮询,显然不如我想的那样好.我的数据库是一个 MysqL 数据库.

我已经阅读了有关websockets的内容,我的新初始计划是创建一个带有Socket.io的NodeJS服务器来处理消息(How to integrate nodeJS + Socket.IO and PHP?),我想将这些消息存储在MysqL 数据库中(MySQL with Node.js).

这是我目前的情况(不多,我想在实际取得进展之前澄清如何进步).这是我的测试设置,实际聊天中使用的HTML显然有点不同.

Node.js服务器：

// NODE
var socket = require( 'socket.io' );
var express = require( 'express' );
var https = require( 'https' );
var http = require( 'http'); //Old
var fs = require( 'fs' );

var app = express();

//Working HTTPS server 
var server = https.createServer({ 
               key: fs.readFileSync('/etc/letsencrypt/live/%site%/privkey.pem'),
               cert: fs.readFileSync('/etc/letsencrypt/live/%site%/fullchain.pem')
             },app);

// var server = https.createServer( app ); Won't work cause no cert. 

var io = socket.listen( server );
console.log("Server Started"); 
io.sockets.on( 'connection', function( client ) {
    console.log( "New client !" );

    client.on( 'message', function( data ) {
        console.log( 'Message received ' + data); //Logs recieved data
        io.sockets.emit( 'message', data); //Emits recieved data to client.
    });
});
server.listen(8080, function() {
    console.log('Listening');
});

JS客户端脚本：

var socket = io.connect('https://%site%:8080');



document.getElementById("sbmt").onclick = function () {

socket.emit('message', "My Name is: " + document.getElementById('nameInput').value + " i say: " + document.getElementById('messageInput').value); 

};

socket.on( 'message', function( data ) {
    alert(data); 
    });

我的超简单测试HTML：

<form id="messageForm">
<input type="text" id="nameInput"></input>
<input type="text" id="messageInput"></input>
<button type="button" id="sbmt">Submits</button>
</form>

PHP需要一些解释 – 当有人连接到我的网站时,我运行session_start().这是因为我希望有类似匿名会话的东西.我通过$_SESSION变量区分登录用户和匿名用户. anon用户将$_SESSION [‘anon’]设置为true,并且不会设置$_SESSION [‘username’].登录用户显然会倒置.

谈到聊天 – 它既可供登录用户使用,也可供匿名用户使用.当用户是匿名用户时,会从数据库或随机名称生成随机用户名.用户登录后,会选择自己的用户名.现在我的Ajax轮询系统的工作原理如下：

用户输入消息(在当前聊天解决方案中,而不是我上面发送的测试HTML)并按下回车键,并对以下功能进行AJAX调用：

  function sendMessage($msg, $col) {
    GLOBAL $db;
      $un = "";


    if (!isset($_SESSION['username'])) {

        $un = self::generaterandomUsername();

    } else {
    $un = $_SESSION['username'];
    }

    try {
      $stmt = $db->prepare('INSERT INTO chat (id, username, timestamp, message, color) VALUES (null, :un, Now(), :msg, :col)');
      $stmt->bindParam(':un', $un, PDO::ParaM_STR);
      $stmt->bindValue(':msg', strip_tags(stripslashes($msg)), PDO::ParaM_STR); //Stripslashes cuz it saved \\\ to the DB before quotes, strip_tags to prevent malicIoUs scripts. Todo: Whitelist some tags. 
      $stmt->bindParam(':col', $col, PDO::ParaM_STR);
        } catch (Exception $e) {
            var_dump($e->getMessage());
    }
      $stmt->execute();
  }

(请不要讨厌我的错误代码和糟糕的异常处理,这不是任何官方项目).此函数将用户消息输入数据库.

为了接收新消息,我使用JS的setTimeout()函数,在新消息之后每1秒运行一次AJAX检查.我保存了JS中显示的最后一条消息的ID,并将该ID作为参数发送到此PHP 函数(并且它每1秒运行一次)：

  /* Recieve new messages, ran every 1s by Ajax call */
  function recieveMessage($msgid) {
    //msgid is latest msg id in this case
    GLOBAL $db;
    $stmt = $db->prepare('SELECT * FROM chat WHERE id > :id');
    $stmt->bindParam(':id', $msgid, PDO::ParaM_INT);
    $stmt->execute(); 
    $result = $stmt->fetchAll(PDO::FETCH_ASSOC);
    return json_encode($result);

  }

问题是：如何实现类似的东西,但我之前提到的node.js服务器和websockets的设置？我需要以某种方式区分登录用户和匿名用户.我的第一个想法是从node.js服务器运行ajax调用到PHP并传递消息数据,PHP将把它完全插入到DB中.但是这种情况下的问题是如何再次将消息发送给客户端？在将消息输入数据库时应用用户名,这意味着我必须调用AJAX保存到数据库,然后调用另一个AJAX来提取新输入的消息并将其发送给客户端,或者创建一个函数插入和提取并返回提取的消息.但是,如果在同一时间输入2条消息,是否会导致问题？

是否有可能在Node.js中访问PHP会话变量？然后我可以重写所有数据库查询以在Node.js服务器而不是PHP中工作.

如果我的代码或解释很混乱,我再次道歉.

解决方法:

所以,对于每个想知道并将在未来找到这个主题的人：我没有找到我想要使用的解决方案的答案,但是我跟那些人在一起,这里有一个描述：

而不是让Node.js服务器发送AJAX请求,我把它留在以前,从客户端的jQuery $.post()请求到PHP 函数.

我接下来要做的是实现一个 MysqL监听器,它检查MysqL binlog的变化.我用过mysql-events模块.它使用所有数据检索新添加的行,然后使用socket.io emit函数将其发送到连接的客户端.我也不得不放弃SSL,因为它显然讨厌我.这是一个小型的爱好项目,所以我真的不必为SSL烦恼.

显然,最好的解决方案是在Node.js中编写整个Web服务器,然后完全删除Apache. Node.js对于实时应用程序来说非常棒,它是一种非常容易学习和使用的语言.

我的Node.js设置Socket.io MysqL-events :(忽略未使用的需求)

// NODE
var socket = require( 'socket.io' );
var express = require( 'express' );
var https = require( 'https' );
var http = require( 'http');
var fs = require( 'fs' );
var request = require( 'request' );
var qs = require( 'qs' );
var MysqLEvents = require('MysqL-events');

var app = express();


/*Correct way of supplying certificates.
var server = https.createServer({
               key: fs.readFileSync('/etc/letsencrypt/live/x/privkey.pem'),
               cert: fs.readFileSync('/etc/letsencrypt/live/x/cert.pem'),
               ca: fs.readFileSync('/etc/letsencrypt/live/x/chain.pem')
       },app); */

var server = http.createServer( app ); // Won't work without cert.

var io = socket.listen( server );
console.log("Server Started");

//DB credentials
var dsn = {
  host:     'x',
  user:     'x',
  password: 'x',
};
var MysqLEventWatcher = MysqLEvents(dsn);

//Watcher magic, waits for MysqL events.
var watcher = MysqLEventWatcher.add(
  'newage_db.chat',
  function (oldRow, newRow, event) {

     //row inserted
    if (oldRow === null) {
      //insert code goes here
      var res = JSON.stringify(newRow.fields); //Gets only the newly inserted row data
    res.charset = 'utf-8'; //Not sure if needed but i had some charset trouble so i'm leaving this. 
      console.log("Row has updated " + res);
      io.sockets.emit('message', "[" + res + "]"); //Emits to all clients. Square brackets because it's not a complete JSON array w/o them, and that's what i need. 
    }

     //row deleted
    if (newRow === null) {
      //delete code goes here
    }

     //row updated
    if (oldRow !== null && newRow !== null) {
      //update code goes here
    }

    //detailed event information
    //console.log(event)
  });

io.sockets.on( 'connection', function( client ) {
    console.log( "New client !" );



    client.on( 'message', function( data ) {
        //PHP Handles DB insertion with POST requests as it used to.
    });
});
server.listen(8080, function() {
    console.log('Listening');
});

客户端JavaScript发送消息：

$('#txtArea').keypress(function (e) {

  if (e.which == 13 && ! e.shiftKey) {

      var emptyValue = $('#txtArea').val();
      if (!emptyValue.replace(/\s/g, '').length) { /*Do nothing, only spaces*/ }
      else {
            $.post("/shana/?p=execPOST", $("#msgTextarea").serialize(), function(data) {

            });


  }

  $('#txtArea').val('');
  e.preventDefault();
}


});

Cliend JavaScript RECIEVE MESSAGE：

socket.on( 'message', function( data ) {
          var obj = JSON.parse(data);

          obj.forEach(function(ob) {
          //Execute appends

          var timestamp = ob.timestamp.replace('T', ' ').replace('.000Z', '');
          $('#messages').append("<div class='msgdiv'><span class='spn1'>"+ob.username+"</span><span class='spn2'style='float: right;'>"+timestamp+"</span><div class='txtmsg'>"+ob.message+"</div>");
          $('#messages').append("<div class='dashed-line'>- - - - - - - - - - - - - - - - - - - - - - - - - - -</div>"); //ADD SCROLL TO BottOM
          $("#messages").animate({ scrollTop: $('#messages').prop("scrollHeight")}, 1000);
        });
    });

不知何故,binlog魔法破坏了时间戳字符串,所以为了清理它我必须更换一些字符串本身.

PHP DB INSERT功能：

  function sendMessage($msg, $col) {
    GLOBAL $db;
      $un = "";


    if (!isset($_SESSION['username'])) {

        $un = self::generaterandomUsername();

    } else {
    $un = $_SESSION['username'];
    }
    try {
      $stmt = $db->prepare('INSERT INTO chat (id, username, timestamp, message, color) VALUES (null, :un, Now(), :msg, :col)');
      $stmt->bindParam(':un', $un, PDO::ParaM_STR);
      $stmt->bindValue(':msg', strip_tags(stripslashes($msg)), PDO::ParaM_LOB); //Stripslashes cuz it saved \\\ to the DB before quotes, strip_tags to prevent malicIoUs scripts. Todo: Whitelist some tags.
      $stmt->bindParam(':col', $col, PDO::ParaM_STR);
        } catch (Exception $e) {
            var_dump($e->getMessage());
    }
      $stmt->execute();
  }

我希望这至少可以帮助一些人.随意使用这段代码,因为我可能已经从互联网上复制了大部分内容:)我会不时检查这个帖子,所以如果你有任何问题请发表评论.

实时聊天,消息处理 – Socket.io,PHP,MySQL,Apache

相关推荐