ActiveMQ基于Queue的发送消息模式

???? activemq既然是基于jms的就存在所谓的点对点模式和发布订阅模式，下面编写基于queue的发送消息方式。

启动activemq的broker进程。

代码如下：

package easyway.app.activemq.demo14;import javax.jms.JMSException;import javax.jms.Queue;import javax.jms.QueueConnection;import javax.jms.QueueConnectionFactory;import javax.jms.QueueSender;import javax.jms.QueueSession;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/** * ActiveMQ的Queue消息队列的 * @author longgangbai * */public final class SimpleQueueSender {    private static final Logger LOG = LoggerFactory.getLogger(SimpleQueueSender.class);    private SimpleQueueSender() {    }    public static void main(String[] args) {        String queueName = "activemqqueue";        QueueConnectionFactory queueConnectionFactory = null;        QueueConnection queueConnection = null;        QueueSession queueSession = null;        Queue queue = null;        QueueSender queueSender = null;        TextMessage message = null;        final int numMsgs=10;        try {        //创建链接工厂        queueConnectionFactory=new ActiveMQConnectionFactory();             //创建连接            queueConnection = queueConnectionFactory.createQueueConnection();            //创建会话            queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);            //创建队列            queue  = queueSession.createQueue(queueName);            //创建消息发送者            queueSender = queueSession.createSender(queue);            message = queueSession.createTextMessage();            for (int i = 0; i < numMsgs; i++) {                message.setText("This is message " + (i + 1));                LOG.info("Sending message: " + message.getText());                queueSender.send(message);            }            //发送消息            queueSender.send(queueSession.createMessage());        } catch (JMSException e) {            LOG.info("Exception occurred: " + e.toString());        } finally {            if (queueConnection != null) {                try {                    queueConnection.close();                } catch (JMSException e) {                }            }        }    }}

?

package easyway.app.activemq.demo14;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.Queue;import javax.jms.QueueConnection;import javax.jms.QueueConnectionFactory;import javax.jms.QueueReceiver;import javax.jms.QueueSession;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/** * ActiveMQ的Queue消息队列的 * @author longgangbai * */public final class SimpleQueueReceiver {    private static final Logger LOG = LoggerFactory.getLogger(SimpleQueueReceiver.class);    private SimpleQueueReceiver() {    }    public static void main(String[] args) {    String queueName = "activemqqueue";        QueueConnectionFactory queueConnectionFactory = null;        QueueConnection queueConnection = null;        QueueSession queueSession = null;        Queue queue = null;        QueueReceiver queueReceiver = null;        TextMessage message = null;        try {         //创建连接工厂        queueConnectionFactory=new ActiveMQConnectionFactory();         //创建连接        queueConnection = queueConnectionFactory.createQueueConnection();         //创建连接会话        queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);         //创建队列        queue  = queueSession.createQueue(queueName);         //创建消息接受者        queueReceiver = queueSession.createReceiver(queue);            queueConnection.start();            while (true) {                Message m = queueReceiver.receive(1);                if (m != null) {                    if (m instanceof TextMessage) {                        message = (TextMessage)m;                        LOG.info("Reading message: " + message.getText());                    } else {                        break;                    }                }            }        } catch (JMSException e) {            LOG.info("Exception occurred: " + e.toString());        } finally {            if (queueConnection != null) {                try {                    queueConnection.close();                } catch (JMSException e) {                }            }        }    }}

?