操作系统:Linux JDK 版本:1.7.0_67 Vert.x 版本:2.1.5
我开始尝试使用github上找到的一些vertx示例。
由于手册中想要尝试一个简单的EventBus发送方和接收方示例,但是多个小时过去了,没有收到ping消息,也没有看到hello world的输出。
有人知道我在这个简单的代码中遗漏了什么吗:
Sender.java
import org.vertx.java.platform.Verticle;
public class Sender extends Verticle {
public void start(){
vertx.eventBus().send("ping-address", "Hello");
}
}
Receiver.java
import org.vertx.java.core.Handler;
import org.vertx.java.core.eventbus.EventBus;
import org.vertx.java.core.eventbus.Message;
import org.vertx.java.platform.Verticle;
public class Receiver extends Verticle {
public void start() {
EventBus eb = vertx.eventBus();
eb.registerHandler("ping-address", new Handler<Message<String>>(){
@Override
public void handle(Message<String> message) {
container.logger().info("Message: "+message.body());
}
});
container.logger().info("PingVerticle started");
}
}
使用以下CLI命令在同一台机器上分别在不同的JVM实例中运行:
vertx run Receiver.java
> Succeeded in deploying verticle
另一个控制台:
vertx run Sender.java
> Succeeded in deploying verticle