Enterprise JavaBeans™ -EJB-



Preamble

This tutorial on the Enterprise JavaBeans™ -EJB- component model is based on the Java Enterprise Edition -Java EE- 8 Application Programming Interface -API- ☛ and EJB version 3.2. Java EE 8 tutorial ☛

Note that Java EE will no longer exist with the emergence of Java 9. Jakarta EE ☛ 8 is a rewritten (iso-functional) version of Java EE 8. Jakarta EE ☛ 9 is the next version of Java EE 8

Case studies are provided as Maven/Apache NetBeans projects; they have also been tested by means of this Integrated Development Environment -IDE-

Quizzes
What is Java EE?

Java EE technologies

Java EE products (Java EE application servers)

Java EE key challengers

Java EE Application Model ☛

Java EE 8 API ☛

EJB history
EJB overview

Principles

Characteristics

Benefits

EJB types

Entity Beans

Example (including JPQL code)

@javax.persistence.Entity(name = "MY_PRISONER")
@javax.persistence.Table(name = "PRISONER")
@javax.persistence.SecondaryTable(name = "INCARCERATION", pkJoinColumns = {@javax.persistence.PrimaryKeyJoinColumn(name = "PRISON_FILE_NUMBER")})
@javax.persistence.NamedNativeQuery(name = "Prisoner.Under_remand_SQL", query = "SELECT * FROM Prisoner WHERE prison_file_number NOT IN (SELECT prison_file_number FROM Conviction)")
@javax.persistence.NamedQueries({@javax.persistence.NamedQuery(name = "Prisoner.All_JPQL", query = "SELECT p FROM Prisoner"),
                                 @javax.persistence.NamedQuery(name = "Prisoner.Under_remand_JPQL", query = "SELECT p FROM Prisoner WHERE p._conviction IS EMPTY")
                                })    
public class Prisoner implements java.io.Serializable { …

Example (Customer_management Stateless Session Bean deals with Customer Entity Bean) 

@javax.ejb.Stateless(mappedName = "Customer_management+", name = "Customer_management")
@javax.ejb.Remote({Customer_managementRemote.class})
public class Customer_managementBean implements Customer_managementRemote {

    @javax.persistence.PersistenceContext(name = "FranckBarbier") // Check 'persistence.xml' file...
    private javax.persistence.EntityManager _entity_manager;

    @Override
    public void insert_customer(final String bank_code, final String customer_PIN, final String name, final String address) {
        Customer client = new Customer(bank_code, customer_PIN);
        client.set_name(name);
        client.set_address(address);
        _entity_manager.persist(client);
    }

    @Override
    public void delete_customer(final String bank_code, final String customer_PIN) {
        Customer client = new Customer(bank_code, customer_PIN);
        _entity_manager.remove(_entity_manager.merge(client));
    }

