2. 程式人生 > >分享知識-快樂自己：FastDFS 上傳 java 原始碼

分享知識-快樂自己：FastDFS 上傳 java 原始碼

阿新 • • 發佈：2018-12-06

FastDFS 上傳 java 原始碼：點我下載原始碼

首先匯入 POM 檔案：解決 maven 不能下載 fastdfs-client-java JAR

<dependency>
    <groupId>org.csource</groupId>
    <artifactId>fastdfs-client-java</artifactId>
    <version>1.27-SNAPSHOT</version>
</dependency>

<dependency>
    <groupId>commons-io</groupId>
    <artifactId>commons-io</artifactId>
    <version>2.4</version>
</dependency>

建立 fdfs_client.conf 檔案：

 
 
connect_timeout=2
network_timeout=30
charset=UTF-8
http.tracker_http_port=80
http.anti_steal_token=no
http.secret_key=FastDFS1234567890

tracker_server=192.168.31.202:22122 
#對應自己的tracker服務IP地址
 
 

或者使用：fastdfs.properties
 
 
 
#FastDFS配置begin-----------除了fastdfs.tracker_servers，其它配置項都是可選的
fastdfs.connect_timeout_in_seconds
 
=5
fastdfs.network_timeout_in_seconds=30
fastdfs.charset=UTF-8
fastdfs.http_anti_steal_token=false
fastdfs.http_secret_key=FastDFS1234567890
fastdfs.http_tracker_http_port=80
fastdfs.tracker_servers=192.168.31.202:22122
#FastDFS配置end-----------
 
 

這裡只測試了上傳一張圖片，然後下載這張圖片；具體java程式碼：
 
 
 
package com.gdbd;


 
import org.apache.commons.io.IOUtils;
import org.csource.common.MyException;
import org.csource.fastdfs.*;
import org.junit.jupiter.api.Test;

import java.io.FileOutputStream;
import java.io.IOException;
import java.util.UUID;

/**
 * @author asus
 */
public class FastdfsUpload {

