entr_jvbeans6_app.pdf

Transcription

1 V 5 EJB EJB JBoss Community EJB LGPL JDK Java Development Kit Apache Maven Git Eclipse IDE m2eclipse Eclipse IntelliJ IDEA

2 Subversion SCM $> git clone git://github.com/jbossejb3/oreilly-ejb-6thedition-book-examples.git $> git clone $> cd oreilly-ejb-6thedition-book-examples tags EJB Maven mylocation $> mvn clean install JBoss Nexus EJB POJO EJB EJB JUnit

3 JUnit JUnit JUnit API TestNG JBoss.org 2 ShrinkWrap ShrinkWrap Java JAR WAR EAR API Java Archives JAR Enterprise Archives EAR 1 Web ShrinkWrap API ZIP Exploded File URL ShrinkWrap JAR EAR ShrinkWrap EJB IDE ShrinkWrap EJB Arquillian EJB POJO

4 Arquillian Arquillian Arquillian Java Arquillian 2 JVM Arquillian Arquillian JVM Arquillian Java EE GlassFish JBoss AS GlassFish Tomcat Jetty Bean Wsld SE Arquillian Arquillian 1. / @Resource 4. / 5. Arquillian JUnit 4 TestNG 5 IDE Ant Maven Arquillian

5 5 A FirstEJB A.1 EJB EJB 2.x EJB 3.1 EJB POJO EJB EJB POJO A firstejb/ A.3 A.3.1 A CalculatorBeanBase.java package org.jboss.ejb3.examples.ch04.firstejb; import org.jboss.logging.logger; CalculatorEJB Bean

6 <a / public class CalculatorBeanBase implements CalculatorCommonBusiness // // // / private static final Logger log = Logger.getLogger(CalculatorBeanBase.class); // // org.jboss.ejb3.examples.ch04.firstejb.calculatorcommonbusiness#add(int[]) public int add(final int... arguments) // final StringBuffer sb = new StringBuffer(); sb.append("adding arguments: "); int result = 0; // for (final int arg : arguments) result += arg; sb.append(arg); sb.append(" "); // log.info(sb.tostring()); log.info("result: " + result); return result;

7 7 A CalculatorCommonBusiness.java package org.jboss.ejb3.examples.ch04.firstejb; <a / public interface CalculatorCommonBusiness // // // / int add(int... arguments); A CalculatorLocal.java package org.jboss.ejb3.examples.ch04.firstejb; import javax.ejb.ejblocalobject; CalculatorEJB EJB <a href="mailto:andrew.rubinger@jboss.org">alr</a> / public interface CalculatorLocal extends CalculatorCommonBusiness, EJBLocalObject A CalculatorLocalBusiness.java package org.jboss.ejb3.examples.ch04.firstejb; <a href="mailto:andrew.rubinger@jboss.org">alr</a>

8 8 / public interface CalculatorLocalBusiness extends CalculatorCommonBusiness A CalculatorLocalHome.java package org.jboss.ejb3.examples.ch04.firstejb; import javax.ejb.createexception; import javax.ejb.ejblocalhome; CalculatorEJB EJB <a href="mailto:andrew.rubinger@jboss.org">alr</a> / public interface CalculatorLocalHome extends EJBLocalHome // // create<method> // CalculatorEJB / CalculatorLocal create() throws CreateException; A CalculatorRemote.java package org.jboss.ejb3.examples.ch04.firstejb; import javax.ejb.ejbobject; CalculatorEJB EJB <a href="mailto:andrew.rubinger@jboss.org">alr</a> / public interface CalculatorRemote extends CalculatorCommonBusiness, EJBObject

9 9 A CalculatorRemoteBusiness.java package org.jboss.ejb3.examples.ch04.firstejb; <a / public interface CalculatorRemoteBusiness extends CalculatorCommonBusiness A CalculatorRemoteHome.java package org.jboss.ejb3.examples.ch04.firstejb; import java.rmi.remoteexception; import javax.ejb.createexception; import javax.ejb.ejbhome; CalculatorEJB EJB <a / public interface CalculatorRemoteHome extends EJBHome // // create<method> // CalculatorEJB / CalculatorRemote create() throws CreateException, RemoteException; A ManyViewCalculatorBean.java package org.jboss.ejb3.examples.ch04.firstejb; import javax.ejb.local; import javax.ejb.localbean; import javax.ejb.localhome; import javax.ejb.remote;

10 10 import javax.ejb.remotehome; import javax.ejb.stateless; EJB 3.1 CalculatorEJB // No-interface view public class ManyViewCalculatorBean extends CalculatorBeanBase implements CalculatorCommonBusiness / / A NoInterfaceViewCalculatorBean.java package org.jboss.ejb3.examples.ch04.firstejb; import javax.ejb.localbean; import javax.ejb.stateless; CalculatorEJB <a public class NoInterfaceViewCalculatorBean extends CalculatorBeanBase //

