Почему ejb, у которого есть другой ejb как поле, не обновляет значения этого ejb, который действует как поле? - PullRequest
0 голосов
/ 11 апреля 2019

Я делаю свой первый подход к java-ee. То, что я пытаюсь достичь, это следующее: Я написал приложение, которое собирает цены из разных источников, я управляю собранными данными в пользовательском классе List (ListEventsArquitectura), который управляет данными событий, хранящимися в EventoArquitectura (пользовательский класс). Этот класс EventoArquitectura также имеет в качестве полей другие пользовательские объекты, такие как BetArquitectura.

Что я тестирую, так это то, что это приложение работает как клиент Ejb, отправляя собранные данные, чтобы впоследствии они были доступны как веб-сервис Rest Ejb.

Теперь у меня есть удаленный интерфейс ejb для изменения полей экземпляров EventoArquitectura, содержащихся в ListEventsArquitectura, и он работает, но как экземпляры EventoArquitectura имеют в качестве экземпляров полей BetArquitectura, я также создал другой удаленный интерфейс Ejb для изменения полей BetArquitectura, и здесь где у меня проблема, потому что обновления поля BetArquitectura, содержащиеся в EventoArquitectura, не производят никаких изменений.

Я оставляю свой код классов, созданных для тестов и для удаленного клиента.

Для пояснения я не использую @Inject, поскольку он вызывает ошибки при развертывании на glassfish, поэтому я изменяю аннотацию на @ Ejb.

@Stateful
public class ListEventsArquitectura implements ListEventsArquitecturaService{

    List<EventoArquitectura> listaDeEventos;

   @Ejb
    private EventoArquitectura eventoService;


    public ListEventsArquitectura() {
        this.listaDeEventos = new ArrayList<>();
        List<BetArquitectura> betsList = new ArrayList<>();
        //betsList.add(new BetArquitectura("betDelConstructor", "0"));
        this.listaDeEventos.add(new EventoArquitectura("evento del contructor id", "betIdDelConstructor"));
    }

    public List<EventoArquitectura> getListaDeEventos() {
        return listaDeEventos;
    }

    @Override
    public void updateListEvent(EventoArquitectura eventoActualizado){

        for(EventoArquitectura evento : this.listaDeEventos){
            if(evento.equals(eventoActualizado)){
                this.eventoService = evento;
                eventoService.updateEvent(eventoActualizado);
                return;
            }
        }
    }

    @Override
    public EventoArquitectura getEventFromList(int index) {
       return this.listaDeEventos.get(index);
    }

    @Override
    public void addEvent(EventoArquitectura evento) {
        this.listaDeEventos.add(evento);
    }

}
public interface ListEventsArquitecturaService {
    public void updateListEvent(EventoArquitectura updatedEvent);
    public EventoArquitectura getEventFromList(int index);
    public void addEvent(EventoArquitectura evento);
}
@Stateful
public class EventoArquitectura implements Serializable,EventoArquitecturaService {

    String eventId;
   // List<BetArquitectura> betsList;
    String betId;
    public EventoArquitectura() {
    }

    public EventoArquitectura(String eventId, String betId) {
        this.eventId = eventId;
        //this.betsList = betsList;
    }

    public String getEventId() {
        return eventId;
    }

    public void setEventId(String eventId) {
        this.eventId = eventId;
    }

   /* public List<BetArquitectura> getBetsList() {
        return betsList;
    }

    public void setBetsList(List<BetArquitectura> betsList) {
        this.betsList = betsList;
    }
    */

    public String getBetId() {
        return betId;
    }

    public void setBetId(String betId) {
        this.betId = betId;
    }


    @Override
    public void updateEvent(EventoArquitectura updatedEvent){
        if(!(updatedEvent.equals(this))){
            this.eventId = updatedEvent.eventId;
        }

    }

    @Override
    public boolean equals(Object obj) {
         if(!(obj instanceof EventoArquitectura)){
           return false; 
        }

        EventoArquitectura evento = (EventoArquitectura)obj;

       return evento.eventId.equals(this.eventId);
    }

    @Override
    public int hashCode() {
        int hash = 7;
        hash = 59 * hash + Objects.hashCode(this.eventId);
        return hash;
    }


}
@Remote
public interface EventoArquitecturaService {

    public void updateEvent(EventoArquitectura updatedEvent);
    public String getBetId();
    public void setBetId(String betId);

}
public class BetArquitectura implements Serializable{
    String marketId;
    String valorBet;

    public BetArquitectura(String marketId, String valorBet) {
        this.marketId = marketId;
        this.valorBet = valorBet;
    }

