代码之家 › 专栏 › 技术社区 › Aerith

弹簧AMQP头仅作为字符串返回

amqp message rabbitmq spring java

Aerith · 技术社区 · 9 年前

我将Java Spring与AMQP 2.0.0版快照一起使用。我创建了一条AMQP消息,发送它。在另一个服务中,我正确地接收了消息,除了头而不是接收类型Object之外,每个头都是类型String。

发布者代码:

Message responseMessage = MessageBuilder
    .withBody(SerializationUtils.serialize(person))
    .setContentType(MessageProperties.CONTENT_TYPE_SERIALIZED_OBJECT)
    .setHeader("STUDENT_TYPE", "New") // Not part of person object but related
    .setHeader("PET", getPet()) // This is a pet object
    .build();
rabbitTemplate.send(responseMessage);

消费者代码:

Object messageBody = SerializationUtils.deserialize(amqpMessage.getBody());
Person person = (Person)messageBody;
MessageProperties properties = amqpMessage.getMessageProperties();
String type = properties.getHeaders().get("STUDENT_TYPE").toString();
Pet pet = (Pet)properties.getHeaders().get("PET");

当我运行上述代码时,我将在消费者代码的最后一行失败,并显示错误:Cannot cast String to Pet。消息显示正常,但在消费者代码中接收到的每个头都是String类型。

USAGE: MessageBuilder.setHeader(String Key, Object Value);

USAGE: Properties.getHeaders() returns Map<String,Object>

每个头都有类型为String/Object的键/值对。我所做的工作还包括序列化一个我想为其传递非字符串/整数值的标头,但这似乎是在标头的点之外。我错过了什么吗?

2 回复 | 直到 9 年前

Yuri Plevako 9 年前

您需要将您的宠物序列化为字符串,并在另一个服务中获取它时反序列化它。E、 g.可以使用fasterxml Jackson并将其序列化为JSON字符串

Lajos Arpad 9 年前

您正在告诉编译器您的 String 真的是一只宠物。然而 Pet 不是 subclass 属于 一串 有两种可能的解决方案:

解决方案1:确保 Pet extends String ,如下所示:

public class Pet extends String {
    //...
}

然后你就可以 一串 进入 宠物 .

解决方案2:实现 宠物 这需要一个 一串 作为参数:

public class Pet {
    //...
    Public Pet(String name) {
        //...
    }
    //...
}

推荐文章

user29759326 · 如何返回递归函数中的最后一个值?

6 月前

malife89 · 将java中的字符串读取为正确的日期格式

7 月前

Tim · 在java中,有没有更快的方法将字节数组写入文件?

7 月前

pebble unit · 如何检查以前缀开头、以后缀结尾的属性(不是属性值)

7 月前

Nuñito Calzada · Spring Boot with JWT:访问此资源需要完全身份验证

7 月前

rudraraj · java中未声明最终变量

7 月前

Bala Ji · 以下BFS的实施效率如何?

7 月前

MineRickStar · 如何在Java中从Windows获取当前选定的应用程序

7 月前

user2649681 · 实时生成音频以写入“SourceDataLine”`

7 月前

davidalayachew · 为什么我的文件有竞争条件,即使我使用了StandardOpenOption。同步?

7 月前