Java 版的ftp命令行工具，支持文件上传，下载

QCHuangChao

编写目的

自己写了个脚本用来打包发布war但是由于上传的使用使用的ftp(难道比较原始？？)，可是每次都要输入用户名，密码。感觉很烦，想了想就是就自己简单的实现了一个ftp的命令行工具。
可以做撒
与ftp控制台工具类似

java -jar simpleftpclient.jar --host 203.195.167.55 --userName test --password K~wqYDZpTg2

代码中调用

导入 simpleftpclient.jar

FtpUser user = new FtpUser();
user.setAddr(host);
user.setPassword(password);
user.setUserName(userName);
new FtpManager().sendCmd(user,cmd.replace("*"," "));


代码提交在git 上欢迎查看
http://git.oschina.net/94fzb/simpleftpclient
目前支持命令 dir put get cd exit 这些基础命令。欢迎完整。。

代码

1. package com.fzb.ftp;
   
2. 
   
3. import java.net.InetSocketAddress;
   
4. import java.nio.ByteBuffer;
   
5. import java.nio.channels.SelectionKey;
   
6. import java.nio.channels.Selector;
   
7. import java.nio.channels.SocketChannel;
   
8. import java.util.Iterator;
   
9. import java.util.Set;
   
10. 
    
11. public class FtpNIOClient {
    
12.     private SocketChannel client;
    
13.     private SelectionKey selectionKey;
    
14.     private Selector selector;
    
15.     private FtpSession ftpSession;
    
16.     private FtpLoginSuccCallBack callBack;
    
17.     private FtpUser ftpUser;
    
18.      
    
19.     public FtpNIOClient(FtpLoginSuccCallBack callBack, FtpUser ftpUser) {
    
20.         super();
    
21.         this.callBack = callBack;
    
22.         this.ftpUser = ftpUser;
    
23.     }
    
24. 
    
25.     public FtpNIOClient() {
    
26.         super();
    
27.     }
    
28. 
    
29. 
    
30.     public void connectServer() {
    
31.         InetSocketAddress SERVER_ADDRESS = new InetSocketAddress(
    
32.                 ftpUser.getAddr(), ftpUser.getPort());
    
33.         try {
    
34.             // 打开socket通道
    
35.             SocketChannel socketChannel = SocketChannel.open();
    
36.             // 设置为非阻塞方式
    
37.             socketChannel.configureBlocking(false);
    
38.             // 打开选择器
    
39.             selector = Selector.open();
    
40.             Iterator iterator;
    
41.             Set<SelectionKey> selectionKeys;
    
42.             // 注册连接服务端socket动作
    
43.             socketChannel.register(selector, SelectionKey.OP_CONNECT);
    
44.             // 连接
    
45.             socketChannel.connect(SERVER_ADDRESS);
    
46.             // 分配缓冲区大小内存
    
47.             while (true) {
    
48.                 // 选择一组键，其相应的通道已为 I/O 操作准备就绪。
    
49.                 // 此方法执行处于阻塞模式的选择操作。
    
50.                 selector.select();
    
51.                 // 返回此选择器的已选择键集。
    
52.                 selectionKeys = selector.selectedKeys();
    
53.                 iterator = selectionKeys.iterator();
    
54.                 while (iterator.hasNext()) {
    
55.                     selectionKey = (SelectionKey) iterator.next();
    
56.                     client = (SocketChannel) selectionKey.channel();
    
57.                     if (selectionKey.isConnectable()) {
    
58.                         if (client.isConnectionPending()) {
    
59.                             client.finishConnect();
    
60.                             ftpSession=new FtpSession(ftpUser, this);
    
61.                             if(callBack!=null){
    
62.                                 ftpSession.getAttr().put("callBack",callBack);
    
63.                             }
    
64.                             System.out.println("connect finished");
    
65.                         }
    
66.                         client.register(selector, SelectionKey.OP_READ);
    
67.                     } else if (selectionKey.isReadable()) {
    
68.                         ByteBuffer input = ByteBuffer.allocate(1024 * 100);
    
69.                         client.read(input);
    
70.                         input.flip();
    
71.                         String strArr[] = new String(input.array()).trim()
    
72.                                 .split("\r\n");
    
73.                         for (String string : strArr) {
    
74.                             System.out.println("resp --< " + string);
    
75.                         }
    
76.                         for (String string : strArr) {
    
77.                             ftpSession.readMsg(string);
    
78.                         }
    
79.                     } else if(selectionKey.isWritable()){
    
80.                         ftpSession.sendMsg(selectionKey.attachment().toString());
    
81.                     }
    
82.                 }
    
83.                 selectionKeys.clear();
    
84.             }
    
85.         } catch (Exception e) {
    
86.             e.printStackTrace();
    
87.         }
    
88.     }
    
89. 
    
90.     public SocketChannel getClient() {
    
91.         return client;
    
92.     }
    
93. 
    
94.     public SelectionKey getSelectionKey() {
    
95.         return selectionKey;
    
96.     }
    
97. 
    
98.     public Selector getSelector() {
    
99.         return selector;
    
100.     }
     
101.      
     
102.     public FtpSession getFtpSession(){
     
103.         return ftpSession;
     
104.     }
     
105.      
     
106. 
     
107. }

