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();
			}
		}

	}
}