使用WebSphere Adapter Toolkit开发符合J2EE标准的资源适配器: 第3部分

FTP Server(EIS) -> Exporting -> WebSphere FTP Adapter -> Email Server

	// This will be called while initializing the Inbound 
public void endpointActivation(MessageEndpointFactory arg0,
			ActivationSpec arg1) throws ResourceException {
	super.endpointActivation(arg0, arg1);
	System.out.println("ResourceAdapter -> endpointActivation()");
	spec = (J2CA_ftpActivationSpec)arg1;
	eventManager.setSpec(spec);
	if(spec==null) System.out.println("ResourceAdapter -> endpointActivation() -> spec==null");
	else System.out.println("ResourceAdapter -> endpointActivation() -> spec!=null");
	eventManager.addEndpointFactory(arg0,arg1);
	}
 // This will be called while stopping the Inbound
 public void endpointDeactivation(MessageEndpointFactory arg0,
			ActivationSpec arg1) {
		super.endpointDeactivation(arg0, arg1);
		if(eventManager.getEISconnection().getAftp()!=null)
			eventManager.getEISconnection().stop(null);
		eventManager.removeEndpointFactory(arg0);
}
// This will be called while initializing the Inbound
 public com.ibm.j2ca.extension.eventmanagement.EventStore createEventStore(
			javax.resource.spi.ActivationSpec arg0)
			throws javax.resource.ResourceException {
		System.out.println("ResourceAdapter -> createEventStore()");
		J2CA_ftpEventStore event = new J2CA_ftpEventStore();
		return event;
	}
// This will be called while initializing the Inbound 
public EventManager createEventManager() {
		System.out.println("ResourceAdapter -> createEventManager()");
		eventManager = new J2CA_ftpEventManager(getLogUtils());
		eventManager.setSpec(spec);
		return eventManager;
	}
	

			J2CA_ftpActivationSpec spec = null;
	J2CA_ftpManagedConnectionFactory mcf;
	J2CA_ftpManagedConnection mc;
	J2CA_ftpConnection EISconnection;
	BufferedReader read = null;
	BufferedWriter write = null;
	FileReader fr = null;
	FileWriter fw = null;
	ArrayList content = null;
	ArrayList filelist = null;
	File[] files = null;
	
// Connect to FTP server 
	public void connect()
	{
		if(spec!=null)
		for(int i=0;i<3;i++)
   	  	{
			System.out.println("Try: "+String.valueOf(i));
EISconnection.connect(spec.getLocal_dir(),spec.getFtp_ip(),Integer.parseInt(spec.getFtp_port()),
spec.getFtp_user(),spec.getFtp_passwd());
   	  		if(EISconnection.getAftp()!=null) break;
   	  		try {Thread.sleep(3000);} catch (InterruptedException e1) {}
   	  	}
		if(EISconnection.getAftp()!=null)
			try {
				EISconnection.setPath(spec.getRemote_dir());
			} catch (IOException e) {
				System.out.println("set FTP server path error!");
				EISconnection.stop(null);
			}
	}
// Construct Function 
public J2CA_ftpEventManager(com.ibm.j2ca.extension.logging.LogUtils arg0) {
		super(arg0);
		System.out.println("EventManager -> EventManager()");
		content = new ArrayList();
		filelist = new ArrayList();
		try {
			mcf = new J2CA_ftpManagedConnectionFactory();
			mc = new J2CA_ftpManagedConnection(mcf,null,null);
			EISconnection = new J2CA_ftpConnection(mc);
		} catch (ResourceException e) {
		System.out.println("EventManager -> Create EISconnection failed");
		}
	}
