php的session和并发

php的session和并发

某天，我准备登录我们一个后台系统，前去解决一个bug，在账户密码验证码都准确输入的情况下，我登录不上，经过多次实验发现主要有两个错误信息：

我们的系统

我们的系统是基于 2.0.8 开发的，如你所见，我们在表单域加入了防止csrf攻击的域。也启用了验证码。

我首先对这两个组件进行查阅，发现他们都是将数据存于：

# phalcon/security.zep
# Security::getToken
let session = 

$this->session->set('admin_get_captcha_action', $captcha);

然后我又查阅了我们的实现，发现是将数据存储于redis的。

找啊找

什么问题导致我登录不上呢？既然是数据验证上出现问题，就从数据着手吧，我登陆我们测试环境的redis机器，执行 redis-cli ,然后走一遍登录流程，发现输出如下(意思意思):

GET sessionId  
GET sessionId  
SETEX sessionId 3600 csrf=xxxx  
SETEX sessionId 3600 captcha=abcd  

我们可以看到：

这里存在两次请求，一次是表单加载，一次是生成验证码的。 存在“并发”的情况，这两个请求应该是表单加载渲染后才请求验证码的，也就是顺序应该是get->set->get->set,看起来怎么是并发请求了。 后面那个SETEX没有csrf的内容，也就是覆盖掉前面的数据了

整个世界都不好了，不过也稍微明白是什么问题了。什么问题呢，说来话长，要从PHP的数据的存取说起。

php的数据的存取

的数据是经过编码成字符串存储在存储器【file、db、redis、等】的，在我们使用的时候，是什么时候去储存器取数据的？又是什么时候将数据写入存储器的？

这个问题的答案可能和一些朋友想的不一样，一个请求里面，PHP只会读取一次存储器，在的时候，然后也只会写入一次存储器php ===，在请求结束的时候，或调用的时候，将数据刷回存储器，关闭。

那么问题来了：

如果一个会话，同时出现两个读写请求，没有保证获取1-写入1-获取2-写入2php ===，同时没有cas版本管理机制的情况下，这些并发请求就会彼此读取不到对方的写入，最后写入的会把前面请求写入的覆盖掉。 如果请求是串行的，像登录页面的表单和验证码，也有可能前面的请求已经输出内容了，但是还没写入，后面的请求就已经发起了。锁与不锁

解决这种资源的并发一般会通过锁或版本管理来处理。但是版本管理我看不到好的方法。就聊聊锁吧。

其实锁是不大适合，有弊端的。

php的，默认是用文件存储的，在打开的时候，会对文件加独占锁，这样，其它请求就无法获取锁了php的session和并发，只能等待直到前面的锁解了。

这样保证了 读取-写入，读取-写入的顺序。

其它存储器，例如mysql，可以借助 for 进行行锁。redis可以通过一个自增键，返回1的获取到锁等来实现。

这个实现的话php的session和并发，对数据流来说很理想，但是，对于目前这种页面大量应用ajax的情况，所有请求排队处理，将大大加大页面展现的耗时php ===，甚至出现请求超时等不可用故障。

没有解决的解决不建议过多使用，其一次读取一次写入的机制所引发的问题，会造成坑的存在。 在模版渲染前，或请求输出前调用

# 立刻回写session,避免session覆盖
$eventManager = $this->view->getEventsManager;
if (!$eventManager) {  
    $eventManager = new Manager;
    $this->view->setEventsManager($eventManager);
}
$eventManager->attach("view:afterRender",function{
    session_write_close;
});
return $this->view;  

if($login) {  
    # 立刻回写session,避免session读取不到
    $eventManager = $this->dispatcher->getEventsManager;
    if (!$eventManager) {
        $eventManager = new Manager;
        $this->dispatcher->setEventsManager($eventManager);
    }
    $eventManager->attach('dispatch:afterDispatchLoop',function{
        session_write_close;
    });
    return $this->response->setHeader('Location', '/');
}