node链接mongodb数据库的方法详解【阿里云服务器环境ubuntu】
程序员文章站
2023-12-24 15:22:45
本文实例讲述了node链接mongodb数据库的方法。分享给大家供大家参考,具体如下:
一、安装2.6版本以上的mongodb在云服务器上(百度就能查到安装方法,以及验证...
本文实例讲述了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('<h3 style="font-size: 35px">' + xltitle1 + '</h3>' + '<pre style="white-space: pre-wrap;word-wrap: break-word;font-size: 30px">' + 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程序设计有所帮助。