Java EE 中 MDB 的管道和过滤器模式

Question

我正在尝试在 Java EE 中使用消息驱动的 Bean 实现管道和过滤器模式，但我想以队列可配置且 bean 在运行时间。这样更改过滤器的执行顺序将很容易。

我是 Java EE 的新手，过去使用 MDB 时我总是这样做：

@MessageDriven(mappedName = "jms/myQueue", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})
public class ReceiveMessageBean implements MessageListener {

这对我想要的不起作用。

我正在考虑做一个每个过滤器都可以继承的 bean，这样我就可以把从队列读取和写入的方法放在一个地方，就像这样：

public class StepBean {
    public void createBean(String queueRead, String queueWrite) {
        //make the bean listen from queueRead
        //make the bean write to queueWrite
    }
    public void onMessage(Message message){
        //get the message  from queueRead and transform it to my own class
        processMessage(myMessage);
    }

    public void processMessage(MyMessage message){
        //each filter should implement this method 
        sendMessage(myMessage);
    }

    public void sendMessage(MyMessage message){
        //send message to queueWrite
    }
}

然后在我的 ejb 中有某种工厂来创建具有队列所需值的步骤 bean。

但我几乎不知道如何做这些。我一直在查看 this，但由于我的 bean 都从队列中读取和写入，所以它们不是严格的 MDB。

我正在使用 GlassFish 4.1.2 和 Netbeans 8.2。

欢迎提供有关如何执行此操作或是否可行的任何指导。

Answer 1

您不能以编程方式创建 MDB，因为它们必须由服务器管理。如果要创建动态侦听器，请使用 MessageConsumer 和 setMessageListener。根据您的设置，您需要从某个连接工厂访问 Connection，然后创建会话、消费者，最后创建消息侦听器。可以使用 message selector = your filter 创建消费者。一个简短的例子：

ConnectionFactory conFactory = (ConnectionFactory) ic.lookup("java:/ConnectionFactory");//customize the jndi to match your server
Connection connection = conFactory.createConnection();
Queue myqueue = ic.lookup("java:/jms/queue/MyQueue");
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
String messageSelector = "MY_MSG_PROPERTY = 'MY_FILTER_VALUE'";
Consumer consumer = session.createConsumer(myqueue, messageSelector);

consumer.setMessageListener(new MessageListener() {
    @Override
    public void onMessage(Message message) {
        //handle you message here
    }
});

使用这种方法，您可以创建具有不同过滤器和不同消息侦听器的多个消费者。但请记住，这些侦听器不是容器管理的，如果您不再需要这些侦听器（关闭会话等），则需要处理资源 cleanup/close。

Java EE 中 MDB 的管道和过滤器模式

Pipes and filters pattern with MDB in Java EE

java

ejb

jms

message-driven-bean

jakarta-ee