    public BetArquitectura() {
    }

    public String getMarketId() {
        return marketId;
    }

    public void setMarketId(String marketId) {
        this.marketId = marketId;
    }

    public String getValorBet() {
        return valorBet;
    }

    public void setValorBet(String valorBet) {
        this.valorBet = valorBet;
    }

    private void updateValor(String valorBet){
        this.valorBet = valorBet;
    }

    public void updateBet(BetArquitectura betActualizada){
        if(this.equals(betActualizada)){
            this.updateValor(betActualizada.getValorBet());
        }

    }

    @Override
    public boolean equals(Object obj) {
        if(!(obj instanceof BetArquitectura)){
           return false; 
        }

        BetArquitectura bet = (BetArquitectura)obj;

       return bet.marketId.equals(this.marketId);
    }

    @Override
    public int hashCode() {
        int hash = 7;
        hash = 89 * hash + Objects.hashCode(this.marketId);
        return hash;
    }

}

И здесь я оставляю свой удаленный клиент, он может изменять значения полей экземпляров EventoArquitectura, содержащихся в ListEventsArquitectura, но если он не вносит изменения в объект BetArquitectura, содержащийся в каждом экземпляре EventoArquitectura.

public class ClienteArquitecturaTest {

    public static void main(String[] args){


        try {
            Properties props = new Properties();
            props.setProperty("java.naming.factory.initial", "com.sun.enterprise.naming.SerialInitContextFactory");
            props.setProperty("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
            props.setProperty("java.naming.factory.state", "com.sun.corba.ee.impl.presentation.rmi.JNDIStateFactoryImpl");
            // optional. Default localhost. Aquise cambia la IP del servidor donde esta Glassfishprops.setProperty("org.omg.CORBA.ORBInitialHost", "127.0.0.1");
            // optional. Puerto por Default 3700. Solo se necesita cambiar si el puerto no es 3700.
            //props.setProperty("org.omg.CORBA.ORBInitialPort", "3700");
            Context jndi;
            jndi = new InitialContext(props);
            ListEventsArquitecturaService listEventsService = (ListEventsArquitecturaService) jndi.lookup("java:global/ArquitecturaEJBTest/ListEventsArquitectura!com.mycompany.ejb.interfaces.ListEventsArquitecturaService");

            System.out.println("Id of the event added into constructor: " + listEventsService.getEventFromList(0).getEventId());

            EventoArquitecturaService eventoParaModificar = listEventsService.getEventFromList(0);
            eventoParaModificar.setBetId("betIdModified");

            listEventsService.addEvent(new EventoArquitectura("newEventId", "newBetId"));            



           System.out.println("Modified Bet Id: " + listEventsService.getEventFromList(0).getBetId());
            System.out.println("Added EventoArquitectura id: " + listEventsService.getEventFromList(1).getEventId());
            System.out.println("Added Bet Id: " + listEventsService.getEventFromList(1).getBetId());

        } catch (NamingException ex) {
            Logger.getLogger(ClienteArquitecturaTest.class.getName()).log(Level.SEVERE, null, ex);
        }

    }
}

И вывод, который я получаю с этим клиентом, показывает, что я не смог изменить объекты BetArquitectura, они всегда равны нулю:

Id of the event added into constructor: evento del contructor id
Modified Bet Id: null
Added EventoArquitectura id: newEventId
Added Bet Id: null

1 Ответ

0 голосов
/ 13 апреля 2019

Я думаю, что ваша проблема в том, что вы модифицируете свойство экземпляра, которое существует только на стороне клиента.Когда вы вызываете метод через клиентский прокси EJB, который возвращает объект, вы получаете собственный экземпляр (сериализованный на стороне сервера и десериализованный на стороне клиента).Это два разных объекта, один существует на стороне клиента, а другой на стороне сервера.Это распространенное недоразумение при работе с удаленными ejbs.

Попробуйте реализовать такой метод в вашем EJB, который изменяет свойство предполагаемого объекта на стороне сервера.

setIdAt(Integer idx, String id) 

Затем реализуйте нана стороне клиента

 // will pass parameters to server side EJB, which modifies the object property
service.setIdAt(0, "betIdModified");
// Get server side modified instance and its id
service.getElementFromList(0).getBetId();

В этом примере вы передаете параметры в EJB на стороне сервера, и объект на стороне сервера модифицируется, что вы получаете после того, как EJB на стороне сервера изменил его.Опять же, вы получаете свой собственный экземпляр, который не является прокси, как я полагаю, вы ожидаете, что это будет.Прокси проксируется только служба, а не объекты, возвращаемые ее методами.

...