11 11 A SimpleCalculatorBean.java package org.jboss.ejb3.examples.ch04.firstejb; import javax.ejb.local; import javax.ejb.stateless; CalculatorEJB public class SimpleCalculatorBean extends CalculatorBeanBase implements CalculatorCommonBusiness / / A.3.2 A CalculatorAssertionDelegate.java package org.jboss.ejb3.examples.ch04.firstejb; import junit.framework.testcase; import <a href="mailto:andrew.rubinger@jboss.org">alr</a> / class CalculatorAssertionDelegate // // // /

12 12 private static final Logger log = Logger.getLogger(CalculatorAssertionDelegate.class); // // // Calculator / void assertadditionsucceeds(final CalculatorCommonBusiness calc) // final int[] arguments = new int[] 2, 3, 5; final int expectedsum = 10; // final int actualsum = calc.add(arguments); // TestCase.assertEquals(" ", expectedsum, actualsum); // final StringBuffer sb = new StringBuffer(); sb.append("obtained expected result, "); sb.append(actualsum); sb.append(", from arguments: "); for (final int arg : arguments) sb.append(arg); sb.append(" "); log.info(sb.tostring()); A CalculatorIntegrationTestCase.java package org.jboss.ejb3.examples.ch04.firstejb; import java.net.malformedurlexception; import javax.ejb.ejb; import org.jboss.arquillian.api.deployment; import org.jboss.arquillian.junit.arquillian;

13 13 import org.jboss.logging.logger; import org.jboss.shrinkwrap.api.shrinkwrap; import org.jboss.shrinkwrap.api.spec.javaarchive; import org.junit.beforeclass; import org.junit.test; import org.junit.runner.runwith; 1 <a href="mailto:andrew.rubinger@jboss.org">alr</a> public class CalculatorIntegrationTestCase // // // / private static final Logger log = Logger.getLogger(CalculatorIntegrationTestCase.class); CalculatorEJB EJB 3.x private static CalculatorLocalBusiness calclocalbusiness; Calculator / private static CalculatorAssertionDelegate assertiondelegate; public static JavaArchive createdeployment() throws MalformedURLException final JavaArchive archive = ShrinkWrap.create("firstejb.jar", JavaArchive.class). addpackage(calculatorbeanbase.class.getpackage()); log.info(archive.tostring(true)); return archive;

14 14 // // // public static void beforeclass() throws Throwable // assertiondelegate = new CalculatorAssertionDelegate(); // // // EJB 3.x CalculatorEJB public void testadditionusingbusinessreference() throws Throwable // log.info("testing EJB via business reference..."); assertiondelegate.assertadditionsucceeds(calclocalbusiness); A CalculatorUnitTestCase.java package org.jboss.ejb3.examples.ch04.firstejb; import junit.framework.testcase; import org.jboss.logging.logger; import org.junit.beforeclass; import org.junit.test; CalculatorEJB

15 <a / public class CalculatorUnitTestCase // // // / private static final Logger log = Logger.getLogger(CalculatorUnitTestCase.class); POJO / private static CalculatorCommonBusiness calc; // // // public static void beforeclass() // CalculatorCommonBusiness // POJO calc = new SimpleCalculatorBean(); // // // CalculatorEJB POJO public void testaddition() // final int[] arguments = new int[] 3, 7, 2; final int expectedsum = 12;

16 16 // final int actualsum = calc.add(arguments); // TestCase.assertEquals(" ", expectedsum, actualsum); // final StringBuffer sb = new StringBuffer(); sb.append("obtained expected result, "); sb.append(actualsum); sb.append(", from arguments: "); for (final int arg : arguments) sb.append(arg); sb.append(" "); log.info(sb.tostring()); A MultiViewCalculatorIntegrationTestCase.java package org.jboss.ejb3.examples.ch04.firstejb; import java.net.malformedurlexception; import javax.naming.context; import javax.naming.initialcontext; import org.jboss.arquillian.api.deployment; import org.jboss.arquillian.junit.arquillian; import org.jboss.logging.logger; import org.jboss.shrinkwrap.api.shrinkwrap; import org.jboss.shrinkwrap.api.spec.javaarchive; import org.junit.beforeclass; import org.junit.test; import org.junit.runner.runwith; <a href="mailto:andrew.rubinger@jboss.org">alr</a> public class MultiViewCalculatorIntegrationTestCase //

17 17 // // / private static final Logger log = Logger.getLogger(MultiViewCalculatorIntegrationTestCase.class); JNDI / private static Context namingcontext; CalculatorEJB EJB 3.x / private static CalculatorLocalBusiness calclocalbusiness; CalculatorEJB EJB 2.x / private static CalculatorLocal calclocal; Calculator / private static CalculatorAssertionDelegate assertiondelegate; JNDI / // JNDI private static final String JNDI_NAME_CALC_LOCAL_BUSINESS = ManyViewCalculatorBean.class. getsimplename() + "Local"; JNDI / // JNDI private static final String JNDI_NAME_CALC_REMOTE_HOME = ManyViewCalculatorBean.class. getsimplename() + "LocalHome";

