申请会员ID: lovelyhedong
1、申 请 I D：lovelyhedong
2、个人邮箱：755964539@qq.com
3、原创技术文章：linux安装fastdfs，并且java上传下载对象文件
Linux------FASTDFS安装
cd /usr/local/
mkdir fdfs
cd fdfs
wget https://github.com/happyfish100/fastdfs/archive/master.zip -O ./fastdfs_server.zip
wget https://github.com/happyfish100/libfastcommon/archive/master.zip -O ./libfastcommon.zip
wget https://github.com/happyfish100/fastdfs-nginx-module/archive/master.zip -O./fastdfs-nginx-module.zip
unzip fastdfs-nginx-module.zip
unzip fastdfs_server.zip
unzip libfastcommon.zip
cd libfastcommon-master
./make.sh
./make.sh install
cd ..
cd fastdfs-master
./make.sh
./ make.sh install
cd /etc/fdfs/
cp tracker.conf.sample tracker.conf
cp storage.conf sample storage.conf
cp client.conf.sample client.conf
vim tracker.conf
修改22行:
base_path=/home/yuqing/fastdfs/
修改22行后:
base_path=/home/fastdfs/
修改261行:
http.server_port=8888
修改261行后:
http.server_port=80
cd /home/
mkdir fastdfs
cd fastdfs
mkdir storage
cd /etc/fdfs/
/usr/bin/fdfs_trackerd /etc/fdfs/tracker.conf
vim storage.conf
修改41行:
base_path=/home/yuqing/fastdfs/
修改41行后:
base_path=/home/fastdfs/storage
修改110行:
store_path1=/home/yuqing/fastdfs2
修改110行后:
store_path0=/home/fastdfs/storage
修改119行:
tracker_server=192.168.1.121:22122
修改119行后:
tracker_server=本机服务器ip(或者虚拟机ip):22122
修改285行:
http.server_port=8888
修改285行后:
http.server_port=80
/usr/bin/fdfs_storaged /etc/fdfs/storage.conf
cd /usr/local/fdfs/fastdfs-nginx-module-master/src/
vim mod_fastdfs.conf
修改53行:
url_have_group_name = false
修改53行后:
url_have_group_name = true
修改62行:
store_path1=/home/yuqing/fastdfs1
修改62行后:
store_path0=/home/fastdfs/storage
cp ./mod_fastdfs.conf /etc/fdfs/
cd /usr/local/fdfs/fastdfs-master/conf/
cp ./{anti-steal.jpg,http.conf,mime.types} /etc/fdfs
netstat -tunlp|grep fdfs
kill -9 xxxx -----(22122端口)
kill -9 xxxx -----(23000端口)
cd /usr/
yum install gcc-c++
yum install -y pcre pcre-devel
yum install -y zlib zlib-devel
yum install -y openssl openssl-devel
wget http://nginx.org/download/nginx-1.15.12.tar.gz -O ./nginx.tar.gz
tar -zxvf nginx.tar.gz
cd nginx-1.15.12
./configure
make
make install
cd /usr/local/nginx/conf/
vim nginx.conf
在server添加:
location /group1/M00/ {
root /home/fastdfs/storage/data;
}
location ~/group()/M00 {
ngx_fastdfs_module;
}
cd /usr/nginx-1.15.12/
./configure --add-module=/usr/local/fdfs/fastdfs-nginx-module-master/src (添加fastdfs-nginx模块)
/usr/bin/fdfs_trackerd /etc/fdfs/tracker.conf (启动tracker)
/usr/bin/fdfs_storaged /etc/fdfs/storage.conf (启动storage)
/usr/local/nginx/sbin/nginx (启动nginx)
以下是java测试上传下载删除代码
工具类代码
package com.test;
import org.csource.common.MyException;
import org.csource.common.NameValuePair;
import org.csource.fastdfs.*;
import java.io.BufferedOutputStream;
import java.io.IOException;
/**
* FastDFS工具类【实现文件上传、下载、删除、查询】
* @author lovelyhedong
*/
public class FastDFSUtil{
private static TrackerClient trackerClient = null;
private static TrackerServer trackerServer = null;
private static StorageServer storageServer = null;
private static StorageClient1 storageClient = null;
static {
try {
ClientGlobal.init("fdfs_client.conf");
trackerClient = new TrackerClient();
trackerServer = trackerClient.getConnection();
storageServer = null;
storageClient = new StorageClient1(trackerServer, storageServer);
}catch(Exception e) {
e.printStackTrace();
}
}
/**
* 上传文件方法
* <p>Title: uploadFile</p>
* <p>Description: </p>
* @param fileName 文件全路径
* @param extName 文件扩展名，不包含（.）
* @param metas 文件扩展信息
* @return
* @throws Exception
*/
public static String uploadFile(String fileName, String extName, NameValuePair[] metas) {
String result=null;
try {
result = storageClient.upload_file1(fileName, extName, metas);
} catch (IOException e) {
e.printStackTrace();
} catch (MyException e) {
e.printStackTrace();
}
return result;
}
/**
* 上传文件,传fileName
* @param fileName 文件的磁盘路径名称 如：D:/image/aaa.jpg
* @return null为失败
*/
public static String uploadFile(String fileName) {
return uploadFile(fileName, null, null);
}
/**
*
* @param fileName 文件的磁盘路径名称 如：D:/image/aaa.jpg
* @param extName 文件的扩展名 如 txt jpg等
* @return null为失败
*/
public static String uploadFile(String fileName, String extName) {
return uploadFile(fileName, extName, null);
}
/**
* 上传文件方法
* <p>Title: uploadFile</p>
* <p>Description: </p>
* @param fileContent 文件的内容，字节数组
* @param extName 文件扩展名
* @param metas 文件扩展信息
* @return
* @throws Exception
*/
public static String uploadFile(byte[] fileContent, String extName, NameValuePair[] metas) {
String result=null;
try {
result = storageClient.upload_file1(fileContent, extName, metas);
} catch (IOException e) {
e.printStackTrace();
} catch (MyException e) {
e.printStackTrace();
}
return result;
}
/**
* 上传文件
* @param fileContent 文件的字节数组
* @return null为失败
* @throws Exception
*/
public static String uploadFile(byte[] fileContent) throws Exception {
return uploadFile(fileContent, null, null);
}
/**
* 上传文件
* @param fileContent文件的字节数组
* @param extName文件的扩展名 如 txtjpg png 等
* @return null为失败
*/
public static String uploadFile(byte[] fileContent, String extName) {
return uploadFile(fileContent, extName, null);
}
/**
* 文件下载到磁盘
* @param path 图片路径
* @param output 输出流 中包含要输出到磁盘的路径
* @return -1失败,0成功
*/
public static int download_file(String path,BufferedOutputStream output) {
int result=-1;
try {
byte[] b = storageClient.download_file1(path);
try{
if(b != null){
output.write(b);
result=0;
}
}catch (Exception e){} //用户可能取消了下载
finally {
if (output != null){
try {
output.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
/**
* 获取文件数组
* @param path 文件的路径 如group1/M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg
* @return
*/
public static byte[] download_bytes(String path) {
byte[] b=null;
try {
b = storageClient.download_file1(path);
} catch (IOException e) {
e.printStackTrace();
} catch (MyException e) {
e.printStackTrace();
}
return b;
}
/**
* 删除文件
* @param group 组名 如：group1
* @param storagePath 不带组名的路径名称 如：M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg
* @return -1失败,0成功
*/
public static Integer delete_file(String group ,String storagePath){
int result=-1;
try {
result = storageClient.delete_file(group, storagePath);
} catch (IOException e) {
e.printStackTrace();
} catch (MyException e) {
e.printStackTrace();
}
returnresult;
}
/**
*
* @param storagePath文件的全部路径 如：group1/M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg
* @return -1失败,0成功
* @throws IOException
* @throws Exception
*/
public static Integer delete_file(String storagePath){
int result=-1;
try {
result = storageClient.delete_file1(storagePath);
} catch (IOException e) {
e.printStackTrace();
} catch (MyException e) {
e.printStackTrace();
}
returnresult;
}
/**
* 获取远程服务器文件资源信息
* @param groupName 文件组名 如：group1
* @param remoteFileName M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg
* @return
*/
public static FileInfo getFile(String groupName,String remoteFileName){
try {
return storageClient.get_file_info(groupName, remoteFileName);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}
测试代码
package com.test.test;
import java.io.IOException;
import java.util.LinkedHashMap;
import java.util.Map;
import org.csource.common.MyException;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient1;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerGroup;
import org.csource.fastdfs.TrackerServer;
import com.test.FastDFSUtil;
import com.test.FastDFSUtils;
import cn.hutool.core.date.DateUtil;
public class MainTest {
public static void main(String[] args) throws IOException, MyException {
ClientGlobal.init("fdfs_client.conf");
System.out.println("ClientGlobal.configInfo(): " + ClientGlobal.configInfo());
TrackerGroup group= ClientGlobal.g_tracker_group;
TrackerClient trackerClient=new TrackerClient(group);
TrackerServer trackerServer=trackerClient.getConnection();
StorageServer storageServer=trackerClient.getStoreStorage(trackerServer);
// StorageClient storageClient=new StorageClient(trackerServer, storageServer);
StorageClient1 storageClient1=new StorageClient1(trackerServer, storageServer);
// Integer delete_file = FastDFSUtil.delete_file("group1/M00/00/00/rBsAEFzAL0iASL-eAASpeEkOW6c968.jpg");
// System.out.println("删除："+delete_file);
// String uploadFile = FastDFSUtil.uploadFile("C:\\Users\\Administrator\\Desktop\\110.png");
// //group1/M00/00/00/rBsAEFy-wYiAV32HAAfbmiK0IQo766.png
// System.out.println("文件路径地址："+uploadFile);
// System.out.println("ac929c28562b9253a0726d86f28dc393".length());
}
}
抱歉，未能达到申请要求，申请不通过，可以关注论坛官方微信（吾爱破解论坛），等待开放注册通知。
页:
[1]