• 现象：收到消息会打印告警消息:：Could not convert incoming message with content-type [null]
• 解决：

RabbitMQ已经实现了Jackson的消息转换（Jackson2JsonMessageConverter），由于考虑到效率，如下使用Gson实现消息转换。

如下消息的转换类的接口MessageConverter，Jackson2JsonMessageConverter的父类AbstractJsonMessageConverter针对json转换的基类。

我们实现Gson2JsonMessageConverter转换类也继承AbstractJsonMessageConverter。

引入Gson的pom

[html] view plain copy

1. <dependency>
2. <groupId>com.google.code.gson</groupId>
3. <artifactId>gson</artifactId>
4. <version>2.3</version>
5. </dependency>

转换类实现如下：

[java] view plain copy

1. package cn.slimsmart.rabbitmq.demo.spring.tag;
3. import java.io.IOException;
4. import java.io.UnsupportedEncodingException;
6. import org.apache.commons.logging.Log;
7. import org.apache.commons.logging.LogFactory;
8. import org.springframework.amqp.core.Message;
9. import org.springframework.amqp.core.MessageProperties;
10. import org.springframework.amqp.support.converter.AbstractJsonMessageConverter;
11. import org.springframework.amqp.support.converter.ClassMapper;
12. import org.springframework.amqp.support.converter.DefaultClassMapper;
13. import org.springframework.amqp.support.converter.MessageConversionException;
15. import com.google.gson.Gson;
17. public class Gson2JsonMessageConverter extends AbstractJsonMessageConverter {
19. private static Log log = LogFactory.getLog(Gson2JsonMessageConverter.class);
21. private static  ClassMapper classMapper =  new DefaultClassMapper();
23. private static Gson gson = new Gson();
25. public Gson2JsonMessageConverter() {
26. super();
27. }
29. @Override
30. protected Message createMessage(Object object,
31. MessageProperties messageProperties) {
32. byte[] bytes = null;
33. try {
34. String jsonString = gson.toJson(object);
35. bytes = jsonString.getBytes(getDefaultCharset());
36. }
37. catch (IOException e) {
38. throw new MessageConversionException(
39. "Failed to convert Message content", e);
40. }
41. messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
42. messageProperties.setContentEncoding(getDefaultCharset());
43. if (bytes != null) {
44. messageProperties.setContentLength(bytes.length);
45. }
46. classMapper.fromClass(object.getClass(),messageProperties);
47. return new Message(bytes, messageProperties);
48. }
50. @Override
51. public Object fromMessage(Message message)
52. throws MessageConversionException {
53. Object content = null;
54. MessageProperties properties = message.getMessageProperties();
55. if (properties != null) {
56. String contentType = properties.getContentType();
57. if (contentType != null && contentType.contains("json")) {
58. String encoding = properties.getContentEncoding();
59. if (encoding == null) {
60. encoding = getDefaultCharset();
61. }
62. try {
63. Class<?> targetClass = getClassMapper().toClass(
64. message.getMessageProperties());
65. content = convertBytesToObject(message.getBody(),
66. encoding, targetClass);
67. }
68. catch (IOException e) {
69. throw new MessageConversionException(
70. "Failed to convert Message content", e);
71. }
72. }
73. else {
74. log.warn("Could not convert incoming message with content-type ["
75. + contentType + "]");
76. }
77. }
78. if (content == null) {
79. content = message.getBody();
80. }
81. return content;
82. }
84. private Object convertBytesToObject(byte[] body, String encoding,
85. Class<?> clazz) throws UnsupportedEncodingException {
86. String contentAsString = new String(body, encoding);
87. return gson.fromJson(contentAsString, clazz);
88. }
89. }

现象：收到消息会打印告警消息:：Could not convert incoming message with content-type [null] 解决：RabbitMQ已经实现了Jackson的消息转换（Jackson2JsonMessageConverter），由于考虑到效率，如下使用Gson实现消息转换。如下消息的转换类的接口MessageConverter，Jackson2JsonMessageConverter的父类AbstractJsonMessageConverter针对json转 支持byte[] 、CharSequence 两种类型直接传输 ，其余对象直接用fastjson转为json字符串传输 。 byte[] 一般用来传输文件 ， 而 CharSequence用来传输字符串效率更高。 import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.serializer.SerializerFeature; import org.springframework.amqp.core. Message ; impor <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 2.配置 RabbitMQ 连接信息，例如在application.properties中添加以下配置： spring. rabbitmq .host=localhost spring. rabbitmq .port=5672 spring. rabbitmq .username=guest spring. rabbitmq .password=guest 3.创建一个发送 消息 的工具类，例如AlertSender.java： @Component public class AlertSender { @Autowired private RabbitTemplate rabbitTemplate; public void send(String message ) { rabbitTemplate. convert AndSend("alert.exchange", "alert.key", message ); 4.在需要发送 告警 消息 的地方调用AlertSender的send方法，例如： @Autowired private AlertSender alertSender; public void doSomething() { // 发送 告警 消息 alertSender.send("发生了错误！"); 5.在 RabbitMQ 中创建exchange和queue，并将它们绑定起来，例如： @Bean public DirectExchange alertExchange() { return new DirectExchange("alert.exchange"); @Bean public Queue alertQueue() { return new Queue("alert.queue"); @Bean public Binding alertBinding(DirectExchange alertExchange, Queue alertQueue) { return BindingBuilder.bind(alertQueue).to(alertExchange).with("alert.key"); 这样就完成了使用SpringBoot和 RabbitMQ 发送 告警 消息 的实现。