ActiveMQ（二）——ActiveMQ的安装和基本使用

一、安装
ActiveMQ（二）——ActiveMQ的安装和基本使用
启动之后成功

创新互联是一家集网站建设,慈溪企业网站建设,慈溪品牌网站建设,网站定制,慈溪网站建设报价,网络营销,网络优化,慈溪网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。

二、创建实例测试ActiveMQ

配置Maven所需的依赖


org.apache.activemq
activemq-all
5.9.0


org.apache.xbean
xbean-spring
3.16

消息发送

public class QueueSender {
public static void main(String[] args) throws Exception{
    //连接工厂
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    Connection connection = connectionFactory.createConnection();
    connection.start();

    //带事务的session
    Session session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE);
    Destination destination = session.createQueue("my-queue");
    MessageProducer producer = session.createProducer(destination);

    for (int i = 0; i < 3; i++) {
        TextMessage message = session.createTextMessage("message--"+i);
        Thread.sleep(1000);
        //通过消息生产者发出消息
        producer.send(message);
    }
    session.commit();
    session.close();
    connection.close();
}
}

运行main方法，控制台输出如下：

ActiveMQ（二）——ActiveMQ的安装和基本使用

那这个消息发送到哪里去了呢？
ActiveMQ（二）——ActiveMQ的安装和基本使用

消息接收

public class QueueReceive {
public static void main(String[] args) throws Exception{
    //连接工厂
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    Connection connection = connectionFactory.createConnection();
    connection.start();

    //带事务的session，并且自动签收
    final Session session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE);
    Destination destination = session.createQueue("my-queue");
    MessageConsumer consumer = session.createConsumer(destination);

    int i = 0;
    while (i<3){
        i++;
        TextMessage message = (TextMessage) consumer.receive();
        session.commit();
        System.out.println("收到的消息是："+message.getText());
    }
    session.close();
    connection.close();
}
}

运行main方法
ActiveMQ（二）——ActiveMQ的安装和基本使用

此时再看服务器端会发送消息已经被接收处理了。
ActiveMQ（二）——ActiveMQ的安装和基本使用

网页题目：ActiveMQ（二）——ActiveMQ的安装和基本使用
本文URL：http://cdiso.cn/article/peepoe.html

ActiveMQ（二）——ActiveMQ的安装和基本使用

其他资讯