ActiveMQ环境搭建及实例详解的源码

package Producer; 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.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; /** * 消息生产者 * @author yang * */ public class JMSProducer2 { private static final String USERNAME=ActiveMQConnection.DEFAULT_USER; // 默认的连接用户名 private static final String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD; // 默认的连接密码 private static final String BROKEURL=ActiveMQConnection.DEFAULT_BROKER_URL; // 默认的连接地址 private static final int SENDNUM=10; // 发送的消息数量 /** * 发送消息 静态类 * @param session 会话对象，创建本次会话的基本配置 * @param messageProducer 消息生产者对象，将本次消息发送给Queue * @throws Exception */ public static void sendMessage(Session session,MessageProducer messageProducer)throws Exception{ for(int i=0;i<JMSProducer2.SENDNUM;i++){ //创建消息的格式（以这种格式发送）： TextMessage TextMessage message=session.createTextMessage("ActiveMQ 发送过来的消息"+i+"第三次"); //后台打印 System.out.println("发送消息："+"ActiveMQ 发送过来的消息"+i+"第三次"); //将消息发送给Queue messageProducer.send(message); } } public static void main(String[] args) { ConnectionFactory connectionFactory; // 连接工厂 Connection connection = null; // 连接 Session session; // 会话 接受或者发送消息的线程 Destination destination; // 消息的目的地 MessageProducer messageProducer; // 消息生产者 // 实例化连接工厂 connectionFactory=new ActiveMQConnectionFactory(JMSProducer2.USERNAME, JMSProducer2.PASSWORD, JMSProducer2.BROKEURL); try { connection=connectionFactory.createConnection(); // 通过连接工厂获取连接 connection.start(); // 启动连接 session=connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); // 创建Session destination=session.createTopic("FirstTopic1");//创建消息发布，表示将消息发送到这个地方 messageProducer=session.createProducer(destination); // 根据消息目的地，创建消息生产者 // 发送消息 ，本质上是将TextMessage类型的消息发送给Queue这个消息队列，这是消息的目的地 sendMessage(session, messageProducer); session.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ if(connection!=null){ try { connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } } }