|
非常好的指引资料 https://www.cnblogs.com/chiangchou/p/fastdfs.html 按照这个指引可以完整不fastdfs部署出来，然后通过客户端（linux）进行文件上传下载， 安装FastDFS环境操作环境：CentOS7 X64，以下操作都是单机环境。# vim /etc/hosts
增加如下一行，这是我的IP
192.168.51.128 file.ljzsg.com
1、下载安装 libfastcommonlibfastcommon是从 FastDFS 和 FastDHT 中提取出来的公共 C 函数库，基础环境，安装即可 。
① 下载libfastcommon # wget https://github.com/happyfish100/libfastcommon/archive/V1.0.7.tar.gz ② 解压 # tar -zxvf V1.0.7.tar.gz
# cd libfastcommon-1.0.7 ③ 编译、安装 # ./make.sh
# ./make.sh install ④ libfastcommon.so 安装到了/usr/lib64/libfastcommon.so，但是FastDFS主程序设置的lib目录是/usr/local/lib，所以需要创建软链接。 # ln -s /usr/lib64/libfastcommon.so /usr/local/lib/libfastcommon.so
# ln -s /usr/lib64/libfastcommon.so /usr/lib/libfastcommon.so
# ln -s /usr/lib64/libfdfsclient.so /usr/local/lib/libfdfsclient.so
# ln -s /usr/lib64/libfdfsclient.so /usr/lib/libfdfsclient.so 2、下载安装FastDFS① 下载FastDFS # wget https://github.com/happyfish100/fastdfs/archive/V5.05.tar.gz ② 解压 # tar -zxvf V5.05.tar.gz
# cd fastdfs-5.05 ③ 编译、安装 # ./make.sh
# ./make.sh install ④ 默认安装方式安装后的相应文件与目录
A、服务脚本： /etc/init.d/fdfs_storaged
/etc/init.d/fdfs_tracker B、配置文件（这三个是作者给的样例配置文件） :
/etc/fdfs/client.conf.sample
/etc/fdfs/storage.conf.sample
/etc/fdfs/tracker.conf.sample C、命令工具在 /usr/bin/ 目录下
fdfs_appender_test
fdfs_appender_test1
fdfs_append_file
fdfs_crc32
fdfs_delete_file
fdfs_download_file
fdfs_file_info
fdfs_monitor
fdfs_storaged
fdfs_test
fdfs_test1
fdfs_trackerd
fdfs_upload_appender
fdfs_upload_file
stop.sh
restart.sh ⑤ FastDFS 服务脚本设置的 bin 目录是 /usr/local/bin， 但实际命令安装在 /usr/bin/ 下。 创建软连接
# ln -s /usr/bin/fdfs_trackerd /usr/local/bin
# ln -s /usr/bin/fdfs_storaged /usr/local/bin
# ln -s /usr/bin/stop.sh /usr/local/bin
# ln -s /usr/bin/restart.sh /usr/local/bin 3、配置FastDFS跟踪器(Tracker)配置文件详细说明参考：FastDFS 配置文件详解 ① 进入 /etc/fdfs，复制 FastDFS 跟踪器样例配置文件 tracker.conf.sample，并重命名为 tracker.conf。 # cd /etc/fdfs
# cp tracker.conf.sample tracker.conf
# vim tracker.conf ② 编辑tracker.conf ，标红的需要修改下，其它的默认即可。
# 配置文件是否不生效，false 为生效
disabled=false
# 提供服务的端口
port=22122
# Tracker 数据和日志目录地址(根目录必须存在,子目录会自动创建)
base_path=/ljzsg/fastdfs/tracker
# HTTP 服务端口
http.server_port=80 ③ 创建tracker基础数据目录，即base_path对应的目录 # mkdir -p /ljzsg/fastdfs/tracker ④ 防火墙中打开跟踪端口（默认的22122） # vim /etc/sysconfig/iptables
添加如下端口行：
-A INPUT -m state --state NEW -m tcp -p tcp --dport 22122 -j ACCEPT
重启防火墙：
# service iptables restart ⑤ 启动Tracker 初次成功启动，会在 /ljzsg/fdfsdfs/tracker/ (配置的base_path)下创建 data、logs 两个目录。 可以用这种方式启动
# /etc/init.d/fdfs_trackerd start
也可以用这种方式启动，前提是上面创建了软链接，后面都用这种方式
# service fdfs_trackerd start 查看 FastDFS Tracker 是否已成功启动 ，22122端口正在被监听，则算是Tracker服务安装成功。
# netstat -unltp|grep fdfs 
关闭Tracker命令： # service fdfs_trackerd stop ⑥ 设置Tracker开机启动 # chkconfig fdfs_trackerd on
或者：
# vim /etc/rc.d/rc.local
加入配置：
/etc/init.d/fdfs_trackerd start ⑦ tracker server 目录及文件结构
Tracker服务启动成功后，会在base_path下创建data、logs两个目录。 4、配置 FastDFS 存储 (Storage)① 进入 /etc/fdfs 目录，复制 FastDFS 存储器样例配置文件 storage.conf.sample，并重命名为 storage.conf # cd /etc/fdfs
# cp storage.conf.sample storage.conf
# vim storage.conf ② 编辑storage.conf 标红的需要修改，其它的默认即可。 # 配置文件是否不生效，false 为生效
disabled=false
# 指定此 storage server 所在 组(卷)
group_name=group1
# storage server 服务端口
port=23000
# 心跳间隔时间，单位为秒 (这里是指主动向 tracker server 发送心跳)
heart_beat_interval=30
# Storage 数据和日志目录地址(根目录必须存在，子目录会自动生成)
base_path=/ljzsg/fastdfs/storage
# 存放文件时 storage server 支持多个路径。这里配置存放文件的基路径数目，通常只配一个目录。
store_path_count=1
# 逐一配置 store_path_count 个路径，索引号基于 0。
# 如果不配置 store_path0，那它就和 base_path 对应的路径一样。
store_path0=/ljzsg/fastdfs/file
# FastDFS 存储文件时，采用了两级目录。这里配置存放文件的目录个数。
# 如果本参数只为 N（如： 256），那么 storage server 在初次运行时，会在 store_path 下自动创建 N * N 个存放文件的子目录。
subdir_count_per_path=256
# tracker_server 的列表 ，会主动连接 tracker_server
# 有多个 tracker server 时，每个 tracker server 写一行
tracker_server=file.ljzsg.com:22122
# 允许系统同步的时间段 (默认是全天) 。一般用于避免高峰同步产生一些问题而设定。
sync_start_time=00:00
sync_end_time=23:59 # 访问端口
http.server_port=80 ③ 创建Storage基础数据目录，对应base_path目录 # mkdir -p /ljzsg/fastdfs/storage
# 这是配置的store_path0路径
# mkdir -p /ljzsg/fastdfs/file ④ 防火墙中打开存储器端口（默认的 23000）
# vim /etc/sysconfig/iptables
添加如下端口行：
-A INPUT -m state --state NEW -m tcp -p tcp --dport 23000 -j ACCEPT
重启防火墙：
# service iptables restart 
⑤ 启动 Storage 启动Storage前确保Tracker是启动的。初次启动成功，会在 /ljzsg/fastdfs/storage 目录下创建 data、 logs 两个目录。
可以用这种方式启动
# /etc/init.d/fdfs_storaged start
也可以用这种方式，后面都用这种
# service fdfs_storaged start 查看 Storage 是否成功启动，23000 端口正在被监听，就算 Storage 启动成功。 # netstat -unltp|grep fdfs 
关闭Storage命令： # service fdfs_storaged stop 查看Storage和Tracker是否在通信： /usr/bin/fdfs_monitor /etc/fdfs/storage.conf 
⑥ 设置 Storage 开机启动 # chkconfig fdfs_storaged on
或者：
# vim /etc/rc.d/rc.local
加入配置：
/etc/init.d/fdfs_storaged start ⑦ Storage 目录 同 Tracker，Storage 启动成功后，在base_path 下创建了data、logs目录，记录着 Storage Server 的信息。 在 store_path0 目录下，创建了N*N个子目录： 
5、文件上传测试① 修改 Tracker 服务器中的客户端配置文件 # cd /etc/fdfs
# cp client.conf.sample client.conf
# vim client.conf 修改如下配置即可，其它默认。 # Client 的数据和日志目录
base_path=/ljzsg/fastdfs/client
# Tracker端口
tracker_server=file.ljzsg.com:22122 ② 上传测试 在linux内部执行如下命令上传 namei.jpeg 图片 # /usr/bin/fdfs_upload_file /etc/fdfs/client.conf namei.jpeg 上传成功后返回文件ID号：group1/M00/00/00/wKgz6lnduTeAMdrcAAEoRmXZPp870.jpeg 
返回的文件ID由group、存储目录、两级子目录、fileid、文件后缀名（由客户端指定，主要用于区分文件类型）拼接而成。 
三、安装Nginx上面将文件上传成功了，但我们无法下载。因此安装Nginx作为服务器以支持Http方式访问文件。同时，后面安装FastDFS的Nginx模块也需要Nginx环境。 Nginx只需要安装到StorageServer所在的服务器即可，用于访问文件。我这里由于是单机，TrackerServer和StorageServer在一台服务器上。 1、安装nginx所需环境 ① gcc 安装 ② PCRE pcre-devel 安装 # yum install -y pcre pcre-devel ③ zlib 安装 # yum install -y zlib zlib-devel ④ OpenSSL 安装 # yum install -y openssl openssl-devel 2、安装Nginx① 下载nginx # wget -c https://nginx.org/download/nginx-1.12.1.tar.gz ② 解压 # tar -zxvf nginx-1.12.1.tar.gz
# cd nginx-1.12.1 ③ 使用默认配置 ④ 编译、安装 ⑤ 启动nginx # cd /usr/local/nginx/sbin/
# ./nginx
其它命令
# ./nginx -s stop
# ./nginx -s quit
# ./nginx -s reload ⑥ 设置开机启动 # vim /etc/rc.local
添加一行：
/usr/local/nginx/sbin/nginx
# 设置执行权限
# chmod 755 rc.local ⑦ 查看nginx的版本及模块 /usr/local/nginx/sbin/nginx -V 
⑧ 防火墙中打开Nginx端口（默认的 80）
添加后就能在本机使用80端口访问了。 # vim /etc/sysconfig/iptables
添加如下端口行：
-A INPUT -m state --state NEW -m tcp -p tcp --dport 80 -j ACCEPT
重启防火墙：
# service iptables restart 
3、访问文件简单的测试访问文件 ① 修改nginx.conf # vim /usr/local/nginx/conf/nginx.conf
添加如下行，将 /group1/M00 映射到 /ljzsg/fastdfs/file/data
location /group1/M00 {
alias /ljzsg/fastdfs/file/data;
}
# 重启nginx
# /usr/local/nginx/sbin/nginx -s reload
② 在浏览器访问之前上传的图片、成功。 http://file.ljzsg.com/group1/M00/00/00/wKgz6lnduTeAMdrcAAEoRmXZPp870.jpeg 四、FastDFS 配置 Nginx 模块1、安装配置Nginx模块① fastdfs-nginx-module 模块说明 FastDFS 通过 Tracker 服务器，将文件放在 Storage 服务器存储， 但是同组存储服务器之间需要进行文件复制， 有同步延迟的问题。 假设 Tracker 服务器将文件上传到了 192.168.51.128，上传成功后文件 ID已经返回给客户端。 此时 FastDFS 存储集群机制会将这个文件同步到同组存储 192.168.51.129，在文件还没有复制完成的情况下，客户端如果用这个文件 ID 在 192.168.51.129 上取文件,就会出现文件无法访问的错误。 而 fastdfs-nginx-module 可以重定向文件链接到源服务器取文件，避免客户端由于复制延迟导致的文件无法访问错误。 ② 下载 fastdfs-nginx-module、解压 # 这里为啥这么长一串呢，因为最新版的master与当前nginx有些版本问题。
# wget https://github.com/happyfish100/fastdfs-nginx-module/archive/5e5f3566bbfa57418b5506aaefbe107a42c9fcb1.zip
# 解压
# unzip 5e5f3566bbfa57418b5506aaefbe107a42c9fcb1.zip
# 重命名
# mv fastdfs-nginx-module-5e5f3566bbfa57418b5506aaefbe107a42c9fcb1 fastdfs-nginx-module-master ③ 配置Nginx 在nginx中添加模块 # 先停掉nginx服务
# /usr/local/nginx/sbin/ngix -s stop
进入解压包目录
# cd /softpackages/nginx-1.12.1/
# 添加模块
# ./configure --add-module=../fastdfs-nginx-module-master/src
重新编译、安装
# make && make install ④ 查看Nginx的模块 # /usr/local/nginx/sbin/nginx -V 有下面这个就说明添加模块成功 
⑤ 复制 fastdfs-nginx-module 源码中的配置文件到/etc/fdfs 目录， 并修改 # cd /softpackages/fastdfs-nginx-module-master/src
# cp mod_fastdfs.conf /etc/fdfs/ 修改如下配置，其它默认 # 连接超时时间
connect_timeout=10
# Tracker Server
tracker_server=file.ljzsg.com:22122
# StorageServer 默认端口
storage_server_port=23000
# 如果文件ID的uri中包含/group**，则要设置为true
url_have_group_name = true
# Storage 配置的store_path0路径，必须和storage.conf中的一致
store_path0=/ljzsg/fastdfs/file ⑥ 复制 FastDFS 的部分配置文件到/etc/fdfs 目录 # cd /softpackages/fastdfs-5.05/conf/
# cp anti-steal.jpg http.conf mime.types /etc/fdfs/ ⑦ 配置nginx，修改nginx.conf # vim /usr/local/nginx/conf/nginx.conf 修改配置，其它的默认 在80端口下添加fastdfs-nginx模块 location ~/group([0-9])/M00 {
ngx_fastdfs_module;
}
注意： listen 80 端口值是要与 /etc/fdfs/storage.conf 中的 http.server_port=80 (前面改成80了)相对应。如果改成其它端口，则需要统一，同时在防火墙中打开该端口。
location 的配置，如果有多个group则配置location ~/group([0-9])/M00 ，没有则不用配group。 ⑧ 在/ljzsg/fastdfs/file 文件存储目录下创建软连接，将其链接到实际存放数据的目录，这一步可以省略。
# ln -s /ljzsg/fastdfs/file/data/ /ljzsg/fastdfs/file/data/M00 ⑨ 启动nginx # /usr/local/nginx/sbin/nginx 打印处如下就算配置成功 
⑩ 在地址栏访问。 能下载文件就算安装成功。注意和第三点中直接使用nginx路由访问不同的是，这里配置 fastdfs-nginx-module 模块，可以重定向文件链接到源服务器取文件。 http://file.ljzsg.com/group1/M00/00/00/wKgz6lnduTeAMdrcAAEoRmXZPp870.jpeg
客户端开发
但是我们服务器部署是拿来用的，大多少情况下是在windows使用，怎么样利用java简单实现他的访问呢，首先需要一个包：fastdfs-client-java-1.25.jar 我把包放在D盘， mvn install:install-file -DgroupId=org.csource -DartifactId=fastdfs-client-java -Dversion=5.0.4 -Dpackaging=jar -Dfile=D:\fastdfs-client-java-1.25.jar
在cmd里面执行以上指令，手工装到maven， 在pom配置文件加入： <dependency>
<groupId>org.csource</groupId>
<artifactId>fastdfs-client-java</artifactId>
<version>5.0.4</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.4</version>
</dependency>
在resources生成配置文件client.conf connect_timeout=30
network_timeout=60
tracker_server=192.168.*.*:22122
log_level=info
use_connection_pool = false
connection_pool_max_idle_time = 3600
load_fdfs_parameters_from_tracker=false
use_storage_id = false
storage_ids_filename = storage_ids.conf
http.tracker_server_port=80
http.anti_steal_token = no
http.secret_key = FastDFS1234567890 创建java文件 package com.fastdfs;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.UUID;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.io.IOUtils;
import org.csource.common.MyException;
import org.csource.common.NameValuePair;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.FileInfo;
import org.csource.fastdfs.StorageClient;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
public class TestFastDfs2 {
public String conf_filename = "D:\\code\\git\\SpringMvc\\SpringMvc\\src\\main\\resources\\client.conf";
//public String local_filename = "D:\\code\\git\\SpringMvc\\SpringMvc\\src\\main\\resources\\111.jpg";
@Before
public void setUp() throws Exception {
}
@After
public void tearDown() throws Exception {
}
@Test
public void testUpload(String local_filename,String type) {
try {
ClientGlobal.init(conf_filename);
TrackerClient tracker = new TrackerClient();
TrackerServer trackerServer = tracker.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
NameValuePair nvp [] = new NameValuePair[]{
new NameValuePair("age", "18"),
new NameValuePair("sex", "male")
};
String fileIds[] = storageClient.upload_file(local_filename, type, nvp);
System.out.println(fileIds.length);
System.out.println("组名：" + fileIds[0]);
System.out.println("路径: " + fileIds[1]);
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (MyException e) {
e.printStackTrace();
}
}
@Test
public void testDownload(String groupId,String path,String downloadpath) {
try {
ClientGlobal.init(conf_filename);
TrackerClient tracker = new TrackerClient();
TrackerServer trackerServer = tracker.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
byte[] b = storageClient.download_file(groupId, path);
System.out.println(b);
String filename=path.substring(10,path.length());
IOUtils.write(b, new FileOutputStream(downloadpath+filename));
} catch (Exception e) {
e.printStackTrace();
}
}
//获取文件详情
@Test
public void testGetFileInfo(){
try {
ClientGlobal.init(conf_filename);
TrackerClient tracker = new TrackerClient();
TrackerServer trackerServer = tracker.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
FileInfo fi = storageClient.get_file_info("group1", "M00/00/00/hHXIQVq0o76AcLwdAAJGbMNBxko743.png");
System.out.println(fi.getSourceIpAddr());
System.out.println(fi.getFileSize());
System.out.println(fi.getCreateTimestamp());
System.out.println(fi.getCrc32());
} catch (Exception e) {
e.printStackTrace();
}
}
//获取文件说明
@Test
public void testGetFileMate(){
try {
ClientGlobal.init(conf_filename);
TrackerClient tracker = new TrackerClient();
TrackerServer trackerServer = tracker.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer,
storageServer);
NameValuePair nvps [] = storageClient.get_metadata("group1", "M00/00/00/hHXIQVq0o76AcLwdAAJGbMNBxko743.png");
for(NameValuePair nvp : nvps){
System.out.println(nvp.getName() + ":" + nvp.getValue());
}
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void testDelete(){
try {
ClientGlobal.init(conf_filename);
TrackerClient tracker = new TrackerClient();
TrackerServer trackerServer = tracker.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer,
storageServer);
int i = storageClient.delete_file("group1", "M00/00/00/hHXIQFq0pgCANrbCAAJGbMNBxko949.png");
System.out.println( i==0 ? "删除成功" : "删除失败:"+i);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String []args){
TestFastDfs2 t=new TestFastDfs2();
t.testDownload("group1","M00/00/00/hHXIQFq0tKiAbXq9AAJGbMNBxko707.jpg","D:/fdfsFile/");
//t.testUpload("C:\Users\Administrator\Desktop\111.jpg","jpg");
//t.testDelete();
//t.testGetFileInfo();
//t.testGetFileMate();
//System.out.println(t.path);
}
}
好了，执行之后输入相关函数参数就可以实现上传下载，怎么生成真正的客户端程序还在研究中 以上资料来自：https://www.cnblogs.com/beyondcj/p/7160250.html
| 
转播
