ActiveMQ应用入门

た入场券 2021-11-17 10:31 270阅读 0赞

### ActiveMQ应用入门 ###

*  ActiveMQ中常用API介绍
 *  JMS-Hello
 *   *  导入依赖
     *  创建ActiveMQ中的生产者
     *  创建ActiveMQ中的消费者
     *  测试

# ActiveMQ中常用API介绍 #

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

# 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();
        }

先启动消费者，再启动生产者，查看效果  
消费者启动后阻塞状态，等待消息

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lqbjE5OTU_size_16_color_FFFFFF_t_70]: /images/20211116/33bf367cd38b4843942f677158b0c758.png

发表评论取消回复

表情：

评论列表（有 0 条评论，270人围观）

还没有评论，来说两句吧...

相关阅读

相关 ActiveMQ快速入门

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 1.下载ActiveMQ 去官方网站下载：[htt

柔情只为你懂/ 2022年10月02日 08:53/ 0 赞/ 126 阅读

相关 [JMS] ActiveMQ -- 入门

消息中间件(MOM)：交换信息的一类软件。当分布式应用使用MOM后，分布式应用会得到的好处是：松耦合、可靠、可扩展、安全。 ActiveMQ 就是一个MOM 。Active

拼搏现实的明天。/ 2022年09月30日 14:50/ 0 赞/ 225 阅读

相关 activemq 入门

一、windows下运行 1、下载 [ http://activemq.apache.org/activemq-5100-release.html][http

系统管理员/ 2022年08月04日 14:57/ 0 赞/ 143 阅读

相关 activeMQ入门demo

首先从官网下载[http://activemq.apache.org/download-archives.html][http_activemq.apache.org_down

矫情吗；*/ 2022年05月27日 07:00/ 0 赞/ 168 阅读

相关 ActiveMQ入门实践

一、运行ActiveMQ程序 1、下载ActiveMQ软件包：下载地址：[http://activemq.apache.org/download-archives.htm

绝地灬酷狼/ 2022年05月20日 04:43/ 0 赞/ 172 阅读

相关 ActiveMQ入门

ActiveMQ介绍 MQ是消息中间件，是一种在分布式系统中应用程序借以传递消息的媒介，常用的有ActiveMQ，RabbitMQ，kafka。ActiveMQ

梦里梦外;/ 2022年04月25日 04:48/ 0 赞/ 177 阅读

相关 activeMQ入门、

ActiveMQ是什么？优缺点是什么？使用场景、为什么要使用ActiveMQ？ActiveMQ有什么特性？》 > ActiveMQ官网下载地址：[http://activ

秒速五厘米/ 2022年04月11日 12:10/ 0 赞/ 200 阅读

相关 ActiveMQ应用入门

ActiveMQ应用入门 ActiveMQ中常用API介绍 JMS-Hello 导入依赖创建ActiveMQ中的生产者

た入场券/ 2021年11月17日 10:31/ 0 赞/ 271 阅读

相关 ActiveMQ应用

1. PTP处理模式(Queue) > 消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。 > 消息被消费以后，queue中不再有存储

叁歲伎倆/ 2021年11月04日 16:58/ 0 赞/ 296 阅读

相关 ActiveMQ基本应用

ActiveMQ基本应用 ActiveMQ中常用API介绍 ActiveMQ使用示例Demo 导入依赖实现生产者实

深碍√TFBOYSˉ_/ 2021年10月19日 23:36/ 0 赞/ 298 阅读