IBM? WebSphere Message Broker（后面简称为 Message Broker）是针对涉及信息流的解决方案的IBM企业服务总线产品。简言之，这些信息流会获得一个输入信息，对它应用某种转换，然后使用内置Message Broker节点将它交付给终端节点(end-point)。

　　FileInput和FileOutput节点分别用于在文件系统与FYP服务器之间读取和写入文件。不过，这两个节点都不支持自定义FTP命令。

图 1

　　一个典型的FTP会话

　　以下的记录显示了一个从Linux机器到z/OS服务器上的MVS系统的典型会话：

　　示例 1. 从Linux到z/OS的FTP会话
    

以下是引用片段： nsubrahm@nsubrahm:~$ ftp big.blue.server  Connected to 0.0.0.0.  220-TCPFTP1 IBM FTP CS V1R12 at big.blue.server, 10:03:31 on 2011-03-16.  220 Connection will close if idle for more than 5 minutes.  Name (0.0.0.0:nsubrahm): USERID0  331 Send password please.  Password:  230 USERID0 is logged on.  Working directory is “USERID0.”.  Remote system type is MVS.  ftp> site RECFM=FB LRECL=100 BLKSIZE=27900  200 SITE command was accepted  ftp> put Messages.csv ‘A.TEST.GDG(+1)’  local: Messages.csv remote: ‘A.TEST.GDG(+1)’  200 Port request OK.  125 Storing data set A.TEST.GDG.G0003V00  250 Transfer completed successfully.  336887 bytes sent in 1.17 secs (281.2 kB/s)  ftp> bye  221 Quit command received. Goodbye.

　　这个FTP会话使用SITE命令为目标数据集传递信息。Message Broker FileOutput节点并不具备此功能，因此本文会介绍如何实现它。

　　Java解决方案

　　Java解决方案基于Apache Commons Net包。如FTPClient中的javadoc所述，首先连接到FTP服务器，使用您的用户名和密码登录，然后使用get或put命令。以下是一个样例实现。

　　示例 2. 使用Apache Commons Net 的FTP的样例实现
    

