2

我正在尝试使用来自 Java 应用程序的数据为碳（石墨）服务器提供数据。我想使用 pickle 协议而不是 oneline 协议，因为它似乎要快得多。

我已经在一个从我的 Java 应用程序调用的小型 python 脚本中完成了这项工作。但我想用原生 Java 写这个。

python 脚本如下所示：

listOfMetricTuples = [('test', (1, 1352903620)), ('test', (2, 1352903620))]
payload = pickle.dumps(listOfMetricTuples)
header = struct.pack("!L", len(payload))
message = header + payload

不需要包含任何库会很棒。

有人对此有解决方案吗？

4

2 回答 2

2

它现在解决了。

我通过使用 Jython 和以下代码解决了这个问题。

try{
    Socket s = null;
    try{
    s = new Socket("debian-srv", 2004);
    }catch(UnknownHostException e){
    e.printStackTrace();
    }catch(IOException e){
    e.printStackTrace();
    }
    if (s == null) {
    return -1;
    }


    PyTuple t = new PyTuple(new PyString("Test.brange-debian.mojo"), new PyTuple(new PyInteger(1352975858), new PyInteger(56)));
    PyTuple t2 = new PyTuple(new PyString("Test.brange-debian.mojo"), new PyTuple(new PyInteger(1352975858-60), new PyInteger(43)));
    PyTuple t3 = new PyTuple(new PyString("Test.brange-debian.mojo"), new PyTuple(new PyInteger(1352975858-2*+60), new PyInteger(65)));

    PyList list = new PyList();
    list.append(t);
    list.append(t2);
    list.append(t3);

    PyString payload = cPickle.dumps(list);

    byte[] bytes = ByteBuffer.allocate(4).putInt(payload.__len__()).array();

    s.getOutputStream().write(bytes);
    s.getOutputStream().write(payload.toBytes());
    s.getOutputStream().flush();

    s.close();
}
catch (Exception e) {
    e.printStackTrace();
}
于 2012-11-15T11:16:15.987 回答
1

另一种选择，根据我如何序列化 Java 对象，以便它可以被pickle（Python）反序列化？，可能是使用热解石。占用空间可能小于必须使用 Jython。

于 2014-03-27T18:02:24.337 回答