如何使用 MemCache 或 Redis 在 PHP 和 Node 之间发送用户特定的数据

Question

我现在知道 MemCache 没有像我最初预期的那样工作，但我仍然无法在 PHP 和节点.

到目前为止我只安装了 Memcache，但如果我需要的话也可以安装 Redis，但是我需要一些方法来根据节点和节点上的会话或 cookie 数据来识别每个登录用户登录时的 Apache (PHP) 服务器。

我宁愿不使用随后用于引用数据库的通用会话 ID，但如果必须的话，我会使用。

这就是我在 PHP

中存储的方式

$memcache = new Memcache;
$memcache->connect('localhost',11211);
$uData = json_encode($_SESSION);
$memcache->set('Session',$uData);

这是我的原始 Node 文件，由于我误解了 Memcache 的功能，显然必须对其进行重大更改。

/*****************************************
 * 1. Configuration
 * 2. Declarations & Definitions
 * 3. Memcache & Session Vars
 * 4. Server Initiation
 * 5. Client Connections
 *  5-1. On Client Connect
 * 6. Helper Functions
 * 7. Utility Functions
 *****************************************/


/*****************************************
 * 1. Configuration
 *****************************************/
// Basic config options
var NodePortNumber = 1337; // t3h 13370rz
var MemCachePortNumber = 11211; // default MemCache port is 11211
var MySQLParams = {
    'Host': 'localhost',
    'User': 'user',
    'Pass': 'pass',
    'DB': 'database'
};


/*****************************************
 * 2. Declarations & Definitions
 *****************************************/

var Express = require('express')();
var HTTP = require('http').Server(Express);
var IO = require('socket.io')(HTTP);

var MySQL      = require('mysql');
var Database = MySQL.createConnection({
    host     : MySQLParams.Host,
    user     : MySQLParams.User,
    password : MySQLParams.Pass,
    database : MySQLParams.DB
});



/*****************************************
 * 3. Memcache & Session Vars
 *****************************************/

var MemCache, Session;

// Define a default value for all Session values so undefined warnings aren't thrown for non-members
Session = [];
Session['MemberID'] = 0;
Session['MemberEmail'] = undefined;
Session['MemberPass'] = undefined;

// Get session vars from Memcache
var Memcached = require('memcached');
MemCache = new Memcached('127.0.0.1:'+MemCachePortNumber); // connect to local memcached
MemCache.get('Session', function(err,result){
    Session = JSON.parse(result);
});


/*****************************************
 * 4. Server Initiation
 *****************************************/
// Initiate the Node server
HTTP.listen(NodePortNumber, function(){
    console.log('Server created. Socket listening on Port '+NodePortNumber);
});


/*****************************************
 * 5. Client Connections
 *****************************************/

var LiveClientCounter = 0; var Members = {};
var IsMember = false;

// Event fired every time a new client connects:
IO.sockets.on('connection', function (client) {
    /*****************************************
     * 5-1. On Client Connect
     *****************************************/
    var clientID = client.id;
    LiveClientCounter++;
    IO.emit('connection count', LiveClientCounter);
    console.log('Member '+Session['MemberID'] +' connected');
    if ( typeof Session['MemberID'] != typeof undefined && Session['MemberID'] > 0 ) {
        IsMember = true;
        if ( typeof Members[Session['MemberID']] == typeof undefined )
            Members[Session['MemberID']] = [];

        Members[Session['MemberID']][clientID] = {
            SocketOBJ: client,
            ClientID: clientID,
            MemberID: Session['MemberID']
        };

        console.log('Key added for Member #'+Session['MemberID']);
    }

});

Answer 1

你不能那样做

$memcache = new Memcache;
$memcache->connect('localhost',11211);
$uData = json_encode($_SESSION);
$memcache->set('Session',$uData);

每个用户都会覆盖会话密钥。

你可以这样做

$memcache = new Memcache;
$memcache->connect('localhost',11211);
$_SESSION['id'] = 'Session_' . phpsessionid();
$uData = json_encode($_SESSION);
$memcache->set($_SESSION['id'], $uData);

然后想办法让节点进程知道$_SESSION['id']

如何使用 MemCache 或 Redis 在 PHP 和 Node 之间发送用户特定的数据

How to send user-specific data between PHP and Node with MemCache or Redis

php

memcached

redis

node.js