使用MDB进行滚动升级

Question

我们在Glassfish 3.1.2集群上部署了一个Java EE应用程序，该集群使用JAX-RS提供REST API。我们定期通过将EAR部署到重复的集群实例来部署新版本的应用程序，然后更新HTTP负载平衡器，以将流量发送到更新的实例，而不是旧实例。

这使我们能够在不损失可用性的情况下进行升级，如下所述：http://docs.oracle.com/cd/E18930_01/html/821-2426/abdio.html#abdip.我们经常对应用程序进行重大更改，这使得新版本“不兼容”（这就是为什么我们使用两个集群）。

我们现在必须为应用程序提供一个消息队列接口，用于一些高吞吐量的内部消息传递（来自C生产者）。然而，使用消息驱动Beans，我看不出如何在没有任何服务中断的情况下升级应用程序？

我调查过的选项有：

单个远程JMS队列（openMQ）

生产者将消息发送到单个消息队列，消息由MDB处理。当我们启动第二个集群实例时，消息应该负载均衡到升级的集群，但是当我们停止“旧”集群时，未完成的事务将丢失。

我考虑过在升级期间使用JMX禁用消息队列的生产者/消费者，但这只会暂停消息传递。当我们禁用旧集群时（我想是吧？）。

我还考虑放弃@MessageDriven注释并手动创建MessageConsumer。这似乎是可行的，但MessageConsumer随后无法使用EJB注释访问其他EJB（据我所知）：

// Singleton bean with start()/stop() functions that 
// enable/disable message consumption

@Singleton
@Startup
public class ServerControl {

private boolean running=false;

@Resource(lookup = "jms/TopicConnectionFactory")
private TopicConnectionFactory topicConnectionFactory;

@Resource(lookup = "jms/MyTopic")
private Topic topic;
private Connection connection;
private Session session;
private MessageConsumer consumer;    

public ServerControl()
{
    this.running = false;         
}

public void start() throws JMSException {
    if( this.running ) return;

    connection = topicConnectionFactory.createConnection();
    session = dbUpdatesConnection.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
    consumer = dbUpdatesSession.createConsumer(topic);
    consumer.setMessageListener(new MessageHandler());    


    // Start the message queue handlers
    connection.start();

    this.running = true;
}

public void stop() throws JMSException {
    if( this.running == false ) return;

    // Stop the message queue handlers

    consumer.close();

    this.running = false;
}
}

// MessageListener has to invoke functions defined in other EJB's

@Stateless
public class MessageHandler implements MessageListener {

@EJB
SomeEjb someEjb; // This is null

public MessageHandler() {
}

@Override
public void onMessage(Message message) {
    // This works but someEjb is null unless I 
    // use the @MessageDriven annotation, but then I 
    // can't gracefully disconnect from the queue
}

}

每个集群的本地/嵌入式JMS队列

• 客户端必须连接到两个不同的消息队列代理（每个集群一个）
• 必须通知客户机集群实例正在停机，并停止向该代理上的队列发送消息
• 通常情况下，与现有的http解决方案相比，它不那么方便和整洁

替代消息队列提供程序

• 将Glassfish连接到不同类型的消息队列或不同的供应商（例如：Apache OpenMQ），也许其中一个有能力平衡远离特定消费者集的流量？

我假设仅仅禁用该应用程序将“杀死”任何未完成的事务。如果禁用该应用程序允许现有事务完成，那么我可以在启动第二个集群后执行该操作。

任何帮助都将不胜感激！提前谢谢。

Answer 1

我不理解你的假设，即当我们停止“旧”集群时，未完成的事务将丢失。MDB将被允许在应用程序停止之前完成消息处理，任何未确认的消息将由“新”集群处理。

如果旧版本和新版本之间的负载平衡是一个问题，我将把MDB放在单独的中。耳朵，并在新MDB上线后立即停止旧的MDB，甚至在此之前，如果您的用例允许延迟消息处理，直到部署新版本。

Answer 2

如果使用高可用性，那么集群的所有消息将存储在单个数据存储中，而不是每个实例上的本地数据存储中。然后可以将两个集群配置为使用同一存储。然后，当关闭旧的和旋转新的你有权访问所有的消息。

这是一个很好的视频，有助于解释glassfish的高可用性jms。