18 18 public static JavaArchive createdeployment() throws MalformedURLException final JavaArchive archive = ShrinkWrap.create("firstejb.jar", JavaArchive.class).addPackage( CalculatorBeanBase.class.getPackage()); log.info(archive.tostring(true)); return archive; // // // public static void beforeclass() throws Throwable // CP jndi.properties namingcontext = new InitialContext(); // EJB 3.x calclocalbusiness = (CalculatorLocalBusiness) namingcontext.lookup(jndi_name_calc_local_business); // assertiondelegate = new CalculatorAssertionDelegate(); // EJB 2.x final Object calclocalhomereference = namingcontext.lookup(jndi_name_calc_remote_home); final CalculatorLocalHome calcremotehome = (CalculatorLocalHome) calclocalhomereference; calclocal = calcremotehome.create(); // // // EJB 3.x CalculatorEJB public void testadditionusingbusinessreference() throws Throwable //

19 19 log.info("testing remote business reference..."); assertiondelegate.assertadditionsucceeds(calclocalbusiness); EJB 2.x CalculatorEJB public void testadditionusingcomponentreference() throws Throwable // log.info("testing remote component reference..."); assertiondelegate.assertadditionsucceeds(calclocal); A jndi.properties # OpenEJB JNDI java.naming.factory.initial=org.apache.openejb.client.localinitialcontextfactory

20

21 21 B EJB B.1 Bean SLSB / SLSB XML B encryption/ B.3 B.3.1 B EncryptionBean.java package org.jboss.ejb3.examples.ch05.encryption; import java.io.unsupportedencodingexception; import java.security.messagedigest; import java.security.nosuchalgorithmexception; import java.security.spec.algorithmparameterspec; import java.security.spec.keyspec; import javax.annotation.postconstruct;

22 22 import javax.annotation.resource; import javax.crypto.cipher; import javax.crypto.secretkey; import javax.crypto.secretkeyfactory; import javax.crypto.spec.pbekeyspec; import javax.crypto.spec.pbeparameterspec; import javax.ejb.local; import javax.ejb.remote; import javax.ejb.sessioncontext; import javax.ejb.stateless; import org.apache.commons.codec.binary.base64; import org.jboss.logging.logger; EncryptionEJB <a href="mailto:alr@jboss.org">alr</a> public class EncryptionBean implements EncryptionLocalBusiness, EncryptionRemote Business // // // / private static final Logger log = Logger.getLogger(EncryptionBean.class); EJB META-INF/ejb-jar.xml / static final String EJB_NAME = "EncryptionEJB"; ejb-jar.xml

23 23 / private static final String ENV_ENTRY_NAME_CIPHERS_PASSPHRASE = "cipherspassphrase"; ejb-jar.xml / private static final String ENV_ENTRY_NAME_MESSAGE_DIGEST_ALGORITHM = "messagedigestalgorithm"; / private static final String DEFAULT_ALGORITHM_MESSAGE_DIGEST = "MD5"; / / private static final String CHARSET = "UTF-8"; / private static final String DEFAULT_ALGORITHM_CIPHER = "PBEWithMD5AndDES"; / / private static final String DEFAULT_PASSPHRASE = "LocalTestingPassphrase"; / / private static final byte[] DEFAULT_SALT_CIPHERS = (byte) 0xB4, (byte) 0xA2, (byte) 0x43, (byte) 0x89, 0x3E, (byte) 0xC5, (byte)0x78, (byte) 0x53; / / private static final int DEFAULT_ITERATION_COUNT_CIPHERS = 20; // // // /

24 24 API / EJB EJB private SessionContext context; SessionContext.lookup / private String cipherspassphrase; env-entry = ENV_ENTRY_NAME_MESSAGE_DIGEST_ALGORITHM) private String messagedigestalgorithm; / private MessageDigest messagedigest; / private Cipher encryptioncipher; / private Cipher decryptioncipher; // // //

