使用无模式数据库来改造dz的session

作者 : admin 于 2009年12月29日, 09:26:58
2009
12-29

前两天还不知道啥是无模式数据库，不过最近迫切需要修改discuz bbs的session表，所以研究了一下相关的资料，发现了无模式这个名字。

具体无模式是啥，这里找了两篇文章：

关系数据库的末日是否已经来临
关系数据库的根本问题分析及数据库革命之走向

关于无模式的应用案例，很典型的一个，就是康盛uchome的feed表。

这里简单介绍几个无模式数据库，供大家参考：

mongodb : http://www.mongodb.org/display/DOCS/Home

mongodb的php扩展 http://www.mongodb.org/display/DOCS/Installing+the+PHP+Driver#InstallingthePHPDriver-PECL

这个数据库已经在淘宝上配合10gen做了云计算的session（名字很操蛋）,具体资料在这里 http://rdc.taobao.com/blog/dw/archives/410。具有了实际应用的东西应该很不错，不过我没尝试过。

Tokyo Tyrant：http://1978th.net/

tt的php扩展 http://www.php.net/manual/en/book.tokyo-tyrant.php

这个大家就比较熟悉了，SB日本鬼子写的东西，应用很广，sina，qq等公司里都在大量应用，sina的研发团队在此基础上还做了个分布式的东东，很是不错。据说这玩意还得到了很多公司的赞助，shit。

TCSQL：张宴基于tt开发的一套东西，内部做了很多算法优化，具体可参考此文章 http://blog.s135.com/tcsql/

总结：康盛使用mysql来存储session，不能说是一种错，但对于dz的负载绝对是第一个瓶颈。用这种方式，在线人数5w对数据库绝对是个坎。很多负载比较大的论坛，都做了此方面的优化，比如，给session表单独一个数据库，或者干脆阉割此功能。不错，独立的session表，或者分库，访问量大的时候，瓶颈依然在mysql上；阉割此功能，有些心疼，而且很多运营数据会丢失。所以，保持原功能而平滑提升性能，是一个不错的解决方向。

Session处理，比较怪异的应用

作者 : admin 于 2008年12月04日, 23:47:35
2008
12-4

其实我很不喜欢把session放在数据库中处理，不过公司一直这么用，就先这么写，更倒霉的是，花了老大力气集成在一个不适合大项目的小框架里。
session本来是用URI类统一处理，过滤全局变量中的不安全因素，这样依赖，因为要重写session的几个方法，把原来的流程整得乱七八糟。
我正在想，是不是要把他做成一个钩子，钩挂在原来系统中，通过命令的方式开关，这样貌似是个不错的办法，不过，得把钩子的类写好……

补充：session放到数据库中的好处：可以即时得查看在新的用户（当然不是非常准确），可以踢人，如果是有登录认证的话。缺点：速度贼拉得慢，不如放到内存中。操作一次内存，得反复读写数据库，且不说硬盘，网络传输就是不消的消耗。

使用mysql保存session，并建立在线用户列表

作者 : admin 于 2008年08月15日, 23:02:21
2008
08-15

写OA，使用mysql存储session，这样，是为了获得在线用户的列表，为做一个web im做准备。

首先创建表,注，这里使用了adodb中数据字典的描述方法：

  1. $Session_Fields = "
  2. session_id VARCHAR(100) NOTNULL,
  3. session_value X DEFAULT '',
  4. session_expires I(10) DEFAULT NULL,
  5. userid I(5) DEFAULT NULL
  6. ";
  7. $Session_Tables = array('mysql' => "ENGINE = MYISAM CHARACTER SET utf8 COLLATE utf8_unicode_ci COMMENT = 'session表'");
  8. $dict = NewDataDictionary(GetDB());
  9. $sqlarray = $dict->CreateTableSQL($_CFG['table']['session'], $Session_Fields, $Session_Tables);
  10. $dict->ExecuteSQLArray($sqlarray);

