2

我们在网络上遇到延迟问题。每个连接、会话和生产者创建都会受到 1 毫秒的惩罚。这就是为什么我想在我的无状态 EJB 实例变量中缓存我的 jms 连接、会话和 MessageProducer。

我可以在@PostConstruct 中创建它们，这样做安全吗？

@Stateless
public class MyEJB {
    @Resource(mappedName = Messaging.LOCAL_JNDI_CONN_FACTORY)
    private ConnectionFactory connectionFactory;

    @Resource(mappedName = AutoRecolteIndexerConsumer.QUEUE_NAME)
    private Queue queue;

    private Connection connection;
    private Session session;
    private MessageProducer producer;


    @PostConstruct
    public void init() {
        connection = connectionFactory.createConnection();// 1ms
        session = connection.createSession(true, Session.SESSION_TRANSACTED);// 1ms
        producer = session.createProducer(queue); //1ms
    }

    public void send(Object data) {
        ObjectMessage obj = session.createObjectMessage();
        obj.setObject(data);
        producer.send(obj);
    }

}
4

1 回答 1

2

预初始化像连接工厂、连接和会话这样的重量级对象并没有错，事实上，这是一种很好的做法，因为我们不想在每次发送消息时都创建这些东西。

但我认为您混淆了无状态和有状态 EJB。您正在初始化 bean 的状态，所以它不是无状态的，而是有状态的。其次，既然你有状态，你的代码应该假设最坏的情况，并在发生错误时清理资源，像这样......

   public void send(Object data) {
        ObjectMessage obj = session.createObjectMessage();
        obj.setObject(data);
        try{
           producer.send(obj);

        }catch( JMSException jex){
          producer.close();
          session.close();
          connection.close();
          throw new EJBException( jex);
        }
    }

通过清理避免资源泄漏，然后抛出 EJBException 以便容器销毁 EJB 实例并在其位置创建一个新实例。

于 2013-06-07T01:44:58.853 回答