제10장 EJB 사용하기

내용 목차

10.1. Session Bean 예제

10.1.1. 예제
10.1.2. 컴파일
10.1.3. Deploy
10.1.4. 실행 및 결과

10.2. Java Persistence API 예제

10.2.1. 예제
10.2.2. 컴파일
10.2.3. Deploy
10.2.4. 실행 및 결과

본 장에서는 예제를 이용해서 Stateless Session Bean과 Java Persistence API를 이용하여 Entity를 개발하고 deploy하는 과정에 대해 설명한다.

10.1. Session Bean 예제

Session Bean은 기본적으로 Business Interface와 Bean Class로 구성된다.

10.1.1. 예제

EJB 예제

다음의 예제 코드는 helloejb를 출력하는 Business 메소드를 가진 간단한 Stateless Session Bean 예제이다.

Business Interface

[예 10.1] <<Hello.java>>

package helloejb;

import javax.ejb.Remote;

@Remote
public interface Hello {
    String sayHello();
}

Bean Class

[예 10.2] <<HelloBean.java>>

package helloejb;

import javax.ejb.Stateless;

@Stateless(mappedName="helloejb.Hello")
public class HelloBean implements Hello {

    public String sayHello() {
        return "Hello EJB!";
    }
    
}

예제 코드는 다음의 디렉터리에서 찾아볼 수 있다.

JEUS_HOME/samples/getting_started/helloejb/helloejb-ejb/src/java/helloejb

서블릿 클라이언트 예제

helloejb를 호출하는 서블릿 클라이언트를 다음과 같이 구현한다.

[예 10.3] <<HelloClient.java>>

package helloejb;

import java.io.*;
import javax.ejb.EJB;

import javax.servlet.*;
import javax.servlet.http.*;

public class HelloClient extends HttpServlet {
    @EJB(mappedName="helloejb.Hello")
    private Hello hello;

    protected void processRequest(HttpServletRequest request,
        HttpServletResponse response)
    throws ServletException, IOException {
        PrintWriter out = response.getWriter();
        try {
            // Call session bean business method.
            String msg = hello.sayHello();
            
            response.setContentType("text/html");
            out.println("<html>");
            out.println("<head>");
            out.println("<title>HelloClient</title>");
            out.println("</head>");
            out.println("<body>");
            out.println("<center><h1>" + msg + "</h1></center>");
            out.println("</body>");
            out.println("</html>");
            out.close();
        } catch(Exception ex){
            response.setContentType("text/plain");
            ex.printStackTrace(out);
        }
    }
    
    protected void doGet(HttpServletRequest request,
        HttpServletResponse response)
    throws ServletException, IOException {
        processRequest(request, response);
    }
    
    protected void doPost(HttpServletRequest request, 
        HttpServletResponse response)
    throws ServletException, IOException {
        processRequest(request, response);
    }
    
}

예제 코드는 다음 위치의 디렉터리에서 찾아볼 수 있다.

JEUS_HOME/samples/getting_started/helloejb/helloejb-war/src/java/helloejb

10.1.2. 컴파일

작성된 예제는 Ant를 이용하여 다음과 같이 빌드할 수 있다.

%JEUS_HOME%/samples/getting_started/helloejb>jant build

빌드가 정상적으로 완료되면 %JEUS_HOME%/samples/getting_started/helloejb/dist/helloejb.ear 애플리케이션 EAR 파일이 생성된다.

10.1.3. Deploy

패키징한 EJB 애플리케이션을 WebAdmin과 콘솔 툴로 deploy할 수 있다.

WebAdmin을 사용한 Deploy

WebAdmin을 사용하여 deploy하는 과정은 다음과 같다.

웹 브라우저로 접속해서 WebAdmin에 로그인한다.
WebAdmin 왼쪽 메뉴의 [Applications]를 선택하면 애플리케이션 목록 조회 화면으로 이동한다.

다음과 같이 Deployed Applications 화면에서 [Install] 버튼을 클릭한다.

[그림 10.1] DAS에 install된 애플리케이션 목록
Install 화면에서 'Id' 항목에 사용할 ID 값을 입력한다. 'Path' 항목의 [찾아보기] 버튼을 클릭해서 생성된 애플리케이션을 선택한 뒤 [확인] 버튼을 클릭한다.

