java - -t 标志 ("- stalling -"的 SCP 问题)

Question

我正在开发一个 Java 应用程序，它应该向我们的远程计算机发送一个特定文件。我正在使用 Jsch 库，并遵循网站 @ ( http://www.jcraft.com/jsch/examples/ScpTo.java) 中的 ScpTo.java 示例

但是，scp 命令在应用程序中很难执行，因此我尝试使用 Cygwin 在我的终端中的应用程序外部手动运行 SCP 命令。

我的命令是这样的:

    scp -t /home/user/test.csv
    C0644 197171 C:\Users\user\Documents\test.csv

命令的输出为:

C:\Users\user\Documents\test.csv                0%    0     0.0KB/s - stalled -

这就是它似乎所做的全部。现在我想这可能是防火墙问题，所以我尝试了其他几台远程机器，他们仍然给我同样的问题。

关于如何处理此类问题的任何想法？

非常感谢，

乔

编辑:这是 Java 代码:

import java.awt.Container;
import java.awt.GridBagConstraints;
import java.awt.GridBagLayout;
import java.awt.Insets;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JPasswordField;
import javax.swing.JTextField;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.UIKeyboardInteractive;
import com.jcraft.jsch.UserInfo;

class HPCConnector
{
    private static String username = "username";
    private static String host = "host.edu";

    JSch jsch;
    Session session;
    UserInfo ui;

    public HPCConnector() throws JSchException
    {
        jsch = new JSch();
        session = jsch.getSession(username, host, 22);
        ui = new HPCUserInfo();
        session.setUserInfo(ui);
    }

    public boolean validateConnection() 
    {
        boolean status = true;
        try {
            session.connect();
            if (status)
                return status;
            } catch (JSchException e) {
                e.printStackTrace();
                status = false;
            }
        return status;
    }

    public static class HPCUserInfo implements UserInfo, UIKeyboardInteractive
    {
        public String getPassword(){ return passwd; }
        public boolean promptYesNo(String str)
        {
          Object[] options={ "Yes", "No" };
          int foo=JOptionPane.showOptionDialog(null, str,"Warning", JOptionPane.DEFAULT_OPTION, JOptionPane.WARNING_MESSAGE,null, options, options[0]);
           return foo==0;
        }

        String passwd;
        JTextField passwordField=(JTextField)new JPasswordField(20);

        public String getPassphrase(){ return null; }
        public boolean promptPassphrase(String message){ return true; }
        public boolean promptPassword(String message)
        {
          Object[] ob={passwordField}; 
          int result=
          JOptionPane.showConfirmDialog(null, ob, message,
                        JOptionPane.OK_CANCEL_OPTION);
          if(result==JOptionPane.OK_OPTION)
          {
              passwd=passwordField.getText();
              return true;
          }
          else{ return false; }
        }
        public void showMessage(String message)
        {
          JOptionPane.showMessageDialog(null, message);
        }
        final GridBagConstraints gbc = new GridBagConstraints(0,0,1,1,1,1,GridBagConstraints.NORTHWEST,GridBagConstraints.NONE,new Insets(0,0,0,0),0,0);
        private Container panel;
        public String[] promptKeyboardInteractive(String destination,String name,String instruction,String[] prompt,boolean[] echo)
        {
          panel = new JPanel();
          panel.setLayout(new GridBagLayout());

          gbc.weightx = 1.0;
          gbc.gridwidth = GridBagConstraints.REMAINDER;
          gbc.gridx = 0;
          panel.add(new JLabel(instruction), gbc);
          gbc.gridy++;

          gbc.gridwidth = GridBagConstraints.RELATIVE;

          JTextField[] texts=new JTextField[prompt.length];
          for(int i=0; i<prompt.length; i++)
          {
            gbc.fill = GridBagConstraints.NONE;
            gbc.gridx = 0;
            gbc.weightx = 1;
            panel.add(new JLabel(prompt[i]),gbc);

            gbc.gridx = 1;
            gbc.fill = GridBagConstraints.HORIZONTAL;
            gbc.weighty = 1;
            if(echo[i])
            {
              texts[i]=new JTextField(20);
            }
            else
            {
              texts[i]=new JPasswordField(20);
            }
            panel.add(texts[i], gbc);
            gbc.gridy++;
          }

          if(JOptionPane.showConfirmDialog(null, panel, destination+": "+name,JOptionPane.OK_CANCEL_OPTION,JOptionPane.QUESTION_MESSAGE) ==JOptionPane.OK_OPTION)
          {
            String[] response=new String[prompt.length];
            for(int i=0; i<prompt.length; i++)
            {
              response[i]=texts[i].getText();
            }
            return response;
          }
          else
          {
            return null;  // cancel
          }
        }
     }

    public void transferToHPC(File spreadsheet) throws JSchException
    {
        OutputStream out = null;
        InputStream in = null;
        String command = "scp -t /home/user/" + spreadsheet.getName();
        Channel channel = session.openChannel("exec");
        ((ChannelExec)channel).setCommand(command);
        try{
            out = channel.getOutputStream();
            in = channel.getInputStream();
        } catch (IOException ex) {
            ex.printStackTrace();
        }

        System.out.println(command);
        long fileSize=  spreadsheet.length();

        channel.connect();

        command = "C0644 " + fileSize + " " + spreadsheet.getAbsolutePath() + "\n";
        try {
            if(checkAck(in)!=0){
                System.exit(0);
              }
            out.write(command.getBytes());
            out.flush();

            FileInputStream fis = new FileInputStream(spreadsheet);
            byte[] buffer = new byte[1024];

            while (true)
            {
                int length = fis.read(buffer, 0, buffer.length);
                if (length <= 0)
                    break;
                out.write(buffer, 0, 1);
            }
            fis.close();
            fis = null;
            System.out.println(command);

            buffer[0] = 0;
            out.write(buffer, 0, 1);
            out.flush();

            out.close();
        } catch (FileNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        channel.disconnect();
        session.disconnect();
    }

      static int checkAck(InputStream in) throws IOException{
            int b=in.read();
            // b may be 0 for success,
            //          1 for error,
            //          2 for fatal error,
            //          -1
            if(b==0) return b;
            if(b==-1) return b;

            if(b==1 || b==2){
              StringBuffer sb=new StringBuffer();
              int c;
              do {
            c=in.read();
            sb.append((char)c);
              }
              while(c!='\n');
              if(b==1){ // error
            System.out.print(sb.toString());
              }
              if(b==2){ // fatal error
            System.out.print(sb.toString());
              }
            }
            return b;
          }
}

EDIT2:控制台上没有出现异常，给我带来麻烦的主要功能是 transferToHPC(File spreadsheet)

EDIT3:好吧，我终于放弃了；能够使用 JSch 的 Sftp 类并且它按我预期的方式工作。

我做了更多阅读并阅读了 Kenster 的回答，我想我应该将 -t 标志留给 scp 内部处理:)谢谢大家!!

Answer 1

我的理解正确吗？您手动运行了 scp -t 命令并输入了 C0644 行，然后您收到了 stalling 消息？这并不表示有任何问题。

scp -t 通常是 scp 传输的接收端。它由另一个 scp 实例启动，该实例将文件发送到接收端。发送 scp 实例启动接收器，发送 C 行来标记文件即将到来，然后发送文件的数据。

您所做的是手动和交互地启动一个接收器，并向它发送一个 C 行，指示一个文件即将到来。之后，接收方期望读取文件的数据。由于您没有发送任何文件数据，接收方最终打印了一条状态消息，指示传输已停止。

唯一的问题是人类通常不会直接运行 scp -t。 scp 程序在这些情况下的工作方式完全符合您的预期。