
2005年10月26日
帕金森定律
美國著名歷史學(xué)家諾斯古德-帕金森通過長期調(diào)查研究,寫了一本名叫《帕金森定律》的書,他在書中闡述了機(jī)構(gòu)人員膨脹的原因及后果:一個(gè)不稱職的官員,可能有三條出路。第一是申請(qǐng)退職,把位子讓給能干的人;第二是讓一位能干的人來協(xié)助自己工作;第三是任用兩個(gè)水平比自己更低的人當(dāng)助手。
這第一條路是萬萬走不得的,因?yàn)槟菢訒?huì)喪失許多權(quán)力;第二條路也不能走,因?yàn)槟莻€(gè)能干的人會(huì)成為自己的對(duì)手;看來只有第三條路最適宜。于是,兩個(gè)平庸的助手分擔(dān)了他的工作,他自己則高高在上發(fā)號(hào)施令。兩個(gè)助手既無能,也就上行下效,再為自己找兩個(gè)無能的助手。如此類推,就形成了一個(gè)機(jī)構(gòu)臃腫、人浮于事、相互扯皮、效率低下的領(lǐng)導(dǎo)體系。
苛希納定律
西方管理學(xué)中有一條著名的苛希納定律:如果實(shí)際管理人員比最佳人數(shù)多兩倍,工作時(shí)間就要多兩倍,工作成本就要多四倍;如果實(shí)際管理人員比最佳人數(shù)多三倍,工作時(shí)間就要多三倍,工作成本就要多六倍。
苛希納定律告訴我們,在管理上并不是人多力量大,管理人員越多,工作效率未必就會(huì)越高。苛希納定律要求我們,要認(rèn)真研究并找到一個(gè)最佳人數(shù),以最大限度地減少工作時(shí)間,降低工作成本。
馬蠅效應(yīng)
林肯少年時(shí)和他的兄弟在肯塔基老家的一個(gè)農(nóng)場里犁玉米地,林肯吆馬,他兄弟扶犁,而那匹馬很懶,慢慢騰騰,走走停停。可是有一段時(shí)間馬走得飛快。林肯感到奇怪,到了地頭,他發(fā)現(xiàn)有一只很大的馬蠅叮在馬身上,他就把馬蠅打落了。看到馬蠅被打落了,他兄弟就抱怨說:“哎呀,你為什么要打掉它,正是那家伙使馬跑起來的嘛!”
沒有馬蠅叮咬,馬慢慢騰騰,走走停停;有馬蠅叮咬,馬不敢怠慢,跑得飛快。這就是馬蠅效應(yīng)。馬蠅效應(yīng)給我們的啟示是:一個(gè)人只有被叮著咬著,他才不敢松懈,才會(huì)努力拼搏,不斷進(jìn)步。
“南風(fēng)”法則
“南風(fēng)”法則也稱“溫暖”法則,源于法國作家拉封丹寫過的一則寓言:北風(fēng)和南風(fēng)比威力,看誰能把行人身上的大衣脫掉。北風(fēng)首先來一個(gè)冷風(fēng)凜冽寒冷刺骨,結(jié)果行人為了抵御北風(fēng)的侵襲,便把大衣裹得緊緊的。南風(fēng)則徐徐吹動(dòng),頓時(shí)風(fēng)和日麗,行人因?yàn)橛X得春暖上身,始而解開紐扣,繼而脫掉大衣,南風(fēng)獲得了勝利。
這則寓言形象地說明了一個(gè)道理:溫暖勝于嚴(yán)寒。領(lǐng)導(dǎo)者在管理中運(yùn)用“南風(fēng)”法則,就是要尊重和關(guān)心下屬,以下屬為本,多點(diǎn)“人情味”,盡力解決下屬日常生活中的實(shí)際困難,使下屬真正感受到領(lǐng)導(dǎo)者給予的溫暖,從而激發(fā)出工作的積極性。
酒與污水定律
酒與污水定律是指,如果把一匙酒倒進(jìn)一桶污水中,你得到的是一桶污水;如果把一匙污水倒進(jìn)一桶酒中,你得到的還是一桶污水。
在任何組織里,都存在幾個(gè)難弄的人物,他們存在的目的似乎就是為了把事情搞糟。最糟糕的是,他們像果箱里的爛蘋果一樣,如果你不及時(shí)處理,它會(huì)迅速傳染,把果箱里其他的蘋果也弄爛。“爛蘋果”的可怕之處在于它那驚人的破壞力。一個(gè)正直能干的人進(jìn)入一個(gè)混亂的部門可能被吞沒,而一個(gè)無德無才者能很快將一個(gè)高效的部門變成一盤散沙。一個(gè)能工巧匠花費(fèi)時(shí)日精心制作的陶瓷品,一頭驢子一秒鐘就能將它毀壞掉。
posted @
2007-11-27 14:18 surffish 閱讀(381) |
評(píng)論 (0) |
編輯 收藏
1、WINKEY+D:這是高手最常用的第一快捷組合鍵(木頭按:也是我最喜歡用的哦,好像有點(diǎn)自詡為高手)。這個(gè)快捷鍵組合可以將桌面上的所有窗口瞬間最小化,無論是聊天的窗口還是游戲的窗口……只要再次按下這個(gè)組合鍵,剛才的所有窗口都回來了,而且激活的也正是你最小化之前在使用的窗口!
2、WINKEY + F:不用再去移動(dòng)鼠標(biāo)點(diǎn)“開始→搜索→文件和文件夾”了,在任何狀態(tài)下,只要一按WINKEY+F就會(huì)彈出搜索窗口。
3、WINKEY + R:在我們的文章中,你經(jīng)常會(huì)看到這樣的操作提示:“點(diǎn)擊‘開始→運(yùn)行’,打開‘運(yùn)行’對(duì)話框……”。其實(shí),還有一個(gè)更簡單的辦法,就是按WINKEY + R!
4、ALT + TAB :如果打開的窗口太多,這個(gè)組合鍵就非常有用了,它可以在一個(gè)窗口中顯示當(dāng)前打開的所有窗口的名稱和圖標(biāo),選中自己希望要打開的窗口,松開這個(gè)組合鍵就可以了。而ALT+TAB+SHIFT鍵則可以反向顯示當(dāng)前打開的窗口。
5、WINKEY + E:當(dāng)你需要打開資源管理器找文件的時(shí)候,這個(gè)快捷鍵會(huì)讓你感覺非常“爽”!再也不用騰出一只手去摸鼠標(biāo)了!
?????????6、WINKEY+L,鎖定計(jì)算機(jī)
小提示:
WINKEY指的是鍵盤上刻有Windows徽標(biāo)的鍵。WINKEY主要出現(xiàn)在104鍵和107鍵的鍵盤中。104鍵盤又稱Win95鍵盤,這種鍵盤在原來101鍵盤的左右兩邊、Ctrl和Alt鍵之間增加了兩個(gè)Windwos鍵和一個(gè)屬性關(guān)聯(lián)鍵。107鍵盤又稱為Win98鍵盤,比104鍵多了睡眠、喚醒、開機(jī)等電源管理鍵,這3個(gè)鍵大部分位于鍵盤的右上方。
posted @
2007-02-15 15:30 surffish 閱讀(168) |
評(píng)論 (0) |
編輯 收藏
不論你是單一團(tuán)隊(duì)的領(lǐng)導(dǎo)者還是多個(gè)團(tuán)隊(duì)的管理人,團(tuán)隊(duì)管理工作都是你職權(quán)范圍內(nèi)一個(gè)重要的組成部分。在今日,集多重技術(shù)于一身的工作方法已逐漸取代階層式的、缺乏彈性的傳統(tǒng)工作體制,團(tuán)隊(duì)合作因而很快就成為了一種很受歡迎的工作方式。對(duì)于每一位參與團(tuán)隊(duì)管理工作的人而言,《團(tuán)隊(duì)管理》是一本不可或缺的重要讀物。它向你提供了達(dá)成計(jì)劃所需的技巧、建立團(tuán)隊(duì)成員間的信任、激發(fā)團(tuán)隊(duì)最大的潛能等方面的知識(shí),為你能專業(yè)化地管理好你的團(tuán)隊(duì)創(chuàng)造了有利條件。另外,全書還散布了101條簡明提示,為你提供重要而實(shí)用的訊息。后半部分有個(gè)自我評(píng)估練習(xí),使你能正確地評(píng)估自己的領(lǐng)導(dǎo)能力,并針對(duì)自己的不足加以改進(jìn)。
了解團(tuán)隊(duì)運(yùn)作
團(tuán)隊(duì)合作是所有成功管理的根基。無論你是新手還是資深管理人,對(duì)你而言,管理好團(tuán)隊(duì)都是重要且具激勵(lì)性的挑戰(zhàn)。
1.切記:每位成員都能為團(tuán)隊(duì)作出一些貢獻(xiàn)。
2.謹(jǐn)慎地設(shè)定團(tuán)隊(duì)目標(biāo),且認(rèn)真嚴(yán)肅地對(duì)待它們。
3.切記成員間要彼此扶持。
4.將長程目標(biāo)打散成許多短程計(jì)劃。
5.為每個(gè)計(jì)劃設(shè)定明確的期限。
6.盡早決定何種形態(tài)的團(tuán)隊(duì)適合你的目標(biāo)。
7.努力與其它團(tuán)隊(duì)的成員建立強(qiáng)有力的緊密關(guān)系。
8.找一位可提升團(tuán)隊(duì)工作士氣的重量級(jí)人物。
9.時(shí)時(shí)提醒團(tuán)隊(duì)成員:他們都是團(tuán)隊(duì)的一份子。
10.將團(tuán)隊(duì)的注意力集中在固定可衡量的目標(biāo)上。
11.利用友誼的強(qiáng)大力量強(qiáng)化團(tuán)隊(duì)。
12.選擇領(lǐng)導(dǎo)者時(shí)要把握用人唯才原則。
13.領(lǐng)導(dǎo)者需具備強(qiáng)烈的團(tuán)隊(duì)使命感。
14.獎(jiǎng)賞優(yōu)異的表現(xiàn),但絕不姑息錯(cuò)誤。
15.記住每位團(tuán)隊(duì)成員看事情的角度都不一樣。
16.征召團(tuán)隊(duì)成員時(shí),應(yīng)注重他們的成長潛能。
17.密切注意團(tuán)隊(duì)成員缺少的相關(guān)經(jīng)驗(yàn)。
18.應(yīng)使不適任的成員退出團(tuán)隊(duì)。
19.找到能將人際關(guān)系處理得很好的人,并培養(yǎng)他們。
設(shè)立一支團(tuán)隊(duì)
成立一支團(tuán)隊(duì)是領(lǐng)導(dǎo)者的主要工作。確保你的團(tuán)隊(duì)有清楚明確的目的和足夠達(dá)成目標(biāo)的資源。要以開放和公正無私的態(tài)度對(duì)待團(tuán)隊(duì)成員。
20.設(shè)定具挑戰(zhàn)性的目標(biāo)須根據(jù)限期來考量是否合理。
21.設(shè)定目標(biāo)時(shí),考量個(gè)別成員的工作目標(biāo)。
22.計(jì)劃的失敗危及整體計(jì)劃的成功。
23.堅(jiān)持得到信息技術(shù)支持,它能為你提供確實(shí)需要的東西。
24.對(duì)待團(tuán)隊(duì)外的顧問要如同對(duì)待團(tuán)隊(duì)成員一般。
25.讓團(tuán)隊(duì)的贊助者隨時(shí)知道工作進(jìn)展情形。
26.除非你確定沒有人能夠勝任,否則應(yīng)避免“事必躬親”。
27.不要委托不必要的工作,最好將其去除掉。
28.賦予團(tuán)隊(duì)自己作決策的權(quán)力。
29.鼓勵(lì)團(tuán)隊(duì)成員正面積極的貢獻(xiàn)。
30.肯定、宣揚(yáng)和慶祝團(tuán)隊(duì)每次的成功。
31.找到易于讓成員及團(tuán)隊(duì)了解每日工作進(jìn)度的展現(xiàn)方式。
32.鼓勵(lì)成員之間建立工作上的伙伴關(guān)系。
33.鼓勵(lì)天生具有領(lǐng)導(dǎo)才能的人,并引導(dǎo)和培養(yǎng)他們的領(lǐng)導(dǎo)技巧。
34.絕對(duì)不能沒有解釋就駁回團(tuán)隊(duì)的意見,與此相反,解釋要坦白,理由要充分。
35.確定團(tuán)隊(duì)和客戶經(jīng)常保持聯(lián)系。
36.以自信肯定的態(tài)度讓團(tuán)隊(duì)知道誰當(dāng)家,但要預(yù)防予人來勢洶洶的感覺。
37.想辦法給新團(tuán)隊(duì)留下一個(gè)實(shí)時(shí)的好印象,但切忌操之過急。
38.倘若你要求別人的建議,抱持的心態(tài)不能只是歡迎就行了,也要依循建議有所行動(dòng)。
提升團(tuán)隊(duì)效率
團(tuán)隊(duì)要達(dá)到應(yīng)有的效率,唯一的條件是每個(gè)成員都要學(xué)會(huì)集中力量。你必須了解團(tuán)隊(duì)的能力,以確保團(tuán)隊(duì)的成功。
39.協(xié)助團(tuán)隊(duì)找出方法以改變有礙任務(wù)推展的團(tuán)體行為。
40.找出可建設(shè)性地利用沖突的方法。
41.記住要在工作中穿插安排娛樂調(diào)劑身心──這是每個(gè)人應(yīng)得的福利。
42.若有計(jì)劃出錯(cuò),一定要作全面性、公開化的分析。
43.如果你希望團(tuán)隊(duì)成員有問題時(shí)能毫不猶疑地找你談,就要實(shí)施“開門政策”。
44.要求提出問題的人解決問題。
45.安排正式的和非正式的會(huì)面,討論團(tuán)隊(duì)的工作進(jìn)展。
46.使用不帶感情只問事實(shí)的態(tài)度,是化解紛爭的最好方法。
47.保持團(tuán)隊(duì)成員間的熟稔,以易于溝通。
48.設(shè)立交誼場所,讓團(tuán)隊(duì)成員可作非正式的碰面交談。
49.鼓勵(lì)同事間自由的溝通活動(dòng)。
50.建立最適合的通訊科技系統(tǒng),并經(jīng)常更新。
51.實(shí)施會(huì)議主席輪流制,讓每個(gè)人都有機(jī)會(huì)主持會(huì)議。
52.盡可能多地授權(quán)給團(tuán)隊(duì)成員。
53.事先于會(huì)前發(fā)出議程,預(yù)留時(shí)間給與會(huì)者準(zhǔn)備。
54.培養(yǎng)所有對(duì)團(tuán)隊(duì)有益的關(guān)系。
55.努力保持團(tuán)隊(duì)內(nèi)外關(guān)系的均衡與平穩(wěn)。
56.確定所有相關(guān)人士都能聽到、了解好消息。
57.倘有麻煩在團(tuán)隊(duì)關(guān)系中發(fā)酵蘊(yùn)釀,要盡快處理。
58.安排團(tuán)隊(duì)與機(jī)構(gòu)的其它部門作社交聯(lián)誼。
59.找出你與“大佬”保持聯(lián)系的最佳通訊科技。
60.要對(duì)你在團(tuán)隊(duì)或辦公室外接觸過的重要人士作聯(lián)系記錄。
61.謹(jǐn)慎分派角色以避免任務(wù)重復(fù)。
62.找尋建議中的精華,且絕不在公開場合批評(píng)任何建議。
63.一定要找有經(jīng)驗(yàn)的人解決問題。
64.分析團(tuán)隊(duì)成員每個(gè)人所扮演的角色。
65.腦力激發(fā)出的意見,就算不采用,亦不得輕視。否則,會(huì)打擊人的積極性,創(chuàng)意的流動(dòng)也會(huì)因此停止。
66.公平對(duì)待每個(gè)成員才能避免怨恨。
67.確定團(tuán)隊(duì)成員真正有錯(cuò)之前,都須視他們沒有錯(cuò)。
68.告訴同事他們做得很好,這有助于激勵(lì)團(tuán)隊(duì)士氣。
69.尊重每一位成員,包括那些給你制造麻煩的人。
70.避免和團(tuán)隊(duì)成員有直接的沖突。
71.記住采用對(duì)事不對(duì)人的處事態(tài)度。
72.確定整個(gè)團(tuán)隊(duì)都能夠從解決問題中學(xué)習(xí)經(jīng)驗(yàn)。
73.先選擇完成一些規(guī)模大的、可快速達(dá)成及有成就感的任務(wù),以激勵(lì)成員再接再勵(lì)。
74.確信團(tuán)隊(duì)成員皆了解團(tuán)隊(duì)中的其它角色。
75.計(jì)算品質(zhì)的成本之前,先計(jì)算失敗的成本。
76.針對(duì)每筆預(yù)算及每項(xiàng)團(tuán)隊(duì)行動(dòng)計(jì)劃,設(shè)定重大的改進(jìn)目標(biāo)。
為未來努力
為團(tuán)隊(duì)設(shè)定新的、更高的挑戰(zhàn)目標(biāo)是團(tuán)隊(duì)工作中最令人興奮的事情之一。可運(yùn)用一些適當(dāng)?shù)募记桑苿?dòng)團(tuán)隊(duì)向更大、更好的目標(biāo)前進(jìn)。
77.告知團(tuán)隊(duì)每位成員,在設(shè)定的標(biāo)準(zhǔn)中有哪些評(píng)量的項(xiàng)目。
78.確定所有改善措施及新訂目標(biāo)都持續(xù)進(jìn)行著。
79.召開檢討會(huì)議前傳閱所有相關(guān)資料及資料。
80.開檢討會(huì)時(shí)一定要避諱人身攻擊。
81.記住關(guān)系會(huì)隨時(shí)間改變。
82.避開低估或忽視壞消息的陷井。
83.每天結(jié)束時(shí)自問團(tuán)隊(duì)今天是否又向前跨出了一步。
84.傾聽受訓(xùn)者關(guān)于訓(xùn)練課程的回饋意見。
85.找到有最好設(shè)備的最佳訓(xùn)練場所。
86.聘請(qǐng)顧問設(shè)立公司內(nèi)部的訓(xùn)練課程。
87.利用移地訓(xùn)練時(shí)的用餐時(shí)間作非正式的計(jì)劃。
88.每位團(tuán)隊(duì)成員都必須參與設(shè)定目標(biāo)的工作,以促進(jìn)團(tuán)隊(duì)合作及達(dá)成共識(shí)。
89.允許團(tuán)隊(duì)自行決定達(dá)成目標(biāo)的方法,可激勵(lì)團(tuán)隊(duì)努力工作。
90.確定目標(biāo)能激發(fā)團(tuán)隊(duì)的斗志,如果不行,請(qǐng)改變目標(biāo)。
91.一支沒有“嚴(yán)峻”目標(biāo)的團(tuán)隊(duì),工作表現(xiàn)將不如接受過此類考驗(yàn)的團(tuán)隊(duì)。
92.設(shè)定獎(jiǎng)勵(lì)標(biāo)準(zhǔn)時(shí),允許團(tuán)隊(duì)成員有發(fā)言權(quán)。
93.避免使用名次表,因?yàn)槁浜蟮膱F(tuán)隊(duì)成員將會(huì)感到自尊心受創(chuàng)。
94.指定某人監(jiān)視市場上每一個(gè)相關(guān)變化。
95.隨時(shí)準(zhǔn)備作改變,甚至計(jì)劃的根本要素亦包含在改變的范圍內(nèi)。
96.記住有某些人很害怕變革。
97.尋找能推動(dòng)改革的團(tuán)隊(duì)成員。
98.每隔一段時(shí)間作一次生涯發(fā)展的評(píng)量。
99.記住:鼓勵(lì)團(tuán)隊(duì)成員即是在幫助團(tuán)隊(duì)。
100.與團(tuán)隊(duì)同事就生涯規(guī)劃達(dá)成一致意見,并給他們提供必要的協(xié)助。
101.團(tuán)隊(duì)解散后仍舊要與團(tuán)隊(duì)成員保持聯(lián)系,因?yàn)槟憧赡苓€會(huì)與他們再次合作
posted @
2006-09-21 08:05 surffish 閱讀(213) |
評(píng)論 (0) |
編輯 收藏
LEFT JOIN 和 RIGHT JOIN 運(yùn)算
用于 FROM 子句時(shí),把源表記錄組合起來。
語法
FROM表1 [ LEFT | RIGHT ] JOIN表2
????ON 表1.字段1compopr 表2. 字段2
LEFT JOIN 及 RIGHT JOIN 運(yùn)算可分為以下幾個(gè)部分:
部分 |
說明 |
table1, table2 |
記錄被組合的表的名稱。 |
field1, field2 |
被聯(lián)接的字段的名稱。且這些字段必須有相同的數(shù)據(jù)類型及包含相同類型的數(shù)據(jù),但它們不需要有相同的名稱。 |
compopr
|
任何的關(guān)系比較運(yùn)算子:"=," "<," ">," "<=," ">=," 或 "<>." |
說明
用 LEFT JOIN 運(yùn)算 創(chuàng)建左邊外部聯(lián)接.左邊外部聯(lián)接將包含了從第一個(gè)(左邊)開始的兩個(gè)表中的全部記錄,即使在第二個(gè)(右邊)表中并沒有相符值的記錄。
用RIGHT JOIN 運(yùn)算 創(chuàng)建 右邊外部聯(lián)接.右邊外部聯(lián)接將包含了從第二個(gè)(右邊)開始的兩個(gè)表中的全部記錄,即使在第一個(gè)(左邊)表中并沒有匹配值的記錄。
例如,可以使用 LEFT JOIN 與部門(左邊)及員工(右邊)表來選擇所有的部門,包含了沒有分配到員工的部門。可以使用 RIGHT JOIN 選擇所有的員工,包含了沒有分配到部門的員工。
下列示例顯示如何在類標(biāo)識(shí)符字段中聯(lián)接類表及產(chǎn)品表。查詢將會(huì)列出所有種類的列表,包含那些沒有產(chǎn)品在其中的種類:
SELECT CategoryName,
ProductName
FROM Categories LEFT JOIN Products
ON Categories.CategoryID = Products.CategoryID;
在本例中,CategoryID 是聯(lián)接的字段,但由于它不包含在 SELECT 語句中,因此,也不包含在查詢結(jié)果中。要包含聯(lián)接的字段,請(qǐng)?jiān)?SELECT 語句中輸入字段名 — 在這個(gè)示例中為 Categories.CategoryID。
注意
欲創(chuàng)建只包含聯(lián)接字段中數(shù)據(jù)相同的記錄的查詢,請(qǐng)用 INNER JOIN 運(yùn)算。
- 在 INNER JOIN 之中可以寫一個(gè)嵌套的 LEFT JOIN 或一個(gè) RIGHT JOIN,但是在一個(gè) LEFT JOIN 或一個(gè) RIGHT JOIN 之中不能寫嵌套的 INNER JOIN。請(qǐng)參閱 INNER JOIN 主題中有關(guān)使用嵌套的討論,從其中可獲知如何在其它聯(lián)接中編寫嵌套聯(lián)接的信息。
- 可以鏈接多個(gè) ON 子句。若需更多信息,請(qǐng)參閱在 INNER JOIN 主題中的子句鏈接的討論。
若試圖聯(lián)接包含 Memo或 OLE Object數(shù)據(jù)的字段,會(huì)導(dǎo)致錯(cuò)誤。
請(qǐng)參閱
示例
LEFT JOIN 和 RIGHT JOIN 運(yùn)算示例
posted @
2006-09-03 11:52 surffish 閱讀(248) |
評(píng)論 (0) |
編輯 收藏
關(guān)閉msn,在開始->運(yùn)行中分別輸入
regsvr32 softpub.dll
regsvr32 mssip32.dll
regsvr32 intipki.dll
regsvr32 MSXML3.dll
11221399B
再重新啟動(dòng)msn即可
posted @
2006-08-21 08:03 surffish 閱讀(225) |
評(píng)論 (0) |
編輯 收藏
1. 在業(yè)務(wù)層使用JDBC直接操作數(shù)據(jù)庫-最簡單,最直接的操作
1)數(shù)據(jù)庫url,username,password寫死在代碼中
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
String url="jdbc:oracle:thin:@localhost:1521:orcl";
String user="scott";
String password="tiger";
Connection conn= DriverManager.getConnection(url,user,password);
Statement stmt=conn.createStatement(
ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
String sql="select * from test";
ResultSet rs=stmt.executeQuery(sql);
2)采用Facade和Command模式,使用DBUtil類封裝JDBC操作;
數(shù)據(jù)庫url,username,password可以放在配置文件中(如xml,properties,ini等)。
這種方法在小程序中應(yīng)用較多。
2.DAO(Data Accessor Object)模式-松耦合的開始
DAO = data + accessor + domain object
例如User類-domain object (javabean)
UserDAO類-accessor ,提供的方法getUser(int id),save(User user)內(nèi)包含了JDBC操作
在業(yè)務(wù)邏輯中使用這兩個(gè)類來完成數(shù)據(jù)操作。
使用Factory模式可以方便不同數(shù)據(jù)庫連接之間的移植。
3.數(shù)據(jù)庫資源管理模式
3.1 數(shù)據(jù)庫連接池技術(shù)
資源重用,避免頻繁創(chuàng)建,釋放連接引起大大量性能開銷;
更快的系統(tǒng)響應(yīng)速度;
通過實(shí)現(xiàn)JDBC的部分資源對(duì)象接口( Connection, Statement, ResultSet ),可以使用Decorator設(shè)計(jì)模式分別產(chǎn)生三種邏輯資源對(duì)象: PooledConnection, PooledStatement和 PooledResultSet。
一個(gè)最簡單地?cái)?shù)據(jù)庫連接池實(shí)現(xiàn):
public class ConnectionPool {
private static Vector pools;
private final int POOL_MAXSIZE = 25;
/**
* 獲取數(shù)據(jù)庫連接
* 如果當(dāng)前池中有可用連接,則將池中最后一個(gè)返回;若沒有,則創(chuàng)建一個(gè)新的返回
*/
public synchronized Connection getConnection() {
Connection conn = null;
if (pools == null) {
pools = new Vector();
}
if (pools.isEmpty()) {
conn = createConnection();
} else {
int last_idx = pools.size() - 1;
conn = (Connection) pools.get(last_idx);
pools.remove(last_idx);
}
return conn;
}
/**
* 將使用完畢的數(shù)據(jù)庫連接放回池中
* 若池中連接已經(jīng)超過閾值,則關(guān)閉該連接;否則放回池中下次再使用
*/
public synchronized void releaseConnection(Connection conn) {
if (pools.size() >= POOL_MAXSIZE)
try {
conn.close();
} catch (SQLException e) {
// TODO自動(dòng)生成 catch 塊
e.printStackTrace();
} else
pools.add(conn);
}
public static Connection createConnection() {
Connection conn = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
String url = "jdbc:oracle:thin:@localhost:1521:orcl";
String user = "scott";
String password = "tiger";
conn = DriverManager.getConnection(url, user, password);
} catch (InstantiationException e) {
// TODO自動(dòng)生成 catch 塊
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO自動(dòng)生成 catch 塊
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO自動(dòng)生成 catch 塊
e.printStackTrace();
} catch (SQLException e) {
// TODO自動(dòng)生成 catch 塊
e.printStackTrace();
}
return conn;
}
}
注意:利用getConnection()方法得到的Connection,程序員很習(xí)慣地調(diào)用conn.close()方法關(guān)閉了數(shù)據(jù)庫連接,那么上述的數(shù)據(jù)庫連接機(jī)制便形同虛設(shè)。在調(diào)用conn.close()方法方法時(shí)如何調(diào)用releaseConnection()方法?這是關(guān)鍵。這里,我們使用Proxy模式和java反射機(jī)制。
public synchronized Connection getConnection() {
Connection conn = null;
if (pools == null) {
pools = new Vector();
}
if (pools.isEmpty()) {
conn = createConnection();
} else {
int last_idx = pools.size() - 1;
conn = (Connection) pools.get(last_idx);
pools.remove(last_idx);
}
ConnectionHandler handler=new ConnectionHandler(this);
return handler.bind(con);
}
public class ConnectionHandler implements InvocationHandler {
private Connection conn;
private ConnectionPool pool;
public ConnectionHandler(ConnectionPool pool){
this.pool=pool;
}
/**
* 將動(dòng)態(tài)代理綁定到指定Connection
* @param conn
* @return
*/
public Connection bind(Connection conn){
this.conn=conn;
Connection proxyConn=(Connection)Proxy.newProxyInstance(
conn.getClass().getClassLoader(), conn.getClass().getInterfaces(),this);
return proxyConn;
}
/* (非 Javadoc)
* @see java.lang.reflect.InvocationHandler#invoke(java.lang.Object, java.lang.reflect.Method, java.lang.Object[])
*/
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
// TODO自動(dòng)生成方法存根
Object obj=null;
if("close".equals(method.getName())){
this.pool.releaseConnection(this.conn);
}
else{
obj=method.invoke(this.conn, args);
}
return obj;
}
}
在實(shí)際項(xiàng)目中,并不需要你來從頭開始來設(shè)計(jì)數(shù)據(jù)庫連接池機(jī)制,現(xiàn)在成熟的開源項(xiàng)目,如C3P0,dbcp,Proxool等提供了良好的實(shí)現(xiàn)。一般推薦使用Apache dbcp,基本使用實(shí)例:
DataSource ds = null;
try{
Context initCtx = new InitialContext();
Context envCtx = (Context) initCtx.lookup("java:comp/env");
ds = (DataSource)envCtx.lookup("jdbc/myoracle");
if(ds!=null){
out.println("Connection is OK!");
Connection cn=ds.getConnection();
if(cn!=null){
out.println("cn is Ok!");
Statement stmt = cn.createStatement();
ResultSet rst = stmt.executeQuery("select * from BOOK");
out.println("
rst is Ok!" + rst.next());
while(rst.next()){
out.println("
BOOK_CODE:" + rst.getString(1));
}
cn.close();
}else{
out.println("rst Fail!");
}
}
else
out.println("Fail!");
}catch(Exception ne){ out.println(ne);
}
3.2 Statement Pool
普通預(yù)編譯代碼:
String strSQL=”select name from items where id=?”;
PreparedStatement ps=conn.prepareStatement(strSQL);
ps.setString(1, “2”);
ResultSet rs=ps.executeQuery();
但是PreparedStatement 是與特定的Connection關(guān)聯(lián)的,一旦Connection關(guān)閉,則相關(guān)的PreparedStatement 也會(huì)關(guān)閉。
為了創(chuàng)建PreparedStatement 緩沖池,可以在invoke方法中通過sql語句判斷池中還有沒有可用實(shí)例。
4. 持久層設(shè)計(jì)與O/R mapping 技術(shù)
1) Hernate:適合對(duì)新產(chǎn)品的開發(fā),進(jìn)行封閉化的設(shè)計(jì)
Hibernate 2003年被Jboss接管,通過把java pojo對(duì)象映射到數(shù)據(jù)庫的table中,采用了xml/javareflection技術(shù)等。3.0提供了對(duì)存儲(chǔ)過程和手寫sql的支持,本身提供了hql語言。
開發(fā)所需要的文件:
hibernate配置文件: hibernate.cfg.xml 或 hibernate.properties
hibernate 映射文件: a.hbm.xml
pojo類源文件: a.java
導(dǎo)出表與表之間的關(guān)系:
a. 從java對(duì)象到hbm文件:xdoclet
b. 從hbm文件到j(luò)ava對(duì)象:hibernate extension
c. 從數(shù)據(jù)庫到hbm文件:middlegen
d. 從hbm文件到數(shù)據(jù)庫:SchemaExport
2)Iatis :適合對(duì)遺留系統(tǒng)的改造和對(duì)既有數(shù)據(jù)庫的復(fù)用,有很強(qiáng)的靈活性 3) Apache OJB:優(yōu)勢在于對(duì)標(biāo)準(zhǔn)的全面支持 4)EJB:適合集群服務(wù)器,其性能也不象某些人所詬病的那么差勁 5) JDO (java data object)
設(shè)置一個(gè)Properties對(duì)象,從而獲取一個(gè)JDO的PersistenceManagerFactory(相當(dāng)于JDBC連接池中的DataSource),進(jìn)而獲得一個(gè)PersistenceManager對(duì)象(相當(dāng)于JDBC中的Connection對(duì)象),之后,你可以用這個(gè)PersistenceManager對(duì)象來增加、更新、刪除、查詢對(duì)象。
JDOQL是JDO的查詢語言;它有點(diǎn)象SQL,但卻是依照J(rèn)ava的語法的。
5. 基于開源框架的Struts+Spring+Hibernate實(shí)現(xiàn)方案
示例:這是一個(gè)3層架構(gòu)的web 程序,通過一個(gè)Action 來調(diào)用業(yè)務(wù)代理,再通過它來回調(diào) DAO類。下面的流程圖表示了MyUsers是如何工作的。數(shù)字表明了流程的先后順序,從web層(UserAction)到中間層(UserManager),再到數(shù)據(jù)層(UserDAO),然后返回。
Spring是AOP, UserManager和UserDAO都是接口.
1) web層(UserAction) :調(diào)用中間層的接口方法,將UserManager作為屬性注入。
采用流行的Struts框架,雖然有很多人不屑一顧,但是這項(xiàng)技術(shù)在業(yè)界用的比較普遍,能滿足基本的功能,可以減少培訓(xùn)學(xué)習(xí)成本。
2) 中間層(UserManager):將UserDAO作為屬性注入,其實(shí)現(xiàn)主要是調(diào)用數(shù)據(jù)層接口的一些方法;它處于事務(wù)控制中。
采用Spring框架實(shí)現(xiàn),IOC與AOP是它的代名詞,功能齊全,非常棒的一個(gè)架構(gòu)。
3) 數(shù)據(jù)層(UserDAO):實(shí)現(xiàn)類繼承HibernateDaoSupport類,在該類中可以調(diào)用getHibernateTemplate()的一些方法執(zhí)行具體的數(shù)據(jù)操作。
采用Hibernate做O/R mapping,從種種跡象可以看出,Hibernate就是EJB3.0的beta版。 (轉(zhuǎn)載文章請(qǐng)保留出處:Java家(www.javajia.com))
posted @
2006-04-18 11:05 surffish 閱讀(269) |
評(píng)論 (0) |
編輯 收藏
【品名】民間俗稱老婆,正式場合可稱妻子或夫人;古稱內(nèi)人,現(xiàn)亦可叫愛人。
【成分】水、血液和脂肪類碳水化合物。
【性狀】本品為細(xì)長條塊狀糖衣片,表面涂層一般為粉底、口紅等化妝物,除去後呈淺黃色,外觀與除去前略有差異;本品隨時(shí)間推移,形狀會(huì)有所改變,出現(xiàn)發(fā)胖、起皺等現(xiàn)象,但不影響繼續(xù)使用。
【功能主治】主治單身恐懼癥及傳宗接代等頑疾,對(duì)失戀和相思病也有明顯效果。
【用法用量】口服兼外用,一次限一片。對(duì)無效者,可暫時(shí)停用并向婚姻專家咨詢,或間隔一段時(shí)間後重復(fù)使用。
【注意事項(xiàng)】本品僅適用于單身之成年男性。服用時(shí) 小心謹(jǐn)慎,細(xì)心觀察有無不良反應(yīng),如有必須馬上停止服用,沒有則可繼續(xù)使用。若忌煙酒等不良習(xí)慣,會(huì)使療效更佳。
【規(guī)格】通常為45千克至55千克,特殊情況下亦有例外。
【貯藏】常溫下妥善保存,室內(nèi)陰涼處最佳;如在室外,則 避免強(qiáng)烈陽光直射。 貯藏期間,尤忌隨意棄置一旁不管
posted @
2006-03-23 12:00 surffish 閱讀(272) |
評(píng)論 (0) |
編輯 收藏
用java寫服務(wù)端代碼
import java.io.*;
import java.net.*;
public class test {
public test() {
}
public static final int PORT = 8080;
public static final String ip = "10.194.111.222";
public static void main(String[] args) throws IOException {
ServerSocket s = new ServerSocket(51,2,InetAddress.getByName(ip));
System.out.println("Started: " + s);
try {
// Blocks until a connection occurs:
Socket socket = s.accept();
try {
System.out.println(
"Connection accepted: "+ socket);
BufferedReader in =
new BufferedReader(
new InputStreamReader(
socket.getInputStream()));
// Output is automatically flushed
// by PrintWriter:
PrintWriter out =
new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socket.getOutputStream())),true);
while (true) {
String str = in.readLine();
if (str.equals("END")) break;
System.out.println("Echoing: " + str);
out.println(str);
}
// Always close the two sockets...
} finally {
System.out.println("closing...");
socket.close();
}
} finally {
s.close();
}
}
}
.net寫客戶端代碼
private void button2_Click(object sender, System.EventArgs e)
{
try
{
stSend = new Socket ( AddressFamily.InterNetwork ,
SocketType.Stream , ProtocolType.Tcp ) ;
//初始化一個(gè)Socket實(shí)例
IPEndPoint tempRemoteIP = new IPEndPoint(IPAddress.Parse("10.194.111.222"),51);
//根據(jù)IP地址和端口號(hào)創(chuàng)建遠(yuǎn)程終結(jié)點(diǎn)
EndPoint epTemp = ( EndPoint ) tempRemoteIP;
stSend.Connect ( epTemp ) ;
}
catch ( Exception err)
{
string s = err.ToString();
}
}
posted @
2005-12-09 16:36 surffish 閱讀(1190) |
評(píng)論 (0) |
編輯 收藏
1.工作區(qū): (顯隱)
項(xiàng)目面板:ctrl + Alt + p (Project)
設(shè)計(jì)面板: ctrl + Alt + c (content)
結(jié)構(gòu)面板: ctrl + Alt + s (Structure)
信息面板: ctrl + Alt + M (Message)
狀態(tài)面板: ctrl + Alt + Z
2.主面板:(代碼面板和設(shè)計(jì)面板)
激活代碼模塊: ctrl + J (@1)
參數(shù)提示信息的激活: ctrl + shift + H
打開查詢、替換窗口: ctrl + F
類的查詢: ctrl + -
3.F 鍵的用法
F1: 幫助快捷
F4: 運(yùn)行多行
F5: 加入斷點(diǎn)
F7: 當(dāng)遇到方法時(shí)會(huì)運(yùn)行方法內(nèi)的代碼
F8: 逐步運(yùn)行代碼
F12: 代碼面板和設(shè)計(jì)面板切換
4. Shift 鍵的用法
添加多個(gè)相同組件: 按shift鍵在選項(xiàng)上選取組件,把組件添加到窗口即可
調(diào)整組件間間隔和對(duì)齊: 假設(shè)有組件JPanel 1/2/3;(要達(dá)到3個(gè)組件寬度相同,組件間隔相等,并且都是依據(jù)JPanel1左對(duì)齊),按shift鍵,用鼠標(biāo)選中需要調(diào)整的組件,(第一個(gè)選中的組件是其他的基準(zhǔn))然后右鍵。
5: codeInsight 和 Codetemplates
MemberInsight -- 根據(jù)當(dāng)前的代碼提示可用的類成員或方法(說明)
ParameterInsight -- 提示當(dāng)前的方法需要使用的參數(shù)
SymbolInsigh -- 查看當(dāng)前的變量、方法或者類的愿代碼。
MemberInsight: ctrl + space 或 ctrl + H
ParameterInsight: ctrl + shift + space 或 ctrl + shift + H
SymbolInsight: ctrl + Enter 或 Alt + shift + H
ClassInsight : ctrl + alt + space 或 ctrl + alt + H
注: (@1):使用代碼功能:(ctrl + J)
1、 在想要輸入代碼的位置輸入代碼摸板名,然后按 ctrl + J(開發(fā)人員可以用主菜單上的Tools/Editor/Templates命令來查看代碼摸板的名字)
2、把光標(biāo)定位于想要輸入代碼的位置,然后按ctrl + J
posted @
2005-12-09 11:40 surffish 閱讀(301) |
評(píng)論 (0) |
編輯 收藏
http://blog.csdn.net/javamxj/archive/2004/10/11/131935.aspx
我是一名java的愛好者,理所當(dāng)然裝了不少java方面的軟件,大部分是開放源碼的,而且多數(shù)是綠色軟件,只要解壓,設(shè)置一下環(huán)境變量即可使用。
由于軟件本身升級(jí)比較頻繁,經(jīng)常需要重新設(shè)置使用的環(huán)境變量,而且我常常同時(shí)安裝同一軟件的不同版本(甚至是相同版本)。如eclipse我就分別在F,G,H三個(gè)盤上裝了不同的版本,一個(gè)是中文版,一個(gè)是英文的Latest Release,一個(gè)是Stream Stable,反正是綠色安裝,也不會(huì)發(fā)生沖突,這樣通過對(duì)比便于了解和測試最新版本的先進(jìn)之處。
但是假如把JDK版本從1.3升級(jí)到1.4,即JDK目錄名可能要從“j2sdk1.3”改為“j2sdk1.4”,如果是這樣的話,那么eclipse可能會(huì)無法再啟動(dòng)了(它要從環(huán)境變量中尋找JAVA_HOME變量,而JAVA_HOME變量值已經(jīng)從“j2sdk1.3”改為“j2sdk1.4”了)。
在談?wù)刯akarta-tomcat,這個(gè)軟件升級(jí)比較頻繁,如果你是結(jié)合eclipse來使用Tomcat的,那么每次Tomcat升級(jí),可能都要在eclipse中重新設(shè)置一下Tomcat的安裝目錄,是不是有些麻煩?
對(duì)于此類問題,解決的方法很簡單,只要把默認(rèn)的軟件安裝目錄名去掉版本號(hào)即可(如果擔(dān)心忘記版本號(hào),只要在目錄中添加一個(gè)readme文件加以說明即可)。
如上圖,我的j2sdk,ant,jakata-tomcat等都沒有版本號(hào)。
同樣,在環(huán)境變量設(shè)置中也沒有出現(xiàn)版本號(hào)。
這樣,如果再需要升級(jí)軟件時(shí),僅僅把新版軟件安裝在舊版軟件目錄即可。其它一般都不需要再改動(dòng)了。
另外,在環(huán)境變量設(shè)置中,可以用%變量%代替變量值,如Path變量值可以這樣設(shè)置: %JAVA_HOME%\bin;%JBOSS_HOME%\bin;%ANT_HOME%\bin;
posted @
2005-12-07 16:31 surffish 閱讀(482) |
評(píng)論 (0) |
編輯 收藏
我們要開發(fā)一個(gè)java類:其內(nèi)容只有一句,輸出"hello ant"字符串。并使用ant完成編譯和運(yùn)行工作,這個(gè)例子只是為了跑通ant,不附加多余的東西。
下圖為文件組織,請(qǐng)建立相應(yīng)的目錄,并編寫HelloAnt.java

