本文實例講述了node鏈接mongodb數據庫的方法。分享給大家供大家參考，具體如下：
一、安裝2.6版本以上的mongodb在云服務器上（百度就能查到安裝方法，以及驗證是否安裝成功一般是mongodb –version）；
二、因為mongodb的默認開啟端口是27017，所以要在Ubuntu上開啟這個端口：
ufw allow 27017
ufw enable
ufw reload
ufw status //這是查看這個端口是否開啟，iptables --list也可以查看
光在服務器開了端口還不行，還要在阿里云服務器控制臺的安全組中添加這個端口：
三、在node項目中利用npm安裝mongodb：
npm i mongodb --save
四、鏈接的具體代碼（前提是已經建立了簡單的http或者https服務），具體代碼：
const http = require('http')
, https = require('https');
const express = require('express');
const bodyParser = require('body-parser')
const app = express();
const fs = require('fs');
const ejs = require('ejs');
const path = require('path');
const MongoClient = require('mongodb').MongoClient;
// 返回信息
const questions = {
code: 200,
msg: 'success',
};
// https證書，開https服務的自驗證證書
const options = {
key: fs.readFileSync('./privatekey.pem'),
cert: fs.readFileSync('./certificate.pem')
};
let xltitle = '標題（初始化數據）',
xlcontent = '內容（初始化數據）',
xlfaceid = '1（初始化數據）';
const url = 'mongodb://127.0.0.1/xlbase';
// 默認端口27017，無需填寫
// 也可以修改端口，vim /etc/mongodb.conf
// 初始化數據庫
MongoClient.connect(url, function (err, db) {
if (err) throw err;
let database = db.db('xlbase');
console.log('------------數據庫初始化成功------------');
// 如果沒有face這個集合，會創建一個，所以可以用這個來初始化集合
database.createCollection('face', function (err, res) {
if (err) throw err;
console.log('------------集合初始化完畢------------');
db.close();
});
});
//設置跨域訪問
app.all('*', function (req, res, next) {
res.header("Access-Control-Allow-Origin", "*");
res.header("Access-Control-Allow-Headers", "X-Requested-With");
res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
res.header("X-Powered-By", ' 3.2.1');
// res.header("Content-Type", "application/json;charset=utf-8");
next();
});
// parse application/x-www-form-urlencoded 解析
app.use(bodyParser.urlencoded({extended: false}));
// parse application/json 解析
app.use(bodyParser.json());
// view engine setup，視圖模版
app.set('views', path.join(__dirname, './'));
app.set('view engine', 'jade');
// 靜態資源解析路徑（css，js，圖片等）
app.use(express.static(path.join(__dirname, './static')));
// 數據接收接口
app.post('/info', function (req, res) {
res.header("Content-Type", "application/json;charset=utf-8");
res.status(200);
xltitle = req.body.title;
xlcontent = req.body.content;
xlfaceid = req.body.faceId;
let info = {
'faceid': xlfaceid,
'title': xltitle,
'content': xlcontent
};
let faceid = {
'faceid': xlfaceid
};
let updateInfo = {$set: info};// 組裝更新的信息
MongoClient.connect(url, function (err, db) {
let database = db.db('xlbase');
database.collection('face').find(faceid).toArray(function (err, result) {
if (err) throw err;
// 判斷集合中faceid和當前傳過來的faceid是否相同和存在
// 如果不存在就新插入這條數據
// 如果存在且相同，就更新數據
if (result.length !== 0 && result[0].faceid === xlfaceid) {
database.collection("face").updateOne(faceid, updateInfo, function (err, res) {
if (err) throw err;
console.log("------------數據更新成功------------");
db.close();
});
} else {
database.collection('face').insertOne(info, function (err, res) {
if (err) throw err;
console.log("------------數據添加成功------------");
db.close();
})
}
})
});
res.json(questions); // 返回信息
res.end(JSON.stringify(req.body, null, 2))
});
app.get('/index', function (req, res) {
res.status(200);
res.header("Content-Type", "text/html;charset=utf-8");
// 根據faceId查詢數據
MongoClient.connect(url, function (err, db) {
if (err) throw err;
let dbo = db.db("xlbase");
let face = {"faceid": xlfaceid}; // 查詢條件
let xltitle1 = 404;
let xlcontent1 = '網頁出錯！';
dbo.collection("face").find(face).toArray(function (err, result) {
if (err) throw err;
console.log(result);
xltitle1 = result[0].title;
xlcontent1 = result[0].content;
db.close();
console.log('------------查詢完畢------------');
res.send('<h4 >' + xltitle1 + '</h4>' +
'<pre >' + xlcontent1 + '</pre>');
res.end();
});
});
})
// 配置服務端口
// http.createServer(app).listen(3001, function () {
// console.log('3001')
// });
process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0"; // 繞過證書驗證
https.createServer(options, app).listen(8009, function () {
console.log('port: 8009');
});
// var server = app.listen(3001, function () {
//
// var host = server.address().address;
//
// var port = server.address().port;
//
// console.log('Example app listening at http://%s:%s', host, port);
// })
希望本文所述對大家nodejs程序設計有所幫助。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
