Java ejbCreate函数初始化EJB的一个代码实例

package address; import javax.naming.*; import java.util.Properties; import javax.rmi.PortableRemoteObject; import java.util.Collection; import java.util.Iterator; import java.util.Enumeration; public class AddressesClient { static final private int MAX_OUTPUT_LINE_LENGTH = 50; private AddressesHome addressesHome = null; //创建一个EJB测试客户端 public AddressesClient() { try { //得到名字上下文 Context ctx = getInitialContext(); //查询jndi名 Object ref = ctx.lookup("Addresses"); //通过强制转型得到Home接口 addressesHome = (AddressesHome) PortableRemoteObject.narrow(ref, AddressesHome.class); } catch(Exception e) { e.printStackTrace(); } } //这个函数返回一个经过初始化的上下文 private Context getInitialContext() throws Exception { String url = "t3://cgb-4wn01xj69v6:7001"; String user = null; String password = null; Properties properties = null; try { properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory"); properties.put(Context.PROVIDER_URL, url); if (user != null) { properties.put(Context.SECURITY_PRINCIPAL, user); properties.put(Context.SECURITY_CREDENTIALS, password == null ? "" : password); } return new InitialContext(properties); } catch(Exception e) { System.out.println("Unable to connect to WebLogic server at " + url); System.out.println("Please make sure that the server is running."); throw e; } } // 工具函数 public AddressesHome getHome() { return addressesHome; } private void log(String message) { if (message == null) { System.out.println("-- null"); return ; } if (message.length() > MAX_OUTPUT_LINE_LENGTH) { System.out.println("-- " + message.substring(0, MAX_OUTPUT_LINE_LENGTH) + " ..."); } else { System.out.println("-- " + message); } } public void executeFindAll() { try { executeCollectionFinder(addressesHome.findAll()); } catch(Exception e) { e.printStackTrace(); } } public void executeCollectionFinder(Collection all) { try { Iterator iterator = all.iterator(); while (iterator.hasNext()) { Object object = iterator.next(); Addresses addresses = (Addresses) PortableRemoteObject.narrow(object, Addresses.class); log(addresses.toString()); } } catch(Exception e) { e.printStackTrace(); } } public void executeEnumerationFinder(Enumeration all) { try { while (all.hasMoreElements()) { Object object = all.nextElement(); Addresses addresses = (Addresses) PortableRemoteObject.narrow(object, Addresses.class); log(addresses.toString()); } } catch(Exception e) { e.printStackTrace(); } } //Main函数 public static void main(String[] args) { AddressesClient client = new AddressesClient(); //用client的getHome()函数调用Home接口函数得到远程接口的引用 // 用远程接口的引用访问EJB try { Addresses Addressesobj=client.getHome().create("Jame","Janny"); Addressesobj.setCity("New York"); Addressesobj.setState("New York"); Addressesobj.setZip("310000"); Addressesobj.setAddress("Wall Street"); System.out.print("This is CMP EntityBean example!\n"); System.out.print("FirstName:"+Addressesobj.getFirstName()+"\n"); System.out.print("LastName:"+Addressesobj.getLastName()+"\n"); System.out.print("Address:"+Addressesobj.getAddress()+"\n"); System.out.print("State:"+Addressesobj.getState()+"\n"); System.out.print("The example is over!\n"); } catch(Exception e) { e.printStackTrace(); } } }