ActiveMQ入门代码

Hello world程序演示:

生产者:

package com.mq.helloworld;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {
    public static void main(String[] args) throws JMSException {
        //第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可。默认端口为"tcp://localhost:61616"
        ConnectionFactory connectionfactory=new ActiveMQConnectionFactory(
                ActiveMQConnectionFactory.DEFAULT_USER,
                ActiveMQConnectionFactory.DEFAULT_PASSWORD,
                "tcp://localhost:61616"
                );
        //第二步:通过ConnectionFactory工厂对象,我们创建一个Connection连接,并且调用Connection的start方法开启连接,Connection默认是关闭的
        Connection connection = connectionfactory.createConnection();
        connection.start();
        //第三步:通过Connection对象创建Session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般设置为手动签收
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //第四步:通过Session创建Destination对象,指的是一个客户端用来指定生产消息目标和消费消息来源的对象,在PTP模式中,Destination被称为Queue即队列;在Pub/Sub模式中,Destination被称作Topic即主题,在程序中可以使用多个Queue和Topic
        Destination destinition=session.createQueue("queue1");
        //第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer
        MessageProducer messageProducer = session.createProducer(destinition);
        //第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)
        messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        //第七步:最后我们使用JMS规范的TextMessage形式创建数据(通过Session对象),并用MessageProducer的send方法发送数据
        TextMessage textMessage = session.createTextMessage();
        textMessage.setText("Hello World!");
        messageProducer.send(textMessage);
        if(connection!=null){
            connection.close();
        }
    }
}     

消费者:

package com.mq.helloworld;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {
    public static void main(String[] args) throws JMSException {
        //第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可。默认端口为"tcp://localhost:61616"
        ConnectionFactory connectionfactory=new ActiveMQConnectionFactory(
                ActiveMQConnectionFactory.DEFAULT_USER,
                ActiveMQConnectionFactory.DEFAULT_PASSWORD,
                "tcp://localhost:61616"
                );
        //第二步:通过ConnectionFactory工厂对象,我们创建一个Connection连接,并且调用Connection的start方法开启连接,Connection默认是关闭的
        Connection connection = connectionfactory.createConnection();
        connection.start();
        //第三步:通过Connection对象创建Session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般设置为自动签收
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //第四步:通过Session创建Destination对象,指的是一个客户端用来指定生产消息目标和消费消息来源的对象,在PTP模式中,Destination被称为Queue即队列;在Pub/Sub模式中,Destination被称作Topic即主题,在程序中可以使用多个Queue和Topic
        Destination destinition=session.createQueue("queue1");
        //第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer
        MessageConsumer messageConsumer = session.createConsumer(destinition);
        //第六步:最后我们使用JMS规范的TextMessage形式接收数据
        while (true) {
            TextMessage msg=(TextMessage) messageConsumer.receive();
            System.out.println(msg.getText());
            if(msg==null) break;
        }
        
        if(connection!=null){
            connection.close();
        }
    }
}

安全认证机制:

在activemq.xml文件中的broker节点中的末尾增加下面的内容

        <plugins>
            <simpleAuthenticationPlugin>
                <users>
                    <authenticationUser username="bhz" password="bhz" groups="users,admins"/>
                </users>
            </simpleAuthenticationPlugin>
        </plugins>

然后,再访问MQ时就需要认证了,在生产者和消费者第一步中将default_user、default_password换成配置文件中自定义的username和password即可访问MQ。

生产者详解:

消费者详解:

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • java监听器

    JavaWeb中监听器的事件源(ServletContext、HttpSession、ServletRequest、JavaBean)

    HUC思梦
  • RocketMQ的发送模式和消费模式

    通过之前文章的学习,我们已经对RocketMQ的基本架构有了初步的了解,那今天王子就和大家一起来点实际的,用代码和大家一起看看RocketMQ的几种发送模式和消...

    HUC思梦
  • @Target:注解的作用目标

    @Target(ElementType.TYPE)——接口、类、枚举、注解 @Target(ElementType.FIELD)——字段、枚举的常量 @Targ...

    HUC思梦
  • ActiveMQ发布订阅模式

    前面讲的案例都是点对点的消息,即一个生产者发送的一条消息只能被一个消费者消费,然后就移除了。

    用户4919348
  • activeMQ发布订阅模式中中常用工具类

    用户5166556
  • JMS的常用方法

    用户3003813
  • java开发_快速搜索本地文件_小应用程序

    然后我突发奇想,我之前做过一个Application叫做:java开发_java小程序_邮死你(yousini)_源码下载

    Hongten
  • PHP生成Mysql数据字典

    用户7657330
  • 关于安卓开发通过Toast显示消息提示框

    听着music睡
  • 【leetcode刷题】T52-最长和谐子序列

    We define a harmonious array is an array where the difference between its maximu...

    木又AI帮

扫码关注云+社区

领取腾讯云代金券