如何使用Firefox扩展中的nsISocketTransportService连接到远程服务器？

Question

我需要连接到我的Firefox扩展中的远程服务器（监听端口9442）。我正在使用nsISocketTransportService，我的问题是如何收听dataAvailable事件？我搜索mozilla文档，但可以找到有用的东西。我的问题是，当我使用nsISocketTransportService.createTransport()连接到远程服务器时，如何监听数据？有没有其他方式连接到远程TCP服务器？

var socket = Components.classes["@mozilla.org/network/socket-transport-service;1"] 
          .getService(Components.interfaces.nsISocketTransportService) 
          .createTransport(null, 0, host, port, null); 

var poolOutputStream = socket.openOutputStream(0, 0, 0); 

var helloMessage = JSON.stringify({type: 'hello', clientID: currentClientID}); 
    poolOutputStream.write(helloMessage, helloMessage.length); 

var poolRawInputStream = socket.openInputStream(0, 0, 0); 
var poolInputStream = Components.classes ["@mozilla.org/scriptableinputstream;1"] 
         .createInstance(Components.interfaces.nsIScriptableInputStream) 
         .init(poolRawInputStream); 

Answer 1

可以使用NetUtil module：

Components.utils.import("resource://gre/modules/NetUtil.jsm"); 

NetUtil.asyncFetch(poolRawInputStream, function(stream, result) 
{ 
    if (!Components.isSuccessCode(result)) 
    { 
    // Error handling here 
    } 

    var data = NetUtil.readInputStreamToString(stream, inputStream.available()); 
    ... 
}); 

这种方法的缺点：NetUtil会首先读取所有数据到内存中，你的回调将不会被调用，直到流被关闭。如果你想获得的数据，因为它涉及你将不得不直接使用nsIInputStreamPump：

Components.utils.import("resource://gre/modules/NetUtil.jsm"); 

var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"] 
        .createInstance(Components.interfaces.nsIInputStreamPump); 
pump.init(poolRawInputStream, -1, -1, 0, 0, true); 

var listener = { 
    onStartRequest: function(request, context) {}, 
    onDataAvailable: function(request, context, stream, offset, count) 
    { 
    var data = NetUtil.readInputStreamToString(stream, count); 
    ... 
    }, 
    onStopRequest: function(request, context, result) 
    { 
    if (!Components.isSuccessCode(result)) 
    { 
     // Error handling here 
    } 
    } 
}; 

pump.asyncRead(listener, null);