2012-12-07 41 views
0

我有需要打开一个组插座到本地机器上运行的Flash应用程序的Eclipse插件。 Flash需要一个策略文件(XML blob)来授予访问相关端口的权限。闪存更喜欢得到这个策略文件通过端口843,爪哇把港口< 1024个作为特权端口和Mac OS X和Linux类似的限制访问,我不希望运行我的root权限Eclipse插件端口< 1024,因此服务起来端口843上的策略文件不是一个选项。据Adobe称,文档,如果Flash不能得到端口843的策略文件,它回落到请求的端口上的政策文件,它尝试连接。 ActionScript代码看起来是这样的:如何从Eclipse插件提供Flash策略文件?

/** 
    * Connecting to some port to communicate with the debugger. We initiate the 
    * connection because Flex doesn't allow us to listen to any ports. 
    */ 
private function initSockets():void 
{ 
    requestSocket = new Socket(); 
    requestSocket.addEventListener(Event.CONNECT, requestConnected); 
    requestSocket.addEventListener(Event.CLOSE, closed); 
    requestSocket.addEventListener(ProgressEvent.SOCKET_DATA, processRequestData); 
    requestSocket.addEventListener(IOErrorEvent.IO_ERROR, ioError); 
    requestSocket.addEventListener(SecurityErrorEvent.SECURITY_ERROR, securityError); 
    requestSocket.connect("localhost", SCConstants.DEBUG_LESSON_REQUEST_PORT); 

    eventSocket = new Socket(); 
    eventSocket.addEventListener(Event.CONNECT, eventConnected); 
    eventSocket.addEventListener(Event.CLOSE, closed); 
    eventSocket.addEventListener(ProgressEvent.SOCKET_DATA, processEventData); 
    eventSocket.addEventListener(IOErrorEvent.IO_ERROR, ioError); 
    eventSocket.addEventListener(SecurityErrorEvent.SECURITY_ERROR, securityError); 
    eventSocket.connect("localhost", SCConstants.DEBUG_LESSON_EVENT_PORT); 
} 

在我继承了一些代码,作品在OS X上的时间大部分Eclipse插件的一面,但有时会失败在Windows上。在Wi-Fi而不是有线以太网上运行也往往会失败,尽管我不知道为什么这很重要。

public Boolean connect() throws DebugException { 
    try { 
     try { 
      // connection code 
      fRequestServerSocket = new ServerSocket(requestPort); 
      fRequestServerSocket.setSoTimeout(ACCEPT_TIMEOUT); 
      fEventServerSocket = new ServerSocket(eventPort); 
      fEventServerSocket.setSoTimeout(ACCEPT_TIMEOUT); 

      TWBLogger.logInfo("Open socket request server:" + fRequestServerSocket); 
      TWBLogger.logInfo("Open socket event server:" + fEventServerSocket); 

      String policy = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" + 
       "<cross-domain-policy>\n" + 
       "<allow-access-from domain=\"*\" to-ports=\"5000,5001\" secure=\"false\" />\n" + 
       "</cross-domain-policy>\0"; 

      // Because of the Flash security policy the first thing 
      // that will accept on the socket will be the Flash Player 
      // trying to verify us. The Flash player will request security 
      // policy file with the following string: <policy-file-request/>\0 
      // We will serve back the above policy file and then close the socket 
      // The next thing to accept is our process in the VM. 
      fRequestSocket = fRequestServerSocket.accept(); 

      fRequestWriter = new PrintWriter(fRequestSocket.getOutputStream()); 
      fRequestReader = new BufferedReader(new InputStreamReader(fRequestSocket.getInputStream())); 

      // Wait some time before giving flash the policy file. Otherwise they don't get it. ;(
      // 3 is too much ... ;(
      Thread.sleep(100); 

      fRequestWriter.print(policy); 
      fRequestWriter.flush(); 
      fRequestSocket.close(); 

      // this should be the real connection 
      fRequestSocket = fRequestServerSocket.accept(); 
      TWBLogger.logInfo("Open socket request:" + fRequestSocket); 

      fRequestWriter = new PrintWriter(fRequestSocket.getOutputStream()); 
      fRequestReader = new BufferedReader(new InputStreamReader(fRequestSocket.getInputStream())); 

      // the same situation for the EventSocket 
      fEventSocket = fEventServerSocket.accept(); 
      fEventReader = new BufferedReader(new InputStreamReader(fEventSocket.getInputStream())); 
      TWBLogger.logInfo("Open socket event:" + fEventSocket); 
     } catch (SocketTimeoutException e) { 
      TWBLogger.logWaring("Connection to the Client Timed out."); 
      cleanSockets(); 
      return false; 
      requestFailed("Connection to the VM timed out. Please close any other running lessons that you debug and try again", e); 
     } catch (SocketSecurityException e) { 
      requestFailed("Security error occured when connecting to the VM", e); 
     } catch (Exception e) { 
      if (!fTerminated) 
      requestFailed("Error occured when connecting to the VM. Please close any other running lessons that you debug.", e); 
     } 
    } catch (DebugException e) { 
     // close the sockets so that we can debug another application 
     cleanSockets(); 
     throw e; 
    } 

    // our VM is single threaded 
    fThread = new TWBThread(this); 
    fThreads = new IThread[] {fThread}; 

    // start listening for events from the VM 
    fEventDispatch = new EventDispatchJob(); 
    fEventDispatch.schedule(); 

    // start listening for breakpoints 
    IBreakpointManager breakpointManager = getBreakpointManager(); 
    breakpointManager.addBreakpointListener(this); 

    breakpointManager.addBreakpointManagerListener(this); 
    return true; 
} 

