测试bigpipe

Author: tangguangyao

README.md

@@ -36,4 +36,6 @@ http://hi.baidu.com/tang_guangyao/item/302a9d1a9976c06ae65e0643
 
 使用外网免费数据库https://app.mongohq.com
 
-测试部署分支
+测试部署分支
+
+尝试bigpige

app.js

@@ -24,19 +24,19 @@ app.use(express.bodyParser({uploadDir:'./uploads'}));
 //app.use(express.bodyParser());
 app.use(express.methodOverride());
 app.use(express.cookieParser());
-// app.use(express.session({
-//   secret: settings.cookieSecret,
-//   key: settings.db,
-//   cookie: {maxAge: 1000 * 60 * 60 * 24 * 30},//30 days
-//   store: new MongoStore({
-//     db: settings.db
-//   })
-// }));
 app.use(express.session({
   secret: settings.cookieSecret,
+  key: settings.db,
   cookie: {maxAge: 1000 * 60 * 60 * 24 * 30},//30 days
-  url: settings.url
+  store: new MongoStore({
+    db: settings.db
+  })
 }));
+// app.use(express.session({
+//   secret: settings.cookieSecret,
+//   cookie: {maxAge: 1000 * 60 * 60 * 24 * 30},//30 days
+//   url: settings.url
+// }));
 //声明静态引用在前，路由规则在后
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(app.router);

models/connect.js

@@ -2,17 +2,8 @@
 保持数据库一直连接，保存一个全局变量
 */
 
-var mongodb = require('mongodb').Db;
-var settings = require('../settings');
+var mongodb = require('./db');
 
-// var mongodb = require('./db'),
-// 	settings = require('../settings');
-
-// mongodb.open(settings.url,function(err,db){
-// 	global.db=db;
-// });
-
-
-mongodb.connect(settings.url, function (err, db) {
-	global.db=db;
-});
+mongodb.open(function(err,db){
+  global.db=db;
+});

models/db.js

@@ -1,8 +1,8 @@
-// var settings = require('../settings'),
-//     Db = require('mongodb').Db,
-//     Connection = require('mongodb').Connection,
-//     Server = require('mongodb').Server;
+var settings = require('../settings'),
+    Db = require('mongodb').Db,
+    Connection = require('mongodb').Connection,
+    Server = require('mongodb').Server;
 
-// module.exports = new Db(settings.db, new Server(settings.host, Connection.DEFAULT_PORT, {}), {safe: true});
+module.exports = new Db(settings.db, new Server(settings.host, Connection.DEFAULT_PORT, {}), {safe: true});
 
 

public/js/bigpipe.js

@@ -0,0 +1,17 @@
+var Bigpipe=function(){
+	this.callbacks={};
+}
+
+Bigpipe.prototype.ready=function(key,callback){
+	if(!this.callbacks[key]){
+		this.callbacks[key]=[];
+	}
+	this.callbacks[key].push(callback);
+}
+
+Bigpipe.prototype.set=function(key,data){
+	var callbacks=this.callbacks[key]||[];
+	for(var i=0;i<callbacks.length;i++){
+		callbacks[i].call(this,data);
+	}
+}

public/js/tgy/index.js

@@ -37,7 +37,7 @@ function IndexCtrl($scope, $http, $templateCache) {
       //如果没有信息，就不请求
       return;
     }
-    $scope.url = 'http://xueqiu.com/stock/quote.json?code='+stockCode+'&key=47bce5c74f&access_token=qPVhzoKJWIL1o3UCSgUfRK&_=1389259380479&callback=JSON_CALLBACK';
+    $scope.url = 'http://xueqiu.com/stock/quote.json?code='+stockCode+'&key=47bce5c74f&access_token=qPVhzoKJWIL1o3UCSgUfRK&_=1389603586048&callback=JSON_CALLBACK';
     $scope.code = null;
     $scope.response = null;
     $http({method: $scope.method, url: $scope.url, cache: $templateCache}).
@@ -95,6 +95,11 @@ function IndexCtrl($scope, $http, $templateCache) {
         $scope.topList=topList=data.list;
       }
     });
+  //bigpipe请求热门股
+  var bigpipe=new Bigpipe();
+  bigpipe.ready('hotStock',function(data){
+    var l;
+  })
 
   //请求热门用户
   //由于后端同时请求了热门股票，会导致mongodb同时开启导致bug，暂时注释
@@ -214,7 +219,7 @@ function IndexCtrl($scope, $http, $templateCache) {
           $scope.topList=newTopList;
           //刷新我的收藏
           $scope.addMethod = 'JSONP';
-          $scope.addUrl = 'http://xueqiu.com/stock/quote.json?code='+topStockUid+'&key=47bce5c74f&access_token=gbQtYjUWioQ9DQWGpDIREK&_=1386664870607&callback=JSON_CALLBACK';
+          $scope.addUrl = 'http://xueqiu.com/stock/quote.json?code='+topStockUid+'&key=47bce5c74f&access_token=qPVhzoKJWIL1o3UCSgUfRK&_=1389603586048&callback=JSON_CALLBACK';
           $http({method: $scope.addMethod, url: $scope.addUrl, cache: $templateCache}).
             success(function(data, status) {
               //请求关注的数据