该篇讲述FastDFS和Nginx的优化过程，希望对于初学Nginx服务器相关的朋友有帮助，更多Nginx安装、配置、报错处理等资源请本站内搜索。。
生产环境结果应该如下：
本文tracker、storage都在一台机器上！本机既是tracker，又是storage，仅用于测试！
一、需要下载的
fastdfs-nginx-module_v1.15.tar.gz
nginx-1.4.1.tar.gz
libevent-2.0.21-stable.tar.gz
FastDFS_v4.06.tar.gz
二、安装
1、安装libevent,nginx都是一个套路
tar –xvf xxxxxx.tar.gz
./configure --prefix=xxxxxxx
make && make install
不多说。
2、安装FastDFS
指定下刚才安装的libevent的path
/make.sh C_INCLUDE_PATH=/usr/local/libevent/include LIBRARY_PATH=/usr/local/libevent/lib
/make.shinstall
3、配置FastDFS
PS，FastDFS分为三个Server
Tracker：接受请求，调度请求，路由请求
Storage：文件存放的地方
Client：客户端，发起请求
默认配置文件在/etc/fdfs/，有需要可以修改。
配置项都有注释，仅列一下我修改了的
base_path=/fdfs
# base_path 附目录说明:
tracker server目录及文件结构：
${base_path}
|__data
| |__storage_groups.dat：存储分组信息
| |__storage_servers.dat：存储服务器列表
|__logs
|__trackerd.log：tracker server日志文件
base_path=/fdfs
store_path0=/fdfs
tracker_server=192.168.20.160:22122
base_path=/fdfs
tracker_server=192.168.20.160:22122
http.tracker_server_port=8888(改成nginx的端口)
改完上面的配置文件，已经基本OK了
启动tracker
fdfs_trackerd /etc/fdfs/tracker.conf
启动storage
fdfs_storaged /etc/fdfs/storage.conf
上传文件
fdfs_upload_file /etc/fdfs/http.conf /tmp/f.png
--返回group1/M00/00/00/wKgUoFGwT1WAFqIfAAA-xlb-210799.png
下面配置下nginx，让你上传文件可以通过url访问到
1.修改nginx配置文件
location /M00 {
root /fdfs/data;
ngx_fastdfs_module;
}
2.fastdfs的nginx的module中的mod_fastdfs.conf,copy到/etc/fdfs下，修改配置
base_path=/tmp
tracker_server=192.168.20.160:22122
store_path0=/fdfs
3.启动nginx，
http://192.168.20.160:8888/M00/00/00/wKgUoFGwT1WAFqIfAAA-xlb-210799.png
可以访问到刚才上传的图片！
这里不需要/group1，如果想在url中加入group1，需要修改fdfs的配置文件和nginx的配置文件！
三、Java client
public String conf_filename =
"F:workspacefastdfssrcfdfs_client.conf";
public String local_filename =
"F:workspacefastdfssrcfdfs_client.conf";
@org.junit.Test
public void testUpload() {
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("age", "18");
NameValuePair nvp [] = new NameValuePair[]{
new NameValuePair("age", "18"),
new NameValuePair("sex", "male")
};
String fileIds[] = storageClient.upload_file(local_filename,
null,
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();
}
}
@org.junit.Test
public void testDownload() {
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("group1",
"M00/00/00/wKgUoFGwPuSAS-QZAAAA4y5hK3c33.conf");
System.out.println(b);
getFile(b, "d:", UUID.randomUUID().toString()+".conf");
} catch (Exception e)
{
e.printStackTrace();
}
}
@org.junit.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/wKgUoFGwPuSAS-QZAAAA4y5hK3c33.conf");
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();
}
}
@org.junit.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/wKgUoFGwRMmASXSNAAAA4y5hK3c11.conf");
for(NameValuePair nvp : nvps){
System.out.println(nvp.getName() + ":" + nvp.getValue());
}
} catch (Exception e)
{
e.printStackTrace();
}
}
@org.junit.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/wKgUoFGwRMmASXSNAAAA4y5hK3c11.conf");
System.out.println( i==0 ? "删除成功" : "删除失败:"+i);
} catch (Exception e)
{
e.printStackTrace();
}
}
声明： 此文观点不代表本站立场；转载须要保留原文链接；版权疑问请联系我们。