// This method is called periodically at runtime. 
public void pollForEvents(int arg0) throws ResourceException, CommException {
		System.out.println("EventManager -> Enter pollForEvents()");
		String filename = "", info = "" , infoInFile= "";
		int count = 0, k = 0, i = 0;
		File file = null;
		String message = "";
		while(content.size()>0) content.remove(0);
		while(filelist.size()>0) filelist.remove(0);
		
	// compare the local inbound directory and remote ftp server directory 
		try {
			if(EISconnection.getAftp()==null) connect();
			if(EISconnection.getAftp()==null) 
			{
			System.out.println("Can not connect to FTP Server!");
			System.out.println("EventManager -> Out pollForEvents()");
			return;
			}
		
	ArrayList array = EISconnection.getFileList();
	System.out.println("In FTP server: "+array.size()+" files");
			
	for(i=0; i<array.size(); i++)
	{
		count = 0;
		info = (String)array.get(i);
		System.out.println("File Info: "+info);
		for(k=0;k<info.length();k++)
		{
			if(info.charAt(k)==' ')
			{ 
				count++; 
				while(k<info.length() && info.charAt(k)==' ') 
						  k++; 
			}
			if(count==8) break;
	}
	filename = ((String)array.get(i)).substring(k);
	if(filename == null || filename.length()==0 ||
			filename.equals(".") || filename.equals("..")) continue;
				System.out.println("File: "+filename);
				
	//see if the filename already in the local directory 
	//note: just store filename, not file itself 
	file = new File(spec.getLocal_dir()+"/"+filename);
	if(file!=null && file.exists())
	{
		fr = new FileReader(file);
		read = new BufferedReader(fr);
		infoInFile = read.readLine();
		read.close(); fr.close();
		if(infoInFile!=null && infoInFile.equalsIgnoreCase(info))
		{ // ok, the file is not chaneged in FTP server 
					    ;
		} else { // the file is updated in FTP server 
		file.delete();
		file = new File(spec.getLocal_dir()+"/"+filename);
		fw = new FileWriter(file);
		write = new BufferedWriter(fw);
		write.write(info);
		write.close();
		fw.close();
		message = "File: " + filename +" is updated in FTP Server "
		     +spec.getFtp_ip()+ " at Directory " + spec.getRemote_dir()
			+ " with Property " + info;
		content.add(message);
		}
	           }
		else // new file found in FTP server FTP 
		{
		fw = new FileWriter(file);
		write = new BufferedWriter(fw);
		write.write(info);
		write.close();
		fw.close();
		message = "File: " + filename +" is created in FTP Server "
			+spec.getFtp_ip()+ " at Directory " + spec.getRemote_dir()
                             + " with Property " + info;
		content.add(message);
		}
		filelist.add(filename);
		}
	        // see whether files are deleted from FTP server 
		try {
			file = new File(spec.getLocal_dir());
		    	if(file!=null && file.isDirectory())
			    	files = file.listFiles();
			} catch(Exception ee)
			{
				files = null;
			}
			
			if(files!=null) // some files in the local directory 
			 for(i=0;i<files.length;i++)
			 {
				for(k=0;k<filelist.size();k++)
				{ 
					if(files[i].getName().equals((String)filelist.get(k)))
					{ break; } // ok, this file is still there 
				}
				if(k==filelist.size())
				{ // this file is deleted from FTP server 
			new File(spec.getLocal_dir()+"/"+files[i].getName()).delete();
			message = "File: " + files[i].getName() +" is deleted from FTP Server "
			+spec.getFtp_ip()+ " at Directory " + spec.getRemote_dir();
			        content.add(message);					
				}
			}
		} catch (IOException e) {
		System.out.println("EventManager -> pollForEvents() -> connect to FTP server error");
		e.printStackTrace();
		}
        
		// now log to system out
		message = "";
		for(i=0;i<content.size();i++)
		{
			System.out.println((String)content.get(i));
			message = message + (String)content.get(i) + "\n";
		}
		
		// now send email to notify admin 
		if(content.size()>0) sendEmail(message);
		
		System.out.println("EventManager -> Out pollForEvents()");
	}
	// Send Email to Admin Email Address 
	public void sendEmail(String message)
	{
		String host=spec.getEmailHost();
		String from=spec.getEmailSender()+"@"+spec.getFtp_ip(); 
		String to=spec.getEmail(); 
		String name=spec.getUserName(); 
		String pass=spec.getPassword();
		String subject="FTP Server "+spec.getFtp_ip()+" Notification"; 
		String contents=message; 
		MailAuthenticator ma; 
		System.out.println("host:"+host+" from:"+from+" to:"+to+" name:"+name+" pass:"+pass);
		System.out.println("begin send email");
		try{ 
		ma=new MailAuthenticator(name,pass); 
		Properties props=System.getProperties(); 
		props.put("mail.smtp.host",host); 
		props.put("mail.smtp.auth","true"); 
		Session session=Session.getInstance(props,ma);
		System.out.println("set properties finished");
		
		MimeMessage msg=new MimeMessage(session); 
		System.out.println("init msg");
		msg.setFrom(new InternetAddress(from)); 
		msg.setRecipient(Message.RecipientType.TO,new InternetAddress(to)); 
		msg.setSubject(subject); 
		msg.setText(contents); 
		System.out.println("set msg finished");
		
		Transport transport = session.getTransport("smtp"); 
		transport.connect();
		System.out.println("connected to email host");
		transport.sendMessage(msg, msg.getAllRecipients()); 
		transport.close(); 
		
		System.out.println("Send Email Success"); 
		}catch(Exception e){ 
		System.out.println(e.getMessage()); 
		e.printStackTrace();
		} 
	}
      // Getter and Setter 
	public J2CA_ftpActivationSpec getSpec() {
		return spec;	}
	public void setSpec(J2CA_ftpActivationSpec spec) {
		this.spec = spec;	}
	public J2CA_ftpConnection getEISconnection() {
		return EISconnection;	}
	public void setEISconnection(J2CA_ftpConnection sconnection) {
		EISconnection = sconnection;	}
		

			public J2CA_ftpActivationSpec() {
		super();
		try {
			this.setPollPeriod(10000);
			this.setPollQuantity(1);
			
			// no-use, just required 
			this.setBiDiContextEIS("a");
			this.setBiDiContextMetadata("a");
			this.setBiDiContextSkip("a");
			this.setBiDiContextSpecialFormat("a");
		} catch (ResourceException e) {
			System.out.println("set property error :(");
			e.printStackTrace();
		}
		

package cdlFTP.inbound;
import javax.mail.Authenticator;
import javax.mail.PasswordAuthentication;
public class MailAuthenticator extends Authenticator {
	String authenName;
	String authenPass;
public MailAuthenticator(String authenName,String authenPass) { 
	     super(); 
	     this.authenName=authenName; 
	     this.authenPass=authenPass; 
	} 
	public PasswordAuthentication getPasswordAuthentication()
	{ 
    	     return new PasswordAuthentication(authenName,authenPass); 
	} 
}

<?xml version="1.0" encoding="UTF-8"?>
<scdl:module name="cdlFTP_inbound"
	xmlns:scdl="http://www.ibm.com/xmlns/prod/websphere/scdl/6.0.0">
</scdl:module>

<?xml version="1.0" encoding="UTF-8"?>
<wsdl:definitions name="cdlFTPNotification"
	targetNamespace="http://cdlFTP"
	xmlns:tns="http://cdlFTP"
	xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
	xmlns:data="http://cdlFTP.Operation.data">
	<wsdl:types>
		<xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">
			<xsd:import namespace="http://cdlFTP.Operation.data"
				schemaLocation="FTPOperation.xsd">
			</xsd:import>
		</xsd:schema>
	</wsdl:types>
	<wsdl:message name="NotificationRequest">
		<wsdl:part name="request" element="data:Operation"></wsdl:part>
	</wsdl:message>
	<wsdl:portType name="Notification">
		<wsdl:operation name="create">
			<wsdl:input message="tns:NotificationRequest"></wsdl:input>
		</wsdl:operation>
		<wsdl:operation name="update">
			<wsdl:input message="tns:NotificationRequest"></wsdl:input>
		</wsdl:operation>
		<wsdl:operation name="delete">
			<wsdl:input message="tns:NotificationRequest"></wsdl:input>
		</wsdl:operation>
	</wsdl:portType>
</wsdl:definitions>

<?xml version="1.0" encoding="UTF-8"?>
<scdl:component 
	name="cdlFTP_inbound/cdlFTPNotification"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:scdl="http://www.ibm.com/xmlns/prod/websphere/scdl/6.0.0"
	xmlns:policy="http://www.ibm.com/xmlns/prod/websphere/scdl/policy/plugin/6.0.0"
	xmlns:java="http://www.ibm.com/xmlns/prod/websphere/scdl/java/6.0.0"
	xmlns:wsdl="http://www.ibm.com/xmlns/prod/websphere/scdl/wsdl/6.0.0"
	xmlns:eis="http://www.ibm.com/xmlns/prod/websphere/scdl/eis/6.0.0"
	xmlns:notification="http://cdlFTP"
	xsi:schemaLocation="http://cdlFTP cdlFTP_inbound/cdlFTPNotification.wsdl">
	
	<interfaces>
		<interface xsi:type="wsdl:WSDLPortType" portType="notification:Notification"/>
	</interfaces>
</scdl:component>

<?xml version="1.0" encoding="UTF-8"?>
<scdl:export target="cdlFTP_inbound/cdlFTPNotification"
	name="cdlFTP_inbound/cdlFTPNotification"
	xmlns:scdl="http://www.ibm.com/xmlns/prod/websphere/scdl/6.0.0"
	xmlns:policy="http://www.ibm.com/xmlns/prod/websphere/scdl/policy/plugin/6.0.0"
	xmlns:java="http://www.ibm.com/xmlns/prod/websphere/scdl/java/6.0.0"
	xmlns:wsdl="http://www.ibm.com/xmlns/prod/websphere/scdl/wsdl/6.0.0"
	xmlns:eis="http://www.ibm.com/xmlns/prod/websphere/scdl/eis/6.0.0"
	xmlns:notification="http://cdlFTP"
	xsi:schemaLocation="http://cdlFTP cdlFTP_inbound/cdlFTPNotification.wsdl">
	<interfaces>
		<interface xsi:type="wsdl:WSDLPortType" portType="notification:Notification"/>
	</interfaces>
	<esbBinding xsi:type="eis:EISExportBinding"  dataBindingType="cdlFTP_inbound.cdlFTPDataBinding">
		<resourceAdapter name="IBM cdl FTP Adapter">
		</resourceAdapter>
		<connection type="cdlFTP.inbound.J2CA_ftpActivationSpec"
	listenerType="commonj.connector.runtime.InboundListener">
		</connection>
		<methodBinding method="create" nativeMethod="CREATE">
		</methodBinding>
		<methodBinding method="update" nativeMethod="UPDATE">
		</methodBinding>
		<methodBinding method="delete" nativeMethod="DELETE">
		</methodBinding>
	</esbBinding>
</scdl:export>

<WID root Dir>\runtimes\bi_v6\bin\serviceDeploy cdlFTP_inbound.jar -classpath J2CA_ftp.rar -keep