25 Exception public void initialize() throws Exception // log.info(" " + PostConstruct.class.getName() + " "); / / // final String cipheralgorithm = DEFAULT_ALGORITHM_CIPHER; final byte[] cipherssalt = DEFAULT_SALT_CIPHERS; final int ciphersiterationcount = DEFAULT_ITERATION_COUNT_CIPHERS; final String cipherspassphrase = this.getcipherspassphrase(); // final KeySpec cipherskeyspec = new PBEKeySpec(ciphersPassphrase.toCharArray(), cipherssalt, ciphersiterationcount); final SecretKey cipherskey = SecretKeyFactory.getInstance(cipherAlgorithm). generatesecret(cipherskeyspec); final AlgorithmParameterSpec paramspec = new PBEParameterSpec(ciphersSalt, ciphersiterationcount); // this.encryptioncipher = Cipher.getInstance(ciphersKey.getAlgorithm()); this.decryptioncipher = Cipher.getInstance(ciphersKey.getAlgorithm()); encryptioncipher.init(cipher.encrypt_mode, cipherskey, paramspec); decryptioncipher.init(cipher.decrypt_mode, cipherskey, paramspec); // log.info("initialized encryption cipher: " + this.encryptioncipher); log.info("initialized decryption cipher: " + this.decryptioncipher); / / // final String messagedigestalgorithm = this.getmessagedigestalgorithm(); // try

26 26 this.messagedigest = MessageDigest.getInstance(messageDigestAlgorithm); catch (NoSuchAlgorithmException e) throw new RuntimeException("Could not obtain the " + MessageDigest.class.getSimpleName() + " for algorithm: " + messagedigestalgorithm, e); log.info("initialized MessageDigest for one-way hashing: " + this.messagedigest); // // org.jboss.ejb3.examples.ch05.encryption.encryptioncommonbusiness#compare(java.lang.string, java.lang.string) public boolean compare(final String hash, final String input) throws IllegalArgumentException, EncryptionException // if (hash == null) throw new IllegalArgumentException("hash is required."); if (input == null) throw new IllegalArgumentException("Input is required."); // final String hashofinput = this.hash(input); // final boolean equal = hash.equals(hashofinput); // return

27 org.jboss.ejb3.examples.ch05.encryption.encryptioncommonbusiness#decrypt(java.lang.string) public String decrypt(final String input) throws IllegalArgumentException, IllegalStateException, EncryptionException // final Cipher cipher = this.decryptioncipher; if (cipher == null) throw new IllegalStateException("Decryption cipher not available, has this service been initialized?"); // byte[] resultbytes = null;; try final byte[] inputbytes = this.stringtobytearray(input); resultbytes = cipher.dofinal(base64.decodebase64(inputbytes)); catch (final Throwable t) throw new EncryptionException("Error in decryption", t); final String result = this.bytearraytostring(resultbytes); // log.info("decryption on "" + input + " ": " + result); // org.jboss.ejb3.examples.ch05.encryption.encryptioncommonbusiness#encrypt(java.lang.string) public String encrypt(final String input) throws IllegalArgumentException, EncryptionException // final Cipher cipher = this.encryptioncipher; if (cipher == null) throw new IllegalStateException("Encryption cipher not available, has this service been initialized?");

28 28 // byte[] inputbytes = this.stringtobytearray(input); // byte[] resultbytes = null; try resultbytes = Base64.encodeBase64(cipher.doFinal(inputBytes)); catch (final Throwable t) throw new EncryptionException("Error in encryption of: " + input, t); // log.info("encryption on "" + input + " ": " + this.bytearraytostring(resultbytes)); // final String result = this.bytearraytostring(resultbytes); return result; 1 2 N / / org.jboss.ejb3.examples.ch05.encryption.encryptioncommonbusiness#hash(java.lang.string) public String hash(final String input) throws IllegalArgumentException, EncryptionException // if (input == null) throw new IllegalArgumentException("Input is required."); //

29 29 byte[] inputbytes = this.stringtobytearray(input); // final MessageDigest digest = this.messagedigest; // digest.update(inputbytes, 0, inputbytes.length); final byte[] hashbytes = digest.digest(); final byte[] encodedbytes = Base64.encodeBase64(hashBytes); // final String hash = this.bytearraytostring(encodedbytes); log.info("one-way hash of "" + input + " ": " + hash); // return hash; env-entry org.jboss.ejb3.examples.ch05.encryption.encryptionbeanbase#getcipherspassphrase() public String getcipherspassphrase() // String passphrase = this.cipherspassphrase; // if (passphrase == null) // SessionContext passphrase = this.getenvironmententryasstring(env_entry_name_ciphers_passphrase);

30 30 // if (passphrase == null) // log.warn("no encryption passphrase has been supplied explicitly via " + "an env-entry, falling back on the default..."); // passphrase = DEFAULT_PASSPHRASE; // this.cipherspassphrase = passphrase; // log.info("using encryption passphrase for ciphers keys: " + passphrase); // return passphrase; ejb-jar.xml org.jboss.ejb3.examples.ch05.encryption.encryptionremotebusiness#getmessagedigestalgorithm() public String getmessagedigestalgorithm() // / if (this.messagedigestalgorithm == null) // log.warn("no message digest algorithm has been supplied explicitly via " + "an env-entry, falling back on the default..."); // this.messagedigestalgorithm = DEFAULT_ALGORITHM_MESSAGE_DIGEST; //

