ActiveMQ 5基本使用

安装启动

安装直接去官网下载然后解压即可

windows正常就是通过bin目录下的.\activemq start命令即可启动（5.10以前不用加start）

Linux则是./activemq start

然后可以通过localhost:8161/admin访问web控制台，默认用户名密码都是admin。

发送测试

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.ActiveMQConnectionFactory;

public class Sender {

    public static final String USERNAME = ActiveMQConnectionFactory.DEFAULT_USER;

    public static final String PASSWORD = ActiveMQConnectionFactory.DEFAULT_PASSWORD;

    public static final String URL = "tcp://127.0.0.1:61616";

    public static void main(String[] args) throws Exception {

        // 第一步：建立ConnectionFactory工厂对象，需要填入用户名，密码，以及连接的地址。默认tcp://127.0.0.1:61616
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);

        // 第二部：通过ConnectionFactory工厂对象我们创建一个Connection连接
        // 并且调用Connection的start启动连接， Connection默认是关闭的。
        Connection connection = connectionFactory.createConnection();
        connection.start();

        // 第三部：通过Connection对象创建Session会话（上下文环境对象），用于接受消息
        // 参数配置1为是否启用事物，参数配置2为签收模式，一般设置为自动签收。
        Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

        // 第四部： 通过Session创建Destination，指的是一个客户端用来指定生产消息目标和消息来源的对象
        // 在ptp模式中，Destination被称做为Queue（队列），在Pub/Sub模式下，Destination被称作Topic（主题）
        Destination destination =  session.createQueue("helloworld-queue");

        // 第五步：我们需要通过Session对象创建消息的发送和接受对象，（生产者和消费者）MessageProducer/MessageConsumer
        MessageProducer producer = session.createProducer(destination);

        // 第六步：我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性（DeliveryMode）
        producer.setDeliveryMode(DeliveryMode.PERSISTENT);

        // 第七部：最后我们使用jms规范的TextMessage形式创建数据（通过Session对象），
        // 并用MessageProducer的send方法发送数据，同理客户端使用receive方法进行接受数据。
        TextMessage message = session.createTextMessage("producer hello word!");
        producer.send(message);

        // 最后不要忘了关闭资源。
        if (connection != null) {
            connection.close();
        }
    }

}

接收测试

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.ActiveMQConnectionFactory;

public class Receiver {

    public static final String USERNAME = ActiveMQConnectionFactory.DEFAULT_USER;

    public static final String PASSWORD = ActiveMQConnectionFactory.DEFAULT_PASSWORD;

    public static final String URL = "tcp://127.0.0.1:61616";

    public static void main(String[] args) throws Exception {

        // 第一步：建立ConnectionFactory工厂对象，需要填入用户名，密码，以及连接的地址。默认tcp://127.0.0.1:61616
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);

        // 第二部：通过ConnectionFactory工厂对象我们创建一个Connection连接
        // 并且调用Connection的start启动连接， Connection默认是关闭的。
        Connection connection = connectionFactory.createConnection();
        connection.start();

        // 第三部：通过Connection对象创建Session会话（上下文环境对象），用于接受消息
        // 参数配置1为是否启用事物，参数配置2为签收模式，一般设置为自动签收。
        Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

        // 第四部： 通过Session创建Destination，指的是一个客户端用来指定生产消息目标和消息来源的对象
        // 在ptp模式中，Destination被称做为Queue（队列），在Pub/Sub模式下，Destination被称作Topic（主题）
        // 到此处为止，和生产端的代码一样
        Destination destination =  session.createQueue("helloworld-queue");

        // 第五步：创建MessageConsumer对象
        MessageConsumer consumer = session.createConsumer(destination);

        // 第六步：接受message
        TextMessage message = (TextMessage) consumer.receive();
        System.out.println(message.getText());

        // 最后不要忘了关闭资源。
        if (connection != null) {
            connection.close();
        }
    }

}

接受结果

producer hello word!

最后

至此，就是ActiveMQ的基本使用，至于其他特性可以参考官方文档 (opens new window)。