然后session类:

  1. <?php
  2. /*  Session.Class.php
  3.  *  Session Manager
  4.  *  @link        http://www.sunboyu.cn
  5.  *  @package     OA
  6.  *  @version     V1.0
  7.  *
  8.  *  2008 08 14  sunboyu@gmail.com
  9.  */
  10. class Session
  11. {
  12. var $lifetime;
  13. var $db = null;
  14. function __construct()
  15. {
  16. #return adodb lite connetction
  17. $this->db = GetDB();
  18. }
  19. #open
  20. function open( $savepath , $session_name )
  21. {
  22. $this->lifetime =  get_cfg_var("session.gc_maxlifetime");
  23. return true;
  24. }
  25. #close
  26. function close()
  27. {
  28. return true;
  29. }
  30. #read
  31. function read( $session_id )
  32. {
  33. global $_CFG;
  34. $sql = sprintf("SELECT * FROM %s WHERE session_id = %s",$_CFG['table']['session'],GetSqlString( $session_id ));
  35. $rs = $this->db->Execute( $sql );
  36. if($rs->RecordCount()>0)
  37. {
  38. $result = $rs->fields;
  40. return $result['session_value'];
  41. }
  42. else
  43. {
  44. return null;
  45. }
  46. }
  47. #write
  48. function write( $session_id , $session_value )
  49. {
  50. global $_CFG;
  51. $sql = sprintf("SELECT session_id FROM %s WHERE session_id = %s",$_CFG['table']['session'],GetSqlString( $session_id ));
  52. $rs = $this->db->Execute( $sql );
  53. if($rs->RecordCount()==0)
  54. {
  55. $newsql = sprintf("INSERT INTO %s SET session_id = %s , session_value = %s , session_expires = %d",
  56. $_CFG['table']['session'],
  57. GetSqlString( $session_id ),
  58. GetSqlString( $session_value ),
  59. GetSqlString( $this->lifetime+time() , "int" ));
  60. }
  61. else
  62. {
  63. $newsql = sprintf("UPDATE %s SET session_value = %s , session_expires = %d WHERE session_id = %s",
  64. $_CFG['table']['session'],
  65. GetSqlString( $session_value ),
  66. GetSqlString( $this->lifetime+time() , "int" ),
  67. GetSqlString( $session_id ));
  68. }
  69. return $this->db->Execute( $newsql );
  70. }
  71. #destroy
  72. function destroy( $session_id )
  73. {
  74. global $_CFG;
  75. $delsql = sprintf("DELETE FROM %s WHERE session_id = %s",$_CFG['table']['session'],GetSqlString( $session_id ));
  76. return $this->db->Execute( $delsql );
  77. }
  78. #gc
  79. function gc()
  80. {
  81. global $_CFG;
  82. $gcsql = sprintf("DELETE FROM %s WHERE session_expires < %d",$_CFG['table']['session'],time());
  83. return $this->db->Execute( $gcsql );
  84. }
  85. }
  86. ?>

session机制，之前已经介绍，实现代码如下

  1. $session = new Session();
  2. session_set_save_handler(array(&$session,"open"),
  3. array(&$session,"close"),
  4. array(&$session,"read"),
  5. array(&$session,"write"),
  6. array(&$session,"destroy"),
  7. array(&$session,"gc"));
  8. session_start();

把session与用户id对应，使用以下语句即可

  1. sprintf("UPDATE %s SET userid = %d WHERE session_id = %s",$_CFG['table']['session'],GetSqlString($rs['id'],'int'),GetSqlString(session_id(),'text'))

完美的用户登录验证流程

作者 : admin 于 2008年08月07日, 12:52:18
2008
08-7


登  录  ────────── →  多域
↓
写 session  ────────── →  写cookie
↓                                  ＼
用户session列表  →  在线用户列表      cookie登录
＼  在线踢人

使用Mysql来存储Session

作者 : admin 于 2008年07月31日, 22:39:29
2008
07-31

接上篇，我们已经知道session的具体存储机制，我们来尝试修改一下这个机制，让数据存储在mysql数据库中。

mysql有三部分的内容，session session_data session_expires分别为session的id session的内容，session的过期时间。

创建这样一个数据库

CREATE TABLE IF NOT EXISTS `sessions` (
`session` varchar(255) character set utf8 collate utf8_bin NOT NULL,
`session_expires` int(10) unsigned NOT NULL default ‘0′,
`session_data` mediumtext collate utf8_unicode_ci,
KEY `session` (`session`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

相对于文件方式的session存储，这两个函数是不用动的
function open($save_path, $session_name)
{
global $sess_save_path;

$sess_save_path = $save_path;
return(true);
}

function close()
{
return(true);
}
而需要修改的是读，写，删，过期操作的函数

读的操作，很简单，只是从数据库中，根据sessionid，读出date字段中的内容
function read($sessID) {
global $php_errormsg;
// fetch session-data
$query = ”
SELECT session_data FROM sessions
WHERE session = ‘$sessID’
AND session_expires >
“.time();
$result = $this->mdb2->query($query);
// return data or an empty string at failure
if (MDB2::isError($result)) {
$php_errormsg .= $result->getMessage();
$php_errormsg .= $result->getDebugInfo ();
return false;
}
list($value)=@$result->fetchrow();
return $value;
}
同理，写的操作就是update数据，destory的操作为删除session的记录，另外有个gc的操作是删除过期的session。
具体的代码没有去实现，但在PHP手册上都有。同时手册还介绍了memcache储存的方式，效率应该会不错的。

这是本月最后一篇日志，也算为下月找个题。

PHP session机制详解

作者 : admin 于 2008年07月31日, 20:27:05
2008
07-31

http://cn.php.net/manual/en/function.session-set-save-handler.php

php的session函数非常好用，使用非常简单，$_SESSION[$name] = **  直接写session，而$_SESSION[$name]就可以直接读session。现在剖析一下简单背后，php是如何工作的。看上边的链接，

bool session_set_save_handler ( callback $open , callback $close , callback $read , callback $write , callback $destroy , callback $gc )

此函数有六个动作，关于session的初始化，结束，读，写，删，和超时处理。

open：初始化session存储路径信息。

close：关闭session。

read：读session的内容

write：写session的内容

destroy：删除session内容

gc：删除过期session

可以看这些函数实现，使用了file操作，在服务端写数据保存session。而这些数据以session专有的格式进行存储，类似cookie的，大家可以试着分解一下。

我找了个session，在editplus下打开 是这样的：

UserID|s:1:”1″;UserName|s:5:”admin”;