31 31 log.info("configured MessageDigest one-way hash algorithm is: " + this.messagedigestalgorithm); // return this.messagedigestalgorithm; // // // IllegalStateException enventryname IllegalStateException / private String getenvironmententryasstring(final String enventryname) throws IllegalStateException // SessionContext final SessionContext context = this.context; if (context == null) log.warn("no SessionContext, bypassing request to obtain environment entry: " + enventryname); return null; // SessionContext JNDI ENC Object lookupvalue = null; try lookupvalue = context.lookup(enventryname); log.debug(" " + enventryname + " " + lookupvalue); catch (final IllegalArgumentException iae) // EJB // null log.warn(" " + enventryname); return null;

32 32 // String returnvalue = null; try returnvalue = String.class.cast(lookupValue); catch (final ClassCastException cce) throw new IllegalStateException(" " + lookupvalue + " " + String.class.getName() + " ", cce); // return @throws IllegalArgumentException / private String bytearraytostring(final byte[] bytes) throws RuntimeException, IllegalArgumentException // if (bytes == null) throw new IllegalArgumentException("Byte array is required."); // String result = null; final String charset = this.getcharset(); try result = new String(bytes, charset); catch (final UnsupportedEncodingException e)

33 33 throw new RuntimeException("Specified charset is invalid: " + charset, e); // return @throws IllegalArgumentException null / private byte[] stringtobytearray(final String input) throws RuntimeException, IllegalArgumentException // if (input == null) throw new IllegalArgumentException("Input is required."); // byte[] result = null; final String charset = this.getcharset(); try result = input.getbytes(charset); catch (final UnsupportedEncodingException e) throw new RuntimeException("Specified charset is invalid: " + charset, e); // return result; /

34 / private String getcharset() return CHARSET; B EncryptionCommonBusiness.java package org.jboss.ejb3.examples.ch05.encryption; <a href="mailto:alr@jboss.org">alr</a> / public interface EncryptionCommonBusiness // // // input IllegalArgumentException EncryptionException / String encrypt(string input) throws IllegalArgumentException, @throws IllegalArgumentException EncryptionException / String decrypt(string input) throws IllegalArgumentException, EncryptionException;

35 @throws IllegalArgumentException EncryptionException / String hash(string input) throws IllegalArgumentException, @throws IllegalArgumentException EncryptionException / boolean compare(string hash, String input) throws IllegalArgumentException, EncryptionException; / / / String /

36 36 String getmessagedigestalgorithm(); B EncryptionException.java package org.jboss.ejb3.examples.ch05.encryption; import <a // Exception // public class EncryptionException extends Exception // // // JVM / private static final long serialversionuid = 1L; // // // / / public EncryptionException() super(); public EncryptionException(String message, Throwable cause) super(message, cause);

37 37 public EncryptionException(String message) super(message); public EncryptionException(Throwable cause) super(cause); B EncryptionLocalBusiness.java package org.jboss.ejb3.examples.ch05.encryption; EncryptionEJB EJB <a / public interface EncryptionLocalBusiness extends EncryptionCommonBusiness // B EncryptionRemoteBusiness.java package org.jboss.ejb3.examples.ch05.encryption; EncryptionEJB EJB <a / public interface EncryptionRemoteBusiness extends EncryptionCommonBusiness // B META-INF/ejb-jar.xml <ejb-jar xmlns=" xmlns:xsi=" xsi:schemalocation=" version="3.1"> <enterprise-beans>

38 38 <!-- EncryptionEJB --> <session> <!-- --> <ejb-name>encryptionejb</ejb-name> <!-- --> <env-entry> <env-entry-name>cipherspassphrase</env-entry-name> <env-entry-type>java.lang.string</env-entry-type> <env-entry-value>overriddenpassword</env-entry-value> </env-entry> <!-- --> <env-entry> <env-entry-name>messagedigestalgorithm</env-entry-name> <env-entry-type>java.lang.string</env-entry-type> <env-entry-value>sha</env-entry-value> </env-entry> </session> </enterprise-beans> </ejb-jar> B.3.2 B EncryptionIntegrationTestCase.java package org.jboss.ejb3.examples.ch05.encryption; import java.net.malformedurlexception; import java.net.url; import javax.ejb.ejb; import junit.framework.testcase; import org.jboss.arquillian.api.deployment; import org.jboss.arquillian.junit.arquillian; import org.jboss.logging.logger; import org.jboss.shrinkwrap.api.shrinkwrap; import org.jboss.shrinkwrap.api.spec.javaarchive;

