zoukankan      html  css  js  c++  java
  • JMSJAVAHello World

    添加上面的JAR包

    //JMS
    import org.apache.activemq.ActiveMQConnectionFactory;

    import javax.jms.Connection;
    import javax.jms.DeliveryMode;
    import javax.jms.Destination;
    import javax.jms.ExceptionListener;
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.MessageConsumer;
    import javax.jms.MessageListener;
    import javax.jms.MessageProducer;
    import javax.jms.Session;
    import javax.jms.TextMessage;

    import org.apache.activemq.ActiveMQConnectionFactory;
    import org.apache.activemq.Message;


    public class jms implements MessageListener {

     
     public void send()
     {
      
      try {
                // Create a ConnectionFactory
                ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");

                // Create a Connection
                Connection connection = connectionFactory.createConnection();
                connection.start();

                // Create a Session
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

                // Create the destination (Topic or Queue)
                Destination destination = session.createQueue("TEST.FOO");

                // Create a MessageProducer from the Session to the Topic or Queue
                MessageProducer producer = session.createProducer(destination);
                producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

                // Create a messages
                String text = "Hello world! From: ";


              // TextMessage message = session.createTextMessage(text);

               ActiveMQTextMessage message=new ActiveMQTextMessage();
               message.setText(text);


               
                //message.set

                // Tell the producer to send the message
                System.out.println("Sent message OK ");
                producer.send(message);

                // Clean up
                session.close();
                connection.close();
            }
            catch (Exception e) {
                System.out.println("Caught: " + e);
                e.printStackTrace();
            }
      
     
      
     }
     
     
     public void receive()
     {
      
       try {

                 // Create a ConnectionFactory
                 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");

                 // Create a Connection
                 Connection connection = connectionFactory.createConnection();
                 connection.start();

                 //connection.setExceptionListener(this);

                 // Create a Session
                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

                 // Create the destination (Topic or Queue)
                 Destination destination = session.createQueue("TEST.FOO");
                 

                 // Create a MessageConsumer from the Session to the Topic or Queue
                 MessageConsumer consumer = session.createConsumer(destination);
                 

                 //监听模式
                 consumer.setMessageListener(this);


                 //主动接受模式 
    //             // Wait for a message
    //             Message message = consumer.receive(1000);
    //
    //             if (message instanceof TextMessage) {
    //                 TextMessage textMessage = (TextMessage) message;
    //                 String text = textMessage.getText();
    //                 System.out.println("Received: " + text);
    //             } else {
    //                 System.out.println("Received: " + message);
    //             }
    //
    //             consumer.close();
    //             session.close();
    //             connection.close();
                
                
             } catch (Exception e) {
                 System.out.println("Caught: " + e);
                 e.printStackTrace();
             }

     
      
     }
     
     
     @Override
     public void onMessage(Message arg0) {
      // TODO Auto-generated method stub
     try{
           Message message = arg0;
     
           if (message instanceof TextMessage) {
               TextMessage textMessage = (TextMessage) message;
               String text = textMessage.getText();
               System.out.println("Received: " + text);
           } else {
               System.out.println("Received: " + message);
           }
      
        } catch (Exception e) {
            System.out.println("Caught: " + e);
            e.printStackTrace();
        }
         
     }

      
     
     /**
      * @param args
      */
     public static void main(String[] args) {
      // TODO Auto-generated method stub

      jms j=new jms();
      j.send();
      
      j.receive();
       
     }


    }

  • 相关阅读:
    ES6展开运算符的10个用法
    用react脚手架新建项目
    第六章 组件 56 组件-组件中的data
    第六章 组件 55 组件-使用components定义私有组件
    第六章 组件 54 组件-创建组件的方式3
    第六章 组件 53 组件-创建组件的方式2
    第六章 组件 52 组件-创建组件的方式1
    第六章 组件 51 组件化和模块化的区别以及组件的定义方式
    第五章 动画 50 动画-transition-group中appear和tag属性的作用
    第五章 动画 49 动画-实现列表删除和删除时候的动画效果
  • 原文地址:https://www.cnblogs.com/hedan/p/2688695.html
Copyright © 2011-2022 走看看