FTP

1. リモート転送チェックボックスを選択する
2. 転送プロトコルのプロパティのドロップダウンからSFTPを選択します。

• FTPサーバーのアドレスとポート番号を入力してください。 9.20.192.15:21

mqsisetdbparms -w workDir -n ftp::secId -u <userName> -p <password>

mqsisetdbparms -uftp::DUMMYFTP-nC:\ACE12NODEWS\TEST_SERVER-w builduser-p builduser

ここで、DUMMYFTP は、 IBM App Connect Enterprise コンソールで実行するために指定されたサーバーIDです：

Server Directory：ファイルがあるFTPサーバーのディレクトリ（File inputノードの場合）、またはファイルがアップロードされるディレクトリ（File Outputノードの場合）を指定します。 例えば、ファイルの読み込みには /incoming/ 、ファイルの書き込みには /outgoing/ 。

FTP エンドポイントの詳細画面：

読み込みに成功すると、ファイルはサーバーから自動的に削除される。

Java Compute NodeコードでFTPClientの問題にまだ直面している場合は、プロジェクトのビルドパスにそのjarを追加してください。

package com.ibm.acp.ace.ftp.example;

import com.ibm.broker.javacompute.MbJavaComputeNode;

import com.ibm.broker.plugin.MbElement;

import com.ibm.broker.plugin.MbException;

import com.ibm.broker.plugin.MbMessage;

import com.ibm.broker.plugin.MbMessageAssembly;

import com.ibm.broker.plugin.MbOutputTerminal;

import com.ibm.broker.plugin.MbUserException;

import org.apache.commons.net.ftp.FTPClient;

import java.io.IOException;

public class AcpToAceFileName extends MbJavaComputeNode {

    @Override

    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);

        FTPClient ftpClient = new FTPClient();

        try {

            // Step 1: Get file information from LocalEnvironment

            MbElement localEnv = inAssembly.getLocalEnvironment().getRootElement();

            String localDirectory = null;

            String localFileName = null;

            if (localEnv.getFirstElementByPath("$LocalEnvironment/Destination/File/Directory") != null) {

                localDirectory = localEnv.getFirstElementByPath("$LocalEnvironment/Destination/File/Directory").getValueAsString();

            }

            if (localEnv.getFirstElementByPath("$LocalEnvironment/File/Name") != null) {

                localFileName = localEnv.getFirstElementByPath("$LocalEnvironment/File/Name").getValueAsString();

            }

            // Log the local directory and file name

            System.out.println("Local Directory: " + localDirectory);

            System.out.println("Local File Name: " + localFileName);

            // Step 2: Connect to the FTP server

            String ftpHost = "9.20.192.15"; 

            int ftpPort = 21;              

            String ftpUser = "builduser";  

            String ftpPassword = "builduser"; 

            String remoteDirectory = "/MyTest/VendorImport/Dummy/POLLTO"; 

            ftpClient.connect(ftpHost, ftpPort);

            ftpClient.login(ftpUser, ftpPassword);

            // Step 3: List files in the remote FTP directory

            String[] ftpFileList = ftpClient.listNames(remoteDirectory);

            // Log the list of files retrieved from the FTP server

            if (ftpFileList != null) {

                System.out.println("Files in FTP directory:");

                for (String fileName : ftpFileList) {

                    System.out.println(fileName);

                }

            } else {

                System.out.println("No files found in the FTP directory.");

            }

            // Step 4: Build output message

            MbElement outRoot = outMessage.getRootElement();

            MbElement outBody = outRoot.createElementAsLastChild(MbElement.TYPE_NAME, "XMLNSC", null);

            MbElement fileListElement = outBody.createElementAsLastChild(MbElement.TYPE_NAME, "FileDetails", null);

            // Add local file details from FileOutput Node

            if (localDirectory != null) {

                fileListElement.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "LocalDirectory", localDirectory);

            }

            if (localFileName != null) {

                fileListElement.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "LocalFileName", localFileName);

            }

            // Add file names from FTP server

            if (ftpFileList != null) {

                MbElement ftpFilesElement = fileListElement.createElementAsLastChild(MbElement.TYPE_NAME, "FTPFiles", null);

                for (String fileName : ftpFileList) {

                    ftpFilesElement.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "File", fileName);

                }

            }

            // Step 5: Disconnect from FTP server

            ftpClient.logout();

            ftpClient.disconnect();

        } catch (IOException e) {

            throw new MbUserException(this, "evaluate", "", "", e.toString(), null);

        }

        // Propagate the message to the next node

        out.propagate(outAssembly);

    }

}

mqsisetdbparms -w workDir -n sftp::myidentity -u <myuserid> -p <mypassword>

mqsisetdbparms -w C:\ACE12NODEWS\TEST_SERVER -n sftp::SFTPSERIDENTITY -u user1 -p Access2sftpuser

workDir 統合サーバーの作業ディレクトリ

myidentity セキュリティ・アイデンティティの名前

userName をSFTPサーバーのユーザー名

password SFTPサーバーのパスワード

ファイルが置かれている SFTP サーバー上のディレクトリ（ FileInput ノードの場合）またはファイルをアップロードするディレクトリ（ FileOutput ノードの場合）を指定します。 例えば、ファイルの読み込みには /incoming/ 、ファイルの書き込みには /outgoing/ 。

SFTP エンドポイントの詳細画面：

keystoreType: 「JKS」

keystoreFile: C:/Users/Administrator/keystore.jks

keystorePass: <password> ( <password> を実際のキーストア・パスワードに置き換える)

truststoreType: 「JKS」

truststoreFile: C:/Users/Administrator/truststore.jks

truststorePass: <password> ( <password> を実際の truststore パスワードに置き換える)