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

// This method returns the meta data of our resource adapter
public com.ibm.j2ca.base.WBIResourceAdapterMetadata getResourceAdapterMetadata()
			throws javax.resource.ResourceException {
return new WBIResourceAdapterMetadata("FTP RA","IBM","0.1",false);
}

private J2CA_ftpConnection ftpConnection;
private J2CA_ftpConnectionRequestInfo cri;
J2CA_ftpConnectionFactory factory;
// construct function which is called by ManagedConnectionFactory
public J2CA_ftpManagedConnection(
			com.ibm.j2ca.base.WBIManagedConnectionFactory mfc,
			javax.security.auth.Subject subject,
			com.ibm.j2ca.base.WBIConnectionRequestInfo cri)
			throws javax.resource.ResourceException {
	super(mfc, subject, cri);
	this.cri = (J2CA_ftpConnectionRequestInfo)cri;
	System.out.println("-> Enter J2CA_ftpManagedConnection construct, super finish");
	J2CA_ftpConnectionFactory factory = new J2CA_ftpConnectionFactory(null,mfc);
	System.out.println("### factory created");
}
// this function returns the outbound runtime properties
public J2CA_ftpConnectionRequestInfo getFTPConnectionRequestInfo()
{
return cri;
}
// This function returns the EIS Connection
public java.lang.Object getWBIConnection(
	javax.resource.spi.security.PasswordCredential arg0, boolean arg1)
		throws javax.resource.ResourceException {
	return new J2CA_ftpConnection(this);
}

// Create ManagedConnection Instance, which is called by WBI runtime.
public javax.resource.spi.ManagedConnection createManagedConnection(
	javax.security.auth.Subject subject,
	javax.resource.spi.ConnectionRequestInfo connectionRequestInfo)
		throws javax.resource.ResourceException {
System.out.println("-> Enter createManagedConnection, Class: ManangedConnectionFactory");
		
this.setReauthSupported(false);
J2CA_ftpManagedConnection connection = new J2CA_ftpManagedConnection(
	 (WBIManagedConnectionFactory)this, subject, (WBIConnectionRequestInfo) connectionRequestInfo);
return connection;
}
// Create ConnectionFactory Instance, which is called by WBI runtime.
public java.lang.Object createConnectionFactory(
			javax.resource.spi.ConnectionManager connMgr)
			throws javax.resource.ResourceException {
System.out.println("-> Enter createConnectionFactory, Class: ManangedConnectionFactory 2");
return new J2CA_ftpConnectionFactory(connMgr,(WBIManagedConnectionFactory)this);
}

J2CA_ftpManagedConnectionFactory mcf;
J2CA_ftpConnection cf;
// Construct function
public J2CA_ftpConnectionFactory(javax.resource.spi.ConnectionManager cm,
	com.ibm.j2ca.base.WBIManagedConnectionFactory mcf) {
		super(cm, mcf);
		this.mcf = (J2CA_ftpManagedConnectionFactory)mcf;
		System.out.println("### J2CA_ftpConnectionFactory construct");
}
// This method returns the real EIS connection which will be used during the whole outbound scenario.
public J2CA_ftpConnection getConnection(J2CA_ftpManagedConnection mc) throws ResourceException
{
    	System.out.println("getConnection() - EIS connection");
    	cf = new J2CA_ftpConnection((WBIManagedConnection)mc);
	return cf;
 }

FtpClient ftpConn= null; 
int ch; 
String hostname="";
String message="";
	
J2CA_ftpConnectionRequestInfo cri;
J2CA_ftpManagedConnection ftpMC;
J2CA_ftpManagedConnectionFactory mcf;
String ip = "";
String port = "";
String localdir = "";
String user = "";
String passwd = "";
// Construct function
public J2CA_ftpConnection(com.ibm.j2ca.base.WBIManagedConnection mc)
			throws javax.resource.ResourceException {
	super(mc);
	System.out.println("<- enter J2CA_ftpConnection Construct, finish super");
	ftpMC = (J2CA_ftpManagedConnection)mc;
	cri = ftpMC.getFTPConnectionRequestInfo();
	mcf = (J2CA_ftpManagedConnectionFactory)ftpMC.getManagedConnectionFactory();
	}
// Create Interaction to do the real job. Called by WBI runtime.
public javax.resource.cci.Interaction createInteraction()
			throws javax.resource.ResourceException {
		super.checkValidity();
		return new J2CA_ftpInteraction(this);
	}
