MongoDB是用C ++編寫的面向開源文檔的NoSQL數據庫系統。 您可以從此處閱讀有關MongoDB的更多信息。

1.安裝MangoDB。

2.運行MongoDB

3.啟動MongoDB shell

mongo [ip_address]：[端口]
例如：mongo localhost：4000

4.首先創建一個數據庫。

在MangoDB Shell中輸入以下內容…

> use library

上面應該創建一個名為“ library”的數據庫。

現在查看是否已創建數據庫，只需鍵入以下內容-應該列出所有數據庫。

> show dbs;

5.將數據插入MongoDB。

首先，使用以下命令創建兩本書。

> book1 = {name : "Understanding JAVA", pages : 100}
> book2 = {name : "Understanding JSON", pages : 200}

現在，讓我們將這兩本書插入到名為books的集合中。

> db.books.save(book1)
> db.books.save(book2)

上面的兩個語句將在數據庫庫下創建一個稱為books的集合。 以下語句將列出我們剛剛保存的兩本書。

> db.books.find();{ "_id" : ObjectId("4f365b1ed6d9d6de7c7ae4b1"), "name" : "Understanding JAVA", "pages" : 100 }
{ "_id" : ObjectId("4f365b28d6d9d6de7c7ae4b2"), "name" : "Understanding JSON", "pages" : 200 }

讓我們再添加一些記錄。

> book = {name : "Understanding XML", pages : 300}
> db.books.save(book)
> book = {name : "Understanding Web Services", pages : 400}
> db.books.save(book)
> book = {name : "Understanding Axis2", pages : 150}
> db.books.save(book)

6.編寫地圖功能

讓我們以某種方式處理該圖書館藏書，我們需要找到頁數少于250頁且大于250頁的書籍數量。

> var map = function() {
var category;
if ( this.pages >= 250 ) 
category = 'Big Books';
else 
category = "Small Books";
emit(category, {name: this.name});
};

在此，由Map函數生成的集合將具有以下成員的集合。

{"Big Books",[{name: "Understanding XML"}, {name : "Understanding Web Services"}]);
{"Small Books",[{name: "Understanding JAVA"}, {name : "Understanding JSON"},{name: "Understanding Axis2"}]);

7.編寫減少功能。

> var reduce = function(key, values) {
var sum = 0;
values.forEach(function(doc) {
sum += 1;
});
return {books: sum};
};

8.針對books集合運行MapReduce。

> var count  = db.books.mapReduce(map, reduce, {out: "book_results"});
> db[count.result].find(){ "_id" : "Big Books", "value" : { "books" : 2 } }
{ "_id" : "Small Books", "value" : { "books" : 3 } }

上面說，我們有2本大書和3本小書。

上面使用MongoDB Shell完成的所有操作，也可以使用Java完成。 以下是它的Java客戶端。 您可以從此處下載所需的從屬jar。

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MapReduceCommand;
import com.mongodb.MapReduceOutput;
import com.mongodb.Mongo;public class MongoClient {/*** @param args*/public static void main(String[] args) {Mongo mongo;try {mongo = new Mongo("localhost", 27017);DB db = mongo.getDB("library");DBCollection books = db.getCollection("books");BasicDBObject book = new BasicDBObject();book.put("name", "Understanding JAVA");book.put("pages", 100);books.insert(book);book = new BasicDBObject();  book.put("name", "Understanding JSON");book.put("pages", 200);books.insert(book);book = new BasicDBObject();book.put("name", "Understanding XML");book.put("pages", 300);books.insert(book);book = new BasicDBObject();book.put("name", "Understanding Web Services");book.put("pages", 400);books.insert(book);book = new BasicDBObject();book.put("name", "Understanding Axis2");book.put("pages", 150);books.insert(book);String map = "function() { "+ "var category; " +  "if ( this.pages >= 250 ) "+  "category = 'Big Books'; " +"else " +"category = 'Small Books'; "+  "emit(category, {name: this.name});}";String reduce = "function(key, values) { " +"var sum = 0; " +"values.forEach(function(doc) { " +"sum += 1; "+"}); " +"return {books: sum};} ";MapReduceCommand cmd = new MapReduceCommand(books, map, reduce,null, MapReduceCommand.OutputType.INLINE, null);MapReduceOutput out = books.mapReduce(cmd);for (DBObject o : out.results()) {System.out.println(o.toString());}} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}
}

參考： Facile Login博客上的JCG合作伙伴 Prabath Siriwardena的MongoDB與MapReduce 。