activeMq-1 快速入门

Activemq 是一款开源的消息中间件，适合中小型应用使用，遵循JMS规范。

具体介绍这里就不再阐述了，这里简单说下消息中间件的好处

1请求结果异步处理

客户端发送请求以后，服务器可以把相关数据放到消息中间件上，不一定马上处理

2解耦

client进程和server服务进程都不一定同时可用。

3不仅支持1对1通信，也支持1对多通信

另外我想说的是，JMS只是定义了接口，并没有给出实现。以下是jms相关的术语介绍

Provider（MessageProvider）：生产者生产消息

Consumer（MessageConsumer）：消费者发送消息

PTP：Point To Point，点对点通信消息模型

Pub/Sub：Publish/Subscribe，发布订阅消息模型

Queue：消息队列，和PTP结合

Topic：消息主题，和Pub/Sub结合

ConnectionFactory：连接工厂，JMS用它创建Connnection

Connnection：JMS Client到JMS Provider的连接，用于创建session

Destination：消息目的地，由Session创建

Session：会话，由Connection创建，发送、接受消息的一个线程

快速入门

下载 http://activemq.apache.org/ 启动程序

windows系统（根据你系统 bit的不同选择不同的启动程序

启动完成以后，就可以访问控制台了，web 控制台可以通过

http://localhost:8161 需要输入用户名以及密码（默认是admin admin ）

当然这个是可以修改的，默认这个是运行在jetty里面的

修改conf目录下的jetty-realm.properties

接下来，我们写第一个快速入门程序。具体来说，会有一个生产者用于发送消息，一个消费者用于接收消息。

引入jar包，我这里为了方便，直接引入的是activemq-all-5.9.0.jar

实际开发中应该根据需求引入lib目录下的相关包

=============================================================================================================

生产者

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.ActiveMQConnectionFactory;

public class Producer {
	public static void main(String[] args) throws Exception {
	
		ConnectionFactory factory = new ActiveMQConnectionFactory("cc","cz", ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
		Connection connection = factory.createConnection();
		// 默认是关闭的 需要开启
		connection.start();
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		Destination dest = session.createQueue("test");
		MessageProducer producer = session.createProducer(dest);
		// 设置非持久化  服务器关闭消息就不再保存
		producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
		TextMessage textMessage = session.createTextMessage();
		textMessage.setText("I AM MESSAGE");
		producer.send(textMessage);
		try {
		} finally {
			if(connection!=null)
			connection.close();
		}
	}
}

消费者

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.ActiveMQConnectionFactory;

public class Consumer {
	public static void main(String[] args) throws Exception {

		ConnectionFactory factory = new ActiveMQConnectionFactory("cc", "cz",
				ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
		Connection connection = factory.createConnection();
		// Connection默认是关闭的 需要开启
		connection.start();
		// 设置是否支持事务 和 签收模式
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		Destination dest = session.createQueue("test");
		MessageConsumer consumer = session.createConsumer(dest);
		while (true) {
			//因为这里我们知道发送的是TextMessage 所以没有做类型判断 类型判断可以用 instanceof
			TextMessage mes = (TextMessage) consumer.receive();
			// mes.acknowledge(); 签收消息
			System.out.println(mes.getText());
		}

	
	}

}

运行生产者，在运行消费者（先后顺序是没有关系的，我这里并没有让消费者停止运行）