// Connect to FTP Server
public FtpClient connect(String FileDir,String hostname,int port,String uid,String pwd) 
	{
	  this.hostname = hostname;
	  System.out.println("Connecting to "+hostname+".....");
	  try{ 
	   ftpConn= new FtpClient(hostname,port); 
	   ftpConn.login(uid,pwd); 
	   ftpConn.binary();
	   System.out.println("Connect to host: "+hostname+" success!"); 
	  } 
	  catch(Exception e){ 
	   System.out.println("login to: "+hostname+"failed! "+e);
	   ftpConn= null;
  } 
	  return ftpConn; 
	} 
       // Disconnect to FTP server
	public void stop(String FileDir) 
	{ 
	  try { 
	   if(ftpConn!=null){
		ftpConn.closeServer();
		ftpConn= null;
		System.out.println("Connection to "+hostname+" is close"); 
	   }
	  } 
	  catch(IOException e) 
	  { 
	   System.out.println("Stop: Connect to "+hostname+"failed!"+e); 
	  } 
	} 
       // download file from the connected FTP server
	public boolean downloadFile(String FileDir,String filepathname){ 
	  boolean result=true; 
	  if (ftpConn!= null) 
	  { 
	   System.out.println("downloading "+filepathname+"......"); 
	   String strdir = "";
	   try{ 
		File fi = new File(FileDir + filepathname);
		RandomAccessFile remoteFile = new RandomAccessFile(fi,"rw");
		remoteFile.seek(0);
		TelnetInputStream fget=ftpConn.get(strdir+filepathname);
		DataInputStream puts = new DataInputStream(fget);
		while ((ch = puts.read()) >= 0) {
		 remoteFile.write(ch);
		}
		fget.close();
		remoteFile.close();
		System.out.println("Download "+filepathname+" to "+ FileDir +" success!"); 
	   } 
	   catch(IOException e){ 
		System.out.println("Download "+filepathname+" to "+ FileDir +" failed! "+e); 
		result = false ; 
	   } 
	  } 
	  else{     result = false;   } 
	  return result; 
	} 
    // Upload file to the connected FTP server
	public boolean uploadFile(String FileDir,String filepathname){ 
	  boolean result=true; 
	  String message = "";
	  if (ftpConn!= null) 
	  { 
	   System.out.println("uploading "+FileDir+" "+filepathname+"...."); 
	   try{ 
		String filename = "";
		filename = filepathname;
		RandomAccessFile sendFile = new RandomAccessFile(FileDir+filepathname,"r"); 
		sendFile.seek(0); 
		TelnetOutputStream outs = ftpConn.put(filename); 
		DataOutputStream outputs = new DataOutputStream(outs); 
		while (sendFile.getFilePointer() < sendFile.length() ) 
		{ 
		 ch = sendFile.read(); 
		 outputs.write(ch); 
		} 
		outs.close(); 
		sendFile.close(); 
    
		System.out.println("upload "+filepathname+" success!"); 
	   } 
	   catch(IOException e){ 
		System.out.println("upload "+filepathname+"failed! "+e); 
		result = false ; 
	   } 
	  } 
	  else{    result = false;   } 
	  return result; 
	} 
         // get File List from FTP server
	public ArrayList getFileList() throws IOException {
	  BufferedReader dr = new BufferedReader(new InputStreamReader(ftpConn.list()));
	  ArrayList list = new ArrayList();
	  String s = "";
	  while ( (s = dr.readLine()) != null) {
	  list.add(s);
	  }
	  return list;
	}
          // set Current Directory of FTP server
	public void setPath(String path) throws IOException {
	  if (ftpConn== null)
	  ;  else {
	   ftpConn.cd(path);  }
	}
          // get and set interface of EIS connection
	public FtpClient getftpConn ()
 { return ftpConn;	}
	public void setftpConn (FtpClient client) 
{  ftpConn= client; }

	J2CA_ftpConnection ftpConnection;
