JMS教程(五)

Love The Way You Lie 2022-08-19 11:14 118阅读 0赞

下面来测试一下消息的类型:   Persistent和nonpersistent的消息

/**
     * 测试消息的类型 : DeliveryMode.PERSISTENT
     *               DeliveryMode.NON_PERSISTENT
     */
    public class Sender {
    
    	public static void main(String[] args) throws JMSException {
    		//JDBC:   DriverManager.getConnection("","","");
    		ConnectionFactory factory = new ActiveMQConnectionFactory(  ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");  
    	     
            Connection connection = factory.createConnection();  
            connection.start();  
             
            Queue queue = new ActiveMQQueue("testQueue");  
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
                     
            //第一组消息   persistent消息
            MessageProducer producer = session.createProducer(queue);  
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);  
            producer.send(session.createTextMessage("zy persistent Message"));  
             
            //第二组消息   non_persistent消息
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  
            producer.send(session.createTextMessage("zy non persistent Message"));  
    
            System.out.println("消息发送成功");
            
    	}
    
    }

下面请将activemq关闭. 再运行下面的消费者程序.

/**
     * 这个类用于消费消息
     */
    public class Receiver {
    
    	public static void main(String[] args) throws JMSException {
    		//JDBC:   DriverManager.getConnection("","","");
    		ConnectionFactory factory = new ActiveMQConnectionFactory(  ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");  
            Connection connection = factory.createConnection();  
            connection.start();  
            
            //创建会话
            Session session=connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
            Destination destination=session.createQueue(  "testQueue"  );
            //创建消费者
            MessageConsumer comsumer = session.createConsumer(destination);  
            comsumer.setMessageListener(new MessageListener(){  
                public void onMessage(Message m) {  
                    try {  
                        System.out.println("Consumer get " + ((TextMessage)m).getText());  
                    } catch (JMSException e) {  
                        e.printStackTrace();  
                    }  
                }  
            });  
            
            
    	}
    
    }

运行上面的程序，可以得到下面的输出结果：

![Center][]

从上面输出的结果可以看出， 只有persistent消息才可以在服务器关闭后还能取得.

[Center]: /images/20220731/4822a594dd214d59b15da00d9ae5b146.png