以下是引用片段： package fileTransferProtocol;  import org.apache.commons.net.ftp.*;  import java.io.*;  public class FileTransferProtocol {       public static void main (String [ ] args)  {       String serverName =”my.zos.mainframe”  ;       String userName =”userid” ;       String password =”********” ;       FTPClient ftp = new FTPClient() ;       //Connect to the server       try { ftp.connect (serverName) ;            String replyText =ftp.getReplyString()  ;            System.out.println (replyText) ;       }       catch (Exception  e)  {                 e.printStackTrace () ;       }       //Login to the server       try {   ftp.login (userName, password) ;                 String replyText = ftp.getReplyString() ;                 System.out.println (replyText);       } catch (Exception e) {                 e.printStackTrace();       }       //Tell server that the file will have JCL records       try {   ftp.site (“RECFM=FB LRECL=140”) ;                 String replyText = ftp.getReplyString() ;                 System.out.println (replyText) ;       }       catch (Exception e) {                 e.printStackTrace() ;       }       //Submit the job from the text file.       try {   FileInputStream inputStream = new FileInputStream (“/my/source/file”) ;                 ftp.storeFile (serverName,inputStream) ;                 String replyText = ftp.getReplyString() ;                 System.out.println (replyText) ;       }       catch (Exception e) {                 e.printStackTrace() ;       }       //Quit the server       try { ftp.quit() ;       }       catch (Exception e) {                  e.printStackTrace() ;       }    }  }

　　使用JavaCompute节点

　　前面的小节展示了将文件从本地发送至远程文件系统的实现样例。这一节会介绍如何在Message Broker JavaCompute节点中包装此实现。

　　Message Broker信息中心有大量的JavaCompute节点资料。但有一点需要强调：前面介绍的样例实现要求Commons Net JAR文件在CLASSPATH上是可用的。同样的，使用JavaCompute节点时，您需要在外部JAR文件中添加依赖关系。

　　JavaCompute节点的Java类的类型

　　Message Broker Toolkit提供了基于JavaCompute节点预期功能的类模板。

• 过滤器——过滤传入的信息
• 修改——修改传入的信息
• 创建——创建新的信息

　　模板的选择取决于特定的信息流，例如，传入的信息在文件转换后是否会传播到后续节点，或者完成文件转换后是否不会再有进一步的动作，以至于没有信息需要传播。

　　Java类的描述

　　这一节将描述用来定制FTP的Java类。

　　FTP会话的基本输入

　　通过FTP转换文件所需的重要项目为：

• 服务器主机名或IP地址
• 用户ID和密码
• 源文件和目标文件

　　对于利用FTPClient将数据从Apache Commons Net传送到实际传输文件的类，此信息应该是可用的。本文中显示的类接受上述值作为java.util.Properties对象，或者将它作为“名称-值”对的文件名。在使用Properties对象时，您有动态设置这些值的优势。有了这个文件，就不再需要硬编码值。同时，通过设置适当的访问控制，只能通过broker运行所用的ID来读取该文件。

　　Properties对象

　　由于不同的FTP会话可能需要不同的自定义命令，Properties对象不必一直是同一个对象。本文描述了一个实现，其中需要通过指定数据集控制块（DCB）和一些空间值，使用FTP会话将某个文件提供给z/OS服务器。Properties对象的名称-值对如下所示：

　　示例 3. Properties对象的名称——值对样例
    

以下是引用片段： INTF1.server=big.blue.server  INTF1.userid=USERID01  INTF1.password=HeyThere  INTF1.targetDSN=’A.DUMMY.GDG(+1)’  INTF1.targetDSN.RECFM=FB  INTF1.targetDSN.LRECL=100  INTF1.targetDSN.BLKSIZE=27900  INTF1.targetDSN.pri=10  INTF1.targetDSN.sec=5  INTF1.targetDSN.unit=CYL

　　调用

　　以下是调用自定义FTP类的JavaCompute节点的样例：

　　示例 4. 调用自定义节点类的JavaCompute节点的代码样例
    

以下是引用片段： package customFTP;  import com.ibm.broker.javacompute.MbJavaComputeNode;  import com.ibm.broker.plugin.*;  public class FTPMessageFlow_JC01 extends MbJavaComputeNode {     public void evaluate(MbMessageAssembly inAssembly) throws MbException {        MbOutputTerminal out = getOutputTerminal(“out”);        MbMessage inMessage = inAssembly.getMessage();        MbMessage outMessage = new MbMessage(inMessage);        MbMessageAssembly outAssembly = new MbMessageAssembly(inAssembly,outMessage);        try {           /**            * All logic for this JavaCompute node.            *            * Build Properties object here OR            * Provide file name here            *            * Invoke custom FTP here            *            */        } catch (Exception e) {           /**            * Handle exceptions            */     } finally {        outMessage.clearMessage();     }  }

　　如以上代码所示，我们要先执行所需的业务逻辑，然后准备Properties对象，或者传递文件名，以便调用自定义FTP类。

　　信息流样例

　　以下是两个通过FTP将文件发送到目标机器的信息流样例。

　　连接到FileOutput节点

　　在此信息流中，从FileOutput节点中的End of data终端开始连接JavaCompute节点中的In终端。在这个设置中，在完全写入文件后，就会准备通过FTP交付它。为了简便起见，我们通过从FileInput节点中进行复制，创建了要传输的文件。在课程实践中，可能还会创建更复杂的文件。

图 2. 信息流

　　运行信息流

　　在JavaCompute节点中，提到了包含名称-值对的文件的名称。另外，JavaCompute节点可以手动创建Properties对象并传递它。然后，在FI01中创建一个预期的文件名。现在，就可以将信息流打包成一个BAR文件，然后部署并运行它。

　　连接到MQInput节点

　　在这个信息流中，从MQInput节点的Out终端开始连接JavaCompute节点的In终端。在这个设置中，我们期望创建与要交付的文件同名的信息，然后使用该名称来实际交付文件。在课程实践中，创建信息可能会更复杂。

图 3. 信息流

　　运行信息流

　　在JavaCompute节点中，提到了拥有 “名称-值” 对的文件的名称。另外，JavaCompute节点可以手动创建Properties对象并传递它。然后，为消息设置了一个与要交付的文件相同的名称。现在，可以将信息流打包成一个BAR文件，然后部署并运行它。

　　可从 文章底部下载的zip文件中 有四个Message Broker项目，如上面所述，每个信息流有两个项目前。每一对项目中，其中一个项目包含信息流，另一个包含Java代码。您可以将这些zip文件导入您的工作区，然后在broker上创建并部署它们。可能需要对文件（比如MQ节点）进行一些特定于您的环境的更改。

　　结束语

　　本文介绍了如何使用WebSphere Message Broker JavaCompute节点中的Apache Commons Net来启用FTP的自定义命令，您可以扩展这个解决方案，以支持使用SSH FTP和FTP-SSL的安全FTP，从而支持Message Broker使用所有的FTP功能。