Spring使用MappingJackson2MessageConverter发送接收ActiveMQ消息

一、Spring使用JmsTemplate简化对JMS的访问

在JAVA对JMS队列访问中，使用默认的JMS支持将存在大量的检查型异常。通过Spring的支持，可以将所有的JMS的检查型异常转换为运行时非检查异常。以及在Spring中，通过配置JMSConnectionFactory的DefaultDestinationName指定发送和接收目的地。

下面是ActiveMQ的连接factory配置：

11     @Bean
22     public ActiveMQConnectionFactory getAMQFactory() {
33         ActiveMQConnectionFactory mqConnectionFactory = new ActiveMQConnectionFactory();
44         mqConnectionFactory.setBrokerURL("tcp://59.110.231.87:61616");
55         mqConnectionFactory.setTrustedPackages(Arrays.asList("com.edoctor.bean"));
66         return mqConnectionFactory;
77     }

下面是JmsTemplate的配置：

11     @Bean
22     public JmsTemplate getJmsTemplate(ActiveMQConnectionFactory cf, MessageConverter messageConverter) {
33         JmsTemplate jmsTemplate = new JmsTemplate(cf);
44         jmsTemplate.setDefaultDestinationName("com.demo.testActiveMQ");
55         jmsTemplate.setMessageConverter(messageConverter);
66         // pubSubDomain = true 为队列模式，false为订阅发布模式
77         jmsTemplate.setPubSubDomain(false);
88         return jmsTemplate;
99     }

我是使用纯JAVA注解配置的Bean，基于xml的也类似，可以自行搜索。

上述字段含义如下：

setDefaultDestinationName：设置ActiveMQ的队列名称，当然如果下面的pubSubDomain为true，则为主题名称

setMessageConverter：设置ActiveMQ的消息转换器，默认不写的话是使用的Spring的SimpleMessageConverter

setPubSubDomain：值true代表该Template为队列，false为主题

二、Spring的消息转换器的种类

Spring自带的消息转换器可以大大简化消息的读取以及写入，所有的消息转换器都位于org.springframework.jms.support.converter包中。

消息转换器

功能

MappingJacksonMessageConverter

使用Jackson JSON库实现消息与JSON格式之间的相互转换

MappingJackson2MessageConverter

使用Jackson 2 JSON库实现消息与JSON格式之间相互转换

MarshallingMessageConverter

使用JAXB库实现消息与XML格式之间的相互转换

SimpleMessageConverter

实现String与TextMessage之间的相互转换，字节数组与Bytes
Message之间的相互转换，Map与MapMessage之间的相互转换
以及Serializable对象与ObjectMessage之间的相互转换

默认情况下，JmsTemplate在convertAndSend()方法中会使用SimpleMessage Converter。但是通过将消息转换器声明为bean并将其注入到JmsTemplate的messageConverter属性中，我们可以重写这种行为。例如，如果你想使用JSON消息的话，那么可以声明一个MappingJackson2MessageConverter bean。

三、配置MappingJackson2MessageConverter的Bean

上文的JmsTemplate已经成功注入了ActiveMQConnectionFactory，下面就将注入我们的MessageConverter。

由于使用默认的SimpleMessageConverter如果是Object对象的话，必须将对象序列化，如果对象包含包装类例如Integer将无法实现序列化，因此，我打算使用基于json的MappingJackson2MessageConverter序列化对象发送以及接受，该配置会实现自动序列化。但是在网上查阅相关文档，发现几乎没有中文介绍配置MappingJackson2MessageConverter的，因此，希望写下这个配置帮助大家。

MappingJackson2MessageConverter在JavaDoc中的详细配置：https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jms/support/converter/MappingJackson2MessageConverter.html

对于文档和介绍，上述链接有详细说明，里面主要提到一点：

意思是，如果需要在接受Object对象格式的消息的时候，需要配置这项属性，以及这项属性需要参考typeIdMappings。

我们再看一下这个Map的说明：

这个Map以String为key,Class为值，而这里的Key就是对应的typeId，Value就是你需要序列化的类。所以只需要构建这样一个Map就可以允许从MQ中接受类对象型的消息了。下面是我的POJO(注意该在MQ中发送接收的对象务必有无参构造函数)

