package com.kingsoft.activemq.unit01;

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;

/**

 *

 * @ClassName: JMSProducer

 * @Description: TODO (消息生产者)

 * @author A我去

 * @date 2019年10月11日下午11:16:53

 */

public class JMSProducer {

    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; //发送消息的数量

    /**

     *

     * <b>Description</b><br>

     * (发送消息)

     * <br>

     * -------------------------------------------------<br>

     * <b>A我去  2019年10月11日 下午11:30:44</b>

     */

    public static void sendMessage(Session session, MessageProducer producer)

throws Exception{

        for(int i=0;i<JMSProducer.SENDNUM;i++) {

            TextMessage message = session.createTextMessage("ActiveMQ 发送的消息"+i);

            System.out.println("发送消息："+"ActiveMQ 发送的消息"+i);

            producer.send(message);

        }

    }

    public static void main(String[] args) {

        ConnectionFactory connectionFactory; //连接工厂

        Connection connection = null; //连接

        Session session = null; //会话(接受或发送消息的线程)

        Destination destination; //消息目的地

        MessageProducer producer; //消息生产者

        //1.实例化连接工厂

        connectionFactory = new ActiveMQConnectionFactory(

JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);

        try {

            //2.通过连接工厂获取连接

            connection = connectionFactory.createConnection();

            //3.启动连接

            connection.start();

            //4.创建Session

            session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);

            //5.创建消息队列

            destination = session.createQueue("first-quque1");

            //6.创建消息生产者

            producer = session.createProducer(destination);

            //7.发送消息

            sendMessage(session, producer);

            //8.session提交

            session.commit();

        } catch (JMSException e) {

            e.printStackTrace();

        } catch (Exception e) {

            e.printStackTrace();

        }finally {

            //关闭session

            if(session!=null) {

                try {

                    session.close();

                } catch (JMSException e) {

                    e.printStackTrace();

                }

            }

            //关闭连接

            if(connection != null) {

                try {

                    connection.close();

                } catch (JMSException e) {

                    e.printStackTrace();

                }

            }

        }

    }

}