Cách khắc phục sự cố không đồng bộ của MongoDB/Node này?

Question

Tôi có đoạn mã sau:

// Retrieve 
var MongoClient = require("mongodb").MongoClient; 
var accounts = null; 
var characters = null; 

// Connect to the db 
MongoClient.connect("mongodb://localhost:27017/bq", function(err, db) { 
    if(err) { return console.dir(err); } 

    db.createCollection('accounts', function(err, collection) { 
     if(err) { return console.dir(err); } 
     else { accounts = collection; } 

     createAccount("bob","bob"); 
     createAccount("bob","bob"); 
     createAccount("bob","bob"); 
     createAccount("bob","bob"); 
    }); 
}); 


function createAccount(email, password) 
{ 
    accounts.findOne({"email":email}, function(err, item) { 
     if(err) { console.dir(err); } 
     else { 
      if(item === null) { 
       accounts.insert({"email":email, "password":password}, function(err, result) { 
        if(err) { console.dir(err); } 
        else { console.dir("Account " + email + " created."); } 
       }); 
      } 
      else { 
       console.dir("Account already exists.") 
      } 

     } 
    }); 
} 

Khi tôi chạy kịch bản lần đầu tiên, tôi kết thúc với 4 tài khoản cho bob. Khi tôi chạy nó lần thứ hai, tôi nhận được 4 thông báo rằng tài khoản đã tồn tại.

Tôi khá chắc chắn rằng tôi biết tại sao điều này xảy ra và giải pháp mà tôi đưa ra là sử dụng hàng đợi loại nào đó để xử lý từng đọc/ghi cơ sở dữ liệu theo thứ tự một lần. Những gì tôi muốn biết, liệu đó có phải là cách thích hợp để đi về nó hay không, và thực hành chung tốt nhất cho việc này là gì?

Answer 1

Một số ngôn ngữ cung cấp một cấu trúc ngôn ngữ đặc biệt để giải quyết vấn đề này. Ví dụ: C# có các từ khóa async/await cho phép bạn viết mã như thể bạn đang gọi các API đồng bộ.

JavaScript không và bạn phải chuỗi các cuộc gọi createAccount có gọi lại.

Một số người đã phát triển các thư viện có thể giúp bạn tổ chức mã này. Ví dụ async, step, node-promise và Q

Bạn cũng có thể sử dụng fibers thư viện, thư viện bản địa kéo dài thời gian chạy JavaScript với sợi/coroutines.

Và một số người đã mở rộng ngôn ngữ với các cấu trúc tương tự như async/await: streamline.js, IcedCoffeeScript hoặc wind.js. Ví dụ, streamline.js (Tôi là tác giả vì vậy tôi rõ ràng là thiên vị) sử dụng _ như một giữ chỗ gọi lại đặc biệt và cho phép bạn viết ví dụ của bạn như:

var db = MongoClient.connect("mongodb://localhost:27017/bq", _): 
var accounts = db.createCollection('accounts', _); 
createAccount("bob","bob", _); 
createAccount("bob","bob", _); 
createAccount("bob","bob", _); 
createAccount("bob","bob", _); 

function createAccount(email, password, _) { 
    var item = accounts.findOne({"email":email}, _); 
    if (item === null) { 
     accounts.insert({"email":email, "password":password}, _); 
     console.log("Account " + email + " created."); } 
    } else { 
     console.log("Account already exists.") 
    } 
} 

Và, cuối cùng nhưng không kém, ngôn ngữ mới các tính năng như generators và deferred functions đang được thảo luận cho các phiên bản tương lai của JavaScript (máy phát điện rất có khả năng hạ cánh trong ES6, chức năng trì hoãn có vẻ hơi bị trì hoãn).

Vì vậy, bạn có nhiều lựa chọn:

• dính vào callbacks
• sử dụng một thư viện helper
• sử dụng phần mở rộng sợi runtime
• sử dụng một phần mở rộng ngôn ngữ
• chờ ES6

Answer 2

JavaScript không đồng bộ. accounts.findOne trả về ngay lập tức, vì vậy về cơ bản tất cả 4 câu lệnh của bạn đang được thực hiện cùng nhau.

Điều gì accounts.findOne là, nó nói tìm một {"email":email} và khi bạn tìm thấy, hãy chạy hàm trong đối số thứ hai. Sau đó, nó trả về hàm và tiếp tục đến câu lệnh CreateAccount tiếp theo. Trong khi đó khi các kết quả được trả về từ ổ đĩa cứng (mất nhiều thời gian hơn việc thực hiện các câu lệnh này), nó đi vào hàm, và vì không có người dùng, nó thêm một. Có ý nghĩa?

CẬP NHẬT Đây là cách phù hợp để thực hiện việc này trong JavaScript.

MongoClient.connect("mongodb://localhost:27017/bq", function(err, db) { 
    if(err) { return console.dir(err); } 

    db.createCollection('accounts', function(err, collection) { 
     if(err) { return console.dir(err); } 
     else { accounts = collection; } 

     createAccount("bob","bob", function() { 
      createAccount("bob","bob", function() { 
       createAccount("bob","bob", function() { 
        createAccount("bob","bob", function() { 
        }); 
       }); 
      }); 
     }); 
    }); 
}); 


function createAccount(email, password, fn) 
{ 
    accounts.findOne({"email":email}, function(err, item) { 
     if(err) { console.dir(err); } 
     else { 
      if(item === null) { 
       accounts.insert({"email":email, "password":password}, function(err, result) { 
        if(err) { console.dir(err); } 
        else { console.dir("Account " + email + " created."); } 
        fn(); 
       }); 
      } 
      else { 
       console.dir("Account already exists.") 
       fn(); 
      } 

     } 
    }); 
} 

Answer 3

Thêm ràng buộc duy nhất trên email và bạn sẽ không phải kiểm tra xem người dùng có tồn tại nữa không!