3

我使用 Ruby 非常简单的 Queue 类构建了各种小脚本，并使用 DRb 在 Ruby 和 JRuby 进程之间共享 Queue。如果能够使用 JRuby 从 Scala（可能还有 Java）访问这些内容，那就太好了。

我已经将 Scala 和 JSR-223 接口放在一起来访问 jruby-complete.jar。

import javax.script._

class DRbQueue(host: String, port: Int) {
  private var engine = DRbQueue.factory.getEngineByName("jruby")
  private var invoker = engine.asInstanceOf[Invocable]
  engine.eval("require \"drb\" ")
  private var queue = engine.eval("DRbObject.new(nil, \"druby://" + host + ":" + port.toString + "\")")

  def isEmpty(): Boolean = invoker.invokeMethod(this.queue, "empty?").asInstanceOf[Boolean]
  def size(): Long = invoker.invokeMethod(this.queue, "length").asInstanceOf[Long]
  def threadsWaiting: Long = invoker.invokeMethod(this.queue, "num_waiting").asInstanceOf[Long]
  def offer(obj: Any) = invoker.invokeMethod(this.queue, "push", obj.asInstanceOf[java.lang.Object])
  def poll(): Any = invoker.invokeMethod(this.queue, "pop")
  def clear(): Unit = { invoker.invokeMethod(this.queue, "clear") }
}
object DRbQueue {
  var factory = new ScriptEngineManager()
}

（它大致符合 java.util.Queue 接口，但我没有声明接口，因为它没有实现 element 和 peek 方法，因为 Ruby 类不提供它们。）

问题在于类型转换。JRuby 对 Scala 的字符串很好——因为它们是 Java 字符串。但是，如果我给它一个 Scala Int 或 Long，或者其他 Scala 类型之一（List、Set、RichString、Array、Symbol）或其他一些自定义类型。

这似乎是不必要的 hacky：肯定必须有更好的方法来进行 RMI/DRb 互操作，而不必使用 JSR-223 API。我可以让 offer 方法将对象序列化为 JSON 字符串，并采用仅具有 toJson 方法的对象的结构类型。然后我可以编写一个 Ruby 包装类（或只是 monkeypatch 队列）来解析 JSON。

继续尝试从 Java/Scala 访问 DRb 有什么意义吗？安装真正的消息队列会更容易吗？（如果是这样，对基于 JVM 的轻量级 MQ 有什么建议吗？）

4

1 回答 1

2

安装企业消息队列是值得的，因为 DRB 和 ruby​​ 不是队列技术。

在我看来，你在这里创造了技术债务。

如果你想坚持相同的路径，你可以使用他们放弃八哥的推特队列。

我认为 Java 世界 JMS 中有大量可用的队列。

如果你写了一个 DRB 服务器，你甚至可以做一个数组来实现非常简单的队列接口！然后适当缩放 http://www.java-tips.org/java-se-tips/java.lang/array-based-queue-implementation-in-java.html

在我看来，坚持使用经过验证的企业技术，而不是未经证实的骇人听闻的技术，我已经很难做到这一点。

于 2010-07-01T01:32:19.937 回答