39 39 import org.junit.test; import org.junit.runner.runwith; <a public class EncryptionIntegrationTestCase extends EncryptionTestCaseSupport // // // / private static final Logger log = Logger.getLogger(EncryptionIntegrationTestCase.class); EncryptionEJB EJB 3.x private static EncryptionLocalBusiness encryptionlocalbusiness; ejb-jar.xml env-entry / private static final String EXPECTED_CIPHERS_PASSPHRASE = "OverriddenPassword"; ejb-jar.xml env-entry / private static final String EXPECTED_ALGORITHM_MESSAGE_DIGEST = "SHA"; public static JavaArchive createdeployment() throws MalformedURLException final JavaArchive archive = ShrinkWrap.create("slsb.jar", JavaArchive.class). addclasses(encryptionbean.class, EncryptionCommonBusiness.class, EncryptionLocalBusiness.class, EncryptionRemoteBusiness.class, EncryptionException.class).addManifestResource(new URL(Encryption IntegrationTestCase.class.getProtectionDomain().getCodeSource().getLocation(), "../classes/meta-

40 40 INF/ejb-jar.xml"), "ejb-jar.xml"); // SHRINKWRAP-141 ejb-jar log.info(archive.tostring(true)); return archive; // // // / EncryptionTestCaseSupport#assertHashing(EncryptionCommonBusiness) public void testhashing() throws Throwable // log.info("testhashing"); EncryptionTestCaseSupport#assertEncryption(EncryptionCommonBusiness) public void testencryption() throws Throwable // log.info("testencryption"); // this.assertencryption(encryptionlocalbusiness); Throwable /

41 public void testmessagedigestalgorithmoverride() throws Throwable // log.info("testmessagedigestalgorithmoverride"); // final String algorithm = encryptionlocalbusiness.getmessagedigestalgorithm(); log.info("using MessageDigest algorithm: " + algorithm); // TestCase.assertEquals("MessageDigest algorithm should have been overridden from the environment entry", EXPECTED_ALGORITHM_MESSAGE_DIGEST, algorithm); Throwable public void testcipherspassphraseoverride() throws Throwable // log.info("testcipherspassphraseoverride"); // final String passphrase = encryptionlocalbusiness.getcipherspassphrase(); log.info("using Encryption passphrase: " + passphrase); // TestCase.assertEquals("Encryption passphrase should have been overridden from the environment entry", EXPECTED_CIPHERS_PASSPHRASE, passphrase); B EncryptionTestCaseSupport.java package org.jboss.ejb3.examples.ch05.encryption; import junit.framework.testcase; import org.jboss.logging.logger; Encryption POJO EncryptionEJB

42 <a / public class EncryptionTestCaseSupport // // // / private static final Logger log = Logger.getLogger(EncryptionTestCaseSupport.class); / private static final String TEST_STRING = "EJB 3.1 Examples Test String"; // // // service POJO Throwable / protected void asserthashing(final EncryptionCommonBusiness service) throws Throwable // log.info("asserthashing"); // final String input = TEST_STRING; // final String hash = service.hash(input); log.info(" " + input + " " + hash); //

43 43 TestCase.assertNotSame("The hash function had no effect upon the supplied input", input, hash); // final boolean equal = service.compare(hash, input); // TestCase.assertTrue("The comparison of the input to its hashed result failed", equal); 1 POJO Throwable / protected void assertencryption(final EncryptionCommonBusiness service) throws Throwable // log.info("assertencryption"); // final String input = TEST_STRING; // final String encrypted = service.encrypt(input); log.info("encrypted result of "" + input + " ": " + encrypted); // TestCase.assertNotSame("The encryption function had no effect upon the supplied input", input, encrypted); // final String roundtrip = service.decrypt(encrypted); // TestCase.assertEquals("The comparison of the input to its encrypted result failed", input, roundtrip);

44 44 B EncryptionUnitTestCase.java package org.jboss.ejb3.examples.ch05.encryption; import org.jboss.logging.logger; import org.junit.beforeclass; import org.junit.test; <a / public class EncryptionUnitTestCase extends EncryptionTestCaseSupport // // // / private static final Logger log = Logger.getLogger(EncryptionUnitTestCase.class); POJO / private static EncryptionBean encryptionservice; // // // public static void initialize() throws Throwable // POJO encryptionservice = new EncryptionBean(); encryptionservice.initialize(); // //

45 45 // // / EncryptionTestCaseSupport#assertHashing(EncryptionCommonBusiness) public void testhashing() throws Throwable // log.info("testhashing"); EncryptionTestCaseSupport#assertEncryption(EncryptionCommonBusiness) public void testencryption() throws Throwable // log.info("testencryption"); // this.assertencryption(encryptionservice);

46

47 47 C EJB FTP C.1 FTP Bean FTP RAM SFSB / C filetransfer/ C.3 C.3.1 C FileTransferBean.java package org.jboss.ejb3.examples.ch06.filetransfer; import java.io.ioexception; import java.io.serializable; import javax.annotation.postconstruct; import javax.annotation.predestroy;

