分布式系统图片上传方案

[[email protected] ~]# passwd ftpuser

[[email protected] ~]# service iptables restart

allow_ftpd_anon_write --> off

allow_ftpd_full_access --> off

allow_ftpd_use_cifs --> off

allow_ftpd_use_nfs --> off

ftp_home_dir --> off

ftpd_connect_db --> off

ftpd_use_passive_mode --> off

httpd_enable_ftp_server --> off

tftp_anon_write --> off

[[email protected] ~]# setsebool -P ftp_home_dir on

为 vsftpd 启动 vsftpd：                                    [确定]

pasv_max_port=30999

<groupId>commons-net</groupId>

<artifactId>commons-net</artifactId>

</dependency>

[[email protected] ~]#mkdir -p /home/ftpuser/ego/images

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.net.SocketException;

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

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

public class TestFtp {

static String baseUrl = "/home/ftpuser/ego/images";

public static void main(String[] args) {

//1、建立和服务端的连接

FTPClient client = new FTPClient();

try {

client.connect("192.168.23.12", 21);

//2、身份认证

client.login("ftpuser", "ftpuser");

//3、指定源文件

File file = new File("F:\\图片\\5b7a8115N89613314.jpg");

InputStream local = new FileInputStream(file);

//4、指定文件上传的方式   二进制字节码

client.setFileType(FTP.BINARY_FILE_TYPE);

//5、指定上传目录  默认是/home/ftpuser，即ftpuser用户的家目录

// 切换到ftpuser用户来创建目录。     /home/ftpuser/ego/images/

client.changeWorkingDirectory("/home/ftpuser/ego/images");

//6、设置文件上传的模式，指定为被动模式

client.enterLocalPassiveMode();

boolean flag = client.storeFile("test.jpg", local);

if(flag){

System.out.println("上传成功");

}else{

System.out.println("上传失败");

}

} catch (SocketException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

}

import java.io.IOException;

import java.io.InputStream;

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

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

public class FtpUtils {

FTPClient client = null;

/**

* 文件上传

* @param hostName   ftp主机名

* @param port       ftp主机端口

* @param username   上传用户名

* @param password   上传用户密码

* @param basePath   上传基础路径

* @param filePath   文件存放路径

* @param remoteFileName  上传后文件名称

* @param in         文件输入流

* @return

*/

public static boolean upload(String hostName,int port,String username,String password,String basePath,

String filePath,String remoteFileName,InputStream in){

//1、创建客户端

FTPClient client = new FTPClient();

try {

//2、建立和服务端的链接

client.connect(hostName, port);

//3、登陆服务端

client.login(username, password);

//4、指定图片上传的方式为二进制，即字节流

client.setFileType(FTP.BINARY_FILE_TYPE);

//5、指定上传的访问模式为被动模式    说明：大部分的操作系统，默认的都是被动模式，并且禁用了主动了模式

client.enterLocalPassiveMode();

//6、指定上传的目录     默认目录 是当前ftpuser用户的家目录

boolean flag = client.changeWorkingDirectory(basePath+filePath);

//如果切换目录失败，则创建指定的目录

if(!flag){

//创建目录失败，则可能是存在没有创建的父目录

if(!client.makeDirectory(basePath+filePath)){

String tempPath = basePath;

String[] split = filePath.split("/");

for (String string : split) {

if(null!=string && !"".equals(string)){

tempPath = tempPath+"/"+string;

//先判断第一层路径是否存在，如果不存在，则创建

if(!client.changeWorkingDirectory(tempPath)){

//如果创建第一层路径成功，则判断是否能切换到这一层路径

if(client.makeDirectory(tempPath)){

//切换失败，则返回false

if(!client.changeWorkingDirectory(tempPath)){

return false;

}

//如果创建第一层路径失败，则直接返回false

}else{

return false;

}

}

//如果有空路径，则直接跳过

}else{

continue;

}

}

}else{

//创建成功，则直接切换到指定的目录

if(!client.changeWorkingDirectory(basePath+filePath)){

return false;

}

}

}

//8、上传

boolean result = client.storeFile(remoteFileName, in);

return result;

} catch (Exception e) {

e.printStackTrace();

return false;

}finally {

//9，退出登录，并关闭连接

try {

if(client.logout()){

client.disconnect();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

[[email protected] tengine-2.1.0]# ./configure

[[email protected] sbin]# ./nginx

[[email protected] conf]# vim nginx.conf

[[email protected] conf]# service iptables restart