亚洲av成人无遮挡网站在线观看,少妇性bbb搡bbb爽爽爽,亚洲av日韩精品久久久久久,兔费看少妇性l交大片免费,无码少妇一区二区三区

  免費注冊 查看新帖 |

Chinaunix

  平臺 論壇 博客 文庫
最近訪問板塊 發(fā)新帖
查看: 11197 | 回復(fù): 6
打印 上一主題 下一主題

[FastDFS] fdfs-java-pool連接池V1.0版本 [復(fù)制鏈接]

論壇徽章:
0
跳轉(zhuǎn)到指定樓層
1 [收藏(0)] [報告]
發(fā)表于 2012-12-25 12:10 |只看該作者 |倒序瀏覽
本帖最后由 zhanghua1199 于 2012-12-25 12:11 編輯

fdfs--java--v1.0連接池.zip (21.79 KB, 下載次數(shù): 488)
這是以前的版本說明,可以參考一下。
因為業(yè)務(wù)場景web管理平臺上傳文件,但由于使用fastdfs java api得到的連接并不支持多線程,但也不能每次申請一個接連之后就關(guān)閉(浪費資源)。故需要一個連接池來提高操作文件效率


以下是我看fastdfs java api源代碼的時候總結(jié)出來的一點小東東,能明白就明白,不明白也行(寫的比較亂)。

        使用storageClient上傳文件時,如果storageServer為null,則程序自動
         創(chuàng)建trackerServer,根據(jù)trackerServer得到storageServer,并返回storageServer
         ,在返回storageServer之前會關(guān)閉trackerServer。通過storageServer上傳完文件
         之后,關(guān)閉storageServer.
          反之storageServer不為null則不會被關(guān)閉。
         按這個邏輯,創(chuàng)建完storageClient,storageServer,則trackerServer就可以關(guān)閉了。
         其實不然,這樣得到的storageClient上傳文件只會上傳到storageServer所指向的主機,比方說,

         現(xiàn)有a,b兩臺主機,程序獲得的storageServer只指向a.以后使用storageclient上傳的文件都會
         上傳到a的storage,并不會上傳b的storage.這樣導(dǎo)致不平衡
         正常做法建議:trackerServer可以創(chuàng)建連接池,storageServer每次上傳文件都重新創(chuàng)建一個。

目前發(fā)表這個是更新版,修改了幾個bug,和增加了點功能。

1、本連接池是個人所寫,公司內(nèi)部在用()。
2、目前接口只提供了上傳和刪除操作,其它操作需要自己增加。

        連接池代碼更新版,新增以下參數(shù)
        size--->連接池大小。默認(rèn)2個
        waitTimes --->等待超時,默認(rèn)兩秒,單位為秒
        其它不變。一般構(gòu)造形式如下:
        只帶域名
        ImageServer ims=new ImageServerImpl("imageserver.com");
         
        帶有端口形式如下:
        ImageServer ims=new ImageServerImpl("imageserver.com",22122);
         
        帶有連接池大小構(gòu)造如下:
        ImageServer ims=new ImageServerImpl("imageserver.com",22122,5);
         
        設(shè)置等待超時:
        ims.setWaitTimes( 5 ); //五秒
3、支持當(dāng)管理平臺的使用連接池與fdfs連接,當(dāng)fdfs宕機,重啟后,管理平臺無需重啟,連接自動建立。

論壇徽章:
0
2 [報告]
發(fā)表于 2012-12-25 12:13 |只看該作者
如果發(fā)現(xiàn)什么bug,望及時到
謝  212801927(群)里的指點

論壇徽章:
0
3 [報告]
發(fā)表于 2013-10-24 14:08 |只看該作者
使用了你提供的連接池。但是發(fā)現(xiàn)一個問題連接池初始化大小最多只能裝36個。再大的話在初始化連接池時調(diào)用org.csource.fastdfs.ProtoCommon.activeTest(trackerServer.getSocket());會報錯 異常為:
java.net.SocketException: Software caused connection abort: recv failed
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.read(SocketInputStream.java:129)
        at java.net.SocketInputStream.read(SocketInputStream.java:90)
        at org.csource.fastdfs.ProtoCommon.recvHeader(ProtoCommon.java:212)
        at org.csource.fastdfs.ProtoCommon.activeTest(ProtoCommon.java:364)
        at org.csource.connectionPool.imageserver.pool.ConnectionPool.init(ConnectionPool.java:5
        at org.csource.connectionPool.imageserver.pool.ConnectionPool.<init>(ConnectionPool.java:3
        at org.csource.connectionPool.imageserver.ImageServerImpl.<init>(ImageServerImpl.java:37)
        at org.csource.fastdfs.test.TestTomcatUpload.<clinit>(TestTomcatUpload.java:30)
        at org.apache.jsp.uploadFile.upload1_jsp._jspService(upload1_jsp.java:65)
        at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:70)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
        at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:38
        at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:313)
        at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:260)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)
        at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)
        at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)
        at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:103)
        at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
        at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:293)
        at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:861)
        at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:606)
        at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:489)
        at java.lang.Thread.run(Thread.java:619)

樓主有碰到這種情況嗎?有解決思路嗎?

論壇徽章:
0
4 [報告]
發(fā)表于 2014-06-17 14:12 |只看該作者
我對比了 你的代碼 跟 使用common pool做連接池的代碼,我發(fā)現(xiàn)common pool做得更好,因為他連org.csource.fastdfs.StorageClient1 都緩存了,而你的代碼是new 出來的。。

httpclient.zip

536.54 KB, 下載次數(shù): 866

commonpool做的連接池

論壇徽章:
0
5 [報告]
發(fā)表于 2014-08-28 11:09 |只看該作者
chinesejie1990 發(fā)表于 2014-06-17 14:12
我對比了 你的代碼 跟 使用common pool做連接池的代碼,我發(fā)現(xiàn)common pool做得更好,因為他連org.csource.f ...


正在使用

論壇徽章:
0
6 [報告]
發(fā)表于 2015-07-02 15:41 |只看該作者
回復(fù) 5# sdandroid

你在使用的什么連接池?


   

論壇徽章:
0
7 [報告]
發(fā)表于 2015-12-01 11:10 |只看該作者
回復(fù) 1# zhanghua1199
很好
您需要登錄后才可以回帖 登錄 | 注冊

本版積分規(guī)則 發(fā)表回復(fù)

  

北京盛拓優(yōu)訊信息技術(shù)有限公司. 版權(quán)所有 京ICP備16024965號-6 北京市公安局海淀分局網(wǎng)監(jiān)中心備案編號:11010802020122 niuxiaotong@pcpop.com 17352615567
未成年舉報專區(qū)
中國互聯(lián)網(wǎng)協(xié)會會員  聯(lián)系我們:huangweiwei@itpub.net
感謝所有關(guān)心和支持過ChinaUnix的朋友們 轉(zhuǎn)載本站內(nèi)容請注明原作者名及出處

清除 Cookies - ChinaUnix - Archiver - WAP - TOP