J2CA_ftpManagedConnection mc;
Interpreter interpreter;
CommandManager commandMgr;
J2CA_ftpCommandFactoryImpl cfi;
LogUtils log;
// Construct Function
	public J2CA_ftpInteraction(com.ibm.j2ca.base.WBIConnection connection) {
		super(connection);	
		System.out.println("-> Enter create cdl FTP Interaction");
		ftpConnection = (J2CA_ftpConnection)connection;
		
		try {
mc = (J2CA_ftpManagedConnection)ftpConnection.getManagedConnection();
		} catch (ResourceException e) {
			e.printStackTrace(); 	}
		
		log = mc.getManagedConnectionFactory().getLogUtils();
		interpreter = new Interpreter(log);
		J2CA_ftpResourceAdapter ra =
		(J2CA_ftpResourceAdapter)mc.getManagedConnectionFactory().getResourceAdapter();
		J2CA_ftpCommandFactoryImpl comf = new J2CA_ftpCommandFactoryImpl();
		commandMgr = new CommandManager(comf, ftpConnection, log);
                      cfi = new J2CA_ftpCommandFactoryImpl();
		System.out.println("<- Out create cdl FTP Interaction");
	}
	// do the real job based on the passed-in Record
	public javax.resource.cci.Record execute(
			javax.resource.cci.InteractionSpec iSpec,
			javax.resource.cci.Record record)
			throws javax.resource.ResourceException {
	System.out.println(" >>> cdl FTP AdapterInteraction.execute() ");
	WBIInteractionSpec wbiSpec = (WBIInteractionSpec) iSpec;
	com.ibm.j2ca.extension.commandpattern.Command command = null;
	DataObject bo;
String verb;
	if(record==null){  System.out.println("record==null");  return null; }
	System.out.println("record name:"+((WBIRecord)record).getRecordName());
	System.out.println("BO:"+((WBIRecord)record).getDataObject());
System.out.println("string:"+((WBIRecord)record).getDataObject().getString("verb"));
	
         // extract verb and decide the operation
	verb = ((WBIRecord)record).getDataObject().getString("verb");
	wbiSpec.setFunctionName(verb);
	if(verb.equalsIgnoreCase("Retrieve"))
	{
	bo = ((WBIRecord)record).getDataObject().getDataObject("FTPOperation");
	command = cfi.createCommand("Retrieve",bo);
	command.setConnection(ftpConnection);
	} else {
	System.out.println(" Try to get the Command, function: "+verb);
	command = commandMgr.produceCommands((WBIRecord)record, wbiSpec.getFunctionName());
	System.out.println(" Got the Command, function: "+verb);
	}
         // Do the corresponding operation
	command.execute(((WBIRecord)record).getDataObject());
System.out.println(" <<< cdl FTP JDBCAdapterInteraction.execute() ");
	return record;
	}
	

// create Command Instance based on functionName
public com.ibm.j2ca.extension.commandpattern.Command createCommand(
		java.lang.String functionName, commonj.sdo.DataObject arg1)
			throws javax.resource.ResourceException {
	J2CA_ftpBaseCommand command = null;
	if(functionName.equals(WBIInteractionSpec.CREATE_OP)){
			command = new J2CA_ftpCreateCommand();
	}else if(functionName.equals(WBIInteractionSpec.DELETE_OP)){
			command = new J2CA_ftpDeleteCommand();
	}else if(functionName.equals(WBIInteractionSpec.UPDATE_OP)){
			command = new J2CA_ftpUpdateCommand();		
	}else if(functionName.equals(WBIInteractionSpec.RETRIEVE_OP)){
			command = new J2CA_ftpRetrieveCommand();
	}else	    command = new J2CA_ftpNoOperationCommand();
		System.out.println("functionName = "+functionName);
		return command;
	}

