ActiveMQ的入门和安装(linux)

            <!--
             https://mvnrepository.com/artifact/org.apache.activemq/activemq-all 
            -->
            <!--
            ActiveMQ依赖包
            -->
            <
            dependency
            >
            <
            groupId
            >org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.xbean/xbean-spring --><!--ActiveMQ和SPring整合包--><dependency><groupId>org.apache.xbean</groupId><artifactId>xbean-spring</artifactId><version>4.14</version></dependency>

            package
             com.yjc.activemq;


            import
             org.apache.activemq.ActiveMQConnectionFactory;


            import javax.jms.*;
/**
 * 消息的生产者
 * */publicclass JMSProducer {
    //ActiveMQ的urlprivatestaticfinal String ACTIVEMQ_URL="tcp://192.168.118.3:61616";
    //Queue的名称privatestaticfinal  String QUEUE_NAME="queue001";

    publicstaticvoid main(String[] args) throws JMSException {
        //1.创建ActiveMQ的连接工程,给定ActiveMQ的url,使用默认账号和密码
        ActiveMQConnectionFactory activeFactory=new ActiveMQConnectionFactory(ACTIVEMQ_URL);
        //2.创建active的连接对象,抛出或捕获异常,并启动connection
        Connection connection = activeFactory.createConnection();
        connection.start();
        //3.创建会话对象,两个参数前者为事务,后者为签收
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //4.创建目的地,目的地的类型为队列(Queue),参数为队列的名称
        //Queue和Topic都继承自Destination接口
        Queue queue = session.createQueue(QUEUE_NAME);
        //5.创建消息的生产者
        MessageProducer producer = session.createProducer(queue);
        for (int i=1;i<=50;i++){
            //6.通过session创建消息,
            TextMessage textMessage = session.createTextMessage("this is msg\t"+i);
            //7.用producer将消息发送至MQ的队列里            producer.send(textMessage);
        }
        //8.释放资源,先开后关        producer.close();
        session.close();
        connection.close();
        System.out.println("将消息发送至MQ队列中成功!!!");

    }
}

            package
             com.yjc.activemq;


            import
             org.apache.activemq.ActiveMQConnectionFactory;


            import javax.jms.*;
import java.io.IOException;

publicclass JMSConsumer {
    //ActiveMQ的urlprivatestaticfinal String ACTIVEMQ_URL="tcp://192.168.118.3:61616";
    //Queue的名称privatestaticfinal  String QUEUE_NAME="queue001";

    publicstaticvoid main(String[] args) throws JMSException, IOException {
        System.out.println("----------------------11111111111----------------------------");
        //1.创建ActiveMQ的连接工程,给定ActiveMQ的url,使用默认账号和密码
        ActiveMQConnectionFactory activeFactory=new ActiveMQConnectionFactory(ACTIVEMQ_URL);
        //2.创建active的连接对象,抛出或捕获异常,并启动connection
        Connection connection = activeFactory.createConnection();
        connection.start();
        //3.创建会话对象,两个参数前者为事务,后者为签收
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //4.创建目的地,目的地的类型为队列(Queue),参数为队列的名称
        //Queue和Topic都继承自Destination接口
        Queue queue = session.createQueue(QUEUE_NAME);
       //----------------------上面的步骤和Producer的一样------------------------------------------------
        //5.创建消费者
        MessageConsumer consumer = session.createConsumer(queue);
        //6.消费消息/*
        receive(long timeout)方法的重载为等待时间,不传参的话就会一直等待下去
        消费的消息类型需要和生产出的消息类型保持一致

       while(true){
            TextMessage textMessage = (TextMessage) consumer.receive(3000);
            if (textMessage!=null) {
                System.out.println("-----消费信息"+textMessage.getText());
            }else{
                //代表所有的信息都以及被消费完了
                break;
            }
        }*///6.2异步非阻塞方式(监听消息)
       consumer.setMessageListener(new MessageListener(){
           @Override
           publicvoid onMessage(Message message) {

               if (message!=null&&message instanceof TextMessage) {
                   TextMessage message1 =(TextMessage)message;
                   try {
                       String text = message1.getText();
                       System.out.println(text);
                   } catch (JMSException e) {
                       e.printStackTrace();
                   }

               }
           }
       });
        System.in.read();
        //7.释放资源先开后关        consumer.close();
        session.close();
        connection.close();
        System.out.println("消费完毕!!!");
    }
}