2013-12-13 56 views
0

考慮風暴DRPC拓撲結構如下:如何從PHP調用DRPC Storm?

public static void main(String[] args) { 
    LinearDRPCTopologyBuilder builder = new LinearDRPCTopologyBuilder("exclamation"); 
    builder.addBolt(new ExclamationBolt()); 
    Config conf = new Config(); 
    try { 
     StormSubmitter.submitTopology("exclaim", conf, builder.createRemoteTopology()); 
    } catch (AlreadyAliveException e) { 
     e.printStackTrace(); 
    } catch (InvalidTopologyException e) { 
     e.printStackTrace(); 
    } 
} 

測試與LocalClusterdrpc.execute("exclamation", "aaa"),它的工作原理。但問題是如何從PHP遠程調用?


更新:我已經安裝了 thrift,並通過運行 thrift --gen php storm.thrift &得到了一堆PHP類的GEN-php目錄中生成的PHP。

任何人都可以舉一個例子或鏈接顯示實施?

回答