public static Set findAllBusinessUnits() 
throws RepositoryException { 
Set businessUnits = new HashSet(); 
try { 
FileReader businessUnitFile = null; 
BufferedReader bufferedBusinessUnitFile = null; 
try { 
businessUnitFile = new FileReader(FILE_NAME); 
bufferedBusinessUnitFile = 
new BufferedReader(businessUnitFile); 
String businessUnitRecord; 
while((businessUnitRecord =
bufferedBusinessUnitFile.readLine()) != null)
{ 
BusinessUnit businessUnit = BusinessUnitFactory.
createBusinessUnit(businessUnitRecord); 
businessUnits。add(businessUnit); 
} 
} finally 
{ 
if(bufferedBusinessUnitFile != null) 
{ 
bufferedBusinessUnitFile。close(); 
} 
if(businessUnitFile != null)
{ 
businessUnitFile。close(); 
} 
} 
} catch(IOException ioe) 
{ 
String message = 
"IOError. Unable to find Business Unit records"; 
logger.log(SEVERE， message， ioe); 
throw new RepositoryException(message， ioe); 
} 

logger。log(INFO，
"Manager Records returned:" 
+ businessUnits.size()); 
return businessUnits; 
}

public class EmployeeRepository 
{ 

public static void createEmployee
(Employee employee) 
throws RepositoryException 
{ 
//使用print writer把数据放入csv文件 
} 

public static String 
findEmployeeRecordById(String id) 
throws RepositoryException 
{ 
//使用file reader来获得指定id的员工数据 
} 

public static Employee 
findEmployeeById(String id) 
throws RepositoryException 
{ 
//使用该方法获取员工数据，
Employee对象由工厂类创建 
} 

public static void 
updateEmployee(Employee employee) 
{ 
//更新员工数据 
} 
}

public Employee 
createEmployee(String name， 
String contactNumber， 
BusinessUnit businessUnit， 
Manager manager) 
throws EmployeeServiceException 
{ 
String id = createNewEmployeeId(); 
Employee employee = 
EmployeeFactory。createEmployee
(id， name， contactNumber，
businessUnit， manager); 
try { 
EmployeeRepository.createEmployee(employee); 
} catch(RepositoryException re) 
{ 
String message = 
"Created employee successfully:" 
+ employee; 
logger。log(SEVERE， message); 
throw new EmployeeServiceException
(message， re); 
} 
logger。log(INFO， 
"Created employee successfully:"
+ employee); 
return employee; 
}

@Aspect("perJVM") 
public class BufferedFileReaderAspect 
{ 

@Expression("execution
(* org.javatechnocrats.aop.withaop.
aspects.BusinessUnitPersistenceAspect.find*(..))") 
Pointcut businessUnitPersistenceAspect; 

// 其他"切入点"定义 

@Expression("businessUnitPersistenceAspect || 
employeePersistenceAspect || 
managerPersistenceAspect") 
Pointcut allPersistencePointcuts; 

private Map<Class， String> fileNames; 

public BufferedFileReaderAspect() 
{ 
System.out.println
("BufferedFileReaderAspect created"); 
fileNames = new HashMap<Class， String>(); 
fillFileNames(); 
} 

@Before("allPersistencePointcuts") 
public void assignReader
(JoinPoint joinPoint) 
throws Throwable 
{ 
System。out。println
("assignReader advice called"); 
Object callee = 
joinPoint.getCallee(); 
IBufferedFileReaderConsumable
bufReaderConsumable =
(IBufferedFileReaderConsumable)callee; 
Class persistenceClass = 
callee.getClass(); 
String fileName = 
fileNames.get(persistenceClass); 
FileReader fileReader = 
new FileReader(fileName); 
BufferedReader bufferedReader =
new BufferedReader(fileReader); 
bufReaderConsumable.
setBufferedReader(bufferedReader); 
} 

@AfterFinally("allPersistencePointcuts") 
public void releaseReader
(JoinPoint joinPoint) throws Throwable 
{ 
//释放buffered reader等资源 
} 
//其他方法 
}

@Aspect("perJVM") 
public class
BusinessUnitPersistenceAspect 
implements IBufferedFileReaderConsumable
{ 

private BufferedReader buffFileReader; 

@Before("execution
(Collection org.javatechnocrats.aop.withaop.
BusinessUnitService.findAllBusinessUnits())") 
public void findAllBusinessUnits
(JoinPoint joinPoint)
throws Throwable 
{ 
System.out.println
("findAllBusinessUnits advice called"); 
Map<String， BusinessUnit> businessUnits = 
((BusinessUnitService)joinPoint.
getThis()).getBusinessUnits(); 
String businessUnitRecord; 
while((businessUnitRecord =
buffFileReader。readLine()) != null) 
{ 
BusinessUnit businessUnit = BusinessUnitFactory.
createBusinessUnit(businessUnitRecord); 
businessUnits.put
(businessUnit.getId()， businessUnit); 
} 
} 

public void setBufferedReader
(BufferedReader buffFileReader) 
{ 
System.out.println
("BusinessUnitPersistenceAspect.
setBufferedReader called"); 
this.buffFileReader = buffFileReader; 
} 

public BufferedReader getBufferedReader() 
{ 
System.out.println
("BusinessUnitPersistenceAspect.
getBufferedReader called"); 
return this.buffFileReader; 
} 
}

@Aspect("perJVM") 
public class LoggingAspect 
{ 

@Around("execution(
String org.javatechnocrats.aop.
withaop..*.toString())") 
public Object toStringAdvice
(JoinPoint joinPoint)
throws Throwable 
{ 
System.out.println
("toStringAdvice called"); 
String toString = 
(String)joinPoint.proceed(); 
Object target = joinPoint.getThis(); 
Field fields[] = 
target.getClass().getDeclaredFields(); 
List members = 
new ArrayList(fields.length + 1); 
members.add(toString); 
for(Field field : fields) 
{ 
field.setAccessible(true); 
Object member = field.get(target); 
members.add(field.getName() 
+ "=" + member); 
} 
return members。toString(); 
}

set JAVA_HOME=c:\Program Files\Java\jdk1.5.0
set ASPECTWERKZ_HOME=C:\aw_2_0_2
set PATH=%PATH%;%ASPECTWERKZ_HOME%\bin
set CLASSPATH=
C:\aw_2_0_2\lib\aspectwerkz-2.0.RC2.jar;
C:\aw_2_0_2\lib\aspectwerkz-jdk5-2.0.RC2.jar;
classes;
C:\ junit\3.8.1\resources\lib\junit.jar

%ASPECTWERKZ_HOME%\bin\aspectwerkz 
-offline etc/aop。xml -cp classes classes

set JAVA_HOME=c:\Program Files\Java\jdk1.5.0
set ASPECTWERKZ_HOME=C:\aw_2_0_2
set PATH=%PATH%;
%ASPECTWERKZ_HOME%\bin
set CLASSPATH=
C:\aw_2_0_2\lib\aspectwerkz-2.0.RC2.jar;
C:\aw_2_0_2\lib\aspectwerkz-jdk5-2.0.RC2.jar; 
classes;
C:\ junit\3.8.1\resources\lib\junit.jar

%ASPECTWERKZ_HOME%\bin\aspectwerkz
-offline etc/aop。xml -cp classes classes