Docker搭建分布式文件系统fastDFS及SpringBoot整合fastDFS

朴灿烈づ我的快乐病毒、 2022-05-18 23:53 228阅读 0赞

docker安装fastdfs镜像

docker pull morunchang/fastdfs

运行tracker

docker run -d --name tracker --net=host morunchang/fastdfs sh tracker.sh

运行storage,注意把xxx.xxx.xxx.xxx换成自己的EOS服务器IP

docker run -d --name storage --net=host -e TRACKER_IP=xxx.xxx.xxx.xxx:22122 -e GROUP_NAME= morunchang/fastdfs sh storage.sh

进入storage容器内部

docker exec -it storage  /bin/bash

修改nginx配置文件

vi /data/nginx/conf/nginx.conf

添加如下内容

location /group1/M00 {
         proxy_next_upstream http_502 http_504 error timeout invalid_header;
         proxy_cache http-cache;
         proxy_cache_valid  200 304 12h;
         proxy_cache_key $uri$is_args$args;
         proxy_pass http://fdfs_group1;
         expires 30d;
     }

退出

exit

重启storage

docker restart storage

开启端口号22122,80,23000,注意开启23000

firewall-cmd --zone=public --add-port=22122/tcp --permanent 
    firewall-cmd --zone=public --add-port=80/tcp --permanent 
    firewall-cmd --zone=public --add-port=23000/tcp --permanent

在pom.xml中引入依赖fastDFS的java客户端依赖,使用开源中国的

<dependency>
                <groupId>net.oschina.zcx7878</groupId>
                <artifactId>fastdfs-client-java</artifactId>
                <version>1.27.0.0</version>
            </dependency>

在类路径下添加配置文件fdfs\_client.conf

connect_timeout=30
    
    network_timeout=60
    
    base_path=/home/fastdfs
    
    #xxx.xxx.xxx.xxx改为自己EOS服务器的ip
    tracker_server=xxx.xxx.xxx.xxx: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

写一个demo测试使用

package com.lhc.fastdfs.test;
    
    
    import org.csource.fastdfs.*;
    import org.springframework.core.io.ClassPathResource;
    
    public class TestFastDFS { 
    
        public static void main(String[] args) throws Exception {
            String filePath = new ClassPathResource("fdfs_client.conf").getFile().getAbsolutePath();
            // 1、加载配置文件，配置文件中的内容就是 tracker 服务的地址。
            ClientGlobal.init(filePath);
            // 2、创建一个 TrackerClient 对象。直接 new 一个。
            TrackerClient trackerClient = new TrackerClient();
            // 3、使用 TrackerClient 对象创建连接，获得一个 TrackerServer 对象。
            TrackerServer trackerServer = trackerClient.getConnection();
            // 4、创建一个 StorageServer 的引用，值为 null
            StorageServer storageServer = null;
            // 5、创建一个 StorageClient 对象，需要两个参数 TrackerServer 对象、StorageServer 的引用
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            // 6、使用 StorageClient 对象上传图片。
            //扩展名不带“.”
            String[] strings = storageClient.upload_file("C:\Users\Administrator\Desktop\timg.jpg", "jpg",
                null);
    
            // 7、返回数组。包含组名和图片的路径。
            for (String string : strings) {
                System.out.println(string);
            }
        }
    }

输出  
group1  
M00/00/00/rBL-lVtN0uKAImXSAAAVnhPk2K8504.png  
访问fastDFS文件系统,效果如下,可见已经存储在文件系统中  
[http://xxx.xxx.xxx.xxx:8080/group1/M00/00/00/rBL-lVtN2OCAJS0UAAE7\_YSxmAs135.jpg][http_xxx.xxx.xxx.xxx_8080_group1_M00_00_00_rBL-lVtN2OCAJS0UAAE7_YSxmAs135.jpg]  
![这里写图片描述][70]

使用angular.js上传文件  
html的内容如下

<!DOCTYPE html>
    <html lang="en">
    <head>
        <meta charset="UTF-8">
        <title>Index</title>
    </head>
    
    <script type="text/javascript" src="webjars/angularjs/1.7.2/angular.min.js"></script>
    
    <body>
    <div ng-app="myApp" ng-controller="myCon">
    
    
            <input type="file" name="uploadFile" id="uploadFile">
    
            <input type="button" value="upload" ng-click="uploadFile()">
    
            <img src="{ {image.url}}" width="200px" height="200px">
    
    </div>
    
    </body>
    
        <script type="text/javascript" src="userController.js"></script>
    </html>

controller的js如下

springboot后台代码如下,其中FastDFSClient,为对fastDFS的客户端的操作代码的封装,大家可以自己封装一下

@RestController
    public class UserController { 
    
        @Value("${FILE_URL}")
        private String FILE_URL;
    
        @RequestMapping("/uploadFile")
        public R upload(@RequestParam(value = "file",required = true) MultipartFile file)throws Exception{
    
            String originalFilename = file.getOriginalFilename();
    
            String name = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
    
            FastDFSClient fastDFSClient = new FastDFSClient("classpath:fdfs_client.conf");
    
            String s = fastDFSClient.uploadFile(file.getBytes(), name);
            System.out.println(s);
    
            R r = new R();
            r.setMessage(FILE_URL+s);
            r.setStatus("200");
    
            return r;
        }
    }

选择文件点击上传后效果如下  
![这里写图片描述][70 1]

[http_xxx.xxx.xxx.xxx_8080_group1_M00_00_00_rBL-lVtN2OCAJS0UAAE7_YSxmAs135.jpg]: http://xxx.xxx.xxx.xxx:8080/group1/M00/00/00/rBL-lVtN2OCAJS0UAAE7_YSxmAs135.jpg
[70]: /images/20220519/b30d6950227d4bd4aaa2817cdda4d143.png
[70 1]: /images/20220519/07ad66d44a964cfdabb307f0f1ab55a9.png