亚洲精品无码激情AV,亚洲成av人片天堂网,亚洲AV中文无码乱人伦下载

這幾天花了點時間弄了個 db4o 連接池，比較簡單，連接池原型是論壇上面的一篇文章。很簡單，歡迎拍磚。

從 servlet 開始，在這里初始化連接池：

package ?com;

import ?java.io.File;
import ?java.util.Enumeration;

import ?javax.servlet.ServletConfig;
import ?javax.servlet.ServletException;
import ?javax.servlet.http.HttpServlet;

public ? class ?ConnectionPollServlet? extends ?HttpServlet?{
????
???? private ? static ? final ?String?XML_FILE_PROPERTY? = ? " xmlFile " ;
????
???? /**
?????*?servlet?init
????? */
???? public ? void ?init(ServletConfig?servletConfig)? throws ?ServletException{
???????? super .init(servletConfig);
????????String?appDir? = ?servletConfig.getServletContext().getRealPath( " / " );
????????Enumeration?names? = ?servletConfig.getInitParameterNames();
???????? while (names.hasMoreElements()){
????????????String?name? = ?(String)?names.nextElement();
????????????String?value? = ?servletConfig.getInitParameter(name);
???????????? if ?(name.equals(XML_FILE_PROPERTY))?{
????????????????File?file? = ? new ?File(value);
???????????????? if ?(file.isAbsolute())?{
????????????????????XMLReader.configure(value);
????????????????}? else ?{
????????????????????XMLReader.configure(appDir? + ?File.separator? + ?value);
????????????????}
????????????}
????????}
????}

???? /**
?????*?servlet?destroy
????? */
???? public ? void ?destroy()?{
???????? super .destroy();
????????ConnectionPoll.destroy();
????}
}

然后是 XML 解析類：

package?com;

import?java.io.File;

import?org.dom4j.Document;
import?org.dom4j.DocumentException;
import?org.dom4j.Element;
import?org.dom4j.io.SAXReader;

public?class?XMLReader?{

????/**
?????*?parse?XML?file
?????*?@param?xmlFileName
?????*/
????public?static?void?configure(String?xmlFileName)?{
????????try?{
????????????File?file?=?new?File(xmlFileName);
????????????SAXReader?reader?=?new?SAXReader();
????????????Document?doc?=?reader.read(file);
????????????Element?root?=?doc.getRootElement();

????????????String?fileName?=?file.getParent()+"\\"
????????????????+root.elementText("fileName");
????????????String?sport?=?root.elementText("port");
????????????String?sminConn?=?root.elementText("minConn");
????????????String?sidelTime?=?root.elementText("idelTime");

????????????int?port?=?Integer.parseInt(sport);
????????????int?minConn?=?Integer.parseInt(sminConn);
????????????int?idelTime?=?Integer.parseInt(sidelTime);

????????????ConnectionPoll.init(fileName,port,minConn,idelTime);
????????}?catch?(DocumentException?e)?{
????????????e.printStackTrace();
????????}
????}
}

連接池類：

package?com;

import?java.util.concurrent.ConcurrentLinkedQueue;

import?com.db4o.Db4o;
import?com.db4o.ObjectContainer;
import?com.db4o.ObjectServer;

public?class?ConnectionPoll?{

????private?static?int?idelTime;
????
????private?static?ConcurrentLinkedQueue<ObjectContainer>?connectionQueue;
????
????private?ConnectionPoll(){
????}
????
????/**
?????*?init?pool
?????*/
????protected?static?void?init(String?fileName,int?port,int?minConn,int?it)?{
????????idelTime=it;
????????ObjectServer?objectServer?=?Db4o.openServer(fileName,port);
????????connectionQueue?=?new?ConcurrentLinkedQueue<ObjectContainer>();
????????for?(int?i?=?0;?i<minConn;?i++)?{
????????????connectionQueue.offer(objectServer.openClient());
????????}
????}

????/**
?????*?get?connection
?????*?@return?ObjectContainer
?????*?@throws?ConnectionTimeoutException?
?????*?@throws?InterruptedException
?????*/
????public?static?synchronized?ObjectContainer?getConnection()?throws?ConnectionTimeoutException{
????????long?expiration?=?System.currentTimeMillis()?+?idelTime;
????????while?(connectionQueue.isEmpty())
????????{
????????????if?(expiration?<?System.currentTimeMillis())
????????????{
????????????????throw?new?ConnectionTimeoutException("connection?timeout!");
????????????}
????????}
????????ObjectContainer?objectContainer?=?connectionQueue.poll();
????????return?objectContainer;
????????}

????/**
?????*?release?connection
?????*?@return?ObjectContainer
?????*?@throws?InterruptedException
?????*/
????public?static?synchronized?void?releaseConnection(ObjectContainer?objectContainer)?{
????????connectionQueue.offer(objectContainer);
????}
????
????/**
?????*?destroy?connection
?????*
?????*/
????protected?static?void?destroy()?{
????????while?(connectionQueue.iterator().hasNext()){
????????????ObjectContainer?objectContainer?=?connectionQueue.poll();
????????????objectContainer.close();
????????}
????}
}

