Web

java-school.net

메시지 드리븐 빈

C:/ejb 워크스페이스에 새로운 프로젝트 news 를 생성하고, Add External JARs.. 버튼을 이용하여 weblogic.jar 를 Build Path 에 추가합니다.
아래 SQL문을 이용해서 예제에 사용될 테이블을 생성합니다.

create table news (
  seq varchar2(5) primary key,
  name varchar2(20),
  title varchar2(50),
  content varchar2(4000));

엔티티 빈 작성

생성한 테이블과 연관을 맺고 있는 엔티티 빈을 작성합니다.

1. 원격 인터페이스 작성

News.java

package kr.co.hanbitbook.ejb.examples.news;

import java.rmi.RemoteException;

import javax.ejb.EJBObject;

public interface News extends EJBObject {
	
	public String getSeq() throws RemoteException;
	
	public void setName(String name) throws RemoteException;
	public String getName() throws RemoteException;
	
	public void setTitle(String title) throws RemoteException;
	public String getTitle() throws RemoteException;
	
	public void setContent(String content) throws RemoteException;
	public String getContent() throws RemoteException;
	
}

2. 홈 인터페이스 작성

NewsHome.java

package kr.co.hanbitbook.ejb.examples.news;

import java.rmi.RemoteException;

import javax.ejb.CreateException;
import javax.ejb.EJBHome;
import javax.ejb.FinderException;

public interface NewsHome extends EJBHome {
	
	public News create(
			String seq, 
			String name, 
			String title, 
			String content)
			throws CreateException, RemoteException;
	
	public News findByPrimaryKey(String seq) 
			throws FinderException, RemoteException; 

}

3. 빈 클래스 작성

NewsEJB.java

package kr.co.hanbitbook.ejb.examples.news;

import java.rmi.RemoteException;

import javax.ejb.CreateException;
import javax.ejb.EJBException;
import javax.ejb.EntityBean;
import javax.ejb.EntityContext;
import javax.ejb.RemoveException;

public abstract class NewsEJB implements EntityBean {

	private static final long serialVersionUID = -5470278548227735562L;
	EntityContext ctx;
	
	public abstract void setSeq(String seq);
	public abstract String getSeq();
	
	public abstract void setName(String name);
	public abstract String getName();
	
	public abstract void setTitle(String title);
	public abstract String getTitle();
	
	public abstract void setContent(String content);
	public abstract String getContent();
	
	public String ejbCreate(
			String seq, 
			String name, 
			String title, 
			String content) throws CreateException {
		setSeq(seq);
		setName(name);
		setTitle(title);
		setContent(content);
		return null;
	
	}

	public void ejbPostCreate(
			String seq, 
			String name, 
			String title, 
			String content) throws CreateException {
	}
	
	public void ejbActivate() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbLoad() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbPassivate() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbRemove() throws RemoveException, EJBException,
			RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbStore() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void setEntityContext(EntityContext ctx) throws EJBException,
			RemoteException {
		this.ctx = ctx;
	}

	public void unsetEntityContext() throws EJBException, RemoteException {
		ctx = null;
	}

}

메시지 드리븐 빈 작성

AddNewsBean.java

package kr.co.hanbitbook.ejb.examples.news;

import javax.ejb.CreateException;
import javax.ejb.EJBException;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.naming.Context;
import javax.naming.InitialContext;

public class AddNewsBean implements MessageDrivenBean, MessageListener {

	private static final long serialVersionUID = -2106248019150161026L;
	MessageDrivenContext ctx;
	NewsHome home;
	
	public void ejbCreate() throws CreateException {}
	
	public void ejbRemove() throws EJBException {
		// TODO Auto-generated method stub
		
	}

	public void setMessageDrivenContext(MessageDrivenContext ctx)
			throws EJBException {
		this.ctx = ctx;
	}

	public void onMessage(Message msg) {
		System.out.println("on Message 호출");
		
		try {
			Context initial = new InitialContext();
			Object obj = initial.lookup("news"); // news !!!
			home = (NewsHome)obj;
		} catch (Exception e) {
			System.out.println(e);
		}
		
		try {
			if ( msg instanceof MapMessage ) {
				MapMessage mm = (MapMessage)msg;
				String seq = mm.getString("seq");
				String name = mm.getString("name");
				String title = mm.getString("title");
				String content = mm.getString("content");
				System.out.println(seq + ":" + name + ":" + title + ":" + content);
				
				try {
					News news = null;
					try {
						news = home.findByPrimaryKey(seq);
					} catch (Exception e) {
						System.out.println("findByPrimaryKey : " + e.toString());
					}
					
					if (news == null) {
						System.out.println("같은 seq값이 없을 경우......");
						home.create(seq, name, title, content);
						System.out.println("새로운 값을 저장했습니다.");
					}
				} catch (Exception e) {
					System.out.println("CMP Exception : " + e.toString());
				}
			}드
		} catch (JMSException e) {
			System.out.println("JMSException : " + e.toString());
		}
		
	} // onMessage 메소드 끝

}

배치 디스크립터 작성(웹로직 빌더 이용) 및 배치

