activemq系列（2）-简单应用实例

实例代码如下：
 生产者：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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;

/****
* 生产者
*
* @author liuzhihu
*
*/
public class Producer {

private final static String brokerURL = "tcp://localhost:61616";

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

// 1、获取工厂连接

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURL);

// 2、 从连接工厂中获取连接

Connection connection = connectionFactory.createConnection();

// 3、从连接中创建session

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 4、创建消息目的地

Destination destination = session.createQueue("testQueueI");

// 5、创建生产者

MessageProducer producer = session.createProducer(destination);

// 6、发送消息
for (int i = 0; i < 10; i++) {

TextMessage message = session.createTextMessage("testQueueI发送的消息" + i);

System.out.println("发送消息：" + "testQueueI 发送的消息" + i);

producer.send(message);
}

session.close();

connection.close();

}

}

 消费者：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Consume {

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

// 1、获取工厂连接 使用默认的用户名、密码、地址

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD, ActiveMQConnection.DEFAULT_BROKER_URL);

// 2、 从连接工厂中获取连接

Connection connection = connectionFactory.createConnection();

// 3、从连接中创建session

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 4、创建消息目的地

Destination destination = session.createQueue("testQueueI");

// 5、创建消费者

MessageConsumer consumer = session.createConsumer(destination);

// 6、注册
consumer.setMessageListener(new MessageListener() {

@Override
public void onMessage(Message message) {

try {

TextMessage text = (TextMessage) message;

System.out.println("接收消息：" + text.getText());

} catch (JMSException e) {

e.printStackTrace();
}
}
});

connection.start();
}

}

以上代码完成后，首先运行消费者Consume.java，然后再运行Producer.java。

然后，可以看到控制台打印的信息如下：





这个时候，登录activemq的控制台，能够看到如下的内容：



好了，一个简单的activemq的实例代码就完成了，咱们先不做说明，接下来一节进行描述。