如何在vertx中使用事件总线消息传递？

Question

我按照示例中的说明运行：

vertx run eventbus_pointtopoint/receiver.rb -cluster
vertx run eventbus_pointtopoint/sender.rb -cluster

然后我只得到：

➜  ruby  vertx run eventbus_pointtopoint/receiver.rb -cluster
Starting clustering...
No cluster-host specified so using address 192.168.56.1
Succeeded in deploying verticle

➜  ruby  vertx run eventbus_pointtopoint/sender.rb -cluster
Starting clustering...
No cluster-host specified so using address 192.168.56.1
Succeeded in deploying verticle

但没有收到任何消息。我做错了什么？

Answer 1

如果您只想了解事件总线消息传递是如何工作的，可以将这两段代码移动到一个文件中并运行它。

require "vertx"
include Vertx

EventBus.register_handler('ping-address') do |msg|
  puts "Received message: #{msg.body}"
  # Now reply to it
  msg.reply('pong!')
end

Vertx::set_periodic(1000) do
  EventBus.send('ping-address', 'ping') do |reply|
    puts "Received reply: #{reply.body}"
  end
end

运行群集的

如果要运行集群指定的示例，则可能需要更改cluster.xml配置文件，它位于vertx的conf文件夹中。我不得不换两行，第一行换

<multicast enabled="true">

假的：

<multicast enabled="false">

然后改变

<tcp-ip enabled="false">

为真

<tcp-ip enabled="true">

并确保接口标签具有正确的IP地址。然后运行上面指定的命令。