웹로직 빌더를 실행하고 컴파일된 경로인 C:\ejb\news\bin 를 선택합니다.
좌측메뉴에서 NewsEJB 를 선택하고 General 탭에서 JNDI Name: 항목의 값이 news 로 수정합니다.

Classes 탭에서 엔티티 빈을 구성하는 클래스가 올바른지 확인합니다.

Persistence 탭에서 DataSourde name: oraxa9, Table name: NEWS 로 설정합니다.

Resources 메뉴에서 엔티티 빈이 사용할 데이터 소스를 그림처럼 설정합니다.

CMP Fields 메뉴에서 각 필드를 클릭하여 Edit 버튼을 활성화 한 후, Edit 버튼을 이용해서 필드 타입을 모두 LongString 으로 설정합니다.

JNDI name: addnews 로, 목적지 형식을 javax.jms.Topic 로, 목적지의 JNDI 명은 jmstopic 로 지정합니다.
(jmstopic으로 지정하는 부분은 XML 파일을 열어 직접 수정해 주어야 합니다.)

Classes 탭에서 메시지 드리븐 빈을 구성하는 클래스를 확인합니다.

Resources 좌측 메뉴에서 EJB Refs 탭을 선택한 후, Add 버튼을 클릭하여 메시지 빈이 사용할 엔티티 빈에 대한 레퍼런스를 지정합니다.
(그림에서와 같이 news.jar#NewsEJB 값을 넣을 수 없을 수 있습니다. 이 부분은 XML파일을 열어 직접 편집해 주어야 합니다.)
레퍼런스가 추가되는 것을 확인할 수 있습니다.

Save 버튼을 클릭하여 배치 디스크립터 파일을 생성합니다.
ejb-jar.xml 파일을 열고 ejb-link 엘리먼트의 값을 news.jar#NewsEJB 로 수정합니다.
weblogic-ejb-jar.xml 파일을 열고 destination-jndi-name 엘리먼트의 값을 jmstopic 로 수정합니다.
다시 웹로직 빌더를 실행한 후 웹로직 빌더의 Archive...버튼을 이용해서 news.jar 파일을 C:\ejb\news 디렉토리에 생성합니다.
콘솔에서 news.jar 파일을 배치합니다.

테스트

C:/ejb 워크스페이스에 새로운 프로젝트 news_client 를 생성하고, Add External JARs.. 버튼을 이용하여 weblogic.jar 를 Build Path 에 추가합니다.
아래 자바 파일을 작성하고 실행합니다.
다음 SQL*PLUS를 열고 news 테이블에 데이터가 있는지 확인합니다.

NewsClient.java

package kr.co.hanbitbook.ejb.examples.news;

import javax.jms.MapMessage;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class NewsClient {
	public static void main(String[] args) {
		Context ctx = null;
		try{
			java.util.Properties p = new java.util.Properties();
			p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
			p.put(Context.PROVIDER_URL, "t3://localhost:7001");
			ctx = new InitialContext(p);
			
			TopicConnectionFactory tcf = (TopicConnectionFactory) ctx.lookup("weblogic.jms.ConnectionFactory");
			TopicConnection qc = tcf.createTopicConnection();
			qc.start();
	
			Topic Topic = null;
			TopicSession tsession = null;
			try{
				tsession = qc.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
				Topic = (Topic)ctx.lookup("jmstopic");
			}catch(NamingException ne){
				Topic = tsession.createTopic("jmstopic");
				ctx.bind("jmstopic", Topic);
			}
	
			TopicPublisher qsender = tsession.createPublisher(Topic);
			MapMessage mm = tsession.createMapMessage();
			String[] msg = new String[]{ "김성박", "새로운 영화", "반지의 제왕 3" };
			
			mm.setString("seq", "1");
			mm.setString("name",msg[0]);
			mm.setString("title",msg[1]);
			mm.setString("content", msg[2]);
	
			qsender.publish(mm);
			System.out.println("새로운 뉴스를 전송하였습니다.");
			qc.close();
			
		}catch(Exception e){
			System.out.println(e.toString());
		}
	}
}

참고 문서

알기쉽게 풀어 쓴 웹로직과 EJB 11장 -한빛미디어,김성박 저-
예제에 쓰였던 jar,war,ear 파일 (배치시 익셥션 발생할 때 참고용)

EJB

• WebLogic 8.1
  • WebLogic 8.1 SP6 설치
  • JDBC 설정
  • JMS
  • JNDI
  • 무상태 세션 빈
  • 무상태 세션 빈 예제
  • 상태유지 세션 빈
  • 세션 빈을 이용한 게시판
  • 엔티티 빈(CMP)
  • 엔티티 빈(BMP)
  • CMP(EJB-QL 이용)
  • CMR
  • 메시지 드리븐 빈
  • 세션 빈과 엔티티 빈을 이용한 게시판 예제
  • 쇼핑카트 예제

홈페이지

• 홈페이지 제작
  • 회사홍보용 : 10 만원
• 홈페이지 관리
  • 작업당 단가
  • 정액제