MongoDB是一款现在非常流行的NoSql引擎。我看上的原因有两点。
1、完美支持php。非常丰富的接口。
2、高并发的插入和写入对比mysql有极大的优势。我测试过。搜索平均是2.5倍。插入和update是10倍左右。数据就不贴上来了。
但也有很多限制。32位系统,单文件大小不能超过2G。。。插入数据的时候比较依赖内存,内存太小得把虚拟内存搞大点或者完全删除掉虚拟内存的限制
安装、介绍以及手册:www.mongodb.com 资源非常丰富。
上代码
class MDBBrowser{
//链接
private $connect;
private $db = null;
protected $table_name = "statistic";
protected $collection = "browser";
protected $memStorage = null;
//服务器信息
private $config = array(
"host" => "localhost", //服务器
"user" => "sampeng", //用户名
"password" => "这里是你的密码", //密码
"unique" => false //唯一性
);
public function __construct(){
$this->connect();
$this->selectDB();
if($this->config['unique']){
//TODO增加用户唯一性
$this->intMemStorage();
}
}
/**
* 选择数据库
* @param $name 数据库名
* @return 返回collection对象
*/
public function table($name){
$this->collection = $name;
return $this->collection;
}
/**
* 存储方法
* 将appid的需要累计加1的字段自动加1
* @param $appid appid。在命名空间下的应用id
* @param $uid uid.做该操作的用户。这个是用来做限制判断的
* @param $field 需要计数的count字段。比如reader。dig。follow等等
* @param $namespace 命名空间
*/
public function storage($appid,$uid,$field = "reader",$namespace = "default"){
$this->insertAndUpdateTime();
if(! ( $this->config['unique'] && $this->checkUnique($uid,$appid,$namespace)) ) {
//检查该项是否存在
$count = $this->db->count(array('ns'=>$namespace,'appid'=>$appid));
if(0 == $count){
$data['ns'] = $namespace;
$data['appid'] = $appid;
$save[$field] = 0;
$result = $this->db->save($data,$save);
}else{
$data['ns'] = $namespace;
$data['appid'] = $appid;
$result = $this->db->update($data,array('$inc'=>array($field=>1)));
unset($data);
}
}
}
/**
* 获得命名空间下的某个资源的统计计数
* @param $appid
* @param $field 允许逗号分隔
* @param $namespace
*/
public function getCount($appid,$field = 'reader',$namespace = "default"){
$map['ns'] = $namespace;
$map['appid'] = $appid;
$fields = explode(',',$field);
$data = $this->db->findOne($map,$fields);
array_shift($data);
if(1 == count($fields)){
$data = $data[$field];
}
return $data;
}
/**
* 给定一个值,单位秒。检查是否超时。
* 这个是全局的,没有做每个命名空间下的超时检查
* @param $checkTime 单位秒
*/
public function checkUpdateTime($checkTime = 300){
$map['status'] = "extra";
$data = $this->db->findOne($map,array('insertTime','updateTime'));
return $data['updateTime'] - $data['insertTime'] >= $checkTime;
}
/**
* 将指定命名空间的所有数据弹出来。返回数组。
* 此操作将更新初始存储的insertTime和updateTime
*
* @param $namespace stirng|false false时是所有的数据
* @param $remove false|true true时所有历史数据
*/
public function popNsData($namespace,$remove = false){
if(!$namespace){
//所有ns下的统计数据都取出来
$map['status']['$ne'] ='extra';
}else{
//只取一部分
$map['ns'] = $namespace;
}
$data = $this->db->find($map);
$result = array();
while($data->hasNext()){
$data->next();
$tempData = $data->current();
$appId = $tempData['appid'];
unset($tempData['_id']);
$result[$tempData['ns']][$appId] = $tempData;
}
if(!empty($result)){
if($remove){
$this->db->remove($map);
}
//修改更新时间
$statusWhere['status'] = "extra";
$time = time();
$statusSave['insertTime'] = $time;
$statusSave['updateTime'] = $time;
$this->db->update($statusWhere,$statusSave);
}
return $result;
}
protected function connect(){
$config = $this->config;
$this->connect = new Mongo("mongodb://{$config['user']}:{$config['password']}@{$config['host']}");
return $this;
}
protected function selectDB(){
$database = $this->connect->selectDB($this->table_name);
$this->db = $database->selectCollection($this->collection);
return $this->db;
}
protected function insertAndUpdateTime(){
$time = time();
$count = $this->db->count();
//判断是否有数据
if(0 == $count){
$data['status'] = "extra";
$data['insertTime'] = $time;
$data['updateTime'] = $time;
$this->db->insert($data);
}else{
$where['status'] = "extra";
$save['$set']['updateTime'] = $time;
$this->db->update($where,$save);
}
}
}
我的存储结构是这样的
{
"_id": "4c4be8437f8b9a1b36000000",
"appid": 1,
"ns": "default",
"reader": 15
}
{
"_id": "4c4bd4197f8b9a9832000000",
"insertTime": 1280042037,
"updateTime": 1280042037
}
我想的是还可以这样
{
"_id":XXX
"ns":"default”,
"info1":
{
appid:XX,
reader:XXX
}
}
就是一个namespace就只用一个数据集完全存储。。查询倒是可以。。只是我觉得这样比较麻烦。扩展也不方便。。还是用平铺的方式存储就够了。。过多的设计就是过度设计- -
比如这个帖子的浏览数就可以这样增加
$a = new MDBBrowser();
$a->storage(1,2,'reader','bbs');
支持和反对的ajax接受方这样处理
$a = new MDBBrowser();
$a->storage(1,2,'dig','bbs');
等等等等。。。
分享到:
相关推荐
前端 Vue+Node+MongoDB高级全栈开发
图书管理系统,java+express+mongodb+nodejs+gulp.zip 图书管理系统,java+express+mongodb+nodejs+gulp.zip 图书管理系统,java+express+mongodb+nodejs+gulp.zip 图书管理系统,java+express+mongodb+nodejs+...
SpringBoot+MongoDB+Echarts图表数据可视化 SpringBoot+MongoDB+Echarts图表数据可视化
django+mongodb+hui 实现的后台管理系统.zipdjango+mongodb+hui 实现的后台管理系统.zipdjango+mongodb+hui 实现的后台管理系统.zipdjango+mongodb+hui 实现的后台管理系统.zipdjango+mongodb+hui 实现的后台管理...
SpringBoot+Redis+Mqtt+MongoDB全部配置完成,下载Redis+Mqtt+MongoDB三个程序,把项目导入idea中再把SQL导入数据库下好依赖即可,注意Redis,MongoDB,Mqtt账户信息,如不一致可更换成自己的,CURD已完成
基于SpringBoot + Mybatis + Thymeleaf +Redis+MongoDB+MySQL开发的商品管理系统。基于SpringBoot + Mybatis + Thymeleaf +Redis+MongoDB+MySQL开发的商品管理系统。基于SpringBoot + Mybatis + Thymeleaf +Redis+...
Python + MongoDB开发的百度云爬虫.zipPython + MongoDB开发的百度云爬虫.zipPython + MongoDB开发的百度云爬虫.zipPython + MongoDB开发的百度云爬虫.zipPython + MongoDB开发的百度云爬虫.zipPython + MongoDB开发...
nodejs+express+mongodb 博客系统增删改查完整版,包括用户注册,博客发表,博客修改,博客删除,权限控制。后台连接mongodb:blog
基于springboot+mongodb搭建的简约个人博客系统 基于springboot+mongodb搭建的简约个人博客系统 基于springboot+mongodb搭建的简约个人博客系统 基于springboot+mongodb搭建的简约个人博客系统 基于springboot+...
初学mongodb,用php+mongodb写了一个小练习,主要是练习mongodb的增删改查,供大家学习参考,不喜勿下。
springboot+springmvc+mybatis+redis+mongodb整合
基于NodeJS+Express+mongoDB+Bootstrap的全栈式工程化开发前后端分离博客系统实战
物流管理系统源码,基于spirngboot+mongodb+layui.zip
功能包括: 多人注册、登录、发表文章、登出、文章编辑与删除、存档、标签、分页、留言、用户个人主页、文章PV统计及留言统计、增加用户头像、 标题关键字查询(有限的正则查询)、转载功能、日志功能
MongoDB高级技术栈全覆盖 前端 Vue+Node+MongoDB高级全栈开发
nodejs + express + ejs + mongodb 一个非常简单的前后端开发的实例
nodejs + mongodb 资源 合集 01
资源中存有springmongo配置,mongo数据库相关配置,mongo实现类等等
maven(jersey+redis+mongodb+spring)集成
自己电脑需要安装mongodb数据库 和mongoose ,自己在用的时候,记得要和对应数据库和表名一致