JMS

1.发送消息

public static void send()
    {
        try
        {
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                    "tcp://10.47.224.169:61616");
            Connection connection = connectionFactory.createConnection();
            connection.start();
            Session session = connection.createSession(Boolean.TRUE,
                    Session.AUTO_ACKNOWLEDGE);
            Destination destination = session.createQueue("rzy");
            MessageProducer producer = session.createProducer(destination);
            Message msg = session.createTextMessage("Hello World!!!");
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            producer.send(msg);
            session.commit();
            connection.close();
        }
        catch(JMSException e)
        {
            e.printStackTrace();
        }
    }

 

2.接收消息

public static void receive()
    {
        try
        {
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                    "tcp://10.47.224.169:61616");
            Connection connection = connectionFactory.createConnection();
            connection.start();
            Session session = connection.createSession(Boolean.TRUE,
                    Session.AUTO_ACKNOWLEDGE);
            Destination destination = session.createQueue("rzy");
            MessageConsumer consumer = session.createConsumer(destination);
            while(true)
            {
                TextMessage msg = (TextMessage) consumer.receive();
                if(null != msg)
                {
                    System.out.println(msg.getText());
                    msg = null;
                }
                else
                {
                    break;
                }
            }
            session.close();
            connection.close();
        }
        catch(JMSException e)
        {
            e.printStackTrace();
        }
    }