不是重复:这个问题,因为我试图使用发布的链接作为答案来解决我的问题。
我正在创建一个小的虚拟套接字客户端来帮助测试我的一个产品,它看起来像这样:
var ee = require('events').EventEmitter;
require('http').globalAgent.maxSockets = 1000;
function Dummy(){
this.config = require('../config/credentials.js');
this.socket = require('socket.io-client')(this.config.socketIO.url);
var self = this;
this.socket.on('task', function(task) {
self.createTask(task);
});
}
util.inherits(Dummy, ee);
module.exports = Dummy;
Dummy.prototype.createTask = function(name){
var self = this;
setInterval(function sendStuff(){
self.socket.emit("msg")
}, 1000);
};
Run Code Online (Sandbox Code Playgroud)
就其本身而言,它运行良好;但是,当我尝试像这样启动其中许多时:
for (var i = 0; i < 100; i++) {
fakeClients.push(new Dummy());
};
Run Code Online (Sandbox Code Playgroud)
Is 出现在池连接中并仅显示为一个客户端。基于此链接,我认为通过使用 socket.io-client,我可以避免池化行为,但它不起作用。难道我做错了什么?顺便说一句,我简化了循环,我实际上确保在创建之间存在延迟以避免同步心跳。
想法?
找到了答案,它是这样的:
function Dummy(){
this.config = require('../config/credentials.js');
this.socket = require('socket.io-client').connect(this.config.socketIO.url, { "force new connection": true });
var self = this;
this.socket.on('task', function(task) {
self.createTask(task);
});
}
Run Code Online (Sandbox Code Playgroud)
通过使用 connect() 函数,我们可以将 force new connection 标志设置为 true 并避免池化。简单的!
归档时间: |
|
查看次数: |
1571 次 |
最近记录: |