复制代码

ftp 状态码对应的方法

1. package com.fzb.ftp;
   
2. 
   
3. import java.lang.reflect.Method;
   
4. import java.util.HashMap;
   
5. import java.util.Map;
   
6. 
   
7. public class StatusMap {
   
8. 
   
9.     private static Map<Integer, Method> map = new HashMap<Integer, Method>();
   
10. 
    
11.     static {
    
12.         reloadMap();
    
13.     }
    
14. 
    
15.     private static void reloadMap() {
    
16.         try {
    
17.             map.put(220, FtpResponseImpl.class.getMethod("connectSucc",
    
18.                     String.class));
    
19.             map.put(331, FtpResponseImpl.class.getMethod("inputPassword",
    
20.                     String.class));
    
21.             map.put(230,
    
22.                     FtpResponseImpl.class.getMethod("loginSucc", String.class));
    
23.             map.put(200, FtpResponseImpl.class.getMethod("initCmdSucc",
    
24.                     String.class));
    
25.             map.put(215, FtpResponseImpl.class.getMethod("modelChanageSucc",
    
26.                     String.class));
    
27.             map.put(227, FtpResponseImpl.class.getMethod("passiveModeSucc",
    
28.                     String.class));
    
29.             map.put(150,
    
30.                     FtpResponseImpl.class.getMethod("tipsMsg", String.class));
    
31.             map.put(226, FtpResponseImpl.class.getMethod("modelChanageSucc",
    
32.                     String.class));
    
33.             map.put(250, FtpResponseImpl.class.getMethod("initCmdSucc",
    
34.                     String.class));
    
35.             map.put(550,
    
36.                     FtpResponseImpl.class.getMethod("tipsMsg", String.class));
    
37.             map.put(500,
    
38.                     FtpResponseImpl.class.getMethod("tipsMsg", String.class));
    
39.             map.put(425,
    
40.                     FtpResponseImpl.class.getMethod("tipsMsg", String.class));
    
41.             map.put(530,
    
42.                     FtpResponseImpl.class.getMethod("loginFailed", String.class));
    
43. 
    
44.         } catch (NoSuchMethodException e) {
    
45.             e.printStackTrace();
    
46.         } catch (SecurityException e) {
    
47.             e.printStackTrace();
    
48.         }
    
49.     }
    
50. 
    
51.     public static Method getMethod(Integer statusCode) {
    
52.         // just for dev
    
53.         reloadMap();
    
54.         return map.get(statusCode);
    
55.     }
    
56. }

复制代码