[그림 10.2] HelloEJB Deploy 대상 선택
애플리케이션 목록 조회 화면으로 이동하고, DAS에 install된 애플리케이션이 조회된다. 이때 MS에 배포하기 위해 해당 애플리케이션의 [deploy] 버튼을 클릭한다.
[그림 10.3] HelloEJB Deploy 선택 사항
'Target Server' 항목에서 deploy할 서버를 체크하고 [확인] 버튼을 클릭한다. DAS를 선택할 수도 있지만 MS에 deploy하여 애플리케이션을 서비스하는 것을 권장한다.
deploy가 성공적으로 완료되면 다음과 같이 결과 메시지가 출력된다.

[그림 10.4] HelloEJB Deploy 결과

콘솔 툴을 사용한 Deploy

콘솔 툴을 사용하여 deploy하는 과정은 다음과 같다.

위에서 작성한 helloejb.ear 파일을 임의의 경로에 위치시킨다.

jeusadmin으로 JEUS에 접속한다.

jeusadmin johan –u administrator –p  password>

다음과 같이 실행하여 애플리케이션을 DAS에 install한다.

[DAS]jeus_domain.adminServer>install-application -id helloejb C:\TmaxSoft\JEUS8\samples\getting_started\helloejb\dist\helloejb.ear
Successfully installed application[helloejb].

다음과 같이 실행하여 애플리케이션을 MS(server1)에 deploy한다.

[DAS]jeus_domain.adminServer>deploy helloejb -servers server1
Succeeded to deploy the application : helloejb

10.1.4. 실행 및 결과

deploy가 완료되면 작성된 화면를 실행해서 결과를 확인한다.

다음은 웹 클라이언트를 실행하는 과정에 대한 설명이다.

웹 브라우저를 통해 다음 URL로 접속하면 HelloEJB 웹 클라이언트로 접속할 수 있다.
```
http://localhost:8088/helloejb/
```
[그림 10.5] HelloEJB 클라이언트 화면
화면의 [Invoke HelloEJB Client] 버튼을 클릭하면 EJB를 호출하는 HelloClient 서블릿을 실행시키며 다음과 같은 결과를 확인할 수 있다.

[그림 10.6] HelloEJB 서블릿 클라이언트 수행 결과

10.2. Java Persistence API 예제

본 절에서는 Java Persistence API를 통해 Entity를 작성하고 컴파일하여 deploy하는 과정을 설명한다.

10.2.1. 예제

EJB 예제

예제는 Product Entity와 이를 다루는 EJB인 ProductManager Session Bean으로 구성되어 있다.

Entity

[예 10.4] <<Product.java>>

package hellojpa;

import java.io.Serializable;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.NamedQuery;

@Entity
@NamedQuery(name="findAllProducts", query="SELECT p FROM Product p")
public class Product implements Serializable {
    @Id
    private String productId;
    private double price;
    private String description;
    
    public Product() {
    }
    
    public Product(String productId, double price,
        String description){
        this.productId = productId;
        this.price = price;
        this.description = description;
    }

    public String getProductId() {
        return productId;
    }

    public void setProductId(String id) {
        this.productId = id;
    }

    public double getPrice() {
        return price;
    }

    public void setPrice(double price) {
        this.price = price;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }
    
    public String toString() {
        return "Product[productId=" + productId + ", price=" +
            price + ", description=" + description + "]";
    }
}

Business Interface

[예 10.5] <<ProductManager.java>>

package hellojpa;

import java.util.Collection;
import javax.ejb.Local;

@Local
public interface ProductManager {
    Product createProduct(String productId, double price, String desc);
    
    Product getProduct(String productId);
    
    Collection findAllProducts();
    
    Collection findProductsByDescription(String desc);

    Collection findProductsInRange(double low, double high);
    
    void updateProduct(Product product);
    
    void removeProduct(Product product);
    
    void removeAllProducts();
}

Bean Class

[예 10.6] <<ProductManagerBean.java>>

package hellojpa;

import java.util.Collection;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;

@Stateless(mappedName="hellojpa.ProductManager")
public class ProductManagerBean implements ProductManager {
    @PersistenceContext
    private EntityManager em;
    
    public ProductManagerBean() {
    }

    public Product createProduct(String productId, double price, String desc){
        Product product = new Product(productId, price, desc);
        em.persist(product);
        return product;
    }
    
    public Product getProduct(String productId){
        return (Product)em.find(Product.class, productId);
    }
    
    public Collection findAllProducts() {
        return em.createNamedQuery("findAllProducts").getResultList();
    }