此代码看起来不正确。它不会等待来自Flash的消息,而只是将策略响应阻塞到端口中。正如我所说,它大部分时间都在运行,但它有时会失败,似乎不符合Adobe的文档。

我尝试侦听每个端口上请求数据包和发送端口特定响应。我使用WireShark在环回接口(Mac OS X)上观察套接字通信量。我看到了策略请求和收到的响应,但Flash仍然在两个端口上给我安全沙箱违例。

我也试着在上面所示的initSockets的开始加入这一行:

Security.loadPolicyFile("xmlsocket://localhost:5002"); 

然后,我在我的插件添加的代码为侦听端口5002和发送以下主策略文件内容:

private final static String FLASH_POLICY_RESPONSE = 
    "<?xml version=\"1.0\"?>\n" + 
    "<!DOCTYPE cross-domain-policy SYSTEM \"/xml/dtds/cross-domain-policy.dtd\">\n" + 
    "<cross-domain-policy>\n" + 
    "<site-control permitted-cross-domain-policies=\"master-only\"/>\n" + 
    "<allow-access-from domain=\"*\" to-ports=\"5000,5001\"/>\n" + 
    "</cross-domain-policy>\0";   

再次只见请求进来和响应出去,但是Flash似乎并未对此作出回应。我没有收到安全沙箱违例错误,但也没有通过端口的流量。

任何人都可以启发我在Java和Flash之间打开套接字的正确方法吗?

回答

1

我找到了解决这个。我很早就犯了一个错误,并使用BufferedReader.readLine来读取策略请求。这是不合适的,因为策略请求是空终止的,而不是新行终止。这是令人困惑的,因为它在底层流关闭时返回。因此,我收到了请求并发送了一个响应,但是在ActionScript代码已经确定请求失败之后发送了响应。

在Java端我用下面的代码来建立对端口进行通信:

// Create server sockets. 
fRequestServerSocket = new ServerSocket(REQUEST_PORT); 
fRequestServerSocket.setSoTimeout(ACCEPT_TIMEOUT); 
TWBLogger.logInfo("Open socket request server:" + fRequestServerSocket); 

fEventServerSocket = new ServerSocket(EVENT_PORT); 
fEventServerSocket.setSoTimeout(ACCEPT_TIMEOUT); 
TWBLogger.logInfo("Open socket event server:" + fEventServerSocket); 

// Serve up the Flash policy file. 
serveFlashPolicy(); 

// Connect request socket. 
fRequestSocket = fRequestServerSocket.accept(); 
TWBLogger.logInfo("Open socket request:" + fRequestSocket); 

fRequestWriter = new PrintWriter(fRequestSocket.getOutputStream()); 
fRequestReader = new BufferedReader(new InputStreamReader(fRequestSocket.getInputStream())); 

// Connect event socket. 
fEventSocket = fEventServerSocket.accept(); 
TWBLogger.logInfo("Open socket event:" + fEventSocket); 

fEventReader = new BufferedReader(new InputStreamReader(fEventSocket.getInputStream()));     

服务了政策文件的处理如下:

private void serveFlashPolicy() { 
    ServerSocket serverSocket = null; 
    Socket socket = null; 
    TWBLogger.logInfo("Waiting for flash policy request on port " + FLASH_POLICY_PORT); 
    try { 
     serverSocket = new ServerSocket(FLASH_POLICY_PORT); 
     serverSocket.setSoTimeout(ACCEPT_TIMEOUT); 

     socket = serverSocket.accept(); 

     PrintWriter writer = new PrintWriter(socket.getOutputStream()); 
     BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); 

     StringBuilder request = new StringBuilder(); 
     int c; 
     while (0 < (c = reader.read())) { 
      request.append((char) c); 
     } 

     String policyRequest = request.toString(); 
     if (policyRequest.startsWith(FLASH_POLICY_REQUEST)) { 
      writer.print(FLASH_POLICY_RESPONSE); 
      writer.print("\0"); 
      writer.flush(); 
     } 
    } catch (IOException e) { 
     TWBLogger.logWaring("IOException on port " + FLASH_POLICY_PORT + ": " + e.toString()); 
     e.printStackTrace(); 
    } finally { 
     if (null != socket) { 
      try { 
       socket.close(); 
      } catch (Exception e) { 
       // Ignore 
      } 
     } 

     if (null != serverSocket) { 
      try { 
       serverSocket.close(); 
      } catch (Exception e) { 
       // Ignore 
      } 
     } 
    } 

    TWBLogger.logInfo("Flash policy complete on port " + FLASH_POLICY_PORT); 
} 

闪存政策回应的样子这样的:

private final static String FLASH_POLICY_RESPONSE = 
    "<?xml version=\"1.0\"?>\n" + 
    "<!DOCTYPE cross-domain-policy SYSTEM \"/xml/dtds/cross-domain-policy.dtd\">\n" + 
    "<cross-domain-policy>\n" + 
    "<allow-access-from domain=\"*\" to-ports=\"5000,5001\"/>\n" + 
    "</cross-domain-policy>";   

site-control标签我以前有b只有在从端口843提供的主策略文件中才允许发送。