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();
}
}
測試與LocalCluster
即drpc.execute("exclamation", "aaa")
,它的工作原理。但問題是如何從PHP遠程調用?
更新:我已經安裝了 thrift,並通過運行
thrift --gen php storm.thrift
&得到了一堆PHP類的GEN-php目錄中生成的PHP。
任何人都可以舉一個例子或鏈接顯示實施?