    @Override
    public String view_customer(final String bank_code, final String customer_PIN) {
        String result = "";
        Customer client = _entity_manager.find(Customer.class, new CustomerPK(bank_code, customer_PIN));
        result += client != null ? "Found: " + client : "Not found: " + bank_code + "-" + customer_PIN;
        return result;
    }
}

Session Beans

Message-Driven Beans

EJB metamodel
Implementation class

In the UML metamodel above, one shows that an Enterprise Bean is embodied by one and only one Java implementation class (1..1 cardinality). By default, the Enterprise Bean name is the name of that class

Getting a reference on “current” component (instead of using this)

@javax.ejb.Stateful(mappedName = "My_terminal", name = "Railcar_control_system_terminal")
public class TerminalBean implements Terminal {
    @javax.annotation.Resource
    private javax.ejb.SessionContext _ejb_context = null;
    Terminal _self = null;
    …
        _self = _ejb_context.getBusinessObject(Terminal.class);
    …
Stateless Session Beans

Key features

Creation and deletion

Transaction management

Design patterns

Example

@javax.jws.WebService(serviceName = "Railcar_new_destination")
@javax.ejb.Stateless
public class Railcar_new_destination { …

Example

@javax.ejb.Remote
public interface Customer_managementRemote { // Business methods…

@javax.ejb.Stateless(mappedName = "Customer_management+", name = "Customer_management")
// @javax.ejb.Remote({Customer_managementRemote.class}) // Alternative to using '@javax.ejb.Remote' above
public class Customer_managementBean implements Customer_managementRemote { …

Illustration: complementarity between Entity Beans and Stateless Session Beans

A simple Java EE application is based on a Stateless Session Bean named Customer_management interacting with an Entity Bean named Customer

While Banking_system.JavaDB.sql is the database schema, Customer_management.zip is the “server” program, and Customer_management_client.zip is the “client” program

Illustration consists in extending this application so that it supports Create, Read, Update, Delete -CRUD- functions for the Logical_card table in the database (please keep the database schema “as is”)

Singleton Session Beans

Key features

Creation and deletion

Transaction management

Design patterns

Other features

Example (EJB 3.x)

@javax.ejb.Local
public interface Control_center_local { // Business methods locally accessed…

@javax.ejb.Remote
public interface Control_center_remote { // Business methods externally accessed…

@javax.ejb.Singleton
@javax.ejb.Startup
public class Control_center implements Control_center_local, Control_center_remote { …
Stateful Session Beans

Key features

Creation and deletion

Transaction management

Design patterns

Example (EJB 3.x)

@javax.ejb.Stateful
public class Frontend_service {

    private int _counter = 0;

    @javax.ejb.EJB
    private Backend_service _backend_service;

    @javax.ejb.PrePassivate
    public void passivate() {
        _counter--;
    }

    @javax.ejb.PostActivate
    public void activate() {
        _counter++;
    }

    public void service(int i) {
        assert (_backend_service != null);
        _counter += i;
        System.out.println(this + "... " + _counter);
        _backend_service.service(_counter);
    }

    @javax.ejb.Remove
    public void remove() { // Called by the owner!
        // Resource release, if any...
    }
}

Another example ☛

Message-Driven Beans

JMS

JMS ☛ is fully part of Java EE. JMS package is javax.jms. Middleware-oriented messaging like JMS enables the offer of additional services such as fault tolerance, load balancing, message persistence, transaction management…. Benefits are numerous

“Common messaging” versus broker-based messaging

JMS message types

Example (javax.jms.MapMessage)

javax.jms.MapMessage order = _session.createMapMessage();
order.setString("entrée","foie gras");
order.setString("plat principal","magret");
order.setBoolean("dessert du jour ?",false);
_sender.send(order);

Example (javax.jms.ObjectMessage, Java world only!)

javax.jms.ObjectMessage ambient_temperature_changed = _session.createObjectMessage();
ambient_temperature_changed.setObject(_temperature); // '_temperature' is an instance of a type, which implements 'java.io.Serializable'...
_sender.send(ambient_temperature_changed);

Key features

Creation and deletion

Transaction management

Design patterns

Example (message sending)

@javax.ejb.Singleton
@javax.ejb.Startup
public class Starter {

    private javax.jms.QueueConnectionFactory _queue_connection_factory;
    private javax.jms.Queue _queue;
    private javax.jms.QueueConnection _queue_connection;
    private javax.jms.QueueSession _queue_session;
    private javax.jms.QueueSender _queue_sender;