48 48 import javax.ejb.postactivate; import javax.ejb.prepassivate; import javax.ejb.remote; import javax.ejb.remove; import javax.ejb.stateful; import org.apache.commons.net.ftp.ftpclient; import org.apache.commons.net.ftp.ftpfile; import org.apache.commons.net.ftp.ftpreply; import org.jboss.logging.logger; Bean FileTransferEJB <a = public class FileTransferBean implements FileTransferRemoteBusiness, Serializable // UID / private static final long serialversionuid = 1L; / private static final Logger log = Logger.getLogger(FileTransferBean.class); JNDI EJB / public static final String EJB_NAME = "FileTransferEJB"; / private static String CONNECT_HOST = "localhost";

49 49 FTP IANA 21 nix / private static int CONNECT_PORT = 12345; // FTP / private FTPClient client; / private String presentworkingdirectory; // // org.jboss.ejb3.examples.ch06.filetransfer.filetransfercommonbusiness# @Override public void disconnect() // FTP final FTPClient client = this.getclient(); //

50 50 if (client!= null) // if (client.isconnected()) // try client.logout(); log.info("logged out of: " + client); catch (final IOException ioe) log.warn("exception encountered in logging out of the FTP client", ioe); // try log.debug("disconnecting: " + client); client.disconnect(); log.info("disconnected: " + client); catch (final IOException ioe) log.warn("exception encountered in disconnecting the FTP client", ioe); // null this.client = null; @Override public void connect() throws IllegalStateException, FileTransferException

51 51 / / final FTPClient clientbefore = this.getclient(); if (clientbefore!= null && clientbefore.isconnected()) throw new IllegalStateException("FTP "); // final String connecthost = this.getconnecthost(); final int connectport = this.getconnectport(); // final FTPClient client = new FTPClient(); final String canonicalservername = connecthost + ":" + connectport; log.debug("connecting to FTP Server at " + canonicalservername); try client.connect(connecthost, connectport); catch (final IOException ioe) throw new FileTransferException("Error in connecting to " + canonicalservername, ioe); // log.info("connected to FTP Server at: " + canonicalservername); this.setclient(client); // this.checklastoperation(); try // client.login("user", "password"); // this.checklastoperation(); catch (final Exception e) throw new FileTransferException("Could not log in", e); // pwd cd

52 52 final String pwd = this.getpresentworkingdirectory(); if (pwd!= null) this.cd(pwd); // // // / org.jboss.ejb3.examples.ch06.filetransfer.filetransfercommonbusiness#cd(java.lang.string) public void cd(final String directory) // final FTPClient client = this.getclient(); // cd try // cd client.changeworkingdirectory(directory); e); // this.checklastoperation(); catch (final Exception e) throw new FileTransferException("Could not change working directory to "" + directory + " "", // pwd log.info("cd > " + directory); this.setpresentworkingdirectory(directory); / org.jboss.ejb3.examples.ch06.filetransfer.filetransfercommonbusiness#mkdir(java.lang.string) public void mkdir(final String directory)

53 53 // final FTPClient client = this.getclient(); // cd try // mkdir client.makedirectory(directory); // this.checklastoperation(); catch (final Exception e) throw new FileTransferException("Could not make directory "" + directory + " "", e); / org.jboss.ejb3.examples.ch06.filetransfer.filetransfercommonbusiness#pwd() public String pwd() // final FTPClient client = this.getclient(); // pwd try final FTPFile[] files = client.listfiles(); for (final FTPFile file : files) log.info(file); // pwd return client.printworkingdirectory(); catch (final IOException ioe) throw new FileTransferException("Could not print working directory", ioe);

54 54 // // FileTransferException / protected void checklastoperation() throws FileTransferException // final FTPClient client = this.getclient(); // final int connectreply = client.getreplycode(); if (!FTPReply.isPositiveCompletion(connectReply)) // throw new FileTransferException("Did not receive positive completion code from server, instead code was: " + connectreply); / public void endsession() log.info("session Ending..."); // / connecthost / public String getconnecthost() return CONNECT_HOST;

55 connectport / public int getconnectport() return client / protected final FTPClient getclient() return client / private void setclient(final FTPClient client) this.client = presentworkingdirectory / private String getpresentworkingdirectory() return presentworkingdirectory presentworkingdirectory / private void setpresentworkingdirectory(string presentworkingdirectory) this.presentworkingdirectory = presentworkingdirectory;

56 56 C FileTransferCommonBusiness.java package org.jboss.ejb3.examples.ch06.filetransfer; <a / public interface FileTransferCommonBusiness // // // IllegalStateException / void mkdir(string directory) throws IllegalStateException / void cd(string directory) IllegalStateException / String pwd() throws IllegalStateException; /

