在MongoDB中，可以以循環(huán)方式將文檔的插入順序保留到集合中。 這些類型的集合在MongoDB中稱為上限集合。 MongoDB文檔描述了上限集合：

上限集合是固定大小的集合，它們支持高吞吐量操作，這些操作根據(jù)插入順序來插入，檢索和刪除文檔。 上限集合的工作方式類似于循環(huán)緩沖區(qū)：一旦集合填滿了分配的空間，它就會通過覆蓋集合中最舊的文件為新文件騰出空間?！?

好的，所以我們知道什么是上限集合，但是如何創(chuàng)建集合呢？

在MongoDB Shell中，我們將使用db.createCollection命令創(chuàng)建一個有上限的集合：

db.createCollection("logs", {capped: true,size: 4096,max:5})

該命令告訴MongoDB創(chuàng)建一個稱為“日志”的集合，最大大小為4096字節(jié)，最多可容納5個文檔。 當添加第6個文檔時，第一個文檔將從集合中刪除，以確保該集合中最多只能有5個文檔。 “ size”參數(shù)是必需的，但是“ max”參數(shù)是可選的。

在Java中，有兩種常見的與MongoDB進行通信的方式： MongoDB Java驅動程序以及Morphia （用于將Java對象映射到MongoDB或從MongoDB映射的輕量級類型安全映射庫）。

首先，讓我們首先來看一下使用Java驅動程序。

Java驅動

再次使用Java驅動程序，我們使用db.createCollection命令，這一次傳遞了BasicDBObject作為參數(shù)。 此參數(shù)具有字段“封頂”，“大小”和“最大”，這些字段指定對集合進行封頂，集合的最大大小（以字節(jié)為單位）和集合中的最大條目數(shù)。 以下代碼段顯示了如何連接到MongoDB的本地實例并創(chuàng)建上限集合。

MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://localhost")); DB db = mongoClient.getDB("test");DBCollection collection; if (!db.collectionExists("cappedLogsJavaDriver")) {BasicDBObject options = new BasicDBObject("capped", true);options.append("size", 4096);options.append("max", 5);collection = db.createCollection("cappedLogsJavaDriver", options); } else {collection = db.getCollection("cappedLogsJavaDriver"); }

創(chuàng)建集合后，我們可以將文檔插入其中以確保其按預期工作。 以下代碼段顯示了如何將8個文檔插入到集合中（請記住，由于這是一個有上限的集合，因此將僅存儲其中的最后5個）。

for (int i = 0; i < 8; i++) {BasicDBObject logEntry = new BasicDBObject("logId", i);collection.insert(logEntry); }

使用MongoDB交互式外殼，我們可以驗證現(xiàn)在存儲在集合中的文檔是否符合預期。

> db.cappedLogsJavaDriver.find() { "_id" : ObjectId("54a1ca44a82617da4f72e025"), "logId" : 3 } { "_id" : ObjectId("54a1ca44a82617da4f72e026"), "logId" : 4 } { "_id" : ObjectId("54a1ca44a82617da4f72e027"), "logId" : 5 } { "_id" : ObjectId("54a1ca44a82617da4f72e028"), "logId" : 6 } { "_id" : ObjectId("54a1ca44a82617da4f72e029"), "logId" : 7 }

摩菲亞

現(xiàn)在，我們已經(jīng)了解了如何通過Java驅動程序創(chuàng)建集合，讓我們看看如何使用Morphia來完成相同的事情。

Morphia的本質(zhì)是將Java類映射到MongoDB或從MongoDB映射。 我們希望保留在MongoDB中的類使用@Entity注釋進行注釋，然后將其存儲在通常以該類進行命名的集合中。 要創(chuàng)建一個有上限的集合，我們必須在@Entity批注上添加其他值，以指定集合中的最大條目數(shù)和集合的大小。 對與Java驅動程序示例中使用的對象類型相同的模型進行建模，我們將創(chuàng)建一個LogEntry類，如下所示：

@Entity(value="cappedLogsMorphia", cap=@CappedAt(count=5, value=4096)) public class LogEntry {private int logId;@Idprivate ObjectId id;public LogEntry(int logId) {this.logId = logId;}public int getLogId() {return logId;}public void setLogId(int logId) {this.logId = logId;} }

我們可以看到該類帶有@Entity注釋，指定該集合最多應包含5個文檔和4096字節(jié)的大小。

使用Morphia，可以在啟動時通過調(diào)用Morphia Datastore上的.ensureCaps .ensureCaps()方法來創(chuàng)建有上限的集合，如下所示。

MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://localhost")); DB db = mongoClient.getDB("test");Morphia morphia = new Morphia(); morphia.map(LogEntry.class);Datastore datastore = morphia.createDatastore(mongoClient, "test"); datastore.ensureCaps();

再次，和以前一樣，我們可以將8個文檔插入集合中，以驗證僅存儲了最后5個文檔。

for (int i = 0; i < 8; i++) {LogEntry logEntry = new LogEntry(i);datastore.save(logEntry); }> db.cappedLogsMorphia.find() { "_id" : ObjectId("54a1ce9da82629642c64f5d9"), "className" : "com.davidsalter.cappedcollection.LogEntry", "logId" : 3 } { "_id" : ObjectId("54a1ce9da82629642c64f5da"), "className" : "com.davidsalter.cappedcollection.LogEntry", "logId" : 4 } { "_id" : ObjectId("54a1ce9da82629642c64f5db"), "className" : "com.davidsalter.cappedcollection.LogEntry", "logId" : 5 } { "_id" : ObjectId("54a1ce9da82629642c64f5dc"), "className" : "com.davidsalter.cappedcollection.LogEntry", "logId" : 6 } { "_id" : ObjectId("54a1ce9da82629642c64f5dd"), "className" : "com.davidsalter.cappedcollection.LogEntry", "logId" : 7 }

檢查收集狀態(tài)

在MongoDB中創(chuàng)建一個有上限的集合后，我們可以通過在Mongo DB交互式外殼程序中對該集合執(zhí)行.stats()方法來檢查其狀態(tài)。

> db.cappedLogsJavaDriver.stats() {"ns" : "test.cappedLogsJavaDriver","count" : 5,"size" : 180,"avgObjSize" : 36,"storageSize" : 4096,"numExtents" : 1,"nindexes" : 1,"lastExtentSize" : 4096,"paddingFactor" : 1,"systemFlags" : 1,"userFlags" : 0,"totalIndexSize" : 8176,"indexSizes" : {"_id_" : 8176},"capped" : true,"max" : 5,"ok" : 1 }

在這里，我們可以看到集合確實是有上限的（“ capped” = true），并且集合中的最大條目數(shù)是5（“ max” = 5）。

• 本文中使用的示例的源代碼可以在GitHub上找到 。

翻譯自: https://www.javacodegeeks.com/2015/03/creating-a-mongodb-capped-collection-in-java.html

總結

以上是生活随笔為你收集整理的用Java创建MongoDB上限集合的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。