activemq 入门-蒲公英云

一、windows下运行

1、下载

[ http://activemq.apache.org/activemq-5100-release.html][http_activemq.apache.org_activemq-5100-release.html]

2、下载.zip格式的文件

解压缩后根据电脑位数，运行相应位数下面的.bat文件
例：我的电脑为64位放在d盘；运行为：D:\\activemq510\\bin\\win64\\activemq.bat

3、启动成功后访问管理界面

[http://localhost:8161/admin/

]httplocalhost_8161_admin

用户名密码默认为：admin/admin

4、创建eclipse项目

 项目结构为

Center

 maven的依赖为
<dependency>  
    <groupId>org.apache.activemq</groupId>  
    <artifactId>activemq-broker</artifactId>  
    <version>5.10.0</version>  
</dependency>

5、创建serder

package com.bahd.activemq;

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.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {

private static final int SEND\_NUMBER = 5;  
public static void main(String\[\] args) \{  
    // ConnectionFactory ：连接工厂，JMS 用它创建连接  
    ConnectionFactory connectionFactory;  
    // Connection ：JMS 客户端到JMS Provider 的连接  
    Connection connection = null;  
    // Session： 一个发送或接收消息的线程  
    Session session;  
    // Destination ：消息的目的地;消息发送给谁.  
    Destination destination;  
    // MessageProducer：消息发送者  
    MessageProducer producer;  
    // TextMessage message;  
    // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar  
    connectionFactory = new ActiveMQConnectionFactory(  
            ActiveMQConnection.DEFAULT\_USER,  
            ActiveMQConnection.DEFAULT\_PASSWORD,  
            "tcp://localhost:61616");  
    try \{  
        // 构造从工厂得到连接对象  
        connection = connectionFactory.createConnection();  
        // 启动  
        connection.start();  
        // 获取操作连接  
        session = connection.createSession(Boolean.TRUE,  
                Session.AUTO\_ACKNOWLEDGE);  
        // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置  
        destination = session.createQueue("FirstQueue");  
        // 得到消息生成者【发送者】  
        producer = session.createProducer(destination);  
        // 设置不持久化，此处学习，实际根据项目决定  
        producer.setDeliveryMode(DeliveryMode.NON\_PERSISTENT);  
        // 构造消息，此处写死，项目就是参数，或者方法获取  
        sendMessage(session, producer);  
        session.commit();  
    \} catch (Exception e) \{  
        e.printStackTrace();  
    \} finally \{  
        try \{  
            if (null != connection)  
                connection.close();  
        \} catch (Throwable ignore) \{  
        \}  
    \}  
\}  
public static void sendMessage(Session session, MessageProducer producer)  
        throws Exception \{  
    for (int i = 1; i <= SEND\_NUMBER; i++) \{  
        TextMessage message = session  
                .createTextMessage("ActiveMq 发送的消息" + i);  
        // 发送消息到目的地方  
        System.out.println("发送消息：" + "ActiveMq 发送的消息" + i);  
        producer.send(message);  
    \}  
\}

}

6、创建Receiver

package com.bahd.activemq;

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.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

public static void main(String\[\] args) \{  
    // ConnectionFactory ：连接工厂，JMS 用它创建连接  
    ConnectionFactory connectionFactory;  
    // Connection ：JMS 客户端到JMS Provider 的连接  
    Connection connection = null;  
    // Session： 一个发送或接收消息的线程  
    Session session;  
    // Destination ：消息的目的地;消息发送给谁.  
    Destination destination;  
    // 消费者，消息接收者  
    MessageConsumer consumer;  
    connectionFactory = new ActiveMQConnectionFactory(  
            ActiveMQConnection.DEFAULT\_USER,  
            ActiveMQConnection.DEFAULT\_PASSWORD,  
            "tcp://localhost:61616");  
    try \{  
        // 构造从工厂得到连接对象  
        connection = connectionFactory.createConnection();  
        // 启动  
        connection.start();  
        // 获取操作连接  
        session = connection.createSession(Boolean.FALSE,  
                Session.AUTO\_ACKNOWLEDGE);  
        // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置  
        destination = session.createQueue("FirstQueue");  
        consumer = session.createConsumer(destination);  
        while (true) \{  
            //设置接收者接收消息的时间，为了便于测试，这里谁定为100s  
            TextMessage message = (TextMessage) consumer.receive(100000);  
            if (null != message) \{  
                System.out.println("收到消息" + message.getText());  
            \} else \{  
                break;  
            \}  
        \}  
    \} catch (Exception e) \{  
        e.printStackTrace();  
    \} finally \{  
        try \{  
            if (null != connection)  
                connection.close();  
        \} catch (Throwable ignore) \{  
        \}  
    \}  
\}