    @javax.annotation.PostConstruct
    public void create() {
        try {
            System.out.println("One starts immediately because of '@javax.ejb.Startup'...");
            javax.naming.Context _jndi_context = new javax.naming.InitialContext();
            _queue_connection_factory = (javax.jms.QueueConnectionFactory) _jndi_context.lookup("jms/MY_QUEUE_FACTORY");
            _queue = (javax.jms.Queue) _jndi_context.lookup("jms/MY_QUEUE");
            _queue_connection = _queue_connection_factory.createQueueConnection();
            _queue_session = _queue_connection.createQueueSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
            _queue_sender = _queue_session.createSender(_queue);

            _queue_sender.send(_queue_session.createTextMessage("0"));
            _queue_sender.send(_queue_session.createTextMessage("1"));
            _queue_sender.send(_queue_session.createTextMessage("1"));
            Thread.sleep(1000);
            _queue_sender.send(_queue_session.createTextMessage("Stop..."));
        } catch (Exception e) {
            // Error...
        }
    }
}

Example (message reception and processing - EJB 3.x)

@javax.ejb.MessageDriven(mappedName = "jms/MY_QUEUE", activationConfig = {
                        @javax.ejb.ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
                        @javax.ejb.ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") })
public class Receiver implements javax.jms.MessageListener {
    @javax.annotation.Resource
    private javax.ejb.MessageDrivenContext _ejb_context; // Optional, but necessary for getting a transaction object (BMT mode)
    @javax.annotation.PostConstruct 
    public void construct() { // Resource acquisition } 
    @Override    
    public void onMessage(javax.jms.Message message) {  
        if (message instanceof javax.jms.TextMessage) …   
    }    
    @javax.annotation.PreDestroy
    public void destroy() { // Resource release }            
}
Entity Beans

Key features

Creation and deletion

Additional information on Entity Beans requires a survey of the JPA technology ☛

Transaction management

Design patterns

Example ☛

Lifecycle of Enterprise Beans ☛

Lifecycle management

Passivation and activation

Because resources on Java EE application servers decrease performance, developers must take care of releasing these resources when unused. This may occur when Enterprise Beans are destroyed. This may also occur when Enterprise Beans like Stateful Session Beans are passivated

Example (how to optimally handle a naming context)

private javax.naming.Context _jndi_context;
…
@javax.ejb.PrePassivate
public void passivate() {
    if (_jndi_context != null) _jndi_context.close(); // This code may raise an exception if the resource has been obtained through dependency injection
    _jndi_context = null; // Safer in case of dependency injection  
}
@javax.ejb.PostActivate
public void activate() {
    _jndi_context = new javax.naming.InitialContext(); 
}

Note: in general, resources acquired by dependency injection must not be managed by developers. In other words, the best solution when releasing such resources is to assign null to the variable embodying the resource

The notion of EJB “container”

An Enterprise Bean container is a kind of controller. Effectively, a container is an instance of a Java class generated by the application server at deployment time. This class mixes the Java code released by the EJB's developer with the configuration attribute values assigned by this developer to its EJB. For example, an Enterprise Bean container opens and closes transactions (CMT mode) on the behalf on the Enterprise Bean, which delegates this charge to its container. For various reasons, Enterprise Beans must sometimes access to their execution context materialized by their container in order to access resources/facilities. As an illustration, the BMT mode requires the access to the current transaction ☛

Interacting with a container (a.k.a. execution context)

In EJB ver. 2.x, one may, for instance, access to the execution context of a Session Beans instance

Example (EJB ver. 2.x)

public class X_bean implements SessionBean {
    private SessionContext _ejb_context;
    public void setSessionContext(SessionContex ejb_context) {
        _ejb_context = ejb_context;
    }
    …

The access to the Session Bean itself (then avoiding this) is as follows

Example (EJB ver. 2.x)

X_remote x_remote = _ejb_context.getEJBObject(); // 'X_remote' is a Java interface that is declared in a XML file as the remote interface of 'X_bean'

In EJB ver. 3.x, one accesses to the execution context of a Session Bean instance through dependency injection ☛

EJB dependencies

Dependencies are links at run-time so that Enterprise Beans are able to interact. Dependencies are also concerned by links between software components and services on one side and, resources (databases, JMS queues/topics…) on another side

From Java 5, resource injection (or dependency injection) is a key mechanism to set up dependencies between Enterprise Beans. From Java 6, the Context and Dependency Injection -CDI- mechanism is a more powerful mechanism. Historically, the EJB technology uses the Java Naming and Directory Interface -JNDI- technology to dynamically create references embodying dependencies between Enterprise Beans

 

Dependency design patterns

Resource dependency management

Local, remote or no interface at all?

The case of “home” interfaces being local or remote

Local or remote “home” interfaces are a concept from older EJB versions, prior to 3.x especially. However, they remain useful in certain cases, namely when one want to initialize Session Beans with specific values at creation time. For that, the javax.ejb.Init annotation may be used

@javax.ejb.Remote annotation

Enterprise Beans are located (packaged) in an EJB module. An EJB module is a unit of deployment. An instance of an EJB of type A in an EJB module can access to an instance of an EJB of type B in another EJB module only if and only if B is annotated with @javax.ejb.Remote. @javax.ejb.Remote has to be used sparingly. It is especially useful when one distributes EJB modules to different Java EE VMs (i.e., Java EE application server running instances)

Illustration: “local” versus “remote” interface for Stateless Session Beans

A simple Java EE application Test_Asterix_Obelix.zip relies on Asterix Asterix.zip and Obelix Obelix.zip as two collaborative Session Beans. Asterix has a business method named strength, which itself calls a business method offered by Obelix also named strength

The issue of about the exposure of Obelix between javax.ejb.LocalBean, javax.ejb.Local, and javax.ejb.Remote

  1. Implement Asterix and Obelix in the same EJB module as follows:
    • Both are Stateless Session Beans (use the following annotation value for Obelix: mappedName = "OBELIX")
    • Dependency injection in Asterix to Obelix as follows: @javax.ejb.EJB(mappedName = "OBELIX") Obelix o = null;
    • Call of Obelix strength in Asterix strength: o.strength();
  2. Implement Asterix and Obelix in two different EJB modules. Change the code in both Asterix and Obelix so that strength in Asterix is still able to call strength in Obelix
Concurrency

From EJB 3.x, it exists two major mechanisms to deal with concurrency, more precisely, to control the concurrent access to a component

Example

@javax.ejb.Remote({Obelix.class})
@javax.ejb.Stateless(mappedName = "ejb/Obelix")
public class Obelix_implementation implements Obelix {

    @javax.ejb.Asynchronous // The result is returned to the Enterprise Bean container, not directly to the client component...
    @Override
    public java.util.concurrent.Future<String> complain() {
        return new javax.ejb.AsyncResult<>("Arrrrrgggglllll");
    }

    @Override
    public String strength() {
        return "I'm really the strongest... ";
    }
}
@javax.ejb.EJB(mappedName = "ejb/Obelix", lookup = "ejb/Obelix")
Obelix o = null;

@Override
public void strength() {
    java.util.concurrent.Future<String> result = o.complain();
    try {
        System.out.println(o.strength() + (result.isDone() ? result.get() : "not yet available, operation canceled: " + result.cancel(false)));
    } catch (InterruptedException | java.util.concurrent.ExecutionException ex) {
        java.util.logging.Logger.getLogger(Asterix.class.getSimpleName()).log(java.util.logging.Level.SEVERE, null, ex);
    }
}
Reentrance

Enterprise Beans are by default not reentrant. This means that an Enterprise Bean involved in a business method cannot receive at the same time a request from elsewhere demanding the execution of the same, or another offered, business method. Reentrance is firstly linked to transactions. If the executing business method is configured such that it is included within a transaction, calling at the same time the Enterprise Bean is incompatible with the ongoing transaction, which handles the Enterprise Bean as an exclusive resource

Otherwise, reentrance is also not possible even if the transaction mode is set to BMT (@javax.ejb.TransactionManagement(javax.ejb.TransactionManagementType.BEAN)) or is not supported (@javax.ejb.TransactionAttribute(javax.ejb.TransactionAttributeType.NOT_SUPPORTED)). In this case, no transaction is in progress but the Enterprise Bean is nevertheless active for the execution duration of a given business method

Reentrance is mainly concerned with Stateful Session Beans because references to other Enterprise Beans do not require to be kept. Reentrance issues have been better addressed in EJB ver 3.x with the arrival of Singleton Session Beans

Transaction management

Key features

The general functioning of a transaction is as follows

In this example, one may imagine that step 2 fails (a raised exception materialized such a failure). The overall business logic is such that step 3 must not success. Having a transaction associated with step 1 guarantees a consistent (collaborative) functioning between step 2 and step 3

Container-Managed Transaction -CMT-

@javax.ejb.Stateful
public class TerminalBean implements Terminal {
    @javax.ejb.TransactionAttribute(javax.ejb.TransactionAttributeType.NOT_SUPPORTED)
    public String get_name() {
        …
    …

Containers roll back transactions in case of “system” failures, namely when a javax.ejb.EJBException is raised. However, there are some tricky cases when such an exception is not raised. At the same time, one wants to roll back the transaction because of a local business dysfunction, which is not captured by the container. In this specific case, one rolls back the current transaction while the CMT mode is active

@javax.annotation.Resource
private javax.ejb.SessionContext _ejb_context = null;
…
assert(_ejb_context != null);
javax.transaction.UserTransaction ut = _ejb_context.getUserTransaction();
…
if(/* some test */) ut.setRollbackOnly();

Bean-Managed Transaction -BMT-

In this case, the developer must setup the Enterprise Bean so that it may benefit from the BMT status 

@javax.ejb.Stateful
@javax.ejb.TransactionManagement(javax.ejb.TransactionManagementType.BEAN)
public class RailcarBean implements Railcar { …

Next, she/he must catch the ongoing transaction, start it, stop it through the COMMIT or ROLLBACK facilities 

@javax.annotation.Resource
private javax.ejb.SessionContext _ejb_context = null;
…
assert(_ejb_context != null);
javax.transaction.UserTransaction ut = _ejb_context.getUserTransaction();
ut.begin();
…
if(/* some test */) ut.commit();
else ut.rollback();

Transactions in Message-Driven Beans

Message consumption is associated with an acknowledgement mechanism. Message acknowledgement is automatic unless specific settings. By default, acknowledgment leads to COMMIT while other situations lead to ROLLBACK (e.g., failure within onMessage)

Fine-grain transaction control

There is a support for managing transactions with higher accuracy (CMT Stateful Session Beans only): namely, when transactions are to be started, they are to be completed and have just completed. The javax.ejb.SessionSynchronization ☛ interface is devoted to this job

Configuration

The deep nature of Enterprise Beans is the possibility of configuring deployment values. These values are that of parameters, which are interpretable by a Java EE application server. The latter transforms the developer's values into code in order to match to the execution environments characteristics, constraints, etc. Application server administration allows the introduction of homemade parameters but, it is outside the scope of this tutorial. Configuration preferably occurs through XML files (EJB 2.x and older versions) or annotations (EJB 3.x). The last approach does not exclude the utilization of XML files in tricky cases. The core configuration file is the ejb-jar.xml file. So, for example, in aged EJB versions (2.x), transaction attributes may be setup in ejb-jar.xml  as follows (one declares that all (*) business methods of My_bean have the RequiresNew transaction attribute) 

<ejb-jar …> <!--EJB ver. 2.x--> 
    …
    <assembly-descriptor>
        …
        <container-transaction>
            <method>
                <ejb-name>My_bean</ejb-name>
                <method-name>*</method-name>
            </method>
            <trans-attribute>RequiresNew</trans-attribute>
        </container-transaction>
    </assembly-descriptor>
</ejb-jar>

There are some other important configurations files like persistence.xml -JPA- or glassfish-resources.xml. The latter is a proprietary file of the Glassfish Java EE application server. Any configured value within this file is not portable across application servers. For example, one may force Glassfish to create no more than 1 instance of a given Message-Driven Bean with <max-pool-size>1</max-pool-size>

EJB dependencies in ejb-jar.xml file

<?xml version="1.0" encoding="UTF-8"?>
<ejb-jar xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         version="3.2"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/ejb-jar_3_2.xsd"> <!--EJB ver. 3.x-->
    <enterprise-beans>
        <session>
            <ejb-name>My_Asterix</ejb-name>
            <business-remote>Asterix.Asterix</business-remote>
            <ejb-class>Asterix.Asterix_implementation</ejb-class>
            <session-type>Stateless</session-type>
            <transaction-type>Container</transaction-type>
            <ejb-ref>
                <ejb-ref-name>ejb/Obelix</ejb-ref-name>
                <ejb-ref-type>Session</ejb-ref-type>
                <remote>Obelix.Obelix</remote>
            </ejb-ref>
        </session>
    </enterprise-beans>
</ejb-jar>
Packaging

EJB applications are packaged in EJB modules or in EJB applications (.ear or .jar files). Files including source files and configuration data must be located in precise directories with a special tree structure

Security

Security features can be setup at design to be experienced at run-time

Other features

Service computing in EJB

The big picture: the Java EE platform itself provides “technical” services as provided by any middleware. The major Java EE services are transaction management, security, performance (load balancing), persistence, naming, messaging… Most of them often come from the Java EE sublayer. As an illustration, practically, the Glassfish Java EE application server may be built on the top of CORBA ☛ that itself supports technical services: COS naming, CORBA Object Transaction Service -OTS-… OSGi is another candidate for Java EE application server implementation. In EJB, there are also business services that are the primary way of modularizing applications through the sharing of these software components among several enterprise applications. Endowing these business services with Internet interoperability leads to giving the status of Web services to Stateless Sessions Beans

Support for Web services

Stateless Sessions Beans (including Singleton Sessions Beans) annotated with @javax.ejb.WebService can be accessed as a Web service ☛

CDI

The beans.xml file is dedicated to CDI. It can be empty

Quizzes

Quiz 1

Soit le code EJB qui suit. S1 et S2 sont dans le même EJB module

@javax.ejb.Stateless
public class S1 {
    private int _i;
    public void increment() {
        _i++;
    }
    public int get_i() {
        return _i;
    }
}
@javax.ejb.Singleton
@javax.ejb.Startup
public class S2 {
    @javax.ejb.EJB
    private S1 _s1;
    @javax.ejb.EJB
    private S1 _s1_bis;
    @javax.annotation.PostConstruct
    public void g() {
        int result = 0;
        _s1.increment();
        result += _s1.get_i();
        _s1.increment();
        result += _s1.get_i();
        System.out.println("result (g): " + result);
    }
    public void h() {
        int result = 0;
        _s1.increment();
        result += _s1.get_i();
        _s1_bis.increment();
        result += _s1_bis.get_i();
        System.out.println("result (h): " + result);
    }
}
  1. Au déploiement de l’EJB module, que se passe-t-il ? Répondre en choisissant parmi les hypothèses suivantes :
    1. rien n’est affiché
    2. est affiché un entier positif ou nul
    3. est affiché un entier ne pouvant varier que dans l’intervalle [0..3]
    4. est affiché 3 exactement dans tous les cas d’exécution
    5. est affiché 2 exactement dans tous les cas d’exécution
  2. L’annotation @javax.annotation.PostConstruct est placée sur la méthode h dans S2 (et supprimée sur la méthode g). Au déploiement de l’EJB module, que se passe-t-il ? Répondre en choisissant parmi les hypothèses suivantes :
    1. rien n’est affiché
    2. est affiché un entier positif ou nul
    3. est affiché un entier ne pouvant varier que dans l’intervalle [0..2]
    4. est affiché un entier ne pouvant varier que dans l’intervalle [0..3]
    5. est affiché 3 exactement dans tous les cas d’exécution
    6. est affiché 2 exactement dans tous les cas d’exécution
  3. L’annotation @javax.ejb.Stateless sur S1 est remplacée par @javax.ejb.Stateful et l’annotation @javax.annotation.PostConstruct est mise sur la méthode g dans S2. Au déploiement de l’EJB module, que se passe-t-il ? Répondre en choisissant parmi les hypothèses suivantes :
    1. rien n’est affiché
    2. est affiché un entier positif ou nul
    3. est affiché un entier ne pouvant varier que dans l’intervalle [0..2]
    4. est affiché un entier ne pouvant varier que dans l’intervalle [0..3]
    5. est affiché 3 exactement dans tous les cas d’exécution
    6. est affiché 2 exactement dans tous les cas d’exécution
  4. L’annotation @javax.ejb.Stateless sur S1 est remplacée @javax.ejb.Stateful et l’annotation @javax.annotation.PostConstruct est sur la méthode h dans S2. Au déploiement de l’EJB module, que se passe-t-il ? Répondre en choisissant parmi les hypothèses suivantes :
    1. rien n’est affiché
    2. est affiché un entier positif ou nul
    3. est affiché un entier ne pouvant varier que dans l’intervalle [0..2]
    4. est affiché un entier ne pouvant varier que dans l’intervalle [0..3]
    5. est affiché 3 exactement dans tous les cas d’exécution
    6. est affiché 2 exactement dans tous les cas d’exécution

Quiz 2

Dans le code EJB qui suit MDB.EJB.zip , Starter et Dispatcher sont dans le même EJB module alors que Service est dans un autre EJB module

Le développeur souhaite voir affiché dans le log du serveur : « To be or not to be, this is the question… ». Malheureusement, ce n'est pas le cas. Modifier le programme pour obtenir ce résultat

Note : création de ressources JMS avec asadmin ☛ 

public class My_message implements java.io.Serializable {
    final String _word;
    public String getWord() {
        return _word;
    }
    final int _order;
    public int getOrder() {
        return _order;
    }
    My_message(String content, int order) {
        _word = content;
        _order = order;
    }
}
/***************************************/
public interface Service {
    void construct_sentence(My_message my_message);
    void display_sentence();
    boolean stop();
}
/***************************************/
@javax.ejb.Local({Service.class})
@javax.ejb.Stateful
public class Service_implementation implements Service {
    private final java.util.Vector<String> _sentence = new java.util.Vector<>();
    public void construct_sentence(My_message my_message) {
        if (my_message.getOrder() + 1 > _sentence.size()) _sentence.setSize(my_message.getOrder() + 1);
        _sentence.set(my_message.getOrder(), my_message.getWord());
    }
    public void display_sentence() {
        String sentence = "";
        for (String word : _sentence) sentence += word;
        System.out.println(sentence);
    }
    public boolean stop() {
        int n = 0;
        for (String word : _sentence)
            if (word != null) n++;
        return n == Starter.Number;
    }
}
/***************************************/
@javax.ejb.MessageDriven(activationConfig = {@javax.ejb.ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "jms/MY_QUEUE"), @javax.ejb.ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")})
public class Dispatcher implements javax.jms.MessageListener {
    @javax.ejb.EJB
    private Service _service = null;
    @Override
    public void onMessage(javax.jms.Message message) {
        try {
            My_message my_message = (My_message) ((javax.jms.ObjectMessage) message).getObject();
            _service.construct_sentence(my_message);
            if (_service.stop()) _service.display_sentence();
        } catch (Exception e) { // Error... }
    }
}
/***************************************/
@javax.ejb.Singleton
@javax.ejb.Startup
public class Starter {

    public static final int Number = 10;

    private javax.jms.QueueConnectionFactory _queue_connection_factory;
    private javax.jms.Queue _queue;
    private javax.jms.QueueConnection _queue_connection;
    private javax.jms.QueueSession _queue_session;
    private javax.jms.QueueSender _queue_sender;

    @javax.annotation.PostConstruct
    public void create() {
        try {
            javax.naming.Context _jndi_context = new javax.naming.InitialContext();
            _queue_connection_factory = (javax.jms.QueueConnectionFactory) _jndi_context.lookup("jms/MY_QUEUE_FACTORY");
            _queue = (javax.jms.Queue) _jndi_context.lookup("jms/MY_QUEUE");
            _queue_connection = _queue_connection_factory.createQueueConnection();
            _queue_session = _queue_connection.createQueueSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
            _queue_sender = _queue_session.createSender(_queue);
            int i = 0;
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("To ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("be ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("or ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("not ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("to ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("be, ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("this ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("is ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("the ", i++)));
            _queue_sender.send(_queue_session.createObjectMessage(new My_message("question...", i++)));
            assert (i == Number);
        } catch (Exception e) { // Error... }
    }
}

Quiz 3

Dans le code EJB qui suit, toute instance d’EJB My_stateful maintient une liste de références (champ _collection_of_My_stateless_remote) sur une collection d’EJBs My_stateless 

public interface My_stateless_remote {
    void business();
}
…
@javax.ejb.Stateless
public class My_stateless implements My_stateless_remote {
    @Override
    public void business() {
        // Any business code here
    }
}
public interface My_stateful_remote {
    void business();
}
…
@javax.ejb.Stateful
@javax.ejb.Remote(My_stateful_remote.class)
public class My_stateful {
    private java.util.Collection<My_stateless_remote> _collection_of_My_stateless_remote;
    // Le code des questions s’ajoute ici…
}
  1. Est-ce que ce lien (cette liste de réf.) est susceptible de causer des erreurs à l’exécution ?
  2. Est-ce que ce lien est susceptible d’améliorer la performance à l’exécution ?
  3. En EJB, il n’est pas possible de faire une injection de ressource sur une collection. En d’autres termes, ce code ne fonctionne pas : 
    // '@javax.ejb.EJB' est mise en commentaires car ne fonctionne pas...
private java.util.Collection<My_stateless_remote> _collection_of_My_stateless_remote;

    Pour pallier le problème, on « capture » les composants différemment (ce code s'ajoute au code préalable) : 

    My_stateful() throws Exception {
    javax.naming.Context jndi_context = new javax.naming.InitialContext();
    for (int i = 0; i < 10; i++) {
        My_stateless_remote msr = (My_stateless_remote) jndi_context.lookup("java:global/My_EJB_module/My_stateless"); // 'My_EJB_module' is the name of the deployment file
        _collection_of_My_stateless_remote.add(msr);
    }
}
    Bien que ce code fonctionne, quelle est une meilleure alternative ?
  4. Soit la méthode business dans la classe My_stateful (ce code s'ajoute au code préalable) : 
    public void business() {
    for (My_stateless_remote msr : _collection_of_My_stateless_remote)
        msr.business();
}
    Bien que ce code fonctionne, quelle est une meilleure alternative ?

Quiz 4

Implémenter le programme Lotto! ☛ en EJB Tirage_loto.EJB.zip sous les contraintes suivantes :

  1. Tirer_un_chiffre est un composant assurant un seul service tirer retournant un chiffre dans un intervalle [1-borne]
  2. Tirer_tous_les_chiffres (dont le mappedName est "Loto") est un composant assurant un service tirer établissant un tirage de 48 chiffres différents dans l'intervalle [1-49]. Une autre business method stocker envoie le résultat du tirage dans une file d'attente JMS. Tirer_tous_les_chiffres utilise Tirer_un_chiffre
  3. Faire un programme de test qui appelle tirer puis stocker sur "Loto"