单个 .JSON 文件上的两个 Node.JS 脚本 read/write,但第一个脚本无法修改文件

Two Node.JS scripts read/write on a single .JSON file but the first script cant modify the file

我在 Ubuntu 服务器上的 Node.JS 中有两个 discord 机器人(app.js 和 activity.js)运行。我面临的问题是,当它们都是 运行 时,只有 activity.js 能够修改文件。该文件是 users.JSON 。 app.js代码:

const Discord = require("discord.js")
var moment = require("moment")
var data_users = fs.readFileSync('/home/discord/activity_bot/users.json', 'utf-8')
var arxeio = JSON.parse(data_users)
...
for (var i in duos) {
  if (arxeio[duos[i].username]) {
     console.log(`before: ` + arxeio[duos[i].username])
     arxeio[duos[i].username]+=15
     console.log(`after: ` + arxeio[duos[i].username])
  } else {
     arxeio[duos[i].username]=15
  }
}
fs.writeFile('/home/discord/activity_bot/users.json', JSON.stringify(arxeio, null, 2), 'utf-8', function(err) {
  if (err) throw err
  console.log('entered')
})

Activity.js 的代码是:

const Discord = require("discord.js");
var fs = require('fs');
var data = fs.readFileSync('/home/discord/activity_bot/users.json', 'utf-8')
var arxeio = JSON.parse(data)
...
var kuklos = setInterval(function(done) {
        client.guilds.get('323921290543235073').channels.forEach(function(kanali, kanaliID) {
          if (kanali.type === 'voice' && !kanali.name.includes("AFK")) {
            kanali.members.forEach(function(melos, melosID) {
              let xristis = melos.user.username;
              if (arxeio[xristis]) {
                arxeio[xristis]++;
              } else {
                arxeio[xristis] = 1
              }
              fs.writeFile('/home/discord/activity_bot/users.json', JSON.stringify(arxeio, null, 2), 'utf-8', function(err) {
                  if (err) throw err
              })
            })
          }
        })
      }, 60*1000);

其中,duos 是 table 个成员。 我得出的结论是,问题出在 App.js 中的 fs.writeFile,因为当 activity.js 不是 运行 时,它就起作用了。当 activity.js 运行时 "entered" 确实记录在 app.js 中,但文件未被修改。此外,+= 命令上方和下方的命令都显示它已被修改但未保存在 users.Json 文件中。知道应该怪什么吗? (除了我的 skillz :P )

我认为问题出在您的应用程序设计上。你完全可以用两个进程共享一个文件,但是你总是会遇到并发问题。

对于这类事情,您必须使用锁定 rows/tables 的数据库。