ActiveMQ中常用API介绍

下述API都是接口类型,由定义在javax.jms包中.是JMS标准接口定义
在这里插入图片描述

JMS-Hello

导入依赖

<dependencies>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.12.0</version>
        </dependency>
    </dependencies>

创建ActiveMQ中的生产者

package com.yjn.jms;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/** * ActiveMQ中的生产者(Producer) * @author JustinNeil * */
public class HelloProducer { 
    public void sendhello2ActiveMq(String messageText) { 
        // 连接工厂，用于创建Connection对象
        ConnectionFactory factory = null;
        // activeMQ 连接对象
        Connection conn = null;
        // 一次和ActiveMQ的持久会话对象
        Session session = null;
        // 目的地
        Destination destination = null;
        // 消息发送者
        MessageProducer producer = null;
        // 封装消息的对象
        Message message = null;
        try { 
            /* * 创建链接工厂 ActiveMQConnectionFactory -由ActiveMQ实现的ConnectionFactory接口实现类. * 构造方法: public ActiveMQConnectionFactory(String userName, String password, * String brokerURL) * userName - 访问ActiveMQ服务的用户名,用户名可以通过jetty-realm.properties配置文件配置. * password - 访问ActiveMQ服务的密码,密码可以通过jetty-realm.properties配置文件配置. * brokerURL -访问ActiveMQ服务的路径地址. 路径结构为 - 协议名://主机地址:端口号 此链接基于TCP/IP协议. */
            factory = new ActiveMQConnectionFactory("admin", "admin", "tcp://192.168.192.171:61616");
            // 创建链接对象
            conn = factory.createConnection();
            // 启动连接对象
            conn.start();
            /* * 创建会话对象 * 方法 - connection.createSession(boolean transacted, int acknowledgeMode); * transacted - 是否使用事务, * 可选值为true|false * true - 使用事务, 当设置此变量值, 则acknowledgeMode参数无效, * 建议传递的acknowledgeMode参数值为 Session.SESSION_TRANSACTED * false - 不使用事务, 设置此变量值,则acknowledgeMode参数必须设置. * acknowledgeMode - 消息确认机制, 可选值为: * Session.AUTO_ACKNOWLEDGE - 自动确认消息机制 * Session.CLIENT_ACKNOWLEDGE -客户端确认消息机制 * Session.DUPS_OK_ACKNOWLEDGE - 有副本的客户端确认消息机制 */
            session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // 创建目的地，目的地的命名既是队列的命令
            destination = session.createQueue("MQ-Hello");
            // 创建消息生成者, 创建的消息生成者与某目的地对应, 即方法参数目的地.
            producer = session.createProducer(destination);
            // 创建消息对象，创建一个文本消息对象。此消息对象中保存要传递的文本数据.
            message = session.createTextMessage(messageText);
            // 发送消息
            producer.send(message);
        } catch (Exception e) { 
            e.printStackTrace();
            System.out.println("访问ActiveMQ服务发生错误!!");
        } finally { 
            try { 
                // 回收消息发送者资源
                if (null != producer)
                    producer.close();
            } catch (JMSException e) { 
                e.printStackTrace();
            }
            try { 
                // 回收会话资源
                if (null != session)
                    session.close();
            } catch (JMSException e) { 
                e.printStackTrace();
            }
            try { 
                // 回收链接资源
                if (null != conn)
                    conn.close();
            } catch (JMSException e) { 
                e.printStackTrace();
            }
        }
    }
}

创建ActiveMQ中的消费者

package com.yjn.jms;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/** * ActiveMQ中的消费者(Consumer) * @author JustinNeil * */
public class HelloConsumer { 
    public void reciveHelloFormActiveMq() { 
        // 连接工厂，用于创建Connection对象
        ConnectionFactory factory = null;
        // activeMQ 连接对象
        Connection conn = null;
        // 一次和ActiveMQ的持久会话对象
        Session session = null;
        // 目的地
        Destination destination = null;
        // 消息消费者
        MessageConsumer consumer = null;
        // 封装消息的对象
        Message message = null;
        try { 
            /* * 创建链接工厂 ActiveMQConnectionFactory -由ActiveMQ实现的ConnectionFactory接口实现类. * 构造方法: public ActiveMQConnectionFactory(String userName, String password, * String brokerURL) * userName - 访问ActiveMQ服务的用户名,用户名可以通过jetty-realm.properties配置文件配置. * password - 访问ActiveMQ服务的密码,密码可以通过jetty-realm.properties配置文件配置. * brokerURL -访问ActiveMQ服务的路径地址. 路径结构为 - 协议名://主机地址:端口号 此链接基于TCP/IP协议. */
            factory = new ActiveMQConnectionFactory("admin", "admin", "tcp://192.168.192.171:61616");
            // 创建链接对象
            conn = factory.createConnection();
            // 启动连接对象
            conn.start();
            /* * 创建会话对象 * 方法 - connection.createSession(boolean transacted, int acknowledgeMode); * transacted - 是否使用事务, * 可选值为true|false * true - 使用事务, 当设置此变量值, 则acknowledgeMode参数无效, * 建议传递的acknowledgeMode参数值为 Session.SESSION_TRANSACTED * false - 不使用事务, 设置此变量值,则acknowledgeMode参数必须设置. * acknowledgeMode - 消息确认机制, 可选值为: * Session.AUTO_ACKNOWLEDGE - 自动确认消息机制 * Session.CLIENT_ACKNOWLEDGE -客户端确认消息机制 * Session.DUPS_OK_ACKNOWLEDGE - 有副本的客户端确认消息机制 */
            session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // 创建目的地，目的地的命名既是队列的命令
            destination = session.createQueue("MQ-Hello");
            // 创建消息消费者, 创建的消息消费者与某目的地对应, 即方法参数目的地.
            consumer = session.createConsumer(destination);
            // 从ActiveMQ中获取消息
            message = consumer.receive();
            String textMessage = ((TextMessage)message).getText();
            System.out.println("ActiveMQ获取的消息是:"+textMessage);
        } catch (Exception e) { 
            e.printStackTrace();
            System.out.println("访问ActiveMQ服务发生错误!!");
        } finally { 
            try { 
                // 回收消息发送者资源
                if (null != consumer)
                    consumer.close();
            } catch (JMSException e) { 
                e.printStackTrace();
            }
            try { 
                // 回收会话资源
                if (null != session)
                    session.close();
            } catch (JMSException e) { 
                e.printStackTrace();
            }
            try { 
                // 回收链接资源
                if (null != conn)
                    conn.close();
            } catch (JMSException e) { 
                e.printStackTrace();
            }
        }
    }
}

测试

生产者

public static void main(String[] args) { 
        HelloProducer helloProducer = new HelloProducer();
        helloProducer.sendhello2ActiveMq("你好。。。");
    }

消费者

public static void main(String[] args) { 
        HelloConsumer helloConsumer = new HelloConsumer();
        helloConsumer.reciveHelloFormActiveMq();
    }