57 57 / void disconnect(); IllegalStateException / / void connect() throws IllegalStateException; C FileTransferException.java package <a href="mailto:andrew.rubinger@jboss.org">alr</a> / public class FileTransferException extends RuntimeException // private static final long serialversionuid = 1L; // public FileTransferException() super(); public FileTransferException(final String message, final Throwable cause) super(message, cause); public FileTransferException(final String message)

58 58 super(message); public FileTransferException(final Throwable cause) super(cause); C FileTransferRemoteBusiness.java package org.jboss.ejb3.examples.ch06.filetransfer; import javax.ejb.remove; FileTransferEJB <a / public interface FileTransferRemoteBusiness extends FileTransferCommonBusiness // // // javax.ejb.remove / void endsession(); C.3.2 C FileTransferIntegrationTestCase.java package org.jboss.ejb3.examples.ch06.filetransfer; import java.io.file; import javax.ejb.ejb; import javax.ejb.nosuchejbexception;

59 59 import junit.framework.testcase; import org.jboss.arquillian.api.deployment; import org.jboss.arquillian.junit.arquillian; import org.jboss.logging.logger; import org.jboss.shrinkwrap.api.shrinkwrap; import org.jboss.shrinkwrap.api.spec.javaarchive; import org.junit.after; import org.junit.afterclass; import org.junit.beforeclass; import org.junit.test; import org.junit.runner.runwith; FileTransferEJB EJB FileTransferTestCaseBase <a public class FileTransferIntegrationTestCase extends FileTransferTestCaseBase // / private static final Logger log = Logger.getLogger(FileTransferIntegrationTestCase.class); FTP / private static final String FTP_SERVER_USERS_CONFIG_FILENAME = "ftpusers.properties"; FTP / private static final int FTP_SERVER_BIND_PORT = 12345;

60 60 FTP / private static FtpServerPojo public static JavaArchive createdeployment() final JavaArchive archive = ShrinkWrap.create("ftpclient.jar", JavaArchive.class). addpackage(filetransferbean.class.getpackage()); log.info(archive.tostring(true)); return archive; // EJB private FileTransferRemoteBusiness client1; FTP private FileTransferRemoteBusiness client2; // // // FTP public static void startftpserver() throws Exception // final FtpServerPojo server = new FtpServerPojo();

61 61 // server.setusersconfigfilename(ftp_server_users_config_filename); server.setbindport(ftp_server_bind_port); // server.initializeserver(); server.startserver(); ftpserver = server; Exception public static void stopftpserver() throws Exception ftpserver.stopserver(); FTP SFSB public void endclientsessions() throws Exception // 1 try client1.endsession(); // catch (final NoSuchEJBException nsee) // // 2 try client2.endsession(); // catch (final NoSuchEJBException nsee)

62 62 // // Exception public void testsessionisolation() throws Exception // log.info("testsessionisolation"); // final FileTransferRemoteBusiness session1 = this.getclient(); // final FileTransferRemoteBusiness session2 = this.client2; // final String ftphome = getftphome().getabsolutepath(); session1.cd(ftphome); session2.cd(ftphome); // final String newdirsession1 = "newdirsession1"; final String newdirsession2 = "newdirsession2"; session1.mkdir(newdirsession1); session1.cd(newdirsession1); session2.mkdir(newdirsession2); session2.cd(newdirsession2); // final String pwdsession1 = session1.pwd(); final String pwdsession2 = session2.pwd(); // TestCase.assertEquals(" 1 pwd ", ftphome + File.separator + newdirsession1, pwdsession1); TestCase.assertEquals(" 2 pwd ", ftphome + File.separator + newdirsession2, pwdsession2);

63 63 // 2 1 FileTransferRemoteBusiness#endSession() Exception public void testsfsbremoval() throws Exception // log.info("testsfsbremoval"); // final FileTransferRemoteBusiness sfsb = this.getclient(); // final String ftphome = getftphome().getabsolutepath(); sfsb.cd(ftphome); // pwd final String pwdbefore = sfsb.pwd(); TestCase.assertEquals(" FTP ", // Bean sfsb.endsession(); // NoSuchEJBException boolean gotexpectedexception = false; try sfsb.pwd(); catch (final NoSuchEJBException nsee) gotexpectedexception = true; TestCase.assertTrue(" SFSB Bean ", gotexpectedexception);

64 64 // / org.jboss.ejb3.examples.ch06.filetransfer.filetransfertestcasebase#getclient() protected FileTransferRemoteBusiness getclient() return this.client1; C FileTransferTestCaseBase.java package org.jboss.ejb3.examples.ch06.filetransfer; import java.io.file; import junit.framework.testcase; import org.jboss.logging.logger; import org.junit.after; import org.junit.before; import <a href="mailto:andrew.rubinger@jboss.org">alr</a> / public abstract class FileTransferTestCaseBase // / private static final Logger log = Logger.getLogger(FileTransferTestCaseBase.class);