我正在尝试实现Trident+DRPC。我设计了拓扑结构,使其不会无限运行。我有两个独立的类,一个用于spout实现,另一个用于实现DRPC和Trident。我的spout类(扩展IRichSpout的spout )发出客户的id。即
public class TriSpout implements IRichSpout{
//some logic here
spoutOutputCollector.emit(new Values(id))
}
现在,我从输出收集器的另一个类中获得了值,这个类用DRPC实现了Trident。
public class TriDrpc{
我正在做一个使用OMNET++的位置隐私项目,最近我开发了一个两个节点的网络(像Tic- Toc游戏),想把它转换成一个真实的网络,根据用户的要求从2个节点到n个节点变化。
这是2个节点的结构:
simple Txc1
{
gates:
input in;
output out;
}
`enter code here`// Two instances (tic and toc) of Txc1 connected both ways.
// Tic and toc will pass messages to one another.
//
network Tictoc1
{
submodule