0

我正在尝试在 FF 插件（使用 jetpack）和将处理来自插件的所有请求的 java 服务器之间实现连接。看来我可以建立连接，但消息不流动。我没有从插件中得到任何东西。

在这里我发布代码：

JavaScript（客户端）

const {Cc,Ci} = require("chrome");

exports.main = function() {
try  {
    // At first, we need a nsISocketTransportService
    var transportService =  
        Cc["@mozilla.org/network/socket-transport-service;1"]
        .getService(Ci.nsISocketTransportService);  
       
    // Try to connect to localhost:2222
    var transport = transportService.createTransport(null, 0, "localhost", 2222, null);  

    var stream = transport.openInputStream(Ci.nsITransport.OPEN_UNBUFFERED,null,null); 
    var instream = Cc["@mozilla.org/scriptableinputstream;1"]
        .createInstance(Ci.nsIScriptableInputStream); 
        
    // Initialize
    instream.init(stream);
    var outstream = transport.openOutputStream(0, 0, 0);
     
    // Write data
    var outputData = "bye";
    outstream.write(outputData, outputData.length);

    var dataListener = { 
        data : "", onStartRequest: function(request, context){},
         
        onStopRequest: function(request, context, status){
            instream.close();
            outstream.close();
            listener.finished(this.data); 
        }, 
        
        onDataAvailable: function(request, context, inputStream, offset, count) { 
            this.data += instream.read(count); 
            console.log(this.data);             
        }, 
    };

    var pump = Cc["@mozilla.org/network/input-stream-pump;1"].createInstance(Ci.nsIInputStreamPump); 
    pump.init(stream, -1, -1, 0, 0, false); 
    pump.asyncRead(dataListener, null); 
    
} catch (e){ 
    console.log("Error" + e.result + ": " + e.message); 
    return e; 
} return null;
};

Java（服务器）

ServerSocket providerSocket;
Socket connection = null;
ObjectOutputStream out;
ObjectInputStream in;
String message;
GoopirServer(){}
void run() {
    try{
        // Creating a server socket
        providerSocket = new ServerSocket(2222, 10);
        
        // Wait for connection
        System.out.println("Waiting for connection");
        connection = providerSocket.accept();
        System.out.println("Connection received from " + connection.getInetAddress().getHostName());
        
        // Get Input and Output streams
        out = new ObjectOutputStream(connection.getOutputStream());
        out.flush();
        in = new ObjectInputStream(connection.getInputStream());
        sendMessage("Connection successful");
        
        // The two parts communicate via the input and output streams
        do{
            try{
                message = (String)in.readObject();
                System.out.println("client>" + message);
                if (message.equals("bye"))
                    sendMessage("bye");
            }
            catch(ClassNotFoundException classnot){
                System.err.println("Data received in unknown format");
            }
        }while(!message.equals("bye"));
    }
    catch(IOException ioException){
        ioException.printStackTrace();
    }
    finally{
        // Closing connection
        try{
            in.close();
            out.close();
            providerSocket.close();
        }
        catch(IOException ioException){
            ioException.printStackTrace();
        }
    }
}

/*
 * Sends a message to the plugin
 */
void sendMessage(String msg)
{
    try{
        out.writeObject(msg);
        out.flush();
        System.out.println("server>" + msg);
    }
    catch(IOException ioException){
        ioException.printStackTrace();
    }
}
4

2 回答 2

0

您可以尝试添加：outstream.flush(); 之后：outstream.write(outputData, outputData.length);

于 2012-04-16T21:12:02.170 回答
0

您的 Firefox 端似乎是正确的（除了使用阻塞调用来写入数据），问题出在 Java 端。ObjectInputStream并且ObjectOutputStream用于交换序列化对象（以未记录的格式），而不是字符串。而且我认为ObjectInputStream期望立即收到幻数，难怪它在没有输入的情况下锁定。您可能想要使用的是BufferedReaderand PrintWriter。此外，您应该为您的消息使用一些分隔符，例如换行符（这将允许使用BufferedReader.readLine()）。

于 2012-04-17T10:27:05.280 回答