    public Collection findProductsByDescription(String desc){
        Query query = em.createQuery("SELECT p FROM Product p WHERE  
            p.description=:desc");
        query.setParameter("desc", desc);
        return query.getResultList();
    }

    public Collection findProductsInRange(double low, double high){
        Query query = em.createQuery("SELECT p FROM Product p WHERE 
            p.price between :low and :high");
        query.setParameter("low", low).setParameter("high", high);
        return query.getResultList();
    }
    
    public void updateProduct(Product product){
        Product managed = em.merge(product);
        em.flush();
    }
    
    public void removeProduct(Product product){
        Product managed = em.merge(product);
        em.remove(managed);
    }
    
    public void removeAllProducts(){
        em.createQuery("DELETE FROM Product p").executeUpdate();
    }
}

예제 코드는 다음의 디렉터리에서 찾아볼 수 있다.

JEUS_HOME/samples/getting_started/hellojpa/hellojpa-ejb/src/java/hellojpa

서블릿 클라이언트 예제

ProductManager EJB를 사용하여 데이터베이스에 데이터를 저장하고 데이터를 다루는 서블릿 클라이언트를 다음과 같이 구현한다.

[예 10.7] <<ProductManagerClient.java>>

package hellojpa;

import java.io.*;
import java.util.Collection;
import javax.ejb.EJB;

import javax.servlet.*;
import javax.servlet.http.*;

public class ProductManagerClient extends HttpServlet {
    @EJB
    private ProductManager productManager;    

    protected void processRequest(HttpServletRequest request,
        HttpServletResponse response)
    throws ServletException, IOException {        
        response.setContentType("text/plain");
        PrintWriter out = response.getWriter();
        out.println("SERVLET CLIENT CONSOLE OUTPUT:\n");
        
        productManager.removeAllProducts();
        out.println("Cleaned up existing products.\n");
        
        out.println("Creating products...");
        Product p1 = productManager.createProduct("1", 10.00, "Ceramic Dog");
        Product p2 = productManager.createProduct("2", 13.00, "Wooden Duck");
        Product p3 = productManager.createProduct("3", 19.00, "Ivory Cat");
        Product p4 = productManager.createProduct("4", 33.00, "Ivory Cat");
        Product p5 = productManager.createProduct("5", 22.00, "Chrome Fish");
        
        Collection products;

        out.println("Created products:");
        products = productManager.findAllProducts();
        for(Object product : products){
             out.println(product);
        }
        out.println();
        
        out.println("Find product with productId 1:");
        Product pp1 = productManager.getProduct("1");
        out.println("Found = " + pp1.getDescription() + " $" + pp1.getPrice());
        
        out.println("Update the price of this product to 12.00");
        pp1.setPrice(12.00);
        productManager.updateProduct(pp1);
        
        Product pp2 = productManager.getProduct("1");
        out.println("Product " + pp2.getDescription() + " is now $" + pp2.getPrice());
        out.println();
        
        out.println("Find products with description:");
        products = productManager.findProductsByDescription("Ivory Cat");
        for(Object product : products){
            out.println(product);
        }
        out.println();
        
        out.println("Find products with price range between 10.00 and 20.00");
        products = productManager.findProductsInRange(10.00, 20.00);
        for(Object product : products){
            out.println(product);
        }
        out.println();
        
        out.println("Removed all products.");
        productManager.removeProduct(p1);
        productManager.removeProduct(p2);
        productManager.removeProduct(p3);
        productManager.removeProduct(p4);
        productManager.removeProduct(p5);
        
        out.close();
    }
    
    protected void doGet(HttpServletRequest request,
        HttpServletResponse response)
    throws ServletException, IOException {
        processRequest(request, response);
    }

    protected void doPost(HttpServletRequest request,
        HttpServletResponse response)
    throws ServletException, IOException {
        processRequest(request, response);
    }
}

예제코드는 다음의 디렉터리에서 찾아볼 수 있다.

JEUS_HOME/samples/getting_started/hellojpa/hellojpa-war/src/java/hellojpa

10.2.2. 컴파일

jant를 이용하여 예제 코드를 다음과 같이 빌드할 수 있다.

예제가 작성된 경로에서 다음과 같이 ant build 명령을 실행한다.
```
C:\TmaxSoft\JEUS8\samples\getting_started\hellojpa>jant build
```
빌드가 정상적으로 완료되면 dist\hellojpa.ear 애플리케이션 EAR 파일이 생성된다.

이번 예제는 데이터베이스를 필요로 하므로 Derby를 시작시키도록 한다. 또한 데이터베이스가 jdbc/sample 데이터소스로 설정되어 있어야 한다. 자세한 내용은 “제8장 시스템 설정”을 참고한다.

Derby가 시작되었다면 다음과 같이 데이터베이스 테이블을 생성한다. 본 예제에서는 "sample"이라는 데이터베이스를 사용할 것이다.
```
CREATE TABLE PRODUCT (PRODUCTID VARCHAR(255) NOT NULL, PRICE FLOAT,
    DESCRIPTION VARCHAR(255), PRIMARY KEY (PRODUCTID));
```
다음과 같이 ant setup 명령을 실행해서 데이터베이스 테이블을 생성한다.
```
C:\TmaxSoft\JEUS8\samples\getting_started\hellojpa>jant setup 
```

이제 빌드와 데이터베이스 설정이 완료되었다면 패키징된 모듈을 deploy할 준비가 완료되었다.

10.2.3. Deploy

패키징한 EJB 애플리케이션을 WebAdmin과 콘솔 툴로 deploy할 수 있다.

WebAdmin을 사용한 Deploy

다음 과정에 따라 패키징된 모듈을 WebAdmin을 사용하여 deploy한다.

웹 브라우저로 접속해서 WebAdmin에 로그인한다.
WebAdmin 왼쪽 메뉴의 [Applications]를 선택하면 애플리케이션 목록 조회 화면으로 이동한다.

다음과 같이 Deployed Applications 화면에서 [Install] 버튼을 클릭한다.

[그림 10.7] DAS에 install된 Application의 목록
Install 화면에서 'Id' 항목에 사용할 ID 값을 입력한다. 'Path' 항목의 [찾아보기] 버튼을 클릭해서 생성된 애플리케이션을 선택한 뒤 [확인] 버튼을 클릭한다. 생성된 애플리케이션은 'JEUS_HOME/samples/getting_started/hellojpa/dist'에 존재한다.

[그림 10.8] install 대상 선택
애플리케이션 목록 조회 화면으로 이동하고, DAS에 install된 애플리케이션이 조회된다. 이때 MS에 배포하기 위해 해당 애플리케이션의 [deploy] 버튼을 클릭한다.

[그림 10.9] Web Application의 install 성공
'Target Server' 항목에서 deploy할 서버를 선택하고 [확인] 버튼을 클릭한다. DAS를 선택할 수도 있지만 MS에 deploy하여 애플리케이션을 서비스하는 것을 권장한다.

[그림 10.10] HelloJPA Deploy 배치 옵션
deploy가 성공적으로 완료되면 다음과 같이 결과 메시지가 출력된다.
[그림 10.11] Deploy된 HelloJPA

참고

“8.4. 데이터소스 추가”에서 데이터소스 설정 관련 부분에서 설명했지만, 데이터소스 설정에서 패스워드나 IP 주소가 정확하지 않을 경우에 deploy는 실패한다.

콘솔 툴을 사용한 Deploy

콘솔 툴을 사용하여 deploy하는 방법은 다음과 같다.

jeusadmin으로 JEUS에 접속한다.

jeusadmin –u administrator –p <password>

애플리케이션을 DAS에 install한다.

[DAS]jeus_domain.adminServer>install-application -id hellojpa C:\TmaxSoft\JEUS8\samples\getting_started\hellojpa\dist\hellojpa.ear
Successfully installed application[hellojpa].

애플리케이션을 MS(server1)에 deploy한다.

[DAS]jeus_domain.adminServer>deploy hellojpa -servers server1
Succeeded to deploy the application : hellojpa

모듈이 정상적으로 deploy되었는지 확인한다.

10.2.4. 실행 및 결과

deploy가 완료되면 작성된 화면을 실행해서 결과를 확인한다.

다음은 웹 클라이언트를 실행하는 과정에 대한 설명이다.

웹 브라우저를 통해 다음 URL로 접속하면 HelloJPA 웹 클라이언트로 접속할 수 있다.
```
http://localhost:8088/hellojpa/
```
[그림 10.12] HelloJPA 클라이언트 화면
화면의 [Invoke ProductManager Client] 버튼을 클릭하면 EJB에 요청을 내리는 서블릿 클라이언트를 수행하고 다음과 같이 결과가 표시된다.
[그림 10.13] HelloJPA 서블릿 클라이언트 수행 결과

이전	위로	다음
제9장 WebTier 사용하기	처음으로	제11장 웹 서비스 사용하기

제10장 EJB 사용하기
이전	Part III. JEUS 시작하기	다음