Может ли сторона сервера EJB отправить событие на сторону клиента EJB?

Интересно, можно ли сделать что-то в этом роде:

1) Серверная часть (класс EJB)

@Statefull
public class SomeEJB implements SomeEJBRemote {

@Resource
private SessionContext sessionContext;

//(...)
public void someMethod(Record record){
    //(...)
    //Situation that requires the server to alert all registered listeners
    if(specialSituation){
        sessionContext.fireEventToListeners(new SomeEvent());
    }

    //Do something else...
}
}

2) Клиентская сторона

//(...) 
SomeEJBRemote ejb = initialContext.lookup("SomeEJBRemote");
ejb.addListener(this);

void EJBEventListener(SomeEvent event){
    System.out.println("EJB server has sent an event!");
}

A) Есть ли что-нибудь в спецификации Java EE, позволяющее это сделать?

Б) Я знаю, что JBoss допускает некоторую двустороннюю связь, но могу ли я сделать то же самое, что и в этом примере?

C) Есть ли что-нибудь подобное в OpenEJB (или TOMEE)?


java bidirectional ejb jakarta-ee openejb
person Luis Soeiro    schedule 16.11.2011    source источник

Ответы (2)


arrow_upward
4
arrow_downward

Это легко сделать с помощью встроенного контейнера EJB и MDB в клиенте. У нас есть пример, который делает именно это.

Ознакомьтесь с модулем monitor этого примера .

На высоте 10 000 футов этот пример делает следующее:

На стороне сервера:

  • Компонент @Stateless, который обертывает доступ к EntityManager
  • Сообщение JMS, отправляемое в тему при всех операциях добавления/удаления

Сторона клиента:

  • Встроенный контейнер EJB/MDB, получающий сообщения
  • При получении пользователю выдается уведомление через java.awt.SystemTray

Интересным в этом методе является то, что он полностью транзакционный: обновления EntityManager и отправленные JMS-сообщения являются частью транзакции. В случае сбоя обновления базы данных JMS-сообщение отправлено не будет.

Вот 100% клиентского кода из этого примера. Чтобы сделать то, что описано, многого не требуется.

Основной класс клиента

import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.awt.AWTException;
import java.awt.Image;
import java.awt.MenuItem;
import java.awt.PopupMenu;
import java.awt.SystemTray;
import java.awt.Toolkit;
import java.awt.TrayIcon;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.net.MalformedURLException;
import java.net.URL;

public class NotificationMonitor {
    private static TrayIcon trayIcon;

    public static void main(String[] args) throws NamingException, InterruptedException, AWTException, MalformedURLException {
        addSystemTrayIcon();

        // Boot the embedded EJB Container 
        new InitialContext();

        System.out.println("Starting monitor...");
    }

    private static void addSystemTrayIcon() throws AWTException, MalformedURLException {
        SystemTray tray = SystemTray.getSystemTray();

        URL moviepng = NotificationMonitor.class.getClassLoader().getResource("movie.png");
        Image image = Toolkit.getDefaultToolkit().getImage(moviepng);

        ActionListener exitListener = new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                System.out.println("Exiting monitor...");
                System.exit(0);
            }
        };

        PopupMenu popup = new PopupMenu();
        MenuItem defaultItem = new MenuItem("Exit");
        defaultItem.addActionListener(exitListener);
        popup.add(defaultItem);

        trayIcon = new TrayIcon(image, "Notification Monitor", popup);
        trayIcon.setImageAutoSize(true);
        tray.add(trayIcon);
    }

    public static void showAlert(String message) {
        synchronized (trayIcon) {
            trayIcon.displayMessage("Alert received", message, TrayIcon.MessageType.WARNING);
        }
    }
}

Клиентская MDB

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

@MessageDriven(activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "notifications")})
public class NotificationsBean implements MessageListener {

    public void onMessage(Message message) {
        try {
            TextMessage textMessage = (TextMessage) message;
            String text = textMessage.getText();

            NotificationMonitor.showAlert(text);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

Файл клиента jndi.properties

Это настраивает встроенный контейнер EJB. Вы также можете сделать это в коде.

java.naming.factory.initial=org.apache.openejb.client.LocalInitialContextFactory
Default\ JMS\ Resource\ Adapter=new://Resource?type=ActiveMQResourceAdapter
Default\ JMS\ Resource\ Adapter.BrokerXmlConfig=broker:vm://localhost
Default\ JMS\ Resource\ Adapter.ServerUrl=tcp://localhost:61616
person David Blevins    schedule 28.11.2011

arrow_upward
1
arrow_downward

Нет, в EJB ничего подобного нет. Я бы предложил клиенту либо прослушать очередь/тему JMS. В качестве альтернативы клиент может экспортировать объект прослушивателя в RMI (фактически сам становясь сервером), а затем передавать ссылку на сервер; этот метод потребует немного больше инфраструктуры.

person Brett Kail    schedule 16.11.2011
comment
Я думал об этом, но требования безопасности для RMI и накладные расходы (как вы сказали, для инфраструктуры) на дублирование каналов связи не позволяют нам его использовать. :-/ - person Luis Soeiro; 18.11.2011