spring 整合 actionMQ（一）

前段时间配置了rabbitMQ 主要是为了公司发送大批量邮件而服务，结果锦鲤说要用actionMQ，还能说什么，肯定是actionMq的走起了。

鉴于第一次配置、使用ActionMQ，所以进行详细的配置，记录。如果有最新的用法，或者跟详细、更深入的使用，我会不定期的更新，

期待和小伙伴们共同进步。

添加MAVEN依赖

    org.apache.activemq
    activemq-broker
    5.14.5


    org.apache.activemq
    activemq-pool
    5.14.5


    org.apache.activemq
    activemq-spring
    5.14.5


    org.apache.activemq
    artemis-jms-client
    2.3.0


    org.springframework
    spring-jms
    ${org.springframework.version}

　　这里有的小伙伴可能依赖了

 org.apache.activemq
 activemq-all
 5.9.0

    org.springframework
    spring-jms
    ${org.springframework.version}

毕竟一个顶的上上面的一大堆了，可出问题的时候也是来的猝不及防的。slf4j 冲突。大部分的程序中都会有slf4j,如果你报错了，就乖乖用上面的一大堆把。或者可以考虑把冲突的包从Maven程序中排除。具体怎么排除，可以百度了。

配置文件  （对于我个人来说，第一步，就是搞定配置文件，类什么的在配置的过程中再去书写）

 1 <?xml version="1.0" encoding="UTF-8" ?>
 2 
 3  4        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 5        xmlns:context="http://www.springframework.org/schema/context"
 6        xsi:schemaLocation="http://www.springframework.org/schema/beans
 7        http://www.springframework.org/schema/beans/spring-beans.xsd
 8        http://www.springframework.org/schema/context
 9        http://www.springframework.org/schema/context/spring-context.xsd ">
10 
11     
12 
13     
14     class="org.apache.activemq.ActiveMQConnectionFactory">
15         
16           
17     
18     
19     class="org.springframework.jms.connection.SingleConnectionFactory">
20         
21     
22 
23     
24     class="org.apache.activemq.command.ActiveMQQueue">
25         
26     
27     
28     class="org.apache.activemq.command.ActiveMQQueue">
29         
30     
31     
32     class="org.springframework.jms.core.JmsTemplate">
33         
34     
35     
36     class="mq.ProduceServiceImpl"/>
37 
38 
39     
40     class="mq.SimpleMsgListener"/>
41     
42     class="org.springframework.jms.listener.DefaultMessageListenerContainer">
43         
44         
45         
46         
47         
48         
49         
50         
51     
52 
53 
54     
55     class="org.apache.activemq.RedeliveryPolicy">
56         
57         
58         
59         
60         
61         
62         
63         
64         
66         
67     
68 

　配置的第一步肯定是链接到MQ服务了。（ActionMQ 链接工厂可以添加的属性还有很多，例如 username、password ...）

　　第二步：配置spring jms为我们提供的连接池

　　第三步：配置队列（我的是队列模式，也就是 1对1消费模式（一条消息消费一次），还有一个发布订阅的模式（一条消息可以被订阅的多个客户端消费））

　　第四步：配置模板

　　第五步：声明注入消息发布者（这个没必要，正常可用的类就可以，在其中引入 @Autowired private JmsTemplate jmsTemplate; 模板类，就可以发送消息）

发送消息的类

 1 package mq;
 2 import org.springframework.beans.factory.annotation.Autowired;
 3 import org.springframework.jms.core.JmsTemplate;
 4 import org.springframework.jms.core.MessageCreator;
 5 import javax.annotation.Resource;
 6 import javax.jms.*;
 7 
 8 /**
 9  * @ Author     ：tian
10  * @ Date       ：Created in 下午 2:21 2019/6/13 0015
11  * @ Description：生产者的实现类
12  */
13 public class ProduceServiceImpl{
14     @Autowired
15     private JmsTemplate jmsTemplate;
16     @Resource(name = "queueDestination")
17     private Destination destination;
18 
19     /**
20      * 发送消息
21      * @param msg
22      */
23     public void sendMessage(final String msg) {
24         jmsTemplate.convertAndSend("SpringActiveMQMsg",msg);
25 //        jmsTemplate.send(destination , new MessageCreator() {
26 //            @Override
27 //            public Message createMessage(Session session) throws JMSException {
28 //                TextMessage textMessage = session.createTextMessage(msg);
29 //                return textMessage;
30 //            }
31 //        });
32         System.out.println("现在发送的消息为： " + msg);
33     }
34 
35     /**
36      * 接收消息
37      */
38     public TextMessage receive() {
39         TextMessage tm = (TextMessage) jmsTemplate.receive("SpringActiveMQMsg");
40         try {
41             System.out.println("从队列SpringActiveMQMsg收到了消息：\t"
42                     + tm.getText());
43         } catch (JMSException e) {
44             e.printStackTrace();
45         }
46 
47         return tm;
48 
49     }
50 }

发送消息可以用以上两种方式（不只这两种，但这两个最简单。）

方式1：

jmsTemplate.convertAndSend("SpringActiveMQMsg",msg) // 参数一：你声明的队列的名称 （队列可以不声明，直接到ActionMQ 的控制台创建也可以，简化配置，只不过要换服务器的时候还得创建一次。） 参数二：发送的消息

方式2：

上面程序中注释的部分

        jmsTemplate.send(destination , new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage textMessage = session.createTextMessage(msg);
                return textMessage;
            }
        });
它是可以正确发送消息的 这里可以看到 发送方法也有两个参数 （参数一：声明队列的beanID 参数二：发送的消息创建者）
在这里可以看到有一个 TextMessage  类， 这个是消息的一种类型，actionMQ中消息有多种类型 JMS规范中的消息类型包括TextMessage、MapMessage、ObjectMessage、BytesMessage、和StreamMessage等五种。ActiveMQ也有对应的实现
详细的情况参见博文：

顺便介绍一下 消息的手动接收 TextMessage tm = (TextMessage) jmsTemplate.receive("SpringActiveMQMsg"); 使用jmsTemplate 模板 的receive("队列名称") ，可以一次消费一条消息。（肯定不止这一个方法了，具体的小伙伴们可以自行摸索）

消息的消费类型对应发送类型。如果想要消息自动接收消费，那就得配置消息监听器了。下面贴上消费者的代码

package mq;
import javax.jms.*;

/**
 * Created by Martin Huang on 2018/4/20.
 */
//bean id
public class SimpleMsgListener implements MessageListener {

    //收到信息时的动作
    @Override
    public void onMessage(Message message ) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println("收到的信息：" + textMessage.getText());
            textMessage.acknowledge();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

}

这个类一定要实现 MessageListener 的（当然你可以实现其他的，千万别被我误导了）重载 方法 onMessage(Message message ) 就是消费的方法，这里我进行了消息的手动确认（默认是自动确认的，那样消息不成功也会出队，）消息不成功就不会出队。

其实这样做也不好。赶时间做ActionMQ，只能先把问题留下，以后再解决。如果有解决确认问题的好方法，欢迎留言评论，感激不尽...