按照人家老外的文件組織規(guī)則咱也照搬。
在項(xiàng)目根目錄(hello-ant\)寫1個(gè)文件:ant執(zhí)行配置文件build.xml
ok,一切大功告成,哦,不,還沒有運(yùn)行它。
dos下進(jìn)入hello-ant的目錄,即build.xml所在的目錄,我們要用ant工具執(zhí)行它 ,
執(zhí)行: %ant_home%/bin/ant -file build.xml 用ant工具執(zhí)行當(dāng)前目錄下的配置文件build.xml
或 :ant -file build.xml 你如果設(shè)置%ant_home%/bin到path中
這次ok了,這是答案:
命令提示符窗口 |
D:\temp\hello-ant>ant -file build.xml Buildfile: build.xml
main: [javac] Compiling 1 source file to D:\temp\hello-ant\build\classes [java] hello ant,ant 的第一次接觸,好棒!
BUILD SUCCESSFUL Total time: 2 seconds D:\temp\hello-ant> |
檢查一下build/classes目錄,哦,看到編譯過的文件就在這里:
build/classes/hello/ant/HelloAnt.class.
hello ant 進(jìn)級(jí)
(此段比較廢話,可以略過)
你也許會(huì)說:這末簡單的工作寫個(gè)批處理不就得了,又xml又ant的,把我的時(shí)間都浪費(fèi)完了,我用jbuild或
webShpere不就得了,怎末說你才明白呢?反正網(wǎng)上開源項(xiàng)目大多數(shù)都用ant,你總不能給人家個(gè)*.jpx吧,
而且這樣的工具太貴,受不了(當(dāng)然用D的兄弟不怕^_^ ),而且ant可以讓你明確的管理和自動(dòng)化所有的東西:
編譯-實(shí)施-測試...,哎,稍微麻煩一點(diǎn)點(diǎn),但節(jié)約你以前花在零碎的copy,paste上的時(shí)間.而且我發(fā)現(xiàn)管理
代碼的質(zhì)量有所提高.
我們要改進(jìn)build.xml,讓它做更多的事情:
- 定義全局變量
- 初始化,主要是建立目錄
- 編譯 (已有)
- 打包為jar
- 建立API documentation
- 生成distribution產(chǎn)品
凡事都講究平衡,你要ant給你做更多事,當(dāng)然要累一點(diǎn)點(diǎn),不過只用累一次,以后的代碼修改后的構(gòu)建都是"一鍵式"完成,我們制作一個(gè)hello的簡單例子,你可以自己做j2ee的練習(xí)。
我們要擴(kuò)充目錄結(jié)構(gòu),使它更像回事:
ant處理編譯之前的目錄:

ant處理之后的目錄:

圖中:\src,\docs,\lib是自己組織的文件結(jié)構(gòu),\build,\dist是ant動(dòng)態(tài)生成的成品。
\src 源文件:java源,script源,jsp源,xml配置.....
\src\main java源
\src\script window,unix,liunx的執(zhí)行script,我們的簡單只有一個(gè):
run.bat: java hello.ant.HelloAnt
\docs 手寫說明文檔
\lib 程序所需類庫的jar,比如j2ee.jar,mail,jar...
\build 用ant動(dòng)態(tài)生成的構(gòu)建目錄
\build\classes 編譯的類文件
\build\docs copy "\docs"的手寫說明文檔,和ant生成的api文檔
\build\lib 放置我們自己的HelloAnt.class打包成品hello-ant.jar
\dist\bin copy "\src\script" 得執(zhí)行文件
\dist\docs copy "\build\docs" 的文檔
\dist\lib 除了copy "\build\lib"下的hello-ant.jar外,
還應(yīng)copy "\lib"的程序所需jar,這里我們沒有。
以上是我學(xué)老外的文件組織,大家可以按照自己的愛好組織
我們編寫必要的文件:
hello.ant. HelloAnt.java |
已有 |
\docs\index.html 隨便寫一個(gè)手寫的文檔 |
hello ant 軟件項(xiàng)目手冊docs
訪問api文檔 |
build.xml多了些,但其實(shí)很簡單:(注釋比較詳細(xì)可以參照,這里再簡單說一下)
一個(gè)build.xml包含一個(gè)工程的自動(dòng)化處理的完整xml說明,并且基本由3種東東組成:
<project >
1.全局變量的定義
<property/>
2.任務(wù)組
<target>
3.許多單項(xiàng)任務(wù)... 像copy,delete,javac,jar...
<task1/>
<task2/>
<task3/>
</target>
</project>
參考及下載:
本文程序:第1個(gè)hello-ant
本文程序:第2個(gè)進(jìn)階的hello-ant
ant最新下載:
http://jakarta.apache.org/ant/index.html
ant具體的編寫方法參考ant手冊以下2部分就形,
http://jakarta.apache.org/ant/manual/using 使用說明
http://jakarta.apache.org/ant/manual/coretasklist.html 核心tasks
其他一大堆東西你要看也行。不過我覺得比較浪費(fèi)時(shí)間。
http://jakarta.apache.org/ant/manual/index.html 手冊index
huihoo.com翻譯改編的ant/manual/using
http://www.huihoo.com/java/ant.html
用ANT構(gòu)造Application作者:余斌斌
http://developer.ccidnet.com/pub/disp/Article?columnID=295&articleID=27619&pageNO=1
ibm 利用 Ant 和 JUnit 進(jìn)行增量開發(fā)——使用單元測試來逐步改進(jìn)代碼
http://www-900.ibm.com/developerWorks/cn/java/j-ant/index.shtml
posted @
2005-12-07 14:33 surffish 閱讀(580) |
評(píng)論 (1) |
編輯 收藏
本文以最新發(fā)布的Ant 1.5.1為例,介紹這款優(yōu)秀的Build工具的安裝配置、基本應(yīng)用和一些高級(jí)話題。最新的Ant下載地址是
http://jakarta.apache.org/ant/ 。
Ant是一種基于Java的Build工具。理論上來說,它有些類似于C中的make,但比make優(yōu)越。現(xiàn)在存在的大多數(shù)Build工具,如make、gnumake、nmake、jam等都存在這樣或那樣的不足,比如依賴于特定的平臺(tái)、配置文件過于復(fù)雜或者對(duì)格式無法檢查而容易出錯(cuò)等。與這些工具相比較,Ant的兩個(gè)特性決定了它是一款優(yōu)秀的Build工具:
1. 基于Java的實(shí)現(xiàn)。具有良好的跨平臺(tái)性,同時(shí)可以通過增加新的Java類來擴(kuò)展Ant的功能,而無需去了解不同平臺(tái)上不同的腳本語言。
2.基于XML的配置文件。Ant以XML樹來描述Target/Task的關(guān)系,文件結(jié)構(gòu)清晰、易讀易寫,并且利用XML對(duì)格式的控制來避免由于配置文件的錯(cuò)誤造成的Build操作失敗。
安裝與配置
Ant的安裝非常簡單,把從網(wǎng)上下載的jakarta-ant-1.5.1-bin.zip解開到一個(gè)目錄下即可(以下假定安裝在目錄D:\jakarta-ant-1.5.1)。接下來需要進(jìn)行環(huán)境變量配置:
SET ANT_HOME=D:\jakarta-ant-1.5.1 //注意是Ant的安裝目錄,不是bin子目錄 SET PATH=%PATH%;%ANT_HOME%\bin; |
在配置環(huán)境變量之前,請(qǐng)確認(rèn)已經(jīng)正確設(shè)置了JAVA_HOME系統(tǒng)變量。輸入ant命令,看到如下輸出說明已成功安裝了Ant工具:
Buildfile: build.xml does not exist! Build failed |
提示信息表明在當(dāng)前目錄不存在build.xml配置文件,但這本身已經(jīng)說明Ant成功運(yùn)行了。
快速入門
下面用一個(gè)最簡單也是最經(jīng)典的例子-HelloWorld來感受一下Ant吧。
//HelloWorld.java package com.sharetop.antdemo; public class HelloWorld { public static void main( String args[] ) { System.out.println("Hello world. "); } } |
要讓Ant編譯這個(gè)文件,首先需要編寫一個(gè)Build配置文件。在一般情況下,這個(gè)文件被命名為build.xml。
<?xml version="1.0" encoding="UTF-8" ?> <project name="HelloWorld" default="run" basedir="." > <property name="src" value="src"/> <property name="dest" value="classes"/> <property name="hello_jar" value="hello.jar" /> <target name="init"> <mkdir dir="${dest}"/> </target> <target name="compile" depends="init"> <javac srcdir="${src}" destdir="${dest}"/> </target> <target name="build" depends="compile"> <jar jarfile="${hello_jar}" basedir="${dest}"/> </target> <target name="run" depends="build"> <java classname="com.sharetop.antdemo.HelloWorld" classpath="${hello_jar}"/> </target> </project> |
來看一下這個(gè)文件的內(nèi)容,它描述了以下信息:工程的名字為HelloWorld,工程有四個(gè)target,分別是init、compil、build和run,缺省是run。compile只有一個(gè)任務(wù)javac,源文件位于src目錄下,輸出的類文件要放在classes目錄下。build的任務(wù)是jar,生成的jar文件為hello.jar,它打包時(shí)以classes為根目錄。而run則是執(zhí)行這個(gè)HelloWorld類,用hello.jar作為classpath。這四個(gè)target之間有一個(gè)依賴關(guān)系,這種關(guān)系用depends來指定。即如果Target A依賴于Target B,那么在執(zhí)行Target A之前會(huì)首先執(zhí)行Target B。所以從下面運(yùn)行缺省Target(run)的輸出看,這四個(gè)Target的執(zhí)行順序是:init→compile→build→run。文件目錄結(jié)構(gòu)如圖1所示。HelloWorld.java文件在src\com\sharetop\antdemo子目錄下。
圖1 ant_demo應(yīng)用的目錄結(jié)構(gòu)
在命令行輸入命令:ant,然后運(yùn)行,可以看到如下輸出:
如果配置文件名不是build.xml,比如是build_front.xml,那么,可以使用-buildfile命令參數(shù)指定:
G:\myDoc\ant_demo>ant -buildfile build_front.xml |
也可以單獨(dú)執(zhí)行指定的某個(gè)target,比如,只編譯不打包執(zhí)行,可以使用下面輸入命令即可:
G:\myDoc\ant_demo>ant compile |
在相應(yīng)的目錄下會(huì)找到編譯出的HelloWorld.class文件。
再看看上面的build.xml配置文件,文件開頭定義了3個(gè)屬性,分別指定了源文件輸出路徑、類文件輸出路徑和生成的Jar文件名,后面對(duì)這些路徑的引用都通過一個(gè)${property name}來引用。所以,要注意這樣一個(gè)原則“目錄的定義與目錄的引用應(yīng)該分開”。
基本應(yīng)用
建立工程的目錄 一般要根據(jù)工程的實(shí)際情況來建立工程的目錄結(jié)構(gòu)。但是,有一些比較通用的組織形式可供參考,比如所有的jakarta項(xiàng)目都使用類似的目錄結(jié)構(gòu)。下面讓我們來看一下這種目錄結(jié)構(gòu)的特點(diǎn)。
表1
目錄 |
文件 |
bin |
公共的二進(jìn)制文件,以及運(yùn)行腳本 |
build |
臨時(shí)創(chuàng)建的文件,如類文件等 |
dist |
目標(biāo)輸出文件,如生成Jar文件等。 |
doc/javadocs |
文檔。 |
lib |
需要導(dǎo)出的Java包 |
src |
源文件 |
對(duì)于一個(gè)簡單的工程,一般包括表1的幾個(gè)目錄。其中bin、lib、doc和src目錄需要在CVS的控制之下。當(dāng)然在這樣的目錄結(jié)構(gòu)上,也可以做一些調(diào)整,例如,可以建立一個(gè)extra目錄來放置需要發(fā)布的Jar文件、Inf文件及圖像文件等。同樣,如果開發(fā)Web應(yīng)用可以建立一個(gè)Web目錄放置JSP、HTML等文件。
如果我們開發(fā)的是一個(gè)比較復(fù)雜的項(xiàng)目,包括多個(gè)子項(xiàng)目,并且各個(gè)子項(xiàng)目是由不同的開發(fā)人員來完成的,那么要如何來設(shè)計(jì)它的目錄結(jié)構(gòu)?首先有一點(diǎn)是需要確定的,不同的子項(xiàng)目應(yīng)該擁有不同的Build文件,并且整個(gè)項(xiàng)目也應(yīng)該有一個(gè)總的Build文件。可以通過Ant任務(wù)或是AntCall任務(wù)調(diào)用子項(xiàng)目的Build文件,如下例:
<target name="core" depends="init"> <ant dir="components" target="core"/> <ant dir="waf/src" target="core"/> <ant dir="apps" target="core"/> </target> |
在各個(gè)子項(xiàng)目的耦合不是非常緊密的情況下,各個(gè)子項(xiàng)目應(yīng)該有各自獨(dú)立的目錄結(jié)構(gòu),也就是說它們可以有自己的src、doc、build、dist等目錄及自己的build.xml文件,但是可以共享lib和bin目錄。而對(duì)于那些耦合緊密的子項(xiàng)目,則推薦使用同一個(gè)src目錄,但是不同的子項(xiàng)目有不同的子目錄,各個(gè)子項(xiàng)目的build.xml文件可以放在根目錄下,也可以移到各個(gè)子項(xiàng)目的目錄下。
編寫B(tài)uild文件 要用好Ant工具,關(guān)鍵是要編寫一個(gè)build.xml文件。要編寫出一個(gè)結(jié)構(gòu)良好、靈活可擴(kuò)展的Build文件,有兩個(gè)問題要考慮,一是了解Build文件的基本結(jié)構(gòu),二是了解Ant定義的大量任務(wù)。
Ant的Build文件是一個(gè)標(biāo)準(zhǔn)的XML文件,它包含一個(gè)根節(jié)點(diǎn)Project,每個(gè)Project定義了至少一個(gè)或多個(gè)Target,每個(gè)Target又是一系列Task的集合。它們之間的關(guān)系如圖2所示。

