package org.springblade.modules.information.controller;

import sun.net.ftp.FtpClient;
import sun.net.ftp.FtpProtocolException;

import java.io.*;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.ArrayList;
import java.util.List;

public class FtpUtil {

	FtpClient ftpClient;

	/**
	 * 连接FTP服务
	 *
	 * @param url           //IP地址
	 * @param port//端口号
	 * @param username//用户名
	 * @param password//密码
	 * @return
	 */
	public static FtpClient connectFTP(String url, int port, String username, String password) {
		//创建ftp
		FtpClient ftp = null;
		try {
			//创建地址
			SocketAddress addr = new InetSocketAddress(url, port);
			//连接
			ftp = FtpClient.create();
			ftp.connect(addr);
			//登陆
			ftp.login(username, password.toCharArray());
			ftp.setBinaryType();
		} catch (FtpProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		return ftp;
	}

	/**
	 * 取ftp上的文件内容
	 *
	 * @param ftpFile
	 * @param ftp
	 * @return
	 */
	public static List<String> download(String ftpFile, FtpClient ftp) {
		List<String> list = new ArrayList<String>();
		String str = "";
		InputStream is = null;
		BufferedReader br = null;
		try {
			// 获取ftp上的文件
			is = ftp.getFileStream(ftpFile);
			//转为字节流
			br = new BufferedReader(new InputStreamReader(is));
			while ((str = br.readLine()) != null) {
				list.add(str);
			}
			br.close();
		} catch (FtpProtocolException e) {
			e.printStackTrace();
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		return list;
	}

	public static void main(String[] args) {
		FtpClient ftp = connectFTP("192.168.0.109",21,"anonymous","");
			List<String> list = download("D:\\anbao", ftp);
		for (int i = 0; i < list.size(); i++) {
			String strOut = null;
			if (list.get(i).toString() != null) {
				try {
					byte[] bs = list.get(i).toString().getBytes();

					strOut = new String(bs, "utf-8");
				} catch (UnsupportedEncodingException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			System.out.println(strOut);
			System.out.println(list.get(i).toString());
		}
	}
}