我使用Spring Boot和Rappitmq，以便在两个不同的应用程序之间实现异步消息传递。当我只将字符串作为消息内容交换时，这一点很好。我还执行了pojos的交换。由于pojo在不同的包中进行，序列化/反序列化过程失败。为了解决这个问题，我使用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 +
'}';
}
Beans在发布服务器服务中使用Jackson2JsonConverter：
@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类型的Object，但它试图将其反序列化为String。
问题：当跟踪显示似乎有错误时，为什么会打印正确的输出？当我使用RestController时，传入的Object会自动映射到给定的Model。在使用rabbitmq时，我是否必须以某种方式将其连接起来？
编辑：
那是我跟随的向导。
正如我在订阅服务器的标题中看到的那样，有一个字段headers={__TypeId__=com.publisher.model.Employee}，所以我已经将两个应用程序中的Employee模型设置为具有相同名称的包。还是同样的错误。(正如我所期望的，因为与标准MessageConverter相反，包名称没有用于序列化(
很明显，您不能直接用javabean接收消息。
尝试使用byte[] msg或String msg作为handleMessage()方法的参数，并手动将其转换为Employeebean。
如果您想用javabean接收消息，那么配置会有所帮助。
@Configuration
public class RabbitMQConfig {
@Bean
public RabbitListenerContainerFactory<?> rabbitListenerContainerFactory(ConnectionFactory connectionFactory){
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setMessageConverter(new Jackson2JsonMessageConverter());
return factory;
}
}