插入到堆栈顶部的 MongoDB 并监听更新

Question

这是我的案例： 我在 Node.Js 中有一个 MongoDB 集合。

假设三个元素：a、b、c 我想插入新元素作为第一个元素，并希望最后一个元素消失。

所以它会是： d, a, b

在下一次迭代中： e、d、a

1.如何进行这种插入？

2.是否有机会监听来自另一个node.js应用程序的那些插入？像这样的东西

collection.on('update', function() {
  console.log('updated');    
});

Answer 1

1. 上限集合 MongoDB 中的保留插入顺序并丢弃最旧的项目总集合大小（不幸的是以字节为单位测量）。看起来非常适合您的场景。

2. 我相信MongoDB中还没有触发/通知机制，只有手动轮询。

Answer 2

处理此问题的另一种方法是编写一个自定义队列对象，如果队列中的项目总数超出了您的要求，则当新项目入队时，该对象将使最后一个项目出列，并发出“项目已添加”事件，该事件的其他部分您的应用程序可以监听。

下面是一些通用示例代码，您可以在其中将 Array、length、shift() 和 unshift() 的引用替换为对 MongoDB 的调用：

var util=require('util'),                         // for inheritance
    EventEmitter=require('events').EventEmitter, // for event handling
    MaxQueueItems=10;                             // default total items in queue

var FixedSizeQueue=function(max){
  this._storage=[]; // replace with call to MongoDB
  this._max_items=max||MaxQueueItems;
};

util.inherits(FixedSizeQueue,EventEmitter); // now I can emit

FixedSizeQueue.prototype._add=function(item){ // private
  // replace with call to MongoDB
  this.emit('onItemAdd', this._storage.unshift(item), item);
};

FixedSizeQueue.prototype._remove=function(){ // private
  // replace with call to MongoDB
  var item=this._storage.shift();
  if(item) {
    this.emit('onItemRemove', this._storage.length, item);
    return item;
  }
};

FixedSizeQueue.prototype.enqueue=function(item){
  if (this._storage.length+1 > this._max_items) {
    this._remove(); 
  }
  this._add(item);
  return(this); // for chaining
};

FixedSizeQueue.prototype.dequeue=function(){
  return this._remove();
};

可用作：

var q=new FixedSizeQueue(3); // a queue with only three items

q.on('onItemAdd',function(len,item){
  console.log('item added, queue now contains '+len+' items.');
});

q.on('onItemRemove',function(len,item){
  console.log('item removed, queue now contains '+len+' items.');
});

q.enqueue(1); // emits onItemAdd, queue = (1)

q.enqueue(2); // emits onItemAdd, queue = (2,1)

q.enqueue(3); // emits onItemAdd, queue = (3,2,1)

q.enqueue(1); // emits onItemRemove and onItemAdd, queue = (4,3,2)

控制台输出：

item added, queue now contains 1 items.
item added, queue now contains 2 items.
item added, queue now contains 3 items.
item removed, queue now contains 2 items.
item added, queue now contains 3 items.