    /***
     * 圖片檔案上傳
     */
    @Test
    public void upload() {
        try {
            // 初始化全域性配置。載入一個配置檔案。
            //ClientGlobal.init("fdfs_client.conf");
            ClientGlobal.initByProperties("fastdfs.properties");
            // 建立一個TrackerClient物件。
            TrackerClient trackerClient = new TrackerClient();
            // 建立一個TrackerServer物件。
            TrackerServer trackerServer = trackerClient.getConnection();
            // 宣告一個StorageServer物件，null。
            StorageServer storageServer = null;
            // 獲得StorageClient物件。
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            // 直接呼叫StorageClient物件方法上傳檔案即可。
            String[] strings;
            strings = storageClient.upload_file("imgs/002.jpg", "jpg", null);
            for (String string : strings) {
                System.out.println(string);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (MyException e) {
            e.printStackTrace();
        }
    }

    /***
     * 圖片檔案下載
     */
    @Test
    public void download() {
        try {
            // 初始化全域性配置。載入一個配置檔案
            ClientGlobal.init("fdfs_client.conf");
            // 建立一個TrackerClient物件
            TrackerClient tracker = new TrackerClient();
            // 建立一個TrackerServer物件。
            TrackerServer trackerServer = tracker.getConnection();
            // 宣告一個StorageServer物件，
            StorageServer storageServer = null;
            // 獲得StorageClient物件
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            byte[] b = storageClient.download_file("group1", "M00/00/00/wKgfylwIv72AHyAVAAB38Soj7rc851.jpg");
            System.out.println(b);
            // 將下載的檔案流儲存
            IOUtils.write(b, new FileOutputStream("DownLoadFile/" + UUID.randomUUID().toString() + ".jpg"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}
 
 

在開始測試時遇到一個異常：（沒有報錯直接跳過）
 

  
  
  
connect to server 192.168.206.139:22122 fail
java.net.SocketTimeoutException: connect timed out
    at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:579)
    at org.csource.fastdfs.TrackerGroup.getConnection(TrackerGroup.java:47)
    at org.csource.fastdfs.TrackerGroup.getConnection(TrackerGroup.java:72)
    at org.csource.fastdfs.TrackerClient.getConnection(TrackerClient.java:58)
    at FastDFS.upload(FastDFS.java:26)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
connect to server 192.168.206.139:22122 fail
java.net.SocketTimeoutException: connect timed out
    at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:579)
    at org.csource.fastdfs.TrackerGroup.getConnection(TrackerGroup.java:47)
    at org.csource.fastdfs.TrackerGroup.getConnection(TrackerGroup.java:72)
    at org.csource.fastdfs.TrackerClient.getConnection(TrackerClient.java:58)
    at org.csource.fastdfs.TrackerClient.getStoreStorage(TrackerClient.java:91)
    at org.csource.fastdfs.StorageClient.newWritableStorageConnection(StorageClient.java:1938)
    at org.csource.fastdfs.StorageClient.do_upload_file(StorageClient.java:703)
    at org.csource.fastdfs.StorageClient.upload_file(StorageClient.java:164)
    at org.csource.fastdfs.StorageClient.upload_file(StorageClient.java:132)
    at org.csource.fastdfs.StorageClient.upload_file(StorageClient.java:114)
    at FastDFS.upload(FastDFS.java:33)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
org.csource.common.MyException: getStoreStorage fail, errno code: 0
    at org.csource.fastdfs.StorageClient.newWritableStorageConnection(StorageClient.java:1941)
    at org.csource.fastdfs.StorageClient.do_upload_file(StorageClient.java:703)
    at org.csource.fastdfs.StorageClient.upload_file(StorageClient.java:164)
    at org.csource.fastdfs.StorageClient.upload_file(StorageClient.java:132)
    at org.csource.fastdfs.StorageClient.upload_file(StorageClient.java:114)
    at FastDFS.upload(FastDFS.java:33)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
 
  
 View Code
 

連線超時問題，這是由於linux沒有開放22122埠和23000埠所致，我們可以關閉linux的防火牆iptables，但是不推薦這樣做，會有安全問題，建議將這兩個埠新增到防火牆開放埠中：
 
 
 
#關閉防火牆命令
service iptables stop
 
 
 
 
#將22111和23000埠新增到防火牆中
/sbin/iptables -I INPUT -p tcp --dport 22122 -j ACCEPT
/sbin/iptables -I INPUT -p tcp --dport 23000 -j ACCEPT

#儲存iptables
/etc/rc.d/init.d/iptables save

#重啟iptables
service iptables restart
 
 

配置完iptables，再測試上傳就會成功，打印出上傳資訊：
 

 

 
 

可以將列印的上傳資訊在瀏覽器中檢視是否上傳成功：
 

 
 

 
   
 
 
 
 

            
  

           

              
              

            

            
相關推薦

			   
            
            
            
 

    


    
    
分享知識-快樂自己：FastDFS 上傳 java 原始碼

     
 FastDFS 上傳 java 原始碼：點我下載原始碼 
首先匯入 POM 檔案：解決 maven 不能下載 fastdfs-client-java JAR 
 
 <dependency>
    <groupId>org.csource</groupId>
     



  
 

    


    
    
分享知識-快樂自己：Struts2檔案上傳及檔案下載

     
 1）Struts2單檔案上傳 
 
  
action：類檔案 
 
 package com.mlq.action;

import com.opensymphony.xwork2.ActionSupport;
import org.apache.commons.io.FileUtils;
imp 



  
 

    


    
    
分享知識-快樂自己：Spring切入點的表達式和通知類型

     
 win   返回值   size   正常   執行   println   ble   tps   www   1.切入點的表達式
表達式格式：

execution([修飾符] 返回值類型 包名.類名.方法名(參數))

其他的代替：


<!-- 完全指定一個方法 -->
<!-- & 



  
 

    


    
    
分享知識-快樂自己：搭建第一個 Hibernate （Demo）

     
 分享圖片   depend   文件夾   super   bbb   tool   ets   數據庫配置   unicode   使用 Hibernate 完成持久化操作 七大 步驟：
1、讀取並解析配置文件及映射文件：
　　Configuration configuration=new Configur 



  
 

    


    
    
分享知識-快樂自己：SpringMvc中 頁面日期格式到後臺的類型轉換

     
 字符串   ima   www.   format)   clas   tco   demo   cef   定義   日期格式的類型轉換：
　　以往在 from 表單提交的時候，都會有字符串、數字、還有時間格式等信息。　往往如果是數字提交的話底層會自動幫我們把類型進行了隱式轉換。
　　但是日期格式的卻不能自 



  
 

    


    
    
分享知識-快樂自己：Hibernate對象的三種狀態

     
 png   delete   rup   load()   ear   比較   lec   alt   使用   圖解：

 
1）：瞬時狀態（Transient）
　　對象與session沒有關聯，數據庫中沒有對應的數據。
　　一般new出來的對象便是瞬時對象。
　　對瞬時對象使用save()方法便使之成 



  
 

    


    
    
分享知識-快樂自己：Hibernate 中Criteria Query查詢詳解

     
 limit   all   des   結合   project   實現簡單   result   eager   sele   1）：Hibernate 中Criteria Query查詢詳解
當查詢數據時，人們往往需要設置查詢條件。在SQL或HQL語句中，查詢條件常常放在where子句中。
此外，Hib 



  
 

    


    
    
分享知識-快樂自己：oracle12c建立使用者提示ORA-65096：公用使用者名稱或角色無效

     
 今天在oracle12c上建立使用者，報錯了。如下圖： 
 
我很鬱悶， 就打開了oracle官方網站找了下， 發現建立使用者是有限制的。 
2.解決方案 
建立使用者的時候使用者名稱以c##或者C##開頭即可。 
 
 錯誤寫法： create user zhaojiedi identified by or 



  
 

    


    
    
分享知識-快樂自己：oracle12c創建用戶提示ORA-65096：公用用戶名或角色無效

     
 語句   mod   租用   內容   rac   取消   nis   步驟   ORC   今天在oracle12c上創建用戶，報錯了。如下圖：

我很郁悶， 就打開了oracle官方網站找了下， 發現創建用戶是有限制的。
2.解決方案
創建用戶的時候用戶名以c##或者C##開頭即可。

錯誤寫法： c 



  
 

    


    
    
分享知識-快樂自己： Oracle數據庫實例、用戶、表、表空間之間關系

     
 相同   表數   包含   每一個   oracle版本   有一個   http   instance   但是   數據庫：
　　Oracle數據庫是數據的物理存儲。這就包括（數據文件ORA或者DBF、控制文件、聯機日誌、參數文件）。
　　其實Oracle數據庫的概念和其它數據庫不一樣，這裏的數據庫是一 



  
 

    


    
    
分享知識-快樂自己： Oracle資料庫例項、使用者、表、表空間之間關係

     
 資料庫： 
　　Oracle資料庫是資料的物理儲存。這就包括（資料檔案ORA或者DBF、控制檔案、聯機日誌、引數檔案）。 
　　其實Oracle資料庫的概念和其它資料庫不一樣，這裡的資料庫是一個作業系統只有一個庫。可以看作是Oracle就只有一個大資料庫。 
例項： 
　　一個Oracle例項（Oracle  



  
 

    


    
    
分享知識-快樂自己：MySQL中的約束,新增約束,刪除約束,以及一些其他修飾

     
 建立資料庫： 
 
 CREATE DATABASES 資料庫名； 
 
選擇資料庫： 
 
 USE 資料庫名； 
 
刪除資料庫： 
 
 DROP DATAVBASE 資料庫名； 
 
建立表： 
 
 CREATE TABLE IF NOT NULL EXISTS 表名 （欄位1 資料型別 【欄位屬性 



  
 

    


    
    
分享知識-快樂自己：全面解析 java註解實戰指南

     
 請你在看這篇文章時，不要感到枯燥，從頭到尾一行行看，程式碼一行行讀，你一定會有所收穫的。 
問： 
　　為什麼學習註解？ 
　　學習註解有什麼好處？ 
　　學完能做什麼？ 
答： 
　　1）：能夠讀懂別人的程式碼，特別是框架相關的程式碼 
　　2）：讓程式設計更加簡潔，程式碼更加清晰 
　　3）：讓別人高看一 



  
 

    


    
    
分享知識-快樂自己：Hibernate物件的三種狀態

     
 圖解： 
 
  
1）：瞬時狀態（Transient） 
　　物件與session沒有關聯，資料庫中沒有對應的資料。 
　　一般new出來的物件便是瞬時物件。 
　　對瞬時物件使用save()方法便使之成為持久物件。 
　　由於資料庫中沒有對應的資料，所以對瞬時物件使用update()方法無效。  



  
 

    


    
    
分享知識-快樂自己：Hibernate框架常用API詳解

     
 1）：Configuration配置物件 
Configuration用於載入配置檔案。 
1）： 呼叫configure()方法，載入src下的hibernate.cfg.xml檔案 
　　　　Configuration conf = new Configuration().configure(); 
2） 



  
 

    


    
    
分享知識-快樂自己：Hibernate 中 get() 和 load()、sava、update、savaOrUpdate、merge，不同之處及執行原理？

     
 1)：Hibernate 中 get()  和 load() 有什麼不同之處? 
1）Hibernate的 get方法，會確認一下該id對應的資料是否存在，首先在session快取中查詢，然後在快取中查詢，還沒有就查詢資料庫，資料庫中沒有就返回null。 
2）Hibernate的 load方法載入 



  
 

    


    
    
分享知識-快樂自己：java 中的訪問修飾符

     
 1）：Java中的訪問修飾符： 
Java面向物件的基本思想之一是封裝細節並且公開介面。Java語言採用訪問控制修飾符來控制類及類的方法和變數的訪問許可權，從而向使用者暴露介面，但隱藏實現細節。 
訪問控制分為四種級別： 
1）：public： 用public修飾的類、類屬變數及方法，包內及包外的任何類（包括 



  
 

    


    
    
分享知識-快樂自己：Oracle SQL語法彙總

     
 --刪除重複值-保留重複值最大的編號 
 
 delete from emp where rowid in(
  select rowid from emp where rowid not in(
  select max(rowid) rd from emp group by empname)
) 
 
  



  
 

    


    
    
分享知識-快樂自己：Oracle中定義及使用同義詞

     
 Oracle 同義詞概念： 
　　Oracle的同義詞（synonyms）從字面上理解就是別名的意思，和檢視的功能類似，就是一種對映關係。 
　　它可以節省大量的資料庫空間，對不同使用者的操作同一張表沒有多少差別;它擴充套件了資料庫的使用範圍，能夠在不同的資料庫使用者之間實現無縫交互;Oracle資料庫中提供 



  
 

    


    
    
分享知識-快樂自己：Mybatis快取機制

     
 論快取機制： 

 1）：mybatis 提供了快取機制減輕資料庫壓力，提高資料庫效能。
 

 2）：mybatis 的快取分為兩級：一級快取、二級快取
 

 3）：一級快取是SqlSession級別的快取，快取的資料只在SqlSession內有效。
 

 4）：二級快取是mapper級別的快取，同一個