Mongodb，NodeJS CPU不断增加

分类：编程问答

如何解决Mongodb，NodeJS CPU不断增加

我们遇到一个问题，即每隔一段时间我们的节点应用程序的节点应用程序在100％CPU上运行。该服务器不是很活跃，通常在0％-2％CPU上运行。我想知道可能导致此问题的常见问题是什么，以及找出导致此问题的原因的最佳方法是什么。

服务器端代码下方的代码


var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var mongo = require('mongodb');
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://127.0.0.1:27017";
const fs = require('fs');
var port = process.env.PORT || 3110;

io.on('connection',function (socket) {
  console.log("connected");
  MongoClient.connect(url,{ useUnifiedTopology: true },function (err,db) {
 
  socket.broadcast.on('getMessages',function (msg) {
      var dbo = db.db("Hitesh");
      if (err) throw err;
       console.log(msg)
      dbo.collection(msg["collectionName"]).find({ "roomId": msg["roomId"] }).sort({ $natural: -1 }).limit(parseInt(msg["limit"])).skip(parseInt(msg["total"])).toArray(function (err,result) {
        if (err) throw err;
        result.slice().reverse().forEach(element => {
          io.to(socket.id).emit(msg["roomId"],element);
        });
        //db.close;
      });
  });


  socket.broadcast.on('getMessages_once',function (msg) {
   // MongoClient.connect(url,db) {
      var dbo = db.db("Hitesh");
      if (err) throw err;
      console.log(msg)
      dbo.collection(msg["collectionName"]).find({ "roomId": msg["roomId"] }).sort({ $natural: -1 }).limit(parseInt(msg["limit"])).skip(parseInt(msg["total"])).toArray(function (err,result) {
        if (err) throw err;
        console.log(result.length);
        io.to(socket.id).emit(msg["roomId"] + "_once",result.reverse());
        // result.slice().reverse().forEach(element => {

        // });
        //db.close;
      });
    //});
  });

  //---- send message to from client--///
  socket.broadcast.on('sendMessage',function (msg) {
    //MongoClient.connect(url,db) {
      var dbo = db.db("Hitesh");
      if (err) throw err;
      dbo.collection(msg["collectionName"]).insertOne(msg["data"],res) {
        if (err) throw err;
        var messsageData = {
          "roomId": msg["roomId"],"messageId": msg["messageId"],"collectionName": "conversations"
        };
        getMessageCount(messsageData);
        console.log("1 document inserted");
        msg["limit"] = "1";
        msg["total"] = "0";

        var val = { $set: msg["lastMessage"] };
        var Ids = { "roomId": msg["roomId"] };
        dbo.collection("conversations").findOneAndUpdate(Ids,val,{ upsert: true },res) {
          if (err) throw err;

          var FullArray = res["value"]["userList"];

          FullArray.forEach(element => {
            var someString = element;
            someString["collectionName"] = "conversations";
            MemberList(someString);
          });
        });

        dbo.collection(msg["collectionName"]).find({ "roomId": msg["roomId"] },{ limit: 1 }).sort({ $natural: -1 }).toArray(function (err,result) {
          if (err) throw err;
          result.forEach(element => {
            io.emit(msg["roomId"],element);
          });
          //db.close;
        });
      });
    //});
  });



  //-- add user to database -----///
  socket.broadcast.on('createUser',function (msg) {
    console.log("createUser");
    //MongoClient.connect(url,db) {
      var dbo = db.db("Hitesh");
      dbo.collection(msg["collectionName"]).find({ "userId": msg["userId"],"title": msg["title"] }).toArray(function (err,result) {
         console.log(result);
        if (result.length == 0) {
          dbo.collection(msg["collectionName"]).insertOne(msg,converRes) {
            console.log(converRes);
            //db.close;
          });
        }
        else {
          //db.close;
        }
      });
    //});
  });



  // --------   create Room   ----///
  socket.broadcast.on('createRoom',function (msg) {
    //console.log("createRoom");
   // MongoClient.connect(url,db) {
      var dbo = db.db("Hitesh");
      var dataObject = msg["data"];
      var roomid = dataObject["roomId"];
      dbo.collection(msg["collectionName"]).find({ "roomId": roomid }).toArray(function (err,result) {
        if (result.length == 0) {
          dbo.collection(msg["collectionName"]).insertOne(msg["data"],converRes) {
            // console.log(converRes["insertedId"]);
            io.emit('roomId',converRes["insertedId"]);
            //db.close;
          });
        }
        else {
          //db.close;
        }
      });
   // });
  });


  //---- get member list --////
  socket.on('getChatUserList',function (msg) {
    MemberList(msg);
  });

  function MemberList(msg) {
    //MongoClient.connect(url,db) {
      var dbo = db.db("Hitesh");
      if (err) throw err;
      var nameTopost = msg["userId"] + "_" + msg["title"];

      dbo.collection(msg["collectionName"]).find({ "userList.userId": msg["userId"],"userList.title": msg["title"] }).limit(parseInt(msg["limit"])).skip(parseInt(msg["total"])).toArray(function (err,result) {
        if (err) throw err;

        var userIdlist = [];
        result.forEach(element => {
          var someObject = element["userList"];

          someObject.forEach(obj => {
            userIdlist.push(obj)
          });
        });


        dbo.collection("users").find({ $or: userIdlist }).toArray(function (err,userData) {
          //console.log(userData);
          var someData = {
            "RoomList": result,"userData": userData,};
          //console.log(someData);
          io.emit(nameTopost,someData);
          //db.close;
        });

      });

   // });
  }


  ///----- get total message count ----/////
  socket.on('getTotalCount',function (msg) {
    getTotalCount(msg);
  });


  ///----- set total message count ----/////
  socket.on('setTotalCount',db) {
      var dbo = db.db("Hitesh");
      var val = { $set: msg };
      var Ids = { "totalCountId": msg["totalCountId"] };
      dbo.collection(msg["collectionName"]).findOneAndUpdate(Ids,res) {
        getTotalCount(msg);
      });
    //});
  });



  function getTotalCount(msg) {
    //MongoClient.connect(url,db) {
      var dbo = db.db("Hitesh");
      dbo.collection(msg["collectionName"]).find({ "totalCountId": msg["totalCountId"] }).toArray(function (err,result) {
        io.emit(msg["totalCountId"],result[0]);
        //db.close;
      });
    //});
  }



  socket.on('getMessageCount',function (msg) {
    getMessageCount(msg);
  });


  function getMessageCount(msg) {
   // MongoClient.connect(url,db) {
      if (err) throw err;
      var dbo = db.db("Hitesh");
      dbo.collection(msg["collectionName"]).find({ "roomId": msg["roomId"] }).toArray(function (err,result) {
        io.emit(msg["messageId"],result[0]);
        //db.close;
      });
   // });
  }

  socket.on('setMessageCount',db) {
      if (err) throw err;
      var dbo = db.db("Hitesh");
      var val = { $set: msg["data"] };
      var Ids = { "roomId": msg["roomId"] };
      dbo.collection(msg["collectionName"]).findOneAndUpdate(Ids,res) {
        //db.close
        getMessageCount(msg);
      });
   // });
  });

  });
});




