java - com.fasterxml.jackson.databind.exc.MismatchedInputException：无法从 START_OBJECT 令牌中反序列化 `java.lang.String` 的实例

Question

我使用 Spring Boot 和 Rappitmq 来实现两个不同应用程序之间的异步消息传递。当我只将字符串交换为消息内容时，这很好用。我还实现了pojos的交换。由于 pojos 在不同的包中出现，序列化/反序列化过程失败。为了解决这个问题，我使用 JacksonConverter 来使用 json。正如我在订阅者服务“application/json”的消息头中看到的那样

交换模型（在发布和订阅服务中相同）：

public class Employee{

private Integer id;
private String firstName;
private String lastName;
private Double salary;

public Employee(@JsonProperty("id") Integer id,
                @JsonProperty("firstName") String firstName,
                @JsonProperty("lastName") String lastName,
                @JsonProperty("salary") Double salary) {
    this.id = id;
    this.firstName = firstName;
    this.lastName = lastName;
    this.salary = salary;
}

public Integer getId() {
    return id;
}

public void setId(Integer id) {
    this.id = id;
}

public String getFirstName() {
    return firstName;
}

public void setFirstName(String firstName) {
    this.firstName = firstName;
}

public String getLastName() {
    return lastName;
}

public void setLastName(String lastName) {
    this.lastName = lastName;
}

public Double getSalary() {
    return salary;
}

public void setSalary(Double salary) {
    this.salary = salary;
}

@Override
public String toString() {
    return "{" +
            "id=" + id +
            ", firstName='" + firstName + '\'' +
            ", lastName='" + lastName + '\'' +
            ", salary=" + salary +
            '}';
}

在发布者服务中使用 Jackson2JsonConverter 的 Bean：

 @SpringBootApplication
public class PublisherApplication {

public static void main(String[] args) {

    SpringApplication.run(PublisherApplication.class, args);

}

@Bean
public Jackson2JsonMessageConverter producerMessageConverter(){
    return new Jackson2JsonMessageConverter();
}

@Bean
public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory){
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    rabbitTemplate.setMessageConverter(producerMessageConverter());
    return rabbitTemplate;
}

}

发信息：

    @Override
public void sendEmployeeObject(Employee employee) throws JsonProcessingException {
    rabbitTemplate.convertAndSend(RabbitMqConstants.EXCHANGE_NAME, "foo.bar.baz", employee);
}

}

订阅者配置：

   @Configuration
public class EmployeeMessageSubscriberConfig {

@Bean
@Qualifier("employeeQueue")
Queue queue() {
    return new Queue(RabbitMqConstants.EMPLOYEE_QUEUE, false);
}

@Bean
@Qualifier("employeeExchange")
TopicExchange exchange() {
    return new TopicExchange(RabbitMqConstants.EXCHANGE_NAME);
}

@Bean
@Qualifier("employeeQueueExchangeBinding")
Binding binding(Queue queue, TopicExchange exchange) {
    return BindingBuilder.bind(queue).to(exchange).with("foo.bar.#");
}
@Bean
public Jackson2JsonMessageConverter converter() {
    return new Jackson2JsonMessageConverter();
}

}

监听方法：

 @RabbitListener(queues = RabbitMqConstants.EMPLOYEE_QUEUE)
    public void handleMessage(Employee employee) {

        System.out.println("Received <" + employee.toString() + ">");
    }

为了测试它，我通过 rest api 向发布者服务发送了一个 Employee 对象。在这里，我只是将它原封不动地传递给兔子。订阅者服务读取消息并将其打印到控制台。

问题： 订户服务打印正确的值：

Received <{id=1, firstName='John', lastName='Doe', salary=1.5}>

但我也得到一个错误跟踪：

    Caused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize instance of `java.lang.String` out of START_OBJECT token
 at [Source: (String)"{"id":1,"firstName":"John","lastName":"Doe","salary":1.5}"; line: 1, column: 1]
    at com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59) 

因此，据我了解，订阅者看到传入的 Json 是 ob 类型的对象，但它试图将其反序列化为字符串。

问题： 当跟踪显示似乎有错误时，为什么会打印正确的输出？当我使用 RestController 时，传入的对象会自动映射到给定的模型。使用rabbitmq时我是否必须以某种方式连接它？

编辑：

这就是我遵循的指南。

正如我在订阅者的标题中看到的那样，有一个字段headers={__TypeId__=com.publisher.model.Employee}，因此我将两个应用程序中的 Employee 模型设置为具有相同名称的包。还是一样的错误。（就像我预期的那样，因为与standardMessageConverter相反，packe名称不用于序列化）

标签： javaspringspring-bootrabbitmqjson-deserialization

Answer 1

很明显，您不能直接使用 java bean 接收消息。

尝试使用byte[] msgorString msg作为您的handleMessage()方法的参数并Employee手动将其转换为您的 bean。

如果您想使用 java bean 接收消息，配置会有所帮助。

@Configuration
public class RabbitMQConfig {
    
    @Bean
    public RabbitListenerContainerFactory<?> rabbitListenerContainerFactory(ConnectionFactory connectionFactory){
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        return factory;
    }

}