Đa luồng trong Node.js?

Question

Tôi đang triển khai socket.io trong node.js cho dự án Windows Azure. Tôi phải gửi dữ liệu đến tất cả các khách hàng được kết nối theo các khoảng thời gian đều đặn.

Tôi mới sử dụng node.js nhưng tôi đoán không thể đa luồng được. Mục đích của socket.io là hỗ trợ các ứng dụng thời gian thực, vì vậy có cách nào để tôi có thể gửi dữ liệu liên tục đến tất cả các máy khách được kết nối của tôi theo chu kỳ bình thường và cũng xử lý bất kỳ dữ liệu nào mà máy khách gửi đến máy chủ socket.io cùng một lúc không?

EDIT:

Đây là khoảng thực hiện socket.io tôi

var io = require('socket.io').listen(80); 

io.sockets.on('connection', function (socket) { 
    socket.emit('first', "connected"); 

    socket.on('clientData', function (data) { 
    //processing the data 
    }); 
}); 

function requestQueue() { 
// some processing 
io.sockets.emit('broadcast', recordsQueue); 
// should go to sleep for a time period 
} 

Về cơ bản tôi muốn phương pháp requestQueue được chạy liên tục như một chủ đề, mà sẽ phát ra dữ liệu cho khách hàng kết nối trong khoảng thời gian cụ thể. Và cũng có thể nếu khách hàng gửi bất kỳ dữ liệu nào đến sự kiện "clientData", thì tôi sẽ có thể nhận dữ liệu và xử lý nó.

Bất kỳ ý tưởng nào về cách tôi có thể làm điều đó?

Cảm ơn

Giải pháp của tôi:

var io = require('socket.io').listen(80); 

io.sockets.on('connection', function (socket) { 
    socket.emit('first', "connected"); 

    socket.on('clientData', function (data) { 
    //processing the data 
    }); 
}); 

function requestQueue() { 
var sleepTime = 0; 

// calcuate sleepTime 

io.sockets.emit('broadcast', recordsQueue); 

// should go to sleep for a time period 
    if(sleepTime !=0) 
    setTimeout(function() { requestQueue() }, sleepTime); 
} 

Answer 1

Như những người khác đã gợi ý, bạn có thể đạt được điều này bằng cách sử dụng các setInterval hoặc setTimeout chức năng định kỳ phát ra dữ liệu cho khách hàng được kết nối. Mặc dù mọi thứ chạy trong cùng một chuỗi điều khiển, tất cả các I/O được thực hiện không đồng bộ nên ứng dụng của bạn sẽ vẫn phản hồi. IE, mọi dữ liệu nhận được trong khi bộ hẹn giờ đang chạy sẽ được xếp hàng đợi và xử lý sau khi chức năng hẹn giờ trả về.

Xem Timers trong hướng dẫn sử dụng node.js để biết thêm thông tin.

---

Một lưu ý phụ, bạn sẽ muốn ứng dụng node.js tập trung xử lý I/O không đồng bộ trong thời gian thực gần như là sức mạnh của node.js. Nếu bạn cần phải làm bất kỳ tính toán nặng sau đó bạn sẽ muốn offload đó đến một thread/quá trình nào đó, bằng cách đơn giản làm cho một yêu cầu async cho kết quả.

Answer 2

Bạn đang phải, nút là đơn ren. Nhưng nó làm cho việc sử dụng nhiều sự kiện.

Chiến lược bạn nên thực hiện là lắng nghe các sự kiện trên kết nối, truy xuất dữ liệu và khi bạn muốn gửi lại dữ liệu, bạn làm điều đó vì một sự kiện khác đã được phát hành.

Nếu bạn xem các ví dụ trên frontpage socket.io, bạn sẽ thấy cách chúng sử dụng các sự kiện để bắt đầu xử lý luồng. Phương thức on (eventName, function) là cách bạn nghe cho một sự kiện trong NodeJS.

Nếu bạn muốn làm điều gì đó dựa trên thời gian (thường là ý tưởng tồi), hãy xem phương thức setInterval.

server

var io = require('socket.io').listen(80); 

    io.sockets.on('connection', function (socket) { 
     socket.emit('news', { hello: 'world' }); 
     socket.on('my other event', function (data) { 
     console.log(data); 
     }); 
    }); 

Khách hàng

<script src="/socket.io/socket.io.js"></script> 
    <script> 
     var socket = io.connect('http://localhost'); 
     socket.on('news', function (data) { 
     console.log(data); 
     socket.emit('my other event', { my: 'data' }); 
     }); 
    </script> 

Answer 3

Logic bạn xác định bên trong setInterval, v.v.sẽ không hoạt động trong một chuỗi riêng biệt và cuối cùng là chặn chính. Giả sử có 1000 người dùng và bạn gọi setTimeout v.v. trong 1000 lần, cuối cùng họ sẽ chạy và dành thời gian quý giá đó. Chỉ các hoạt động IO cuối cùng là không chặn!

Bạn có thể xem xét điều tra nodeJX cho đa luồng trong Node.js

Answer 4

Ngoài ra còn có một thư viện Node.js để làm bài: nút-WebWorker-đề

https://github.com/audreyt/node-webworker-threads

này về cơ bản thực hiện các Web Worker browser API cho node.js.

Lưu ý rằng điều này không phù hợp với triết lý chuỗi đơn của node.js, nhưng ở đó nếu bạn cần.

Answer 5

Đa luồng trong Node.js?

Có ..it là có thể trong nodejs sử dụng mô-đun NPM 'java4node', nó gói này một phương pháp là .multiThreading (nhiệm vụ, callbacks) Chức năng này là sử dụng cho thực hiện đa luồng trong java script cách

cho sử dụng liên kết này mô-đun : https://www.npmjs.com/package/java4node

chạy khen

NPM cài đặt java4node

var java = require('java4node') 

java.multiThreading({ 
      one: function(callback,parameters) { 
       console.log("function one is running independently"); 
       callback() 
      }, 
      two: function(callback,parameters) { 
       console.log("function two is running independently"); 
       callback() 
      }, 
      three: function(callback,parameters) { 
       console.log("function three is running independently"); 
       callback() 
      } 
     }, function(err, results) { 
      callback(err, results) 
     });