http.listen(port,function () {
  console.log('listening on *:' + port);
});

... ..... ... ... ... 我不确定是什么原因导致了此问题

Following is the CPU usage

解决方法

似乎您在每个新的套接字连接上都创建了一个新的mongo连接：

io.on('connection',function (socket) {
  console.log("connected");
  MongoClient.connect(url,{ useUnifiedTopology: true },function (err,db) {

您应该创建一个连接并共享一个连接。我通常会创建与数据库的连接，然后然后启动HTTP和套接字服务器。

使用猫鼬的代码段，但概念相同–打开连接，然后设置服务器和处理程序：

mongoose.connect(`${config.db.uri}/${config.db.database}`,{useNewUrlParser: true,useUnifiedTopology: true,autoIndex: false});
const db = mongoose.connection;

db.once('open',() => {
    const app = express();

    app.db = db;
    ...

    const http = require('http').createServer(app);
    const io = require('socket.io')(http);
    ...

    http.listen(config.server.port,() => {
       console.log(`listening on ${config.server.port}`);
    });

    ...

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

导入项目后报错问题
依赖报错 idea导入项目后依赖报错，解决方案：https://blog.csdn.net/weixin_42420249/article/details/81191861 依赖版本报错：更换其他版本 无法下载依赖可参考：https://blog.csdn.net/weixin_42628809/a
idea不能识别yaml文件
使用mybatis plus常见错误
错误1：代码生成器依赖和mybatis依赖冲突 启动项目时报错如下 2021-12-03 13:33:33.927 ERROR 7228 [ main] o.s.b.d.LoggingFailureAnalysisReporter : *************************** APPL
gradle常见问题与错误
错误1：gradle项目控制台输出为乱码 # 解决方案：https://blog.csdn.net/weixin_43501566/article/details/112482302 # 在gradle-wrapper.properties 添加以下内容 org.gradle.jvmargs=-Df
Mybatis Plus传入参数0不起作用
错误还原：在查询的过程中，传入的workType为0时，该条件不起作用 <select id="xxx"> SELECT di.id, di.name, di.work_type, di.updated... <where> <if test=&qu
linux中make编译源码包失败
报错如下，gcc版本太低 ^ server.c:5346:31: 错误：‘struct redisServer’没有名为‘server_cpulist’的成员 redisSetCpuAffinity(server.server_cpulist); ^ server.c: 在函数‘hasActiveC
微服务启动错误：Command line is too long. Shorten command line for
解决方案1 1、改项目中.idea/workspace.xml配置文件，增加dynamic.classpath参数 2、搜索PropertiesComponent，添加如下 <property name="dynamic.classpath" value="tru
vue常见错误
删除根组件app.vue中的默认代码后报错：Module Error (from ./node_modules/eslint-loader/index.js): 解决方案：关闭ESlint代码检测，在项目根目录创建vue.config.js，在文件中添加 module.exports = { lin
spark常见错误
查看spark默认的python版本 [root@master day27]# pyspark /home/software/spark-2.3.4-bin-hadoop2.7/conf/spark-env.sh: line 2: /usr/local/hadoop/bin/hadoop: No s
matplotlib报错：AttributeError: module 'backend_interagg' has no attribute 'FigureCanvas'. Did you mean: 'FigureCanvasAgg'?
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 p
gitlab登录失败，报错：This challenge page was accidentally cached by an intermediary and is no longer available.
设置时间 控制面板
后端开发常见错误
错误1：Request method ‘DELETE‘ not supported 错误还原：controller层有一个接口，访问该接口时报错：Request method ‘DELETE‘ not supported 错误原因：没有接收到前端传入的参数，修改为如下 参考 错误2：cannot r
docker常见错误
错误1：启动docker镜像时报错：Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法：重启docker -> systemctl r
idea常见错误
错误1：private field ‘xxx‘ is never assigned 按Altʾnter快捷键，选择第2项 参考：https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2：启动时报错，不能找到主启动类 #
pip安装依赖失败
报错如下，通过源不能下载，最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
maven常见错误
错误1：maven打包报错 错误还原：使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
cloud项目中常见错误
错误1：服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping("/hires") public class FeignControl
springboot常见错误
错误1：运行项目后报如下错误 解决方案 报错2：Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案：在pom.
springmvc拦截器中使用redisTemplate报空指针异常
参考 错误原因 过滤器或拦截器在生效时，redisTemplate还没有注入 解决方案：在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate<String
vite报错：npm ERR! command C:WINDOWSsystem32cmd.exe /d /s /c C:UsersychenAppDataLocalTempnpx-dde1c848.cmd
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot