ActiceMq学习记录.docx

Hello ActiveMQ！??下面是ActiveMQ5.2的一个最简单例子！环境还是apache-activemq-5.2.0-bin.zip，需要注意的是，开发时候，要将apache-activemq-5.2.0-bin.zip解压缩后里面的activemq-all-5.2.0.jar包加入到classpath下面，这个包包含了所有jms接口api的实现。??import?org.apache.activemq.ActiveMQConnection;?import?org.apache.activemq.ActiveMQConnectionFactory;?import?javax.jms.*;?/**?* 消息的生产者（发送者）?*?* @author leizhimin 2009-8-12 11:41:20?*/?public?class?JmsSender {?????????public?static?void?main(String[] args)?throws?JMSException {?????????????????// ConnectionFactory：连接工厂，JMS 用它创建连接?????????????????ConnectionFactoryconnectionFactory =?new?ActiveMQConnectionFactory(?????????????????????????????????ActiveMQConnection.DEFAULT_USER,?????????????????????????????????ActiveMQConnection.DEFAULT_PASSWORD,?????????????????????????????????tcp://17:61616);?????????????????//JMS 客户端到JMS Provider 的连接?????????????????Connection connection = connectionFactory.createConnection();?????????????????connection.start();?????????????????// Session：一个发送或接收消息的线程?????????????????Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);?????????????????// Destination ：消息的目的地;消息发送给谁.?????????????????// 获取session注意参数值my-queue是Query的名字?????????????????Destination destination = session.createQueue(my-queue);?????????????????// MessageProducer：消息生产者?????????????????MessageProducer producer = session.createProducer(destination);?????????????????//设置不持久化?????????????????producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);?????????????????//发送一条消息?????????????????sendMsg(session, producer);?????????????????mit();?????????????????connection.close();?????????}?????????/**????????? * 在指定的会话上，通过指定的消息生产者发出一条消息????????? *????????? * @param session????消息会话????????? * @param producer 消息生产者????????? */?????????public?static?void?sendMsg(Session session, MessageProducer producer)?throws?JMSException {?????????????????//创建一条文本消息?????????????????TextMessage message = session.createTextMessage(Hello ActiveMQ！);?????????????????//通过消息生产者发出消息?????????????????pro