简单的JMS实例

1.首先需要一台JMS的提供者，在这里我选择使用的是apache-activemq-5.3.2这个服务器，首先下载服务器并通过bin目录下的activemq.bat启动服务器，此时可通过http://ocalhost:8161/admin/访问服务器查看是否发布成功

2.服务器发布成功之后就可以开始写消息发送者的程序了：

　　

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.DeliveryMode;

import javax.jms.Destination;

import javax.jms.MessageProducer;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {

    public static void main(String[] args) {

        // ConnectionFactory ：连接工厂，JMS 用它创建连接

        ConnectionFactory connectionFactory;

        // Connection ：JMS 客户端到JMS Provider 的连接

        Connection connection = null;

        // Session： 一个发送或接收消息的线程

        Session session;

        // Destination ：消息的目的地;消息发送给谁.

        Destination destination;

        // MessageProducer：消息发送者

        MessageProducer producer;

        // TextMessage message;

        // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar

        connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");

        try {

            // 构造从工厂得到连接对象

            connection = connectionFactory.createConnection();

            // 启动

            connection.start();

            // 获取操作连接

            session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);

            // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置

            destination = session.createQueue("FirstQueue");

            //Destination  destination1=session.createTopic("Second");

            //MessageProducer producer1 = session.createProducer(destination1);

            //TextMessage message1 = session.createTextMessage("我想发送给多个人的消息");

            //producer1.send(message1);

            // 得到消息生成者【发送者】

            producer = session.createProducer(destination);

            //创建需要发布的消息

            TextMessage message = session.createTextMessage("ActiveMq 发送的消息");

            // 设置不持久化，此处学习，实际根据项目决定

            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

            //发送消息

            producer.send(message);

            session.commit();

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            try {

                if (null != connection)

                    connection.close();

            } catch (Throwable ignore) {

            }

        }

    }

}  

消息发布者

3.此时消息发送者创建完毕之后就可以创建消息接受者的程序了：

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.MessageConsumer;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

    public static void main(String[] args) {

        // ConnectionFactory ：连接工厂，JMS 用它创建连接

        ConnectionFactory connectionFactory;

        // Connection ：JMS 客户端到JMS Provider 的连接

        Connection connection = null;

        // Session： 一个发送或接收消息的线程

        Session session;

        // Destination ：消息的目的地;消息发送给谁.

        Destination destination;

        // 消费者，消息接收者

        MessageConsumer consumer;

        connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");

        try {

            // 构造从工厂得到连接对象

            connection = connectionFactory.createConnection();

            // 启动

            connection.start();

            // 获取操作连接

            session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

            // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置

            destination = session.createQueue("FirstQueue");

            //destination = session.createTopic("Second");

            consumer = session.createConsumer(destination);

            while (true) {

                // 设置接收者接收消息的时间，为了便于测试，这里设定为100s

                TextMessage message = (TextMessage) consumer.receive(100000);

                if (null != message) {

                    System.out.println("收到消息：" + message.getText());

                } else {

                    break;

                }

            }

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            try {

                if (null != connection)

                    connection.close();

            } catch (Throwable ignore) {

            }

        }

    }

}  

消息接收者