圖2 build.xml文件的結(jié)構(gòu)
每個(gè)Task是一段可被執(zhí)行的代碼,比如,前例中的javac、jar就是兩個(gè)最常用的Task。Ant定義了大量的核心Task,我們要考慮的第二個(gè)問題正是如何去掌握這大量的Task。其實(shí)唯一的方法就是邊學(xué)習(xí)邊實(shí)踐,這方面最好的參考就是官方的Ant使用手冊。
外部文件的使用 使用外部的Property文件可以保存一些預(yù)設(shè)置的公共屬性變量。這些屬性可以在多個(gè)不同的Build文件中使用。
可以將一個(gè)外部的XML文件導(dǎo)入Build文件中,這樣多個(gè)項(xiàng)目的開發(fā)者可以通過引用來共享一些代碼,同樣,這也有助于Build文件的重用,示例代碼如下所示:
<!DOCTYPE project [ <!ENTITY share-variable SYSTEM "file:../share-variable.xml"> <!ENTITY build-share SYSTEM "file:../build-share.xml"> ]> <project name="main" default="complie" basedir="."> &share-variable; &build-share; ... ... |
在J2EE項(xiàng)目中的應(yīng)用
只要掌握了Ant的使用方法,在J2EE項(xiàng)目中的應(yīng)用與在其它項(xiàng)目中的應(yīng)用并沒有太大的不同,但是仍有幾點(diǎn)是需要注意的。
一是要清楚War和Jar文件的目錄結(jié)構(gòu),主要是War的配置文件web.xml文件的位置和EJB的配置文件(ejb-jar.xml和weblogic-ejb-jar.xml等)的位置,在調(diào)用Jar任務(wù)打包文件時(shí)一定要記得把它們也包含進(jìn)來。一般在編譯之前就要注意把這些需打包的文件拷入相應(yīng)目錄下。二是在J2EE項(xiàng)目中可能會(huì)涉及到一些特殊的任務(wù),比如在Weblogic中會(huì)調(diào)用ejbc預(yù)編譯EJB的代碼存根,或者需要在Ant中同時(shí)發(fā)布Jar到相應(yīng)的服務(wù)器中等。可以用兩種途徑實(shí)現(xiàn)這些任務(wù),一是擴(kuò)展Ant任務(wù)實(shí)現(xiàn)這些任務(wù),二是直接用Java任務(wù)來執(zhí)行這些命令。下面是打包、發(fā)布一個(gè)EJB的build.xml配置文件片斷,代碼如下:
<target name="deploy_HelloEJB" depends="compile"> <delete dir="${temp}/ejb_make"/> <!-- 首先刪除臨時(shí)目錄 --> <delete file="${temp}/helloEJB.jar"/> <!-- 刪除WebLogic域中老版本的EJB --> <delete file="${weblogic.deploy.dest}/helloEJB.jar"/> <!-- 創(chuàng)建META-INF目錄,放置ejb-jar.xml和weblogic-ejb-jar.xml --> <mkdir dir="${temp}/ejb_make/META-INF"/> <!-- 拷貝ejb-jar.xml和weblogic-ejb-jar.xml 到臨時(shí)目錄--> <copy todir="${temp}/ejb_make/META-INF"> <fileset dir="etc/baseinfo"> <include name="*.xml"/> </fileset> </copy> <!-- 拷貝所有的helloEJB類到臨時(shí)目錄 --> <copy todir="${temp}/ejb_make/"> <fileset dir="${dest.classes}/"> <!-- dest.classes是輸出的類文件目錄 --> <include name="${dest.classes}/helloEJB/**"/> </fileset> </copy> <!-- 將所有這些文件打包成helloEJB.jar --> <jar jarfile="${temp}/helloEJB.jar" basedir="${temp}/ejb_make"/> <!-- 進(jìn)行weblogic.ejbc編譯 --> <java classpath="${wl_cp}" classname="weblogic.ejbc" fork="yes" > <classpath> <fileset dir="lib"> <include name="*.jar" /> </fileset> </classpath> <arg value="${temp}/helloEJB.jar" /> <arg value="${temp}/helloEJB_deploy.jar" /> </java> <!-- 拷貝/發(fā)布到WebLogic的{DOMAIN}\applications目錄 --> <copy file="${temp}/helloEJB_deploy.jar" todir="${weblogic.deploy.dest}"/> </target> |
用Ant配合JUnit實(shí)現(xiàn)單元測試
Ant 提供了JUnit任務(wù),可以執(zhí)行單元測試代碼。如何使用JUnit,以及如何編寫測試用例(TestCase),感興趣的讀者可以參閱JUnit的相關(guān)文檔。在Ant中使用JUnit的方法非常簡單,首先需要把junit.jar拷入ANT_HOME\lib下,確認(rèn)在這個(gè)目錄下有optional.jar,因?yàn)镴Unit是Ant的擴(kuò)展任務(wù),需要引用這個(gè)擴(kuò)展包。然后就是在Build文件中加入JUnit的任務(wù),代碼如下:
<target name="run" depends="client"> <junit printsummary="yes" fork="yes" haltonfailure="yes"> <classpath> <pathelement location="client.jar" /> </classpath> <formatter type="plain" /> <test name="com.sharetop.antdemo.HelloWorldTest" /> </junit> </target> |
高級(jí)話題
為Ant開發(fā)擴(kuò)展任務(wù) 為Ant實(shí)現(xiàn)擴(kuò)展任務(wù)其實(shí)是非常容易的,只需按照以下幾個(gè)步驟即可:
1. 創(chuàng)建一個(gè)Java類繼承org.apache.tools.ant.Task類;
2. 對(duì)每個(gè)屬性實(shí)現(xiàn)set方法。Ant會(huì)根據(jù)需要自動(dòng)完成類型轉(zhuǎn)換;
3. 如果擴(kuò)展的任務(wù)需要嵌套其它的Task,那么這個(gè)Java類必需實(shí)現(xiàn)接口org.apache.tools.ant.TaskContainer;
4. 如果擴(kuò)展的任務(wù)要支持Text,需要增加一個(gè)方法void addText(String);
5. 對(duì)每個(gè)嵌套的元素,實(shí)現(xiàn)create、add 或 addConfigured 方法;
6. 實(shí)現(xiàn)public void execute方法;
7. 在build.xml文件中使用 <taskdef> 來引用自定義的Task。
下面以一個(gè)簡單的例子來說明如何為Ant增加一個(gè)hello任務(wù),它可以連續(xù)打印多條信息,打印的次數(shù)由屬性count指定,而打印的內(nèi)容則由它內(nèi)嵌的一個(gè)helloinfo任務(wù)的message屬性指定,看上去這非常類似JSP中自定義標(biāo)簽的一些概念,實(shí)現(xiàn)代碼如下:
//HelloInfoTask.java package com.sharetop.antdemo; import org.apache.tools.ant.*; public class HelloInfoTask { private String msg; public void execute() throws BuildException { System.out.println(msg); } public void setMessage(String msg) { this.msg = msg; } } |
下面是外部Task類的代碼:
//HelloTask.java package com.sharetop.antdemo; import org.apache.tools.ant.*; public class HelloTask extends Task implements org.apache.tools.ant.TaskContainer { private Task info; private int count; public void execute() throws BuildException { for(int i=0;i<count;i++) info.execute(); } public void setCount(int c){ this.count=c; } public void addTask(Task t){ this.info=t; } } |
實(shí)現(xiàn)了這兩個(gè)Task,在build.xml文件中定義它的task name,就可以在Target中執(zhí)行它了。如果你不想使用 <taskdef> 標(biāo)簽來定義Task,也可以通過修改default.properties文件來實(shí)現(xiàn)引入新Task,這個(gè)文件位于org.apache.tools.ant.taskdefs 包里。下例是一個(gè)使用 標(biāo)簽來引入新Task的Build文件部分:
<target name="hello" depends="client"> <taskdef name="hello" classname="com.sharetop.antdemo.HelloTask" classpath="client.jar"/> <taskdef name="helloinfo" classname="com.sharetop.antdemo.HelloInfoTask" classpath="client.jar"/> <hello count="3" > <helloinfo message="hello world" /> </hello> </target> |
在自己的程序中調(diào)用Ant
Ant的任務(wù)其實(shí)就是一段功能代碼。Ant內(nèi)置的大量任務(wù)對(duì)于我們開發(fā)Java應(yīng)用具有非常大的意義,為什么我們不能直接使用呢?
因?yàn)楸M管在程序中調(diào)用Ant的任務(wù)并不復(fù)雜,而且我們知道Ant的任務(wù)其實(shí)都是一些Java類,調(diào)用的方法無非就是執(zhí)行這些類而已,不過在執(zhí)行之前需要對(duì)它做一些初始化的工作,所以我們需要引用一個(gè)Task類的子類來實(shí)現(xiàn)這個(gè)功能,比如如下代碼:
package com.sharetop.antdemo; import org.apache.tools.ant.*; import org.apache.tools.ant.taskdefs.*; import java.io.File; public class RunAntTask { public RunAntTask() { } public static void main(String args[]){ AntJAR j = new AntJAR(); j.setBasedir(new File("./classes")); j.setJarfile(new File("aaa.jar")); j.execute(); } } final class AntJAR extends Jar { public AntJAR() { project = new Project(); project.init(); taskType = "jar"; taskName = "jar"; } } |
注意AntJAR類的構(gòu)造方法,先創(chuàng)建了Project并初始化它,這是直接調(diào)用Task的必需條件。
如果要在自己的程序中執(zhí)行Ant,需要了解的是Ant定義的幾個(gè)BuildEvent,它包括:
◆ Build started
◆ Build finished
◆ Target started
◆ Target finished
◆ Task started
◆ Task finished
◆ Message logged
我們需要做的是實(shí)現(xiàn)BuildListener接口來處理各種事件,而執(zhí)行Ant的方法與上面給的例子非常類似,以實(shí)際開發(fā)的AntBuilder軟件的部分代碼為例:
public void buildTarget(String targetName,String buildFileName) { try { Project p = new Project(); p.init(); File f = new File(buildFileName); p.setUserProperty("ant.file",f.getAbsolutePath()); ProjectHelper.configureProject(p,f); p.addBuildListener(this); if( targetName==null ) p.executeTarget(p.getDefaultTarget()); else p.executeTarget(targetName); } catch (Exception ex) { jTextArea1.append(ex.getMessage()); } } |
創(chuàng)建Project并初始化,設(shè)置它的配置文件(build.xml),執(zhí)行它缺省的或指定的Target,然后在實(shí)現(xiàn)了BuildListenser接口的監(jiān)聽器類中對(duì)你感興趣的事件作處理,代碼如下:
public void buildStarted(BuildEvent event){ /* nothing*/ } public void buildFinished(BuildEvent event) { /* nothing*/ } public void targetStarted(BuildEvent event) { this.jTextArea1.append(event.getTarget().getName()+": \n\r"); } public void targetFinished(BuildEvent event) {/* nothing*/ } public void taskStarted(BuildEvent event) {/* nothing*/ } public void taskFinished(BuildEvent event) { /* nothing*/ } public void messageLogged(BuildEvent event) { int prior = event.getPriority(); switch(prior){ case Project.MSG_ERR : this.jTextArea1.append("["+event.getTask().getTaskName()+"]Err:" +event.getMessage()); break; case Project.MSG_INFO: this.jTextArea1.append("["+event.getTask().getTaskName()+"]"+event.getMessage ()); break; case Project.MSG_WARN: this.jTextArea1.append("["+event.getTask().getTaskName()+"]" +event.getMessage()); break; case Project.MSG_VERBOSE: this.jTextArea1.append(event.getMessage()); break; } } |
Build.xml文件的寫法每個(gè)公司都有不同,這里沒有太大的參考價(jià)值,所以略去。(全文完)
posted @
2005-12-07 14:29 surffish 閱讀(1658) |
評(píng)論 (0) |
編輯 收藏
//服務(wù)器代碼
/********************************Main******************************/
import java.io.*;
import java.net.*;
import java.util.*;
public class ServerMain{
public static Vector socketVector=new Vector();
public static void main(String[] args) throws IOException{
System.out.println("服務(wù)器啟動(dòng)........");
ServerSocket s = new ServerSocket(5000);
while(true){
Socket soc = s.accept();
SocketThread st=new SocketThread(soc);
socketVector.addElement(st);
st.start();
}
}
public static void sendEveryone(String msg){
Object object=null;
int len=socketVector.size();
for(int i=0;i<len;i++){
try {
object=socketVector.elementAt(i);
SocketThread st = (SocketThread)object;
st.sender.send(msg);
}
catch (Exception ex) {
socketVector.removeElement(object);
}
}
}
public static void removeObject(Object object){
socketVector.removeElement(object);
}
public static void removeObject(Sender sender) throws Exception{
int len=socketVector.size();
for(int i=0;i<len;i++){
Object object=socketVector.elementAt(i);
SocketThread st = (SocketThread)object;
if(st.sender==sender)
socketVector.removeElement(object);
}
}
}
/*********************************SocketThread **********************/
import java.io.*;
import java.net.*;
import java.util.*;
public class SocketThread implements Runnable{
public Socket socke;
public DataInputStream dis;
public DataOutputStream dos;
public Sender sender;
private boolean stop;
Calendar date;// = Calendar.getInstance(TimeZone.getTimeZone("Asia/ShangHai"));
public SocketThread(Socket sok){
socke=sok;
}
public void start(){
Thread t=new Thread(this);
t.start();
}
public void run() {
try {
socke.setKeepAlive(true);
dis = new DataInputStream(socke.getInputStream());
dos = new DataOutputStream(socke.getOutputStream());
sender = new Sender(dos);
while (true) {
StringBuffer sb = new StringBuffer();
char c;
while (((c = dis.readChar()) != '\n') && (c != -1)) {
sb.append(c);
}
if (c == -1) {
break;
}
date = Calendar.getInstance(TimeZone.getTimeZone("Asia/ShangHai"));
String ljnTime="("+date.get(date.YEAR)+"/"+(date.get(date.MONTH)+1)+"/"+date.get(date.DATE)+" "+date.get(date.HOUR_OF_DAY)+":"+date.get(date.MINUTE)+":"+date.get(date.SECOND)+")";
String acceptMsg=sb.toString();
System.out.println(ljnTime+acceptMsg);
ServerMain.sendEveryone(acceptMsg);
}
stop();
ServerMain.removeObject(this);
} catch (IOException ioe) {
} catch (Exception e) {
e.printStackTrace();
}
}
public void stop() {
try {
stop = true;
if(sender!=null){
sender.stop1();
}
if (dis != null) {
dis.close();
}
if (dos != null) {
dos.close();
}
if (socke != null) {
socke.close();
}
} catch (IOException ioe) {
}
}
}
/*********************************************Sender**************************/
import java.io.*;
public class Sender extends Thread {
private DataOutputStream dos;
private String message;
public Sender(DataOutputStream os) {
this.dos = os;
start();
}
public synchronized void send(String msg) {
message = msg;
notify();
}
public synchronized void run() {
while (true) {
if (message == null) {
try {
wait();
} catch (InterruptedException e) {
}
}
if (message == null) {
break;
}
try {
dos.writeChars(message);
dos.writeChars("\r\n");
} catch (IOException ioe) {
try {
ServerMain.removeObject(this);
}
catch (Exception ex) {
}
}
message = null;
}
}
public synchronized void stop1() {
message = null;
notify();
}
}
//下面為手機(jī)客戶端代碼
import javax.microedition.midlet.*;
import javax.microedition.lcdui.*;
public class ChatClientMIDlet extends MIDlet {
private static ChatClientMIDlet instance;
public static ChatForm displayable = new ChatForm();
/** Constructor */
public ChatClientMIDlet() {
instance = this;
}
/** Main method */
public void startApp() {
Display.getDisplay(this).setCurrent(displayable);
}
/** Handle pausing the MIDlet */
public void pauseApp() {
}
/** Handle destroying the MIDlet */
public void destroyApp(boolean unconditional) {
}
public static void setCurrent(Displayable s){
Display.getDisplay(instance).setCurrent(s);
}
/** Quit the MIDlet */
public static void quitApp() {
instance.destroyApp(true);
instance.notifyDestroyed();
instance = null;
}
}
/********************************************************ChatForm ************************/
import com.nec.io.*;
import javax.microedition.lcdui.*;
import javax.microedition.io.*;
import java.io.*;
public class ChatForm extends Form implements CommandListener,Runnable {
public Form mainForm=new Form("聊天室");
public Command enter=new Command("進(jìn)入",Command.OK,0);
public Command send=new Command("發(fā)送",Command.OK,1);
public Command exit=new Command("退出",Command.EXIT,0);
public DataInputStream dis;
public DataOutputStream dos;
public SocketConnection sc;
public Sender sender;
public boolean stop;
public TextField textField=new TextField("請(qǐng)輸入昵稱:", null, 10, TextField.ANY);
public TextField info=new TextField("請(qǐng)輸入消息:", null,255, TextField.ANY);
public ChoiceGroup choiceGroup=new ChoiceGroup(null,ChoiceGroup.EXCLUSIVE);
public String MyName="游客";
public boolean isCurrent=false;;
public ChatForm() {
super("我的聊天室");
append(textField);
addCommand(enter);
mainForm.append(info);
mainForm.append(choiceGroup);
choiceGroup.append(");
setCommandListener(this);
mainForm.addCommand(send);
mainForm.addCommand(exit);
mainForm.setCommandListener(this);
}
public void commandAction(Command c, Displayable dis) {
if(c==enter){
if(textField.getString().length()==0){
Alert alert=new Alert("警告","昵稱不能為空!", null, AlertType.WARNING) ;
alert.setTimeout(3000);
ChatClientMIDlet.setCurrent(alert);
return;
}else
{
MyName = textField.getString();
append("正在進(jìn)入......");
}
Thread t=new Thread(this);
t.start();
}else if(c==send){
if(info.getString().length()==0){
Alert alert=new Alert("警告","消息內(nèi)容不能為空!", null, AlertType.WARNING) ;
alert.setTimeout(3000);
ChatClientMIDlet.setCurrent(alert);
return;
}
sender.send(MyName+"說:"+info.getString());
info.setString("");
}
else{
stop();
ChatClientMIDlet.quitApp();
}
}
public void run() {
try {
sc = (SocketConnection) Connector.open("socket://127.0.0.1:5000");
sc.setSocketOption(SocketConnection.LINGER, 5);
dis = new DataInputStream(sc.openInputStream());
dos = new DataOutputStream(sc.openOutputStream());
sender = new Sender(dos);
sender.send("歡迎"+MyName+"進(jìn)入房間");
while (true) {
if(stop) break;
StringBuffer sb = new StringBuffer();
char c;
while (((c = dis.readChar()) != '\n') && (c != -1)) {
sb.append(c);
}
if (c == -1) break;
if(!isCurrent){
ChatClientMIDlet.setCurrent(mainForm);
isCurrent=true;
}
String msg=sb.toString();
msg=msg.substring(0,msg.length()-2);
choiceGroup.insert(0,msg,null);
choiceGroup.setSelectedIndex(0,true);
}
stop();
} catch (ConnectionNotFoundException cnfe) {
} catch (IOException ioe) {
if (!stop) {
ioe.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void stop() {
try {
stop = true;
if (sender != null) {
sender.stop1();
}
if (dis != null) {
dis.close();
}
if (dos != null) {
dos.close();
}
if (sc != null) {
sc.close();
}
} catch (IOException ioe) {
}
}
}
/**************************Sender*********************************/
同上
posted @
2005-11-22 12:54 surffish 閱讀(1080) |
評(píng)論 (2) |
編輯 收藏
//怎樣獲取一個(gè)文件夾下中的所有文件File dir = new File("fileDirectory");
String[] filel= dir.list();
//oracle啟動(dòng)方法
--啟動(dòng)數(shù)據(jù)庫
su - oracle
sqlplus /nolog
connect /as sysdba
startup
exit
--監(jiān)聽
lsnrctl
start
posted @
2005-11-21 09:57 surffish 閱讀(229) |
評(píng)論 (0) |
編輯 收藏
telnet 10.194.132.1
ftp 192.168.10.1
ls
vi
i
esc
:wq
ctrl + c
cp
posted @
2005-11-10 15:23 surffish 閱讀(288) |
評(píng)論 (0) |
編輯 收藏
在Weblogic 8.1 sp1 上調(diào)試《精通EJB 2》源代碼
----連接池及數(shù)據(jù)源ejbPool的配置.
作者: naxin9999@163.com
--------------------------------------------------------------------------------
一. 首先在mysql數(shù)據(jù)庫中新建一個(gè)me2庫,再建一個(gè)sa用戶(密碼:222222).授予權(quán)限.再提交源代碼中的EJB.sql文件 ( 在EJB.sql文件頭加上use me2; )。
具體如下:
d:\mysql –u root –p
mysql> create database me2;
mysql> GRANT ALL PRIVILEGES ON me2.* TO sa@'localhost' IDENTIFIED BY '222222' WITH GRANT OPTION;
mysql> quit
d:\ mysql –u sa –p < EJB.sql
password: (輸入222222)
完成.
二. 下面開始創(chuàng)建DS:
a. 把mysql的驅(qū)動(dòng)程序mm.mysql-2.0.14-bin.jar復(fù)制到 D:\bea\weblogic81\server\lib 目錄下.
b. 修改D:\bea\user_projects\domains\mydomain 目錄下的startweblogic.cmd文件中的 CLASSPATH設(shè)置,加上%WL_HOME%\server\lib\mm.mysql-2.0.14-bin.jar;
c. 起動(dòng)weblogic,登陸 http://localhost:7001/console
--------------------------------------------------------------------------------
1.先建個(gè)pool (下圖)

--------------------------------------------------------------------------------
2. (下圖)

--------------------------------------------------------------------------------
3. (下圖)

--------------------------------------------------------------------------------
4. (下圖)

--------------------------------------------------------------------------------
5. (下圖)

--------------------------------------------------------------------------------
6. (下圖)
--------------------------------------------------------------------------------
7. 再建JDBC DS (下圖)

--------------------------------------------------------------------------------
8. (下圖)

--------------------------------------------------------------------------------
9. (下圖)

--------------------------------------------------------------------------------
10(下圖)

--------------------------------------------------------------------------------
11. (下圖)

--------------------------------------------------------------------------------
12. 部署你的EJB,可以進(jìn)行測試了(下圖)

--------------------------------------------------------------------------------
13. 運(yùn)行cmp 2.0的例子. Client輸出:

14. Console 上輸出

1. 在http://localhost:7001/console 找到 Configure a new JMS Topic..

2.如下圖輸入:

3.Create成功后.

4.部署你的消息驅(qū)動(dòng)Bean

5.運(yùn)行客戶端,run_client.bat

6.weblogic控制臺(tái)上的輸出.

posted @
2005-10-31 15:35 surffish 閱讀(274) |
評(píng)論 (0) |
編輯 收藏
/*$T BYBARP~1.H GC 1.137 09/13/05 08:37:52 */
#ifndef ByBarPrinterH
#define ByBarPrinterH
#include "vcl.h"
#define BPLA_OK 1000 //一切正常
///
#define BPLA_COMERROR 1001 //通訊錯(cuò)或者未聯(lián)接打印機(jī)
#define BPLA_PARAERROR 1002 //參數(shù)錯(cuò)誤
#define BPLA_FILEOPENERROR 1003 //文件打開錯(cuò)誤
#define BPLA_FILEREADERROR 1004 //文件讀錯(cuò)誤
#define BPLA_FILEWRITEERROR 1005 //文件寫錯(cuò)誤
#define BPLA_FILEERROR 1006 //文件不合要求
#define BPLA_NUMBEROVER 1007 //指定的接收信息數(shù)量過大
#define BPLA_IMAGETYPEERROR 1008 //圖象文件格式不正確
#define BPLA_PAPERSHORT 1009 //缺紙
#define BPLA_RIBBIONSHORT 1010 //缺色帶
#define BPLA_BUSY 1011 //解釋器忙
#define BPLA_PAUSE 1012 //暫停
///中
#define BPLA_HEADHEAT 1013 //打印頭過熱
#define BPLA_HEADOVER 1014 //打印頭抬起
#define BPLA_CUT 1015 //切刀錯(cuò)
#define BPLA_READERROR 1016 //read error
//打開端口
typedef int (__stdcall *mBY_Open_Port) (int devtype, int porttype, char *opencode, int codelength, int baudrate);
//打印
typedef int (__stdcall *mBY_Print_Label)
(
int LabelType,
const char *JiDaJu,
const char *FenFaJu,
const char *TiaoMaXinXi,
const char *HaoMa,
const char *JianShu,
const char *ZhongLiang,
const char *ZhuanKouJuDaiHao,
const char *XingHao,
const char *BeiZhu,
const char *BiaoPaiBianHao,
const char *ZhongLeiJianCheng,
const char *BenZhuan,
int Pieces
);
//查詢狀態(tài)
typedef int (__stdcall *mBY_Query_Status) ();
//關(guān)閉端口
typedef int (__stdcall *mBY_Close_Port) (char *closecode, long codelength);
class PACKAGE CByBarPrinter
{
public:
long OpenPort(long nPcIndex, long nPortIndex, long baudrate);
void ClosePort(void);
long PrintLabel
(
long LabelType,
String JiDaJu,
String FenFaJu,
String TiaoMaXinXi,
String HaoMa,
String JianShu,
String ZhongLiang,
String ZhuanKouJuDaiHao,
String XingHao,
String BeiZhu,
String BiaoPaiBianHao,
String ZhongLeiJianCheng,
String BenZhuan,
long Pieces
);
CByBarPrinter(void);
long GetStatus(void);
private:
HINSTANCE m_hDll;
bool LoadLib(void);
};
#endif
/*$T BYBARP~1.CPP GC 1.137 09/13/05 08:37:52 */
#pragma hdrstop
#include "ByBarPrinter.h"
/* ---------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------- */
CByBarPrinter::CByBarPrinter(void)
{
m_hDll = NULL;
}
/* ---------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------- */
bool CByBarPrinter::LoadLib(void)
{
if(m_hDll == NULL) m_hDll = ::LoadLibrary("byprndll.dll");
if(m_hDll == NULL)
return false;
else
return true;
}
/* ---------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------- */
long CByBarPrinter::OpenPort(long nPcIndex, long nPortIndex, long baudrate)
{
long retCode;
if(!LoadLib())
{
retCode = -2;
return retCode;
}
mBY_Open_Port BY_Open_Port;
BY_Open_Port = (mBY_Open_Port) GetProcAddress(m_hDll, "BY_Open_Port");
if(BY_Open_Port == NULL)
{
retCode = -1;
}
else
{
String szCom;
szCom = "COM";
szCom += IntToStr(nPortIndex);
int nLen = szCom.Length();
retCode = BY_Open_Port(nPcIndex, nPortIndex, szCom.c_str(), nLen, 19200);
}
return retCode;
}
/* ---------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------- */
void CByBarPrinter::ClosePort(void)
{
if(!LoadLib()) return;
mBY_Close_Port BY_Close_Port;
BY_Close_Port = (mBY_Close_Port) GetProcAddress(m_hDll, "BY_Close_Port");
char CloseCode[50];
int CodeLength = 0;
memset(CloseCode, 0, 50);
BY_Close_Port(CloseCode, CodeLength);
//FreeLibrary(m_hDll);
delete[] CloseCode;
return;
}
/* ---------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------- */
long CByBarPrinter::PrintLabel
(
long LabelType,
String JiDaJu,
String FenFaJu,
String TiaoMaXinXi,
String HaoMa,
String JianShu,
String ZhongLiang,
String ZhuanKouJuDaiHao,
String XingHao,
String BeiZhu,
String BiaoPaiBianHao,
String ZhongLeiJianCheng,
String BenZhuan,
long Pieces
)
{
long retCode;
if(!LoadLib())
{
retCode = -2;
return retCode;
}
//USES_CONVERSION;
mBY_Print_Label BY_Print_Label;
BY_Print_Label = (mBY_Print_Label) GetProcAddress(m_hDll, "BY_Print_Label");
if(BY_Print_Label == NULL)
{
retCode = -1;
return S_OK;
}
retCode = BY_Print_Label
(
LabelType,
JiDaJu.c_str(),
FenFaJu.c_str(),
TiaoMaXinXi.c_str(),
HaoMa.c_str(),
JianShu.c_str(),
ZhongLiang.c_str(),
ZhuanKouJuDaiHao.c_str(),
XingHao.c_str(),
BeiZhu.c_str(),
BiaoPaiBianHao.c_str(),
ZhongLeiJianCheng.c_str(),
BenZhuan.c_str(),
Pieces
);
return retCode;
}
/* ---------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------- */
long CByBarPrinter::GetStatus(void)
{
long state;
if(!LoadLib())
{
state = -1;
return state;
}
mBY_Query_Status BY_Query_Status;
BY_Query_Status = (mBY_Query_Status) GetProcAddress(m_hDll, "BY_Query_Status");
if(BY_Query_Status == NULL)
state = -1;
else
state = BY_Query_Status();
return state;
}
#pragma package(smart_init)
posted @
2005-10-31 13:54 surffish 閱讀(248) |
評(píng)論 (0) |
編輯 收藏
substr(string,1,8)
1.
//將一個(gè)表中符合條件的記錄批量更新到另外一張表。(假設(shè)表名為:toffice,tofficetemp)
??????update toffice a
??????set a.office_code = (select b.office_code from tofficetemp b where a.jgdm = b.jgdm)
??????where a.jgdm in (select jgdm from tofficetemp)
??????update tofficenexas set isuse = '0' where rowid in?
??????(select rowid from tofficenexas a where?
??????rowid !=(select max(rowid) from tofficenexas b where a.office_id = b.office_id and
??????a.father_office_id = b.father_office_id and a.big_kind_id =b.big_kind_id))
2
//查詢某個(gè)時(shí)間段的值
select * from tdespatch t
where t.out_time between to_date('2005-10-18 15:47:42','yyyy-mm-dd hh24:mi:ss')
?and to_date('2005-10-20 10:47:42','yyyy-mm-dd hh24:mi:ss')
3。
//復(fù)制表(只復(fù)制結(jié)構(gòu),源表名:a?新表名:b)
SQL:?select?*?into?b?from?a?where?1<>1
4。
//拷貝表(拷貝數(shù)據(jù),源表名:a?目標(biāo)表名:b)
SQL:?insert?into?b(a,?b,?c)?select?d,e,f?from?b;
5。
說明:顯示文章、提交人和最后回復(fù)時(shí)間
SQL:?select?a.title,a.username,b.adddate?from?table?a,(select?max(adddate)?adddate?from?table?where?table.title=a.title)?b
說明:外連接查詢(表名1:a?表名2:b)
SQL:?select?a.a,?a.b,?a.c,?b.c,?b.d,?b.f?from?a?LEFT?OUT?JOIN?b?ON?a.a?=?b.c
說明:日程安排提前五分鐘提醒
SQL:??select?*?from?日程安排?where?datediff('minute',f開始時(shí)間,getdate())>5
說明:兩張關(guān)聯(lián)表,刪除主表中已經(jīng)在副表中沒有的信息
SQL:??
delete?from?info?where?not?exists?(?select?*?from?infobz?where?info.infid=infobz.infid?)?
說明:--
SQL:??
SELECT?A.NUM,?A.NAME,?B.UPD_DATE,?B.PREV_UPD_DATE
??FROM?TABLE1,?
????(SELECT?X.NUM,?X.UPD_DATE,?Y.UPD_DATE?PREV_UPD_DATE
????????FROM?(SELECT?NUM,?UPD_DATE,?INBOUND_QTY,?STOCK_ONHAND
????????????????FROM?TABLE2
??????????????WHERE?TO_CHAR(UPD_DATE,'YYYY/MM')?=?TO_CHAR(SYSDATE,?'YYYY/MM'))?X,?
????????????(SELECT?NUM,?UPD_DATE,?STOCK_ONHAND
????????????????FROM?TABLE2
??????????????WHERE?TO_CHAR(UPD_DATE,'YYYY/MM')?=?
????????????????????TO_CHAR(TO_DATE(TO_CHAR(SYSDATE,?'YYYY/MM')?¦¦?'/01','YYYY/MM/DD')?-?1,?'YYYY/MM')?)?Y,?
????????WHERE?X.NUM?=?Y.NUM?(+)
??????????AND?X.INBOUND_QTY?+?NVL(Y.STOCK_ONHAND,0)?<>?X.STOCK_ONHAND?)?B
WHERE?A.NUM?=?B.NUM
說明:--
SQL:??
select?*?from?studentinfo?where?not?exists(select?*?from?student?where?studentinfo.id=student.id)?and?系名稱='"&strdepartmentname&"'?and?專業(yè)名稱='"&strprofessionname&"'?order?by?性別,生源地,高考總成績
說明:
從數(shù)據(jù)庫中去一年的各單位電話費(fèi)統(tǒng)計(jì)(電話費(fèi)定額賀電化肥清單兩個(gè)表來源)
SQL:?
SELECT?a.userper,?a.tel,?a.standfee,?TO_CHAR(a.telfeedate,?'yyyy')?AS?telyear,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'01',?a.factration))?AS?JAN,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'02',?a.factration))?AS?FRI,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'03',?a.factration))?AS?MAR,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'04',?a.factration))?AS?APR,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'05',?a.factration))?AS?MAY,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'06',?a.factration))?AS?JUE,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'07',?a.factration))?AS?JUL,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'08',?a.factration))?AS?AGU,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'09',?a.factration))?AS?SEP,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'10',?a.factration))?AS?OCT,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'11',?a.factration))?AS?NOV,
??????SUM(decode(TO_CHAR(a.telfeedate,?'mm'),?'12',?a.factration))?AS?DEC
FROM?(SELECT?a.userper,?a.tel,?a.standfee,?b.telfeedate,?b.factration
????????FROM?TELFEESTAND?a,?TELFEE?b
????????WHERE?a.tel?=?b.telfax)?a
GROUP?BY?a.userper,?a.tel,?a.standfee,?TO_CHAR(a.telfeedate,?'yyyy')
說明:四表聯(lián)查問題:
SQL:?select?*?from?a?left?inner?join?b?on?a.a=b.b?right?inner?join?c?on?a.a=c.c??inner?join?d?on?a.a=d.d?where?.....
說明:得到表中最小的未使用的ID號(hào)
SQL:
SELECT?(CASE?WHEN?EXISTS(SELECT?*?FROM?Handle?b?WHERE?b.HandleID?=?1)?THEN?MIN(HandleID)?+?1?ELSE?1?END)?as?HandleID
?FROM??Handle
?WHERE?NOT?HandleID?IN?(SELECT?a.HandleID?-?1?FROM?Handle?a)
6?? 根據(jù)父表 只取子表最新的一條記錄{
SQL> select * from testa ;
?
??????? F1
----------
???????? 1
???????? 2
???????? 3
SQL> select * from testb ;
??????? F1 F2
---------- -------------------
???????? 1 2006-04-10 14:56:41
???????? 1 2006-04-10 14:56:53
???????? 1 2006-04-10 14:57:00
???????? 2 2006-04-10 14:57:08
???????? 3 2006-04-10 14:57:19
???????? 3 2006-04-10 14:57:25?
6 rows selected.
SQL> select testa.f1,v1.f1,v1.f2 from testa ,(select f1,f2,row_number() over (partition by f1 order
by f2 desc) rn from testb) v1 where testa.f1 = v1.f1 and v1.rn = 1 ;
??????? F1???????? F1 F2
---------- ---------- -------------------
???????? 1??????? ??1 2006-04-10 14:57:00
???????? 2????????? 2 2006-04-10 14:57:08
???????? 3????????? 3 2006-04-10 14:57:25
------------------------------------------
7 查詢語句的優(yōu)化
select t.* from acc$ t
where
not exists (在此不使用not in 是為了性能上的考慮)
(select 'a' from crm$ a
where
a.客戶名=t.用戶名稱
--a.客戶號(hào)=t.用戶編號(hào)
)
posted @
2005-10-30 09:42 surffish 閱讀(284) |
評(píng)論 (0) |
編輯 收藏
用連接池提高Servlet訪問數(shù)據(jù)庫的效率 |
作者:[本站編輯] 來源:[CSDN] 瀏覽:[
] |
|
Java Servlet作為首選的服務(wù)器端數(shù)據(jù)處理技術(shù),正在迅速取代CGI腳本。Servlet超越CGI的優(yōu)勢之一在于,不僅多個(gè)請(qǐng)求可以共享公用資源,而且還可以在不同用戶請(qǐng)求之間保留持續(xù)數(shù)據(jù)。本文介紹一種充分發(fā)揮該特色的實(shí)用技術(shù),即數(shù)據(jù)庫連接池。
一、實(shí)現(xiàn)連接池的意義
動(dòng)態(tài)Web站點(diǎn)往往用數(shù)據(jù)庫存儲(chǔ)的信息生成Web頁面,每一個(gè)頁面請(qǐng)求導(dǎo)致一次數(shù)據(jù)庫訪問。連接數(shù)據(jù)庫不僅要開銷一定的通訊和內(nèi)存資源,還必須完成用戶驗(yàn)證、安全上下文配置這類任務(wù),因而往往成為最為耗時(shí)的操作。當(dāng)然,實(shí)際的連接時(shí)間開銷千變?nèi)f化,但1到2秒延遲并非不常見。如果某個(gè)基于數(shù)據(jù)庫的Web應(yīng)用只需建立一次初始連 接,不同頁面請(qǐng)求能夠共享同一連接,就能獲得顯著的性能改善。 Servlet是一個(gè)Java類。Servlet引擎(它可能是Web服務(wù)軟件的一部分,也可能是一個(gè)獨(dú)立的附加模塊)在系統(tǒng)啟動(dòng)或Servlet第一次被請(qǐng)求時(shí)將該類裝入Java虛擬機(jī)并創(chuàng)建它的一個(gè)實(shí)例。不同用戶請(qǐng)求由同一Servlet實(shí)例的多個(gè)獨(dú)立線程處理。那些要 求在不同請(qǐng)求之間持續(xù)有效的數(shù)據(jù)既可以用Servlet的實(shí)例變量來保存,也可以保存在獨(dú)立的輔助對(duì)象中。 用JDBC訪問數(shù)據(jù)庫首先要?jiǎng)?chuàng)建與數(shù)據(jù)庫之間的連接,獲得一個(gè)連接對(duì)象(Connection),由連接對(duì)象提供執(zhí)行SQL語句的方法。 本文介紹的數(shù)據(jù)庫連接池包括一個(gè)管理類DBConnectionManager,負(fù)責(zé)提供與多個(gè)連接池對(duì)象(DBConnectionPool類)之間的接口。每一個(gè)連接池對(duì)象管理一組JDBC連接對(duì)象,每一個(gè)連接對(duì)象可以被任意數(shù)量的Servlet共享。 類DBConnectionPool提供以下功能:
1) 從連接池獲取(或創(chuàng)建)可用連接。 2) 把連接返回給連接池。 3) 在系統(tǒng)關(guān)閉時(shí)釋放所有資源,關(guān)閉所有連接。
此外, DBConnectionPool類還能夠處理無效連接(原來登記為可用的連接,由于某種原因不再可用,如超時(shí),通訊問題) ,并能夠限制連接池中的連接總數(shù)不超過某個(gè)預(yù)定值。 管理類DBConnectionManager用于管理多個(gè)連接池對(duì)象,它提供以下功能:
1) 裝載和注冊JDBC驅(qū)動(dòng)程序。 2) 根據(jù)在屬性文件中定義的屬性創(chuàng)建連接池對(duì)象。 3) 實(shí)現(xiàn)連接池名字與其實(shí)例之間的映射。 4) 跟蹤客戶程序?qū)B接池的引用,保證在最后一個(gè)客戶程序結(jié)束時(shí)安全地關(guān)閉所有連接池。
本文余下部分將詳細(xì)說明這兩個(gè)類,最后給出一個(gè)示例演示Servlet使用連接池的一般過程。
二、具體實(shí)現(xiàn)
DBConnectionManager.java程序清單如下:
001 import java.io.*; 002 import java.sql.*; 003 import java.util.*; 004 import java.util.Date; 005 006 /** 007 * 管理類DBConnectionManager支持對(duì)一個(gè)或多個(gè)由屬性文件定義的數(shù)據(jù)庫連接 008 * 池的訪問.客戶程序可以調(diào)用getInstance()方法訪問本類的唯一實(shí)例. 009 */ 010 public class DBConnectionManager { 011 static private DBConnectionManager instance; // 唯一實(shí)例 012 static private int clients; 013 014 private Vector drivers = new Vector(); 015 private PrintWriter log; 016 private Hashtable pools = new Hashtable(); 017 018 /** 019 * 返回唯一實(shí)例.如果是第一次調(diào)用此方法,則創(chuàng)建實(shí)例 020 * 021 * @return DBConnectionManager 唯一實(shí)例 022 */ 023 static synchronized public DBConnectionManager getInstance() { 024 if (instance == null) { 025 instance = new DBConnectionManager(); 026 } 027 clients++; 028 return instance; 029 } 030 031 /** 032 * 建構(gòu)函數(shù)私有以防止其它對(duì)象創(chuàng)建本類實(shí)例 033 */ 034 private DBConnectionManager() { 035 init(); 036 } 037 038 /** 039 * 將連接對(duì)象返回給由名字指定的連接池 040 * 041 * @param name 在屬性文件中定義的連接池名字 042 * @param con 連接對(duì)象 043 */ 044 public void freeConnection(String name, Connection con) { 045 DBConnectionPool pool = (DBConnectionPool) pools.get(name); 046 if (pool != null) { 047 pool.freeConnection(con); 048 } 049 } 050 051 /** 052 * 獲得一個(gè)可用的(空閑的)連接.如果沒有可用連接,且已有連接數(shù)小于最大連接數(shù) 053 * 限制,則創(chuàng)建并返回新連接 054 * 055 * @param name 在屬性文件中定義的連接池名字 056 * @return Connection 可用連接或null 057 */ 058 public Connection getConnection(String name) { 059 DBConnectionPool pool = (DBConnectionPool) pools.get(name); 060 if (pool != null) { 061 return pool.getConnection(); 062 } 063 return null; 064 } 065 066 /** 067 * 獲得一個(gè)可用連接.若沒有可用連接,且已有連接數(shù)小于最大連接數(shù)限制, 068 * 則創(chuàng)建并返回新連接.否則,在指定的時(shí)間內(nèi)等待其它線程釋放連接. 069 * 070 * @param name 連接池名字 071 * @param time 以毫秒計(jì)的等待時(shí)間 072 * @return Connection 可用連接或null 073 */ 074 public Connection getConnection(String name, long time) { 075 DBConnectionPool pool = (DBConnectionPool) pools.get(name); 076 if (pool != null) { 077 return pool.getConnection(time); 078 } 079 return null; 080 } 081 082 /** 083 * 關(guān)閉所有連接,撤銷驅(qū)動(dòng)程序的注冊 084 */ 085 public synchronized void release() { 086 // 等待直到最后一個(gè)客戶程序調(diào)用 087 if (--clients != 0) { 088 return; 089 } 090 091 Enumeration allPools = pools.elements(); 092 while (allPools.hasMoreElements()) { 093 DBConnectionPool pool = (DBConnectionPool) allPools.nextElement(); 094 pool.release(); 095 } 096 Enumeration allDrivers = drivers.elements(); 097 while (allDrivers.hasMoreElements()) { 098 Driver driver = (Driver) allDrivers.nextElement(); 099 try { 100 DriverManager.deregisterDriver(driver); 101 log("撤銷JDBC驅(qū)動(dòng)程序 " + driver.getClass().getName()+"的注冊"); 102 } 103 catch (SQLException e) { 104 log(e, "無法撤銷下列JDBC驅(qū)動(dòng)程序的注冊: " + driver.getClass().getName()); 105 } 106 } 107 } 108 109 /** 110 * 根據(jù)指定屬性創(chuàng)建連接池實(shí)例. 111 * 112 * @param props 連接池屬性 113 */ 114 private void createPools(Properties props) { 115 Enumeration propNames = props.propertyNames(); 116 while (propNames.hasMoreElements()) { 117 String name = (String) propNames.nextElement(); 118 if (name.endsWith(".url")) { 119 String poolName = name.substring(0, name.lastIndexOf(".")); 120 String url = props.getProperty(poolName + ".url"); 121 if (url == null) { 122 log("沒有為連接池" + poolName + "指定URL"); 123 continue; 124 } 125 String user = props.getProperty(poolName + ".user"); 126 String password = props.getProperty(poolName + ".password"); 127 String maxconn = props.getProperty(poolName + ".maxconn", "0"); 128 int max; 129 try { 130 max = Integer.valueOf(maxconn).intValue(); 131 } 132 catch (NumberFormatException e) { 133 log("錯(cuò)誤的最大連接數(shù)限制: " + maxconn + " .連接池: " + poolName); 134 max = 0; 135 } 136 DBConnectionPool pool = 137 new DBConnectionPool(poolName, url, user, password, max); 138 pools.put(poolName, pool); 139 log("成功創(chuàng)建連接池" + poolName); 140 } 141 } 142 } 143 144 /** 145 * 讀取屬性完成初始化 146 */ 147 private void init() { 148 InputStream is = getClass().getResourceAsStream("/db.properties"); 149 Properties dbProps = new Properties(); 150 try { 151 dbProps.load(is); 152 } 153 catch (Exception e) { 154 System.err.println("不能讀取屬性文件. " + 155 "請(qǐng)確保db.properties在CLASSPATH指定的路徑中"); 156 return; 157 } 158 String logFile = dbProps.getProperty("logfile", "DBConnectionManager.log"); 159 try { 160 log = new PrintWriter(new FileWriter(logFile, true), true); 161 } 162 catch (IOException e) { 163 System.err.println("無法打開日志文件: " + logFile); 164 log = new PrintWriter(System.err); 165 } 166 loadDrivers(dbProps); 167 createPools(dbProps); 168 } 169 170 /** 171 * 裝載和注冊所有JDBC驅(qū)動(dòng)程序 172 * 173 * @param props 屬性 174 */ 175 private void loadDrivers(Properties props) { 176 String driverClasses = props.getProperty("drivers"); 177 StringTokenizer st = new StringTokenizer(driverClasses); 178 while (st.hasMoreElements()) { 179 String driverClassName = st.nextToken().trim(); 180 try { 181 Driver driver = (Driver) 182 Class.forName(driverClassName).newInstance(); 183 DriverManager.registerDriver(driver); 184 drivers.addElement(driver); 185 log("成功注冊JDBC驅(qū)動(dòng)程序" + driverClassName); 186 } 187 catch (Exception e) { 188 log("無法注冊JDBC驅(qū)動(dòng)程序: " + 189 driverClassName + ", 錯(cuò)誤: " + e); 190 } 191 } 192 } 193 194 /** 195 * 將文本信息寫入日志文件 196 */ 197 private void log(String msg) { 198 log.println(new Date() + ": " + msg); 199 } 200 201 /** 202 * 將文本信息與異常寫入日志文件 203 */ 204 private void log(Throwable e, String msg) { 205 log.println(new Date() + ": " + msg); 206 e.printStackTrace(log); 207 } 208 209 /** 210 * 此內(nèi)部類定義了一個(gè)連接池.它能夠根據(jù)要求創(chuàng)建新連接,直到預(yù)定的最 211 * 大連接數(shù)為止.在返回連接給客戶程序之前,它能夠驗(yàn)證連接的有效性. 212 */ 213 class DBConnectionPool { 214 private int checkedOut; 215 private Vector freeConnections = new Vector(); 216 private int maxConn; 217 private String name; 218 private String password; 219 private String URL; 220 private String user; 221 222 /** 223 * 創(chuàng)建新的連接池 224 * 225 * @param name 連接池名字 226 * @param URL 數(shù)據(jù)庫的JDBC URL 227 * @param user 數(shù)據(jù)庫帳號(hào),或 null 228 * @param password 密碼,或 null 229 * @param maxConn 此連接池允許建立的最大連接數(shù) 230 */ 231 public DBConnectionPool(String name, String URL, String user, String password, 232 int maxConn) { 233 this.name = name; 234 this.URL = URL; 235 this.user = user; 236 this.password = password; 237 this.maxConn = maxConn; 238 } 239 240 /** 241 * 將不再使用的連接返回給連接池 242 * 243 * @param con 客戶程序釋放的連接 244 */ 245 public synchronized void freeConnection(Connection con) { 246 // 將指定連接加入到向量末尾 247 freeConnections.addElement(con); 248 checkedOut--; 249 notifyAll(); 250 } 251 252 /** 253 * 從連接池獲得一個(gè)可用連接.如沒有空閑的連接且當(dāng)前連接數(shù)小于最大連接 254 * 數(shù)限制,則創(chuàng)建新連接.如原來登記為可用的連接不再有效,則從向量刪除之, 255 * 然后遞歸調(diào)用自己以嘗試新的可用連接. 256 */ 257 public synchronized Connection getConnection() { 258 Connection con = null; 259 if (freeConnections.size() > 0) { 260 // 獲取向量中第一個(gè)可用連接 261 con = (Connection) freeConnections.firstElement(); 262 freeConnections.removeElementAt(0); 263 try { 264 if (con.isClosed()) { 265 log("從連接池" + name+"刪除一個(gè)無效連接"); 266 // 遞歸調(diào)用自己,嘗試再次獲取可用連接 267 con = getConnection(); 268 } 269 } 270 catch (SQLException e) { 271 log("從連接池" + name+"刪除一個(gè)無效連接"); 272 // 遞歸調(diào)用自己,嘗試再次獲取可用連接 273 con = getConnection(); 274 } 275 } 276 else if (maxConn == 0 || checkedOut < maxConn) { 277 con = newConnection(); 278 } 279 if (con != null) { 280 checkedOut++; 281 } 282 return con; 283 } 284 285 /** 286 * 從連接池獲取可用連接.可以指定客戶程序能夠等待的最長時(shí)間 287 * 參見前一個(gè)getConnection()方法. 288 * 289 * @param timeout 以毫秒計(jì)的等待時(shí)間限制 290 */ 291 public synchronized Connection getConnection(long timeout) { 292 long startTime = new Date().getTime(); 293 Connection con; 294 while ((con = getConnection()) == null) { 295 try { 296 wait(timeout); 297 } 298 catch (InterruptedException e) {} 299 if ((new Date().getTime() - startTime) >= timeout) { 300 // wait()返回的原因是超時(shí) 301 return null; 302 } 303 } 304 return con; 305 } 306 307 /** 308 * 關(guān)閉所有連接 309 */ 310 public synchronized void release() { 311 Enumeration allConnections = freeConnections.elements(); 312 while (allConnections.hasMoreElements()) { 313 Connection con = (Connection) allConnections.nextElement(); 314 try { 315 con.close(); 316 log("關(guān)閉連接池" + name+"中的一個(gè)連接"); 317 } 318 catch (SQLException e) { 319 log(e, "無法關(guān)閉連接池" + name+"中的連接"); 320 } 321 } 322 freeConnections.removeAllElements(); 323 } 324 325 /** 326 * 創(chuàng)建新的連接 327 */ 328 private Connection newConnection() { 329 Connection con = null; 330 try { 331 if (user == null) { 332 con = DriverManager.getConnection(URL); 333 } 334 else { 335 con = DriverManager.getConnection(URL, user, password); 336 } 337 log("連接池" + name+"創(chuàng)建一個(gè)新的連接"); 338 } 339 catch (SQLException e) { 340 log(e, "無法創(chuàng)建下列URL的連接: " + URL); 341 return null; 342 } 343 return con; 344 } 345 } 346 } 三、類DBConnectionPool說明
該類在209至345行實(shí)現(xiàn),它表示指向某個(gè)數(shù)據(jù)庫的連接池。數(shù)據(jù)庫由JDBC URL標(biāo)識(shí)。一個(gè)JDBC URL由三部分組成:協(xié)議標(biāo)識(shí)(總是jdbc),驅(qū)動(dòng)程序標(biāo)識(shí)(如 odbc、idb、oracle等),數(shù)據(jù)庫標(biāo)識(shí)(其格式依賴于驅(qū)動(dòng)程序)。例如,jdbc:odbc:de mo,即是一個(gè)指向demo數(shù)據(jù)庫的JDBC URL,而且訪問該數(shù)據(jù)庫要使用JDBC-ODBC驅(qū)動(dòng)程序。每個(gè)連接池都有一個(gè)供客戶程序使用的名字以及可選的用戶帳號(hào)、密碼、最大連接數(shù)限制。如果Web應(yīng)用程序所支持的某些數(shù)據(jù)庫操作可以被所有用戶執(zhí)行,而其它一些操作應(yīng)由特別許可的用戶執(zhí)行,則可以為兩類操作分別定義連接池,兩個(gè)連接池使用相同的JDBC URL,但使用不同的帳號(hào)和密碼。 類DBConnectionPool的建構(gòu)函數(shù)需要上述所有數(shù)據(jù)作為其參數(shù)。如222至238行所示,這些數(shù)據(jù)被保存為它的實(shí)例變量: 如252至283行、285至305行所示, 客戶程序可以使用DBConnectionPool類提供的兩個(gè)方法獲取可用連接。兩者的共同之處在于:如連接池中存在可用連接,則直接返回,否則創(chuàng)建新的連接并返回。如果沒有可用連接且已有連接總數(shù)等于最大限制 數(shù),第一個(gè)方法將直接返回null,而第二個(gè)方法將等待直到有可用連接為止。 所有的可用連接對(duì)象均登記在名為freeConnections的向量(Vector)中。如果向量中有多于一個(gè)的連接,getConnection()總是選取第一個(gè)。同時(shí),由于新的可用連接總是從尾部加入向量,從而使得數(shù)據(jù)庫連接由于長時(shí)間閑置而被關(guān)閉的風(fēng)險(xiǎn)減低到最小程度。 第一個(gè)getConnection()在返回可用連接給客戶程序之前,調(diào)用了isClosed()方法驗(yàn)證連接仍舊有效。如果該連接被關(guān)閉或觸發(fā)異常,getConnection()遞歸地調(diào)用自己以嘗試獲取另外的可用連接。如果在向量freeConnections中不存在任何可用連 接,getConnection()方法檢查是否已經(jīng)指定最大連接數(shù)限制。如已經(jīng)指定,則檢查當(dāng)前連接數(shù)是否已經(jīng)到達(dá)極限。此處maxConn為0表示沒有限制。如果沒有指定最大連接數(shù)限制或當(dāng)前連接數(shù)小于該值,該方法嘗試創(chuàng)建新的連接。如創(chuàng)建成功,則增加已使用連接的計(jì)數(shù)并返回,否則返回空值。 如325至345行所示,創(chuàng)建新連接由newConnection()方法實(shí)現(xiàn)。創(chuàng)建過程與是否已經(jīng)指定數(shù)據(jù)庫帳號(hào)、密碼有關(guān)。 JDBC的DriverManager類提供多個(gè)getConnection()方法,這些方法要用到JDBC URL與其它一些參數(shù),如用戶帳號(hào)和密碼等。 DriverManager將使用指定的JDBC URL確定適合于目標(biāo)數(shù)據(jù)庫的驅(qū)動(dòng)程序及建立連接。 在285至305行實(shí)現(xiàn)的第二個(gè)getConnection()方法需要一個(gè)以毫秒為單位的時(shí)間參數(shù),該參數(shù)表示客戶程序能夠等待的最長時(shí)間。建立連接的具體操作仍舊由第一個(gè)getConnection()方法實(shí)現(xiàn)。 該方法執(zhí)行時(shí)先將startTime初始化為當(dāng)前時(shí)間。在while循環(huán)中嘗試獲得一個(gè)連接。如果失敗,則以給定的時(shí)間值為參數(shù)調(diào)用wait()。wait()的返回可能是由于其它線程調(diào)用notify()或notifyAll(),也可能是由于預(yù)定時(shí)間已到。為找出wait()返回的真正原因,程序用當(dāng)前時(shí)間減開始時(shí)間(startTime),如差值大于預(yù)定時(shí)間則返回空值,否則再次調(diào)用getConnection()。 把空閑的連接登記到連接池由240至250行的freeConnection()方法實(shí)現(xiàn),它的參數(shù)為返回給連接池的連接對(duì)象。該對(duì)象被加入到freeConnections向量的末尾,然后減少已使用連接計(jì)數(shù)。調(diào)用notifyAll()是為了通知其它正在等待可用連接的線程。 許多Servlet引擎為實(shí)現(xiàn)安全關(guān)閉提供多種方法。數(shù)據(jù)庫連接池需要知道該事件以保證所有連接能夠正常關(guān)閉。DBConnectionManager類負(fù)協(xié)調(diào)整個(gè)關(guān)閉過程,但關(guān)閉連接池中所有連接的任務(wù)則由DBConnectionPool類負(fù)責(zé)。在307至323行實(shí)現(xiàn)的release()方法供DBConnectionManager調(diào)用。該方法遍歷freeConnections向量并關(guān)閉所有連接,然后從向量中刪除這些連接。
四、類DBConnectionManager 說明
該類只能創(chuàng)建一個(gè)實(shí)例,其它對(duì)象能夠調(diào)用其靜態(tài)方法(也稱為類方法)獲得該唯一實(shí)例的引用。如031至036行所示,DBConnectionManager類的建構(gòu)函數(shù)是私有的,這是為了避免其它對(duì)象創(chuàng)建該類的實(shí)例。 DBConnectionManager類的客戶程序可以調(diào)用getInstance()方法獲得對(duì)該類唯一實(shí)例的引用。如018至029行所示,類的唯一實(shí)例在getInstance()方法第一次被調(diào)用期間創(chuàng)建,此后其引用就一直保存在靜態(tài)變量instance中。每次調(diào)用getInstance() 都增加一個(gè)DBConnectionManager的客戶程序計(jì)數(shù)。即,該計(jì)數(shù)代表引用DBConnectionManager唯一實(shí)例的客戶程序總數(shù),它將被用于控制連接池的關(guān)閉操作。 該類實(shí)例的初始化工作由146至168行之間的私有方法init()完成。其中 getResourceAsStream()方法用于定位并打開外部文件。外部文件的定位方法依賴于類裝載器的實(shí)現(xiàn)。標(biāo)準(zhǔn)的本地類裝載器查找操作總是開始于類文件所在路徑,也能夠搜索CLASSPATH中聲明的路徑。db.properties是一個(gè)屬性文件,它包含定義連接池的鍵-值對(duì)。可供定義的公用屬性如下:
drivers 以空格分隔的JDBC驅(qū)動(dòng)程序類列表 logfile 日志文件的絕對(duì)路徑
其它的屬性和特定連接池相關(guān),其屬性名字前應(yīng)加上連接池名字:
<poolname>.url 數(shù)據(jù)庫的 JDBC URL <poolname>.maxconn 允許建立的最大連接數(shù),0表示沒有限制 <poolname>.user 用于該連接池的數(shù)據(jù)庫帳號(hào) <poolname>.password 相應(yīng)的密碼
其中url屬性是必需的,而其它屬性則是可選的。數(shù)據(jù)庫帳號(hào)和密碼必須合法。用于Windows平臺(tái)的db.properties文件示例 如下:
drivers=sun.jdbc.odbc.JdbcOdbcDriver jdbc.idbDriver logfile=D:\\user\\src\\java\\DBConnectionManager\\log.txt
idb.url=jdbc:idb:c:\\local\\javawebserver1.1\\db\\db.prp idb.maxconn=2
access.url=jdbc:odbc:demo access.user=demo access.password=demopw
注意在Windows路徑中的反斜杠必須輸入2個(gè),這是由于屬性文件中的反斜杠同時(shí)也是一個(gè)轉(zhuǎn)義字符。 init()方法在創(chuàng)建屬性對(duì)象并讀取db.properties文件之后,就開始檢查logfile屬性。如果屬性文件中沒有指定日志文件,則默認(rèn)為當(dāng)前目錄下的DBConnectionManager.log文件。如日志文件無法使用,則向System.err輸出日志記錄。 裝載和注冊所有在drivers屬性中指定的JDBC驅(qū)動(dòng)程序由170至192行之間的loadDrivers()方法實(shí)現(xiàn)。該方法先用StringTokenizer將drivers屬性值分割為對(duì)應(yīng)于驅(qū)動(dòng)程序名稱的字符串,然后依次裝載這些類并創(chuàng)建其實(shí)例,最后在 DriverManager中注冊 該實(shí)例并把它加入到一個(gè)私有的向量drivers。向量drivers將用于關(guān)閉服務(wù)時(shí)從DriverManager取消所有JDBC 驅(qū)動(dòng)程序的注冊。 init()方法的最后一個(gè)任務(wù)是調(diào)用私有方法createPools()創(chuàng)建連接池對(duì)象。如109至142行所示,createPools()方法先創(chuàng)建所有屬性名字的枚舉對(duì)象(即Enumeration對(duì)象,該對(duì)象可以想象為一個(gè)元素系列,逐次調(diào)用其nextElement()方法將順序返 回各元素),然后在其中搜索名字以“.url”結(jié)尾的屬性。對(duì)于每一個(gè)符合條件的屬性,先提取其連接池名字部分,進(jìn)而讀取所有屬于該連接池的屬性,最后創(chuàng)建連接池對(duì)象并把它保存在實(shí)例變量pools中。散列表(Hashtable類 )pools實(shí)現(xiàn)連接 池名字到連接池對(duì)象之間的映射,此處以連接池名字為鍵,連接池對(duì)象為值。 為便于客戶程序從指定連接池獲得可用連接或?qū)⑦B接返回給連接池,類DBConnectionManager提供了方法getConnection()和freeConnection()。所有這些方法都要求在參數(shù)中指定連接池名字,具體的連接獲取或返回操作則調(diào)用對(duì)應(yīng)的連接池對(duì)象完成。它們的實(shí)現(xiàn)分別在051至064行、066至080行、038至049行。 如082至107行所示,為實(shí)現(xiàn)連接池的安全關(guān)閉,DBConnectionManager提供了方法release()。在上面我們已經(jīng)提到,所有DBConnectionManager的客戶程序都應(yīng)該調(diào)用靜態(tài)方法getInstance()以獲得該管理器的引用,此調(diào)用將增加客戶程序計(jì)數(shù)。 客戶程序在關(guān)閉時(shí)調(diào)用release()可以遞減該計(jì)數(shù)。當(dāng)最后一個(gè)客戶程序調(diào)用release(),遞減后的引用計(jì)數(shù)為0,就可以調(diào)用各個(gè)連接池的release()方法關(guān)閉所有連接了。管理類release()方法最后的任務(wù)是撤銷所有JDBC驅(qū)動(dòng)程序的注冊。
五、Servlet使用連接池示例
Servlet API所定義的Servlet生命周期類如:
1) 創(chuàng)建并初始化Servlet(init()方法)。 2) 響應(yīng)客戶程序的服務(wù)請(qǐng)求(service()方法)。 3) Servlet終止運(yùn)行,釋放所有資源(destroy()方法)。
本例演示連接池應(yīng)用,上述關(guān)鍵步驟中的相關(guān)操作為:
1) 在init(),用實(shí)例變量connMgr 保存調(diào)用DBConnectionManager.getInstance()所返回的引用。 2) 在service(),調(diào)用getConnection(),執(zhí)行數(shù)據(jù)庫操作,用freeConnection()將連接返回給連接池。 3) 在destroy(),調(diào)用release()關(guān)閉所有連接,釋放所有資源。
示例程序清單如下:
import java.io.*; import java.sql.*; import javax.servlet.*; import javax.servlet.http.*; public class TestServlet extends HttpServlet { private DBConnectionManager connMgr;
public void init(ServletConfig conf) throws ServletException { super.init(conf); connMgr = DBConnectionManager.getInstance(); }
public void service(HttpServletRequest req, HttpServletResponse res) throws IOException {
res.setContentType("text/html"); PrintWriter out = res.getWriter(); Connection con = connMgr.getConnection("idb"); if (con == null) { out.println("不能獲取數(shù)據(jù)庫連接."); return; } ResultSet rs = null; ResultSetMetaData md = null; Statement stmt = null; try { stmt = con.createStatement(); rs = stmt.executeQuery("SELECT * FROM EMPLOYEE"); md = rs.getMetaData(); out.println("<H1>職工數(shù)據(jù)</H1>"); while (rs.next()) { out.println("<BR>"); for (int i = 1; i < md.getColumnCount(); i++) { out.print(rs.getString(i) + ", "); } } stmt.close(); rs.close(); } catch (SQLException e) { e.printStackTrace(out); } connMgr.freeConnection("idb", con); }
public void destroy() { connMgr.release(); super.destroy(); } } |
posted @
2005-10-28 09:50 surffish 閱讀(304) |
評(píng)論 (0) |
編輯 收藏
exp airport/airport@ems file=airport2.dmp owner=airport log=exp2.log
posted @
2005-10-26 09:56 surffish 閱讀(1192) |
評(píng)論 (0) |
編輯 收藏