activemq

Posted caoxinfang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了activemq相关的知识,希望对你有一定的参考价值。

结构图技术图片

依赖技术图片

 

package com.activemq.activemqdemo.p2p;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class JMSProducer {

    public static final String ACTIVE_URL = "tcp://127.0.0.1:61616";
    // 队列名称
    public static final String QUEUE_NAME = "index";

    public static void main(String[] args) throws JMSException {
        // 1)获取工厂 ConnectionFactory,使用摸摸人的用户名和密码admin/admin, 指定URL
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ACTIVE_URL);
        // 2)获取连接
        Connection connection = connectionFactory.createConnection();
        // 3)启动连接
        connection.start();
        // 4)创建Session ,参数transacted:事务,acknowledgeMode响应模式
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 5)创建目的地: 队列
        Queue queue = session.createQueue(QUEUE_NAME);
        // 6)创建生产者,参数destination表示目的地---Queue
        MessageProducer messageProducer = session.createProducer(queue);
        // 7)发送消息
        for (int i = 1 ; i <= 3; i++){
            TextMessage textMessage = session.createTextMessage("index队列中的消息:" + i);
            messageProducer.send(textMessage);
        }
        // 8)关闭资源
        messageProducer.close();
        session.close();
        connection.close();

    }

}
package com.activemq.activemqdemo.p2p;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class JMSConsumer {

    public static final String ACTIVE_URL = "tcp://127.0.0.1:61616";
    // 队列名称
    public static final String QUEUE_NAME = "index";

    public static void main(String[] args) throws JMSException {
        // 1)获取工厂 ConnectionFactory,使用摸摸人的用户名和密码admin/admin, 指定URL
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ACTIVE_URL);
        // 2)获取连接
        Connection connection = connectionFactory.createConnection();
        // 3)启动连接
        connection.start();
        // 4)创建Session ,参数transacted:事务,acknowledgeMode响应模式
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 5)创建目的地: 队列
        Queue queue = session.createQueue(QUEUE_NAME);
        // 6)创建消费者,
        MessageConsumer messageConsumer = session.createConsumer(queue);
        // 7)接收消息: 获取队列中的所有消息,消费者一直接收消息
        while (true){
            TextMessage msg = (TextMessage) messageConsumer.receive();
            if (msg != null){
                // 接收到消息了
                System.out.println("JMSConsumer接收到消息了:"+msg.getText());
            }else {
                // 队列中的消息全部接收完毕
                System.out.println("-----消息接收完成----");
                break;
            }
        }


    }
}

 

以上是关于activemq的主要内容,如果未能解决你的问题,请参考以下文章

wildfly 实践5 ---分布式服务中的JMS服务访问

ActiveMQ的安全机制使用及其源代码分析 [转]

ActiveMQ——activemq的使用java代码实例

ActiveMQ入门系列二:入门代码实例(点对点模式)

ActiveMQ入门案例-生产者代码实现

ActiveMQ queue 代码示例