Kafka,nodejs客户端(kafkaesque)套接字默认超时
Kafka, nodejs client (kafkaesque) socket default timeout
我正在使用 Ubuntu 14.04。一个 nodejs ->kafkaesque(kafka nodejs 客户端)->kafka_2.9.2-0.8.2.1->storm。在 Kafkaesque(kafka nodejs 客户端)中,我注意到在 api.js 中,有以下行来创建套接字。
_socket = net.createConnection(_options.port, _options.host);
我想知道套接字超时的默认值是多少。如果我希望套接字连接始终为 there/permanent,我应该设置超时(0)吗?
我还注意到代码后面的一行:
_socket.on('timeout', function(){
console.log('socket timeout');
});
如果我想让套接字连接永久,我是否应该在这个超时函数中尝试重新建立连接?
By default net.Socket do not have a timeout.
因此,除非在其他地方有 socket.setTimeout()
调用,否则套接字不应有超时。
另外:
When an idle timeout is triggered the socket will receive a 'timeout' event but the connection will not be severed. The user must manually end() or destroy() the socket.
因此当 timeout
事件触发时您不需要重新连接,除非回调与 end()
或 destroy()
.
断开连接
我正在使用 Ubuntu 14.04。一个 nodejs ->kafkaesque(kafka nodejs 客户端)->kafka_2.9.2-0.8.2.1->storm。在 Kafkaesque(kafka nodejs 客户端)中,我注意到在 api.js 中,有以下行来创建套接字。
_socket = net.createConnection(_options.port, _options.host);
我想知道套接字超时的默认值是多少。如果我希望套接字连接始终为 there/permanent,我应该设置超时(0)吗?
我还注意到代码后面的一行:
_socket.on('timeout', function(){
console.log('socket timeout');
});
如果我想让套接字连接永久,我是否应该在这个超时函数中尝试重新建立连接?
By default net.Socket do not have a timeout.
因此,除非在其他地方有 socket.setTimeout()
调用,否则套接字不应有超时。
另外:
When an idle timeout is triggered the socket will receive a 'timeout' event but the connection will not be severed. The user must manually end() or destroy() the socket.
因此当 timeout
事件触发时您不需要重新连接,除非回调与 end()
或 destroy()
.