什么是基于EJB3的应用程序的最佳通信模式？

我正在启动一个需要高度可扩展的Java EE项目 . 到目前为止，这个概念是：

• 几个Message Driven Beans，负责架构的不同部分

• 每个MDB都注入了会话Bean，处理业务逻辑

• 几个实体Bean，提供对持久层的访问
  通过JMS消息通过请求/回复概念在架构的不同部分之间进行

• 通信：

• MDB接收包含活动请求的消息

• 使用其会话bean来执行必要的业务逻辑

• 将msg中的响应对象返回给原始请求者

这个想法是通过消息总线将部分架构彼此分离，对可扩展性没有限制 . 只需启动更多组件 - 只要它们连接到同一总线，我们就可以成长和发展 .

不幸的是，我们遇到了请求 - 回复概念的大量问题 . 交易管理似乎在我们的方式充足 . 它接缝会话bean不应该使用消息？！

阅读http://blogs.oracle.com/fkieviet/entry/request_reply_from_an_ejb和http://forums.sun.com/message.jspa?messageID=10338789，我觉得人们实际上建议不要使用EJB的请求/回复概念 .

如果是这种情况，您如何在EJB之间进行通信？ （记住，可扩展性是我追求的）

我当前设置的详细信息：

• MDB 1 'TestController'，使用（本地）SLSB 1 'TestService'作为业务逻辑

• TestController.onMessage（）使TestService向队列XYZ发送消息并请求回复

• TestService使用Bean管理事务

• TestService在初始化时通过联合连接工厂 Build 与JMS代理的连接和会话（@PostConstruct）

• TestService在发送后提交事务，然后开始另一个事务并等待10秒的响应

• 消息到达MDB 2 'LocationController'，它使用（本地）SLSB 2 'LocationService'作为业务逻辑

• LocationController.onMessage（）使LocationService将消息发送回请求的JMSReplyTo队列

• 相同的BMT概念，相同的@PostConstruct概念

• 都使用相同的连接工厂来访问代理

问题：第一条消息被发送（通过SLSB 1）并被接收（通过MDB 2）确定 . 发送返回消息（通过SLSB 2）也很好 . 然而，SLSB 1从未收到任何东西 - 它只是超时 .

我试过没有messageSelector，没有改变，仍然没有接收消息 .

会话bean消费消息是不是可以的？

SLSB 1 - TestService.java

@Resource(name = "jms/mvs.MVSControllerFactory")
private javax.jms.ConnectionFactory connectionFactory;

@PostConstruct
public void initialize() {
    try {
      jmsConnection = connectionFactory.createConnection();
      session = jmsConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      System.out.println("Connection to JMS Provider established");
    } catch (Exception e) { }
}

public Serializable sendMessageWithResponse(Destination reqDest, Destination respDest, Serializable request) {
    Serializable response = null;

    try {
        utx.begin();
        Random rand = new Random();
        String correlationId = rand.nextLong() + "-" + (new Date()).getTime();

        // prepare the sending message object
        ObjectMessage reqMsg = session.createObjectMessage();
        reqMsg.setObject(request);
        reqMsg.setJMSReplyTo(respDest);
        reqMsg.setJMSCorrelationID(correlationId);

        // prepare the publishers and subscribers
        MessageProducer producer = session.createProducer(reqDest);

        // send the message
        producer.send(reqMsg);
        System.out.println("Request Message has been sent!");
        utx.commit();

        // need to start second transaction, otherwise the first msg never gets sent
        utx.begin();
        MessageConsumer consumer = session.createConsumer(respDest, "JMSCorrelationID = '" + correlationId + "'");
        jmsConnection.start();
        ObjectMessage respMsg = (ObjectMessage) consumer.receive(10000L);
        utx.commit();

        if (respMsg != null) {
            response = respMsg.getObject();
            System.out.println("Response Message has been received!");
        } else {
            // timeout waiting for response
            System.out.println("Timeout waiting for response!");
        }

    } catch (Exception e) { }

    return response;
}

SLSB 2 - LocationService.Java（只有回复方法，其余与上面相同）

public boolean reply(Message origMsg, Serializable o) {
    boolean rc = false;

    try {
        // check if we have necessary correlationID and replyTo destination
        if (!origMsg.getJMSCorrelationID().equals("") && (origMsg.getJMSReplyTo() != null)) {
            // prepare the payload
            utx.begin();
            ObjectMessage msg = session.createObjectMessage();
            msg.setObject(o);

            // make it a response
            msg.setJMSCorrelationID(origMsg.getJMSCorrelationID());
            Destination dest = origMsg.getJMSReplyTo();

            // send it
            MessageProducer producer = session.createProducer(dest);
            producer.send(msg);
            producer.close();
            System.out.println("Reply Message has been sent");
            utx.commit();

            rc = true;
        }

    } catch (Exception e) {}

    return rc;
}

太阳resources.xml中

<admin-object-resource enabled="true" jndi-name="jms/mvs.LocationControllerRequest"  res-type="javax.jms.Queue"  res-adapter="jmsra">
    <property name="Name" value="mvs.LocationControllerRequestQueue"/>
</admin-object-resource>
<admin-object-resource enabled="true" jndi-name="jms/mvs.LocationControllerResponse"  res-type="javax.jms.Queue"  res-adapter="jmsra">
    <property name="Name" value="mvs.LocationControllerResponseQueue"/>
</admin-object-resource>

<connector-connection-pool name="jms/mvs.MVSControllerFactoryPool"  connection-definition-name="javax.jms.QueueConnectionFactory"  resource-adapter-name="jmsra"/>
<connector-resource enabled="true" jndi-name="jms/mvs.MVSControllerFactory" pool-name="jms/mvs.MVSControllerFactoryPool"  />