从Firefox插件打开TCP套接字

Question

从Firefox插件打开TCP套接字

4

很抱歉，我在使用Firefox插件时无法打开套接字。我的目标是使插件侦听端口，然后Python脚本会定期向其发送一个短字符串以进行操作。

我已经检查过，没有运行防火墙，并且如果我在启动此插件之前将netcat设置为侦听所需的端口，则会有不同的行为（它将打印“已打开端口！”）。不幸的是，我确实想让插件成为侦听器/服务器。

//TCPSocket API: https://developer.mozilla.org/en-US/docs/Web/API/TCPSocket
//Got me started: https://dev59.com/kIfca4cB1Zd3GeqPkIuY
const {Cu,Cc,Ci} = require("chrome");
var tcpSocket = Cc["@mozilla.org/tcp-socket;1"].createInstance(Ci.nsIDOMTCPSocket);
var socket = tcpSocket.open("127.0.0.1", 64515);
socket.ondata = function (event) {
    console.log('port received data!!!');
    if (typeof event.data === 'string') {
        console.log('Got: ' + event.data);
    }
}
socket.onopen = function() {console.log('opened port!');}
socket.onerror = function(event) {
    console.log('port error!');
    console.log(event.data)
}
socket.onclose = function() {console.log('port closed!');}
socket.ondrain = function() {console.log('port drained!');}

现在，即时输出为：

console.log: my-addon: port error!
console.log: my-addon: DOMError {}
console.log: my-addon: port closed!

“DOMError”是由socket.onerror接收到的错误。

我不确定这是否是我对sockets的理解不足，还是在打开端口时需要进行Firefox插件和权限方面的特殊处理。

- JKuin

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- LcSalazar · Accepted Answer

我是你提到的那个问题的OP（原帖作者）（TcpSocket listen on Firefox addon），最终我采用了不同的方法，使它能够正常工作：

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() != "") {
                        console.log(request);
                    }
                }
                catch(ex) { }           
                finally
                {
                    sin.close();
                    input.close();
                    output.close();
                }
            }
        }, 0, 0, tm.mainThread);
    },
    onStopListening: function(socket, status) {
    }
};
serverSocket.asyncListen(listener);