Рассмотрим штормовой топологию КОРД, которая выглядит следующим образом:Как вызвать DRPC Storm из PHP?
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?
Update: Я установил thrift и сгенерировал PHP, запустив
thrift --gen php storm.thrift
& получил каталог генераторных PHP с кучей классов PHP.
Может ли кто-нибудь привести пример или ссылку, показывающую реализацию?