我使用 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 有什么建议吗?)