1

我是 jms 的初学者，我只是想运行一个简单的 Web 应用程序来生成和使用消息。所以在我的欢迎页面上，我有一个带有文本框和提交按钮的表单。在提交时，文本框中的文本被包装在一条消息中，并通过 MessageProducer 发送到服务器上的队列。据我了解，此消息应保留在队列中，直到我从某个 MessageConsumer 调用接收方法，其中消费者链接到该队列。不幸的是，在我单击“获取消息”按钮的第二个 jsp 页面上，收到的消息显示为空。我很确定它们被正确发送（至少没有错误说明）有没有办法可以检查？关于出了什么问题的任何想法？提前致谢。这是生产者/消费者代码。

public class Producer {           
    private static final String CONNECTION_FACTORY = "connectionFactory";     
    private static final String CONNECTION_QUEUE = "jms/myqueue";    
    private static final String CONNECTION_TOPIC = "jms/mytopic";     

    public Producer(String message) {         
        ConnectionFactory connectionFactory = null;       
        Connection connection = null;         
        //Get the JNDI Context        
        try {        
            Context jndiContext = new InitialContext();      

            //Create the Connection Factory  and Connection     
            connectionFactory = (ConnectionFactory) jndiContext.lookup(Producer.CONNECTION_FACTORY);       
            connection = connectionFactory.createConnection();  

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

            publishToQueue(jndiContext, session, message);    
            session.commit();
        } catch (NamingException e) {            
        } catch (JMSException e) {    

        }finally{       
           //close connection     
        }   
    }        

    private void publishToQueue(Context jndiContext, Session session, String message) throws NamingException, JMSException{      
        //Create Queue     
        Queue queue = (Queue) jndiContext.lookup(Producer.CONNECTION_QUEUE); 

        //Create Message Producer       
        MessageProducer producer = session.createProducer(queue);     

        //Send TextMessage        
        producer.setDeliveryMode(DeliveryMode.PERSISTENT);
        TextMessage textMessage = session.createTextMessage();    
        textMessage.setText(message);
        producer.send(textMessage);  
        producer.close();

} 
 } 


public class Consumer {           
    private static final String CONNECTION_FACTORY = "connectionFactory";     
    private static final String CONNECTION_QUEUE = "jms/myqueue";    
    private static final String CONNECTION_TOPIC = "jms/mytopic";     

    private Message message;

    public Consumer() {        
        ConnectionFactory connectionFactory = null;       
        Connection connection = null;         
        //Get the JNDI Context        
        try {        
            Context jndiContext = new InitialContext();     

        //Create the Connection Factory       
        connectionFactory = (ConnectionFactory) jndiContext.lookup(Consumer.CONNECTION_FACTORY);       
        connection = connectionFactory.createConnection();  

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

        //Call methods to retrieve  message      
        message = getFromQueue(jndiContext, session);    
        session.commit();
        if(message!=null){
            System.out.println("Message Received");
        }
    } catch (NamingException e) {            
        // TODO Auto-generated catch block       
        e.printStackTrace();        
    } catch (JMSException e) {    
        // TODO Auto-generated catch block    
        e.printStackTrace();       

    }finally{       
        try {           
            if(connection != null){    
                connection.close();    
            }            
        } catch (JMSException e) {   
            e.printStackTrace();         
        }       
    }   
}        



private Message getFromQueue(Context jndiContext, Session session) throws NamingException, JMSException{      
    //Create new Queue
    Queue queue = (Queue)jndiContext.lookup(Consumer.CONNECTION_QUEUE);  
    //Create Message Consumer       
    MessageConsumer consumer = session.createConsumer(queue); 
    return consumer.receive(10000);    
}

public Message getMessage(){
    return message;
}
}
4

1 回答 1

2

抱歉，在另一个问题中找到了答案.. MessageConsumer 没有使用消息 .. 我只需要在 getFromQueue 方法之前调用 connection.start()

 public Consumer() {        
    ConnectionFactory connectionFactory = null;       
    Connection connection = null;         
    //Get the JNDI Context        
    try {        
        Context jndiContext = new InitialContext();     

    //Create the Connection Factory       
    connectionFactory = (ConnectionFactory) jndiContext.lookup(Consumer.CONNECTION_FACTORY);       
    connection = connectionFactory.createConnection();  

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

    //Call methods to retrieve  message   
     --> connection.start(); <--
    message = getFromQueue(jndiContext, session);    
    session.commit();
    if(message!=null){
        System.out.println("Message Received");
    }
于 2013-08-01T03:10:29.437 回答