TcpSocket在Firefox插件中的监听

Question

我正在尝试创建一个使用TcpSocket进行通信的Firefox插件。我已经成功地通过以下代码使用tcp发送了消息:

var tcpSocket = Cc["@mozilla.org/tcp-socket;1"].createInstance(Ci.nsIDOMTCPSocket);
var socket = tcpSocket.open("127.0.0.1", 3000);
socket.onopen = function() {
    socket.send(sendText);
}

这很完美。

现在，我想要接收tcp消息。我正在使用以下代码（基于MDN的TCP Socket文章）

var tcpSocket = Cc["@mozilla.org/tcp-socket;1"].createInstance(Ci.nsIDOMTCPSocket);
var socket = tcpSocket.listen(3000);
socket.ondata = function (event) {
    console.log(event);
};

但它记录了以下错误（在运行cfx run的命令提示符中）：

console.error: my-addon:
Object
    - message = Cannot modify properties of a WrappedNative
    - fileName = undefined
    - lineNumber = 6
    ...

而且，我可以说这个端口至少是活动的，因为如果我忽略错误并尝试向该端口发送tcp消息，控制台会记录以下内容：

Received unexpected connection!

我有点不理解这里是否有什么遗漏？提前感谢您。

- LcSalazar

---

很酷的东西，这使得浏览器进程和另一个进程之间可以进行跨进程通信，是吗？ - Noitidart

@Noitidart - 是的..我正在构建它以实现扩展和C#应用程序之间的交互... - LcSalazar

很酷的东西，你可能也会发现js-ctypes是一个选项 :) - Noitidart

我正在尝试在一个Firefox配置文件和另一个之间发送消息，所以如果我们解决了这个问题，这也会对我有所帮助 :) - Noitidart

@LcSalazar 你好，我使用了你上面的发送代码，但它不起作用（连接不起来）...但你说过“这个非常好用”。我在stackoverflow上提出了一个问题，请问你能否帮助我。 - Madhawa Priyashantha

Answer 1

我最终采用了不同的方法使其工作：

var port = 3000; //whatever is your port
const {Cc, Ci} = require("chrome");
var serverSocket = Cc["@mozilla.org/network/server-socket;1"].createInstance(Ci.nsIServerSocket);
serverSocket.init(port, true, -1);
var listener = {
    onSocketAccepted: function(socket, transport) {
        var input = transport.openInputStream(Ci.nsITransport.OPEN_BLOCKING,0,0);
        var output = transport.openOutputStream(Ci.nsITransport.OPEN_BLOCKING, 0, 0);
        var tm = Cc["@mozilla.org/thread-manager;1"].getService();
        input.asyncWait({
            onInputStreamReady: function(inp) {
                try
                {
                    var sin = Cc["@mozilla.org/scriptableinputstream;1"].createInstance(Ci.nsIScriptableInputStream);
                    sin.init(inp);
                    sin.available();

                    //Get request message
                    var request = '';
                    while (sin.available()) { request = request + sin.read(5120); }
                    var reqObj = { type: null, info: [] };
                    if(request != null && request.trim() != "") {

                        //Here is the message text
                        console.log(request);

                    }
                }
                catch(ex) { }           
                finally
                {
                    sin.close();
                    input.close();
                    output.close();
                }
            }
        }, 0, 0, tm.mainThread);
    },
    onStopListening: function(socket, status) {
    }
};
serverSocket.asyncListen(listener);

- LcSalazar

---

这个有文档吗？我找不到回复请求的方法。 - Josh Horowitz

非常棒，谢谢@LcSalazar！当有人发布问题并自己解决时，看到分享真是太好了。 - Noitidart