EJB3.0如何使用MDB

Question

嘿，我是 j2ee 编码新手。我的问题是关于 MDB 的。 我已经设置了我的 weblogic 11g 服务器。并且队列已设置。

我已经编写了客户端代码，它是一个向队列发送消息的 java se 客户端。

import java.util.Hashtable;
import java.util.Properties;

import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class MyMDBClient {

    /**
     * @param args
     */
    public static void main(String[] args) {
         QueueConnection cnn = null;
            QueueSender sender = null;
            QueueSession session = null;
            InitialContext ctx;
            Hashtable ht = new Hashtable();

            try {
                ht.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
                ht.put(Context.PROVIDER_URL,"t3://localhost:7001");

                ctx = new InitialContext(ht);
                Queue queue = (Queue) ctx.lookup("jms/testQueue");
                QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("jms/connectionFactory");
                cnn = factory.createQueueConnection();
                session = cnn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
                TextMessage msg = session.createTextMessage();
                msg.setText("helloworld");
                sender = session.createSender(queue);
                sender.send(msg);

                System.out.println("Message sent successfully to remote queue.");
                session.close(); // this is important.
            } catch (Exception e) {
                e.printStackTrace();
            }
    }
}

我可以在 weblogic 管理控制台上看到队列上的消息。

但是，我在服务器端的mdb没有被调用。

谁能告诉我出了什么问题。我更喜欢使用 java 注释的解决方案。感谢大家阅读本文。

这是我的服务器代码：

/**
 * import
 *
 */

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import weblogic.ejbgen.*;


/**
 * Message-Driven Bean implementation class for: MyMDB
 *
 */
@MessageDriven(ejbName="mdb", destinationType="javax.jms.queue",destinationJndiName="jms/testQueue"  )
public class mdb implements MessageListener {

    /**
     * Default constructor. 
     */
    public mdb() {
    }

    /**
     * @see MessageListener#onMessage(Message)
     */
    public void onMessage(Message message) {
        TextMessage tmsg = null;
        tmsg = (TextMessage) message; 

        System.out.println("----------------");
        System.out.println("Received message : ");        
        try {
            System.out.println(tmsg.getText());
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }   

        System.out.println("----------------");        
    }
}

Answer 1

以下是我在正在运行的 MDB 上使用的注释的示例：

@MessageDriven(
    messageListenerInterface = javax.jms.MessageListener.class,
    name = "EventQueueListenerMDB",
    mappedName = Constants.EVENT_QUEUE_JNDI,
    activationConfig = {
            @ActivationConfigProperty(
                    propertyName = "connectionFactoryJndiName",
                    propertyValue = Constants.CONNECTION_FACTORY_JNDI),
            @ActivationConfigProperty(
                    propertyName = "destinationType",
                    propertyValue = "javax.jms.Queue")
    })

另外，您似乎拥有 javax.jms.queue 而不是 javax.jms.Queue。