使用python生成amqp消息，并使用j

Question

我试图从python生成amqp消息，并使用java/spring中的相同消息。

下面是我的制作人代码（python）：

import pika, sys, pickle

sys.path.append("trc/suivi/amqp")

from Person import Person

connection = pika.BlockingConnection()
channel = connection.channel()
me = Person("Juliano", 38)
pickled_me = pickle.dumps(me)
channel.basic_publish(exchange='', 
                      routing_key="myqueue",
                      body=pickled_me,
                      properties=pika.BasicProperties(delivery_mode=1))

以下是我的消费者代码（java）：

^{pr2}$

以下是Person的java类：

package trc.suivi.amqp;


import java.io.Serializable;

public class Person implements Serializable {
    private static final long serialVersionUID = 1L;
    private String name;
    private int age;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

}

以及相应的python类：

class Person:
    def __init__(self, name, age):
        self.name = name
        self.age = age

（位于trc/suivi/amqp目录结构中）

我得到一个类强制转换异常。我很确定这与包/模块名或某些序列化问题有关。。。在

编辑：我现在使用的是JSon，通过java反序列化可以得到：

Exception in thread "main" org.springframework.amqp.support.converter.MessageConversionException: failed to convert Message content. Could not resolve
 __TypeId__ in header
    at org.springframework.amqp.support.converter.DefaultJavaTypeMapper.retrieveHeader(DefaultJavaTypeMapper.java:104)
    at org.springframework.amqp.support.converter.DefaultJavaTypeMapper.toJavaType(DefaultJavaTypeMapper.java:53)
    at org.springframework.amqp.support.converter.JsonMessageConverter.fromMessage(JsonMessageConverter.java:118)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.receiveAndConvert(RabbitTemplate.java:425)
    at trc.suivi.amqp.Consumer.main(Consumer.java:12)

Answer 1

您使用的是通用序列化库吗？查看此答案以了解更多详细信息Is there any library to deserialize with python which is serialized with java。在

您可以尝试将其序列化为json，然后在python代码中对其进行反序列化