1 1 public class TestJMS {
2 2     private String name;
3 3     private Integer age;
4 4     private String email;
5 5 
6 6     public TestJMS() {
7 7     }
8 8 
9 9     public TestJMS(String name, Integer age, String email) {
1010         this.name = name;
1111         this.age = age;
1212         this.email = email;
1313     }
1414 
1515     public String getName() {
1616         return name;
1717     }
1818 
1919     public void setName(String name) {
2020         this.name = name;
2121     }
2222 
2323     public Integer getAge() {
2424         return age;
2525     }
2626 
2727     public void setAge(Integer age) {
2828         this.age = age;
2929     }
3030 
3131     public String getEmail() {
3232         return email;
3333     }
3434 
3535     public void setEmail(String email) {
3636         this.email = email;
3737     }
3838 
3939     @Override
4040     public String toString() {
4141         return "TestJMS{" +
4242                 "name='" + name + '\'' +
4343                 ", age=" + age +
4444                 ", email='" + email + '\'' +
4545                 '}';
4646     }
4747 }

以及这是注入到JmsTemplate的MappingJackson2MessageConverter的Bean定义

1 1     @Bean
2 2     public MappingJackson2MessageConverter getJacksonMessageConverter() {
3 3         MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
4 4         converter.setTargetType(MessageType.TEXT);
5 5         // 定义了typeId到Class的Map
6 6         Map<String, Class<?>> typeIdMap = new HashMap<>();
7 7         typeIdMap.put("TestJMS", TestJMS.class);
8 8         converter.setTypeIdMappings(typeIdMap);
9 9         // 设置发送到队列中的typeId的名称
1010         converter.setTypeIdPropertyName("TestJMS");
1111         converter.setEncoding("UTF-8");
1212         return converter;
1313     }

通过这样的注入，实现了Class Object格式无须序列化的对象发送与接受

完整的ActiveMQ基于JAVA注解的配置代码如下：

1 1 import com.test.bean.TestJMS;
2 2 import org.apache.activemq.ActiveMQConnectionFactory;
3 3 import org.springframework.context.annotation.Bean;
4 4 import org.springframework.context.annotation.Configuration;
5 5 import org.springframework.jms.core.JmsTemplate;
6 6 import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
7 7 import org.springframework.jms.support.converter.MessageConverter;
8 8 import org.springframework.jms.support.converter.MessageType;
9 9 
1010 import java.util.Arrays;
1111 import java.util.HashMap;
1212 import java.util.Map;
1313 
1414 @Configuration
1515 public class MQConfig {
1616 
1717     @Bean
1818     public ActiveMQConnectionFactory getAMQFactory() {
1919         ActiveMQConnectionFactory mqConnectionFactory = new ActiveMQConnectionFactory();
2020         mqConnectionFactory.setBrokerURL("tcp://59.110.231.87:61616");
2121         mqConnectionFactory.setTrustedPackages(Arrays.asList("com.edoctor.bean"));
2222         return mqConnectionFactory;
2323     }
2424 
2525     @Bean
2626     public JmsTemplate getJmsTemplate(ActiveMQConnectionFactory cf, MessageConverter messageConverter) {
2727         JmsTemplate jmsTemplate = new JmsTemplate(cf);
2828         jmsTemplate.setDefaultDestinationName("EDoctor.JMSTemplate.queue2");
2929         jmsTemplate.setMessageConverter(messageConverter);
3030         // pubSubDomain = true 为队列模式，false为订阅发布模式
3131         jmsTemplate.setPubSubDomain(false);
3232         return jmsTemplate;
3333     }
3434 
3535     @Bean
3636     public MappingJackson2MessageConverter getJacksonMessageConverter() {
3737         MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
3838         converter.setTargetType(MessageType.TEXT);
3939         Map<String, Class<?>> typeIdMap = new HashMap<>();
4040         typeIdMap.put("TestJMS", TestJMS.class);
4141         converter.setTypeIdMappings(typeIdMap);
4242         converter.setTypeIdPropertyName("TestJMS");
4343         converter.setEncoding("UTF-8");
4444         return converter;
4545     }
4646 
4747 }

**四、总结
**

MappingJackson2MessageConverter可以很有效的实现MQ的发送和接受序列化，不需要将POJO手动序列化，实现Serializable接口。基于JSON的解析也顺应主流技术。因为踩了较多的坑，所以特地留此篇博客，如果不对的地方，还希望多多指出。有疑问欢迎留言，谢谢！