message-queue - 如何在 vertx 中使用 eventbus 消息传递？

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 地址。然后你上面指定的命令应该运行。