spring 快速搭建JMS

一、简介

JMS（Java Message Service） java异步消息服务

1.JMS是什么?
jms是一个标准，定义了使用消息的通用API，类似于jdbc这样用户可以用同样的接口操作不同的消息服务实现

2.JMS的应用场景？
jms代表应用之间的异步通信，对应的有同步通信，所谓同步通信就是当消息发出后，客户端需要一直等到服务器响应，即使服务器只是返回了一个空。异步消息类似于寄信，当我们把信件放进邮筒并假定它肯定能正确被投递，我们不用等着回信，甚至不用关心信件什么时候寄出去，并且我们相信信件肯定会得到正确的处理！异步消息就是我们将消息发出给消息代理服务器，并假定消息肯定能够送到指定目的地，相信消息肯定能得到处理。

3.JMS涉及的概念?

• jms是一个规范，既然是规范，那肯定有实现规范的服务比如（ActiveMQ）
• 消息代理服务器（类似于邮局）
• 目的地（类似于收信地址）包含点对点的queue和发布/订阅的topic
• 我们将消息发给代理服务器，由代理服务器发送到指定的目的地，就是这么简单！

4.消息队列和发布订阅介绍
消息队列就是点对点，当消息发出后会有一个服务可以接收到，但关注的服务不只一个，发送方不关心是谁接收了消息。这样做的好处是我们可以通过添加更多的接收者来提升性能

发布订阅，当消息发布后，所有订阅了该消息主题的用户都可以接收到消息，但发送者并不知道谁订阅了自己的消息，想象一个场景，当一个新员工来到公司，HR部门会为该员工建立一些档案等，财务部门会为该员工登记工资信息，后勤部会给该员工分配办公用品等等，也就是说，同样的消息当不同的应用获取后可以进行不同的处理。

---

二、从一个helloworld开始

不要急按着步骤一步步来。
第一步、下载ActiveMQ(下载地址就自己去网上搜吧！)
第二步、解压后，在如图所示的bin目录下启动代理服务器

启动代理服务器

第三步、将解压后的lib目录下的activemq-broker-5.9.1.jar和activemq-client-5.9.1.jar拷进你的classpath下，或者在你的pom文件中引入对应版本的依赖

           <dependency>
                <groupId>org.apache.activemq</groupId>
                <artifactId>activemq-broker</artifactId>
                <version>5.9.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.activemq</groupId>
                <artifactId>activemq-client</artifactId>
                <version>5.9.1</version>
            </dependency>

第四步、发送方代码（生产者）

//创建连接工厂 ActiveMQ服务默认的端口号是：61616
 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection conn = null;
        Session session = null;
        try {
       //创建连接
            conn = connectionFactory.createConnection();
            conn.start();
      //创建会话
            session = conn.createSession(false,session.AUTO_ACKNOWLEDGE);
      //创建目的地(点对点目的地，发布订阅是(ActiveMQTopic对象))
            Destination destination = new ActiveMQQueue("gamelife.alert.queue");
      //创建消息发送者
            MessageProducer producer = session.createProducer(destination);
        //创建文本消息
            TextMessage message = new ActiveMQTextMessage();
            message.setText("Hello world!");
        //发送消息
            producer.send(destination,message);
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
        //资源不要忘了关闭
            try {
                if (conn != null) {
                    conn.close();
                }
                if (session != null) {
                    session.close();
                }
            } catch (JMSException e) {
                throw new RuntimeException(e);
            }
        }

第五步、接收方代码（消费者）

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection conn = null;
        Session session = null;
        try {
            conn = connectionFactory.createConnection();
            conn.start();
            session = conn.createSession(false,session.AUTO_ACKNOWLEDGE);
            Destination destination = new ActiveMQQueue("gamelife.alert.queue");
          //创建消息接收者
            MessageConsumer consumer = session.createConsumer(destination);
          //接收消息
            TextMessage message = (TextMessage) consumer.receive();
            System.out.println(message.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            try {
                if (conn != null) {
                    conn.close();
                }
                if (session != null) {
                    session.close();
                }
            } catch (JMSException e) {
                throw new RuntimeException(e);
            }
        }

这样就完成了一个简单的helloworld

三、利用spring的JmsTemplate消灭重复代码

第一步、配置ConnectionFactory、和JmsTemplate

    <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
    </bean>
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>

第二步、发送消息代码

       ApplicationContext context = new ClassPathXmlApplicationContext("/conf/applicationContext.xml");
        JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
//可以通过convertAndSend()直接发送实现了序列化接口的对象，第一个参数是目的地，默认是消息队列如果希望是发布订阅的主题可以传一个对象
        jmsTemplate.convertAndSend("gamelife.alert.queue",new User("username","password"));

第三步、接收消息

        ApplicationContext context = new ClassPathXmlApplicationContext("/conf/applicationContext.xml");
        JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
        System.out.println(jmsTemplate==null);
        User user= (User) jmsTemplate.receiveAndConvert("gamelife.alert.queue");
        System.out.println(user.getUsername());

完成了。

四、利用spring创建消息驱动的POJO

首先要知道之前的操作有什么不好呢？就是每次接收方去取消息的时候recive方法会阻塞，知道有消息到达为止，这样不是我们想要的，我们需要一个基于事件驱动的消息系统，就是说当有消息的时候会自动调用我们的方法。
第一步、创建用于监听消息的对象

//仅仅是一个简单的实现了MessageListener接口的POJO
public class JmsHandler implements MessageListener{

    public void onMessage(Message message) {
        try {
            User user = (User) ((ObjectMessage) message).getObject();
            System.out.println(user.getUsername());
            System.out.println(user.getPassword());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

第二步、配置消息监听对象**

<bean id="jmsHandler" class="jmslistener.JmsHandler"></bean>
<jms:listener-container>
        <jms:listener destination="gamelife.alert.queue" ref="jmsHandler" />
    </jms:listener-container>

启动服务器后，当有消息到来的时候会自动调用对应的方法

到这里就算结束了，快去动手搭建自己的JMS服务器吧，发布订阅模型就不敲重复的代码了只不过是Destination不同（ActiveMQTopic），对象不同而已，自己跟着IDE的提示走就没问题。