ActiveMQ入门实例
在开始之前需要去到网上去下载一个activeMQ，（官方网站下载：http://activemq.apache.org/），然后直接解压运行bin目录下面的activemq.bat文件，启动后登陆：http://localhost:8161/admin/，创建一个Queue，命名为FirstQueue，到这里准备工作就完成了，然后就可以开始了。
第一步，创建一个普通的java项目，然后导入java包（本人导入的是activemq-all-5.9.0.jar）
第二步、添加消息发送者
public class Sender {
//连接工厂
private static ConnectionFactory connectionFactory;
static{
connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
}
public static void main(String[] args) {
//连接
Connection connection = null;
//会话
Session session = null;
//目的地，消息要发往的地方
Destination destination;
//消息发送者
MessageProducer producer = null;
try {
//获取消息连接
connection = connectionFactory.createConnection();
//开启连接
connection.start();
//通过连接创建会话
session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
//创建消息队列
destination = session.createQueue("FirstQueue");
//创建发送者
producer = session.createProducer(destination);
//发送消息
send(session, producer);
} catch (JMSException e) {
e.printStackTrace();
}finally {
try {
session.commit();
connection.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
public static void send(Session session,MessageProducer producer) throws JMSException{
for(int i=0;i<10;i++){
//创建消息
TextMessage msg = session.createTextMessage("消息"+i);
//发送消息
producer.send(msg);
System.out.println("发送消息：消息"+i);
}
}
}
最后一步，添加消息的接受者
public class consumer {
private static ConnectionFactory connectionFactory;
static {
connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
}
public static void main(String[] args) {
Connection connection = null;
Session session = null;
Destination destination;
MessageConsumer consumer = null;
try {
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue("FirstQueue");
consumer = session.createConsumer(destination);
while (true) {
TextMessage msg = (TextMessage)consumer.receive(30000);
if(msg != null){
System.out.println("接受到的消息: "+msg.getText());
}else{
break;
}
}
} catch (JMSException e) {
e.printStackTrace();
} finally {
try {
consumer.close();
session.commit();
connection.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}
注意：接受消息还可以通过MessageListener接收
public class consumerList {
private static ConnectionFactory connectionFactory;
static {
connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
}
public static void main(String[] args) {
Connection connection = null;
Session session = null;
Destination destination;
MessageConsumer consumer = null;
try {
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue("FirstQueue");
consumer = session.createConsumer(destination);
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
TextMessage msg = (TextMessage)message;
try {
System.out.println(msg.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
} catch (JMSException e) {
e.printStackTrace();
} finally {
try {
consumer.close();
session.commit();
connection.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}