超時異常類：

package?com;

public?class?ConnectionTimeoutException?extends?Exception{

????public?ConnectionTimeoutException()
????{
????}

????public?ConnectionTimeoutException(String?s)
????{
????????super(s);
????}
}

XML 配置文件，從上到下依次是，數據庫文件名、端口、初始連接數、等待時間：

<?xml?version="1.0"?encoding="utf-8"?>
??<config>
????<fileName>auto.yap</fileName>
????<port>1010</port>
????<minConn>10</minConn>
????<idelTime>1000</idelTime>
??</config>

web.xml 用于初始化的時候加載：

<?xml?version="1.0"?encoding="UTF-8"?>
<!DOCTYPE?web-app?PUBLIC?"-//Sun?Microsystems,?Inc.//DTD?Web?Application?2.3//EN"?"http://java.sun.com/dtd/web-app_2_3.dtd">
<web-app>
??<servlet>
????<servlet-name>ConnectionPoll</servlet-name>
????<servlet-class>com.ConnectionPollServlet</servlet-class>
??????<init-param>
????????<param-name>xmlFile</param-name>
????????<param-value>WEB-INF/poolConfig.xml</param-value>
??????</init-param>
????<load-on-startup>1</load-on-startup>
??</servlet>
</web-app>

數據庫文件和參數配置文件都放在 WEB-INF 文件夾下。這個連接池還未實現 maxConn（最大連接數）和對多數據庫文件的支持以及日志等。

請注意！引用、轉貼本文應注明原作者：Rosen Jiang 以及出處：http://www.tkk7.com/rosen

posted on 2006-09-27 15:26 Rosen 閱讀(3950) 評論(8) 編輯收藏所屬分類: Versant db4o 中文項目

把我在QQ群上的留言轉到這兒來了呀。上面有些地方沒寫太清楚。
1，使用sleep或者wait/notify是為了避免循環忙等待，這個非常消耗CPU資源，否則不適合用于生產環境。
2，限制在Jdk1.5以上版本了，并非必要。
3，用戶應該可以選擇本地模式，還是遠程模式；對于后者，需要遠程服務器和端口，同時，在代碼上，就無需Db4o.openServer了。回復更多評論

# re: db4o 連接池 2006-11-23 12:25 Rosen

@虎.無名
目前正在改造連接池：
對 jdk 1.2 以上版本的兼容；加入 apache pool 實現；可選擇的本地、遠程模式。如果你有興趣，我們可以共同完成，的確，連接池的呼聲越來越高了。回復更多評論

# re: db4o 連接池 2006-11-24 18:08 虎.無名

新的實現，發布在javaeye上了，看看還有什么問題？
http://zeroliu.javaeye.com/ 回復更多評論

# re: db4o 連接池 2006-11-24 22:01 Rosen

又見 javaeye，我是這種表情 @-@ 。
今天和 andrew 閑談，跟著他的思路走，一下子開闊了許多，我有種非常極端的想法：C/S 模式，在不考慮網絡的因素下 server 端應該自帶連接池，并且，這種性能比獲取 JDBC 的開銷小 N 倍。這樣才是以性能著稱的 db4o 的風格！！！回復更多評論

# re: db4o 連接池 2007-12-05 17:32 vvvic

如何使用這個連接池呢？回復更多評論

# re: db4o 連接池 2007-12-05 20:16 Rosen

@vvvic
今年一月在香港開會的時候，大多數開發者不支持這種連接池方案，我也只好作罷。另外，你可以看看db4o與spring的集成類庫，工具叫做spring-modules。我用過一下，其沒有提供連接池的機制。回復更多評論

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: 開源面向對象數據庫 db4o 之旅: 使用 dRS “db4o 之旅（四）” Versant db4o 8.0 RC發布（翻譯）國際對象數據庫大會（ICOODB）簡介 MapMe（翻譯）為什么Android將掀起一場手機領域的狂風(Why Android will start the mobile Tornado) 實戰 OpenLaszlo 與 db4o 開源面向對象數據庫 db4o 之旅: 深入 db4o “db4o 之旅（三）” 開源面向對象數據庫 db4o 之旅: db4o 查詢方式“db4o 之旅（二）” db4o 連接池 dRS 產品信息 V1.0（中文版）

成都心情

公告

隨筆分類(91)

隨筆檔案(99)

文章分類(2)

友情鏈接

積分與排名

最新評論

閱讀排行榜

評論排行榜

評論