public DataObject execute(DataObject Object) throws ResourceException 
{
J2CA_ftpConnection connection = (J2CA_ftpConnection)this.getConnection();
J2CA_ftpManagedConnection mc = (J2CA_ftpManagedConnection)connection.getManagedConnection();
J2CA_ftpManagedConnectionFactory mcf = (J2CA_ftpManagedConnectionFactory)mc.getManagedConnectionFactory();
	   	  
String ip = mcf.getIp();
String port = mcf.getPort();
String dir = mcf.getRemote_dir();
String user = mcf.getUserName();
String passwd = mcf.getPassword();
String filename = mcf.getRemote_filename();
String localdir = mcf.getLocal_dir();
	   	
DataObject inputObject = Object.getDataObject("FTPOperation");
System.out.println("Got FTPOperationBO");
if(inputObject.getString("ip")!=null && inputObject.getString("ip").length()!=0)
 ip = inputObject.getString("ip");
if(inputObject.getString("port")!=null && inputObject.getString("port").length()!=0) port =
inputObject.getString("port");
if(inputObject.getString("dir")!=null && inputObject.getString("dir").length()!=0) 
dir = inputObject.getString("dir");
if(inputObject.getString("user")!=null && inputObject.getString("user").length()!=0) user =
inputObject.getString("user");
if(inputObject.getString("passwd")!=null&&inputObject.getString("passwd").length()!=0)  
passwd = inputObject.getString("passwd");
if(inputObject.getString("filename")!=null&&inputObject.getString("filename").length()!=0) 
filename = inputObject.getString("filename");
if(inputObject.getString("localdir")!=null&&inputObject.getString("localdir").length()!=0)   
localdir = inputObject.getString("localdir");
	   		
try {  	// try 3 times
	for(int i=0;i<3;i++)
	{
	connection.connect(localdir,ip,Integer.parseInt(port),user,passwd);
	 if(connection.getftpConn ()!=null) break;
	try {Thread.sleep(3000);} catch (InterruptedException e1) {}
	}
// set the directory of FTP server
	connection.setPath(dir);
	System.out.println("dir="+dir);
If(!localdir.endsWith("/") && !localdir.endsWith("\\")) localdir = localdir + "/";
          // Upload file operation
	connection.uploadFile(localdir,filename);
	System.out.println("Success Upload file"+filename);
	connection.stop(null);
} catch (IOException e) {
	System.out.println("Error Upload file"+filename);
	e.printStackTrace();
}
// delete the temp file after uploading
File file = new File(localdir +filename);
if(file.exists()) file.delete();
return null;
}

public DataObject execute(DataObject Object) throws ResourceException
{
J2CA_ftpConnection connection = (J2CA_ftpConnection)this.getConnection();
J2CA_ftpManagedConnection mc = (J2CA_ftpManagedConnection)connection.getManagedConnection();
J2CA_ftpManagedConnectionFactory mcf =
(J2CA_ftpManagedConnectionFactory)mc.getManagedConnectionFactory();
	   	  
String ip = mcf.getIp();
String port = mcf.getPort();
String dir = mcf.getRemote_dir();
String user = mcf.getUserName();
String passwd = mcf.getPassword();
String filename = mcf.getRemote_filename();
String localdir = mcf.getLocal_dir();
	   	  
DataObject inputObject = Object.getDataObject("FTPOperation");
System.out.println("Got FTPOperationBO");
if(inputObject.getString("ip")!=null && inputObject.getString("ip").length()!=0) ip =
inputObject.getString("ip");
if(inputObject.getString("port")!=null && inputObject.getString("port").length()!=0) port =
inputObject.getString("port");
if(inputObject.getString("dir")!=null && inputObject.getString("dir").length()!=0) 
dir = inputObject.getString("dir");
if(inputObject.getString("user")!=null && inputObject.getString("user").length()!=0) 
user = inputObject.getString("user");
if(inputObject.getString("passwd")!=null&&inputObject.getString("passwd").length()!=0)   
passwd = inputObject.getString("passwd");
if(inputObject.getString("filename")!=null&&inputObject.getString("filename").length()!=0)  
filename = inputObject.getString("filename");
if(inputObject.getString("localdir")!=null&&inputObject.getString("localdir").length()!=0)   
localdir = inputObject.getString("localdir");
	   		
try {
	// try 3 times
	for(int i=0;i<3;i++)
	{
	connection.connect(localdir,ip,Integer.parseInt(port),user,passwd);
	 if(connection.getftpConn ()!=null) break;
	try {Thread.sleep(3000);} catch (InterruptedException e1) {}
	 }
           // set directory of FTP server
	connection.setPath(dir);
	System.out.println("dir="+dir);
If(!localdir.endsWith("/") && !localdir.endsWith("\\")) localdir = localdir + "/";
          // download file from FTP server
	connection.downloadFile(localdir,filename);
	System.out.println("Success Down file"+filename);
	connection.stop(null);
} catch (IOException e) {
	System.out.println("Error Upload file"+filename);
	e.printStackTrace();
}
return null;
}

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

<?xml version="1.0" encoding="UTF-8"?>
<scdl:references xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:scdl="http://www.ibm.com/xmlns/prod/websphere/scdl/6.0.0"
	xmlns:wsdl="http://www.ibm.com/xmlns/prod/websphere/scdl/wsdl/6.0.0"
	xmlns:java="http://www.ibm.com/xmlns/prod/websphere/scdl/java/6.0.0"
	xmlns:ftpOperation="http://cdlFTP.Operation"
	xsi:schemaLocation="http://cdlFTP.Operation cdlFTP/FTPOperation.wsdl">
	<reference name="FTP">
		<interface xsi:type="wsdl:WSDLPortType" portType="ftpOperation:FTPOperation"/>
		<wire  target="cdlFTP/cdlFTP"/>
	</reference>
</scdl:references>

<?xml version="1.0" encoding="UTF-8"?>
<wsdl:definitions name="FTPOperation"
	targetNamespace="http://cdlFTP.Operation"
	xmlns:tns="http://cdlFTP.Operation"
	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:Operation="http://cdlFTP.Operation"
	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="OperationRequest">
		<wsdl:part name="request" element="data:Operation"></wsdl:part>
	</wsdl:message>
	<wsdl:message name="OperationResponse">
		<wsdl:part name="response" element="data:Operation"></wsdl:part>
	</wsdl:message>
	
	<wsdl:portType name="FTPOperation">
		<wsdl:operation name="OperationFTP">
			<wsdl:input message="tns:OperationRequest"></wsdl:input>
			<wsdl:output message="tns:OperationResponse"></wsdl:output>
		</wsdl:operation>
	</wsdl:portType>
</wsdl:definitions>

<?xml version="1.0" encoding="UTF-8"?>
<scdl:import name="cdlFTP/cdlFTP"
	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:ftpOperation="http://cdlFTP.Operation"
	xsi:schemaLocation="http://cdlFTP.Operation FTPOperation.wsdl">
	<interfaces>
		<interface xsi:type="wsdl:WSDLPortType" portType="ftpOperation:FTPOperation"/>
	</interfaces>
	
	<esbBinding xsi:type="eis:EISImportBinding">
		<resourceAdapter name="IBM cdl FTP Adapter"/>
		<connection type="cdlFTP.outbound.J2CA_ftpManagedConnectionFactory" shared="Unshareable"> 
		</connection>
		<methodBinding method="OperationFTP" interactionType="cdlFTP.outbound.J2CA_ftpInteractionSpec"
			inDataBindingType="cdlFTP.DataBindingImpl"
			outDataBindingType="cdlFTP.DataBindingImpl">
		</methodBinding>
	</esbBinding>
</scdl:import>

	public Record getRecord() {
	System.out.println("DataBingingImpl: getRecord");
	if(record==null) System.out.println("DataBingingImpl: record==null");
	return (Record)record;
	}
public void setRecord(Record aRecord) {
	System.out.println("DataBingingImpl: getRecord");
	if(record==null) System.out.println("DataBingingImpl: record==null");
	if(aRecord==null) System.out.println("DataBingingImpl: aRecord==null");
           record = (WBIRecord)aRecord;
           data = record.getDataObject();
	}
public DataObject getDataObject() {
	System.out.println("DataBingingImpl: getDataObject");
	if(record==null) System.out.println("DataBingingImpl: record==null");
	return data;
	}
public void setDataObject(DataObject dataObject) {
	this.data = dataObject;
	record.setDataObject(data);
	System.out.println("DataBingingImpl: setDataObject");
	if(dataObject==null) System.out.println("DataBingingImpl: setDataObject==null");
	}
	

ServiceManager serviceManager = ServiceManager.INSTANCE; 
Service service = (Service)serviceManager.locateService("FTP");
DataObject ftpBG = DataFactory.INSTANCE.create("http://cdlFTP.Operation.data", "FTPOperationBG");
ftpBG.setString("verb", "Create");
DataObject ftpBO = DataFactory.INSTANCE.create("http://cdlFTP.Operation.data", "FTPOperation");
String filename = file.getFileName();
ftpBO.setString("ip",ipv);
ftpBO.setString("port",portv);
ftpBO.setString("dir",dirv);
ftpBO.setString("user",userv);
ftpBO.setString("passwd",passwdv);
ftpBO.setString("filename",filename);
ftpBO.setString("localdir",localdir);
ftpBG.setDataObject("FTPOperation",ftpBO);
service.invoke("OperationFTP", ftpBG);
System.out.println("FTP Operation Success");

<% String localdir = "D:/JCA_ftp_Adapter/upload/"; %>

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

<WID root Dir>\prof\installedApps\widCell\cdlFTPApp.ear\cdlFTPWeb.war\

<WID_root_Dir>\prof\installedApps\widCell\cdlFTPApp.ear\cdlFTPWeb.war\lib\WEB-INF\