我一直在玩 JInterface 和 Elixir,我想我已经解决了你的问题。
因此,您尝试将字符串列表从 Elixir/Erlang 节点发送到 Java 节点,但无法正确反序列化。
Elixir 有自己的类型(例如 , atoms
, tuples
..),Java 有自己的类型(例如 , Object
, String
, List<String>
..)。如果他们应该互相交谈,则需要从一种类型转换为另一种类型。最后,无论如何,它只是一堆 1 和 0 通过网络发送。
如果将 Erlang 列表发送到 Java,则到达的内容总是可以解释为OtpErlangObject
. 在我们开始将其转换为 Java 值之前,您可以尝试猜测实际类型是什么。
// We know that everything is at least an OtpErlangObject value!
OtpErlangObject o = mbox.receive();
但是鉴于您知道它实际上是一个列表,我们可以将其转换为一个OtpErlangList
值。
// We know o is an Erlang list!
OtpErlangList erlList = (OtpErlangList) o;
然而,这个列表的元素仍然未知。所以此时它仍然是一个OtpErlangObject
s 列表。
但是,我们知道它是一个字符串列表,所以我们可以将 s 的列表解释为OtpErlangObject
s 的列表OtpErlangString
,并将其转换为 Java 字符串。
public static List<String> ErlangListToStringList(OtpErlangList estrs) {
OtpErlangObject[] erlObjs = estrs.elements();
List<String> strs = new LinkedList<String>();
for (OtpErlangObject erlO : erlObjs) {
strs.add(erlO.toString());
}
return strs;
}
请注意,我在这里经常使用术语列表,因为它实际上是一个 Erlang 列表,在 Java 中它都表示为一个数组!
下面列出了我的整个代码。运行它的方法是将其粘贴到 Java IDE 中,并使用以下参数启动 REPL:
iex --name bob@127.0.0.1 --cookie "secret"
Java部分:
import com.ericsson.otp.erlang.*;
import java.io.IOException;
import java.util.LinkedList;
import java.util.List;
public class Main {
public static OtpErlangList StringListToErlangList(List<String> strs) {
OtpErlangObject[] elems = new OtpErlangObject[strs.size()];
int idx = 0;
for (String str : strs) {
elems[idx] = new OtpErlangString(str);
idx++;
}
return new OtpErlangList(elems);
}
public static List<String> ErlangListToStringList(OtpErlangList estrs) {
OtpErlangObject[] erlObjs = estrs.elements();
List<String> strs = new LinkedList<String>();
for (OtpErlangObject erlO : erlObjs) {
strs.add(erlO.toString());
}
return strs;
}
public static void main(String[] args) throws IOException, InterruptedException {
// Do some initial setup.
OtpNode node = new OtpNode("alice", "secret");
OtpMbox mbox = node.createMbox();
mbox.registerName("alice");
// Check that the remote node is actually online.
if (node.ping("bob@127.0.0.1", 2000)) {
System.out.println("remote is up");
} else {
System.out.println("remote is not up");
}
// Create the list of strings that needs to be sent to the other node.
List<String> strs = new LinkedList<String>();
strs.add("foo");
strs.add("bar");
OtpErlangList erlangStrs = StringListToErlangList(strs);
// Create a tuple so the other node can reply to use.
OtpErlangObject[] msg = new OtpErlangObject[2];
msg[0] = mbox.self();
msg[1] = erlangStrs;
OtpErlangTuple tuple = new OtpErlangTuple(msg);
// Send the tuple to the other node.
mbox.send("echo", "bob@127.0.0.1", tuple);
// Await the reply.
while (true) {
try {
System.out.println("Waiting for response!");
OtpErlangObject o = mbox.receive();
if (o instanceof OtpErlangList) {
OtpErlangList erlList = (OtpErlangList) o;
List<String> receivedStrings = ErlangListToStringList(erlList);
for (String s : receivedStrings) {
System.out.println(s);
}
}
if (o instanceof OtpErlangTuple) {
OtpErlangTuple m = (OtpErlangTuple) o;
OtpErlangPid from = (OtpErlangPid) (m.elementAt(0));
OtpErlangList value = (OtpErlangList) m.elementAt(1);
List<String> receivedStrings = ErlangListToStringList(value);
for (String s : receivedStrings) {
System.out.println(s);
}
}
} catch (OtpErlangExit otpErlangExit) {
otpErlangExit.printStackTrace();
} catch (OtpErlangDecodeException e) {
e.printStackTrace();
}
}
}
}