無(wú)論是身處學(xué)校還是步入社會(huì)，大家都嘗試過(guò)寫(xiě)作吧，借助寫(xiě)作也可以提高我們的語(yǔ)言組織能力。相信許多人會(huì)覺(jué)得范文很難寫(xiě)？下面是小編為大家收集的優(yōu)秀范文，供大家參考借鑒，希望可以幫助到有需要的朋友。
java登錄日志 java實(shí)現(xiàn)登出篇一
實(shí)習(xí)日志
推薦度：
實(shí)習(xí)日志
推薦度：
java程序員年終總結(jié)
推薦度：
《瓦爾登湖》讀后感
推薦度：
教師培訓(xùn)研修日志
推薦度：
相關(guān)推薦
具體實(shí)現(xiàn)代碼：
package ; import edreader;import ;import outputstream;import ption;import treamreader;import streamwriter;import riter;import socket;import ;import p;import ;import ;import ngqueue;import orservice;import ors;import blockingqueue; import nt;import t;import der; /** * dms服務(wù)端，用來(lái)接收每個(gè)客戶端發(fā)送過(guò)來(lái)的 * 配對(duì)日志并保存在本地文件中 * @author administrator * */public class dmsserver { //屬性定義 //用來(lái)接收客戶端連接的服務(wù)端的serversocket private serversocket server; //用來(lái)管理處理客戶端請(qǐng)求的線程的線程池 private executorservice threadpool; //保存所有客戶端發(fā)送過(guò)來(lái)配對(duì)日志的文件 private file serverlogfile; //消息隊(duì)列 private blockingqueue
messagequeue = new linkedblockingqueue
(); public dmsserver() throws exception{ try { n("服務(wù)端正在初始化..."); //1 map
config = loadconfig(); //2 根據(jù)配置文件內(nèi)容初始化屬性 init(config); n("服務(wù)端初始化完畢..."); } catch (exception e) { n("初始化服務(wù)端失敗!"); throw e; } } /** * 構(gòu)造方法初始化第一步，解析配置文件 * @return 返回的map中保存的是配置文件中的 * 每一條內(nèi)容，其中key:標(biāo)簽的名字， * value為標(biāo)簽中間的文本 * @throws exception */ private map
loadconfig() throws exception{ try { saxreader reader = new saxreader(); document doc = (new file("server-")); element root = telement(); map
config = new hashmap
(); /* * 獲取
標(biāo)簽中的所有子標(biāo)簽 * 并將每一個(gè)子標(biāo)簽的名字作為key,中間的 * 文本作為value存入map集合 */ list
list = ts(); for(element e : list){ string key = e(); string value = ttrim(); (key, value); } return config; } catch (exception e) { n("解析配置文件異常!"); tacktrace(); throw e; } } /** * 構(gòu)造方法初始化第二步,根據(jù)配置項(xiàng)初始化屬性 * @param config * @throws exception */ private void init(map
config) throws exception{ /* * 用配置文件中的
初始化屬性：serverlogfile * 用配置文件中的
初始化屬性：threadpool，這里創(chuàng)建固定大小線程池。該值作為線程池線程數(shù)量 * 用配置文件中的
初始化屬性：server,這里這個(gè)值為serversocket的服務(wù)端口 */ = new serversocket( nt(("serverport")) ); logfile = new file( ("logrecfile") ); pool = edthreadpool( nt(("threadsum")) ); } /** * 服務(wù)端開(kāi)始工作的方法 * @throws exception */ public void start() throws exception{ /* * 實(shí)現(xiàn)要求: * 首先單獨(dú)啟動(dòng)一個(gè)線程，用來(lái)運(yùn)行saveloghandler * 這個(gè)任務(wù)，目的是保存所有配對(duì)日志 * 然后開(kāi)始循環(huán)監(jiān)聽(tīng)服務(wù)端端口，一旦一個(gè)客戶端連接了， * 就實(shí)例化一個(gè)clienthander,然后將該任務(wù)交給線程池 * 使其分配線程來(lái)處理與該客戶端的交互。 * */ try { n("服務(wù)端開(kāi)始工作..."); saveloghandler slh=new saveloghandler(); new thread(slh).start(); while(true){ socket socket=(); e(new clienthandler(socket)); } } catch (exception e) { tacktrace(); throw e; } } public static void main(string[] args) { try { dmsserver server = new dmsserver(); (); } catch (exception e) { n("啟動(dòng)服務(wù)端失敗!"); } } /** * 該線程負(fù)責(zé)從消息隊(duì)列中取出每一條配對(duì)日志， * 并存入到serverlogfile文件 * @author administrator * */ private class saveloghandler implements runnable{ public void run(){ printwriter pw = null; try { pw = new printwriter( new fileoutputstream( serverlogfile,true ) ); while(true){ if(()>0){ n(()); }else{ (); (500); } } } catch (exception e) { tacktrace(); } finally{ if(pw != null){ (); } } } } /** * 處理一個(gè)指定客戶端請(qǐng)求 * @author administrator * */ private class clienthandler implements runnable{ private socket socket; public clienthandler(socket socket){ = socket; } public void run(){ /* * 思路: * 首先接收客戶端發(fā)送過(guò)來(lái)的所有配對(duì)日志， * 直到讀取到"over"為止，然后將這些配對(duì) * 日志保存到本地的文件中，并回復(fù)客戶端 * "ok" * 執(zhí)行步驟: * 1:通過(guò)socket創(chuàng)建輸出流，用來(lái)給客戶端 * 發(fā)送響應(yīng) * 2:通過(guò)socket創(chuàng)建輸入流，讀取客戶端發(fā)送 * 過(guò)來(lái)的日志 * 3:循環(huán)讀取客戶端發(fā)送過(guò)來(lái)的每一行字符串，并 * 先判斷是否為字符串"over",若不是，則是 * 一條配對(duì)日志，那么保存到本地文件，若是， * 則停止讀取。 * 4:成功讀取所有日志后回復(fù)客戶端"ok" */ printwriter pw = null; try { //1 pw = new printwriter( new outputstreamwriter( putstream(),"utf-8" ) ); //2 bufferedreader br = new bufferedreader( new inputstreamreader( utstream(),"utf-8" ) ); //3 string message = null; while((message = ne())!=null){ if("over".equals(message)){ break; } //將該日志寫(xiě)入文件保存 (message); } //4 n("ok"); (); } catch (exception e) { tacktrace(); n("error"); (); } finally{ try { //與客戶端斷開(kāi)連接釋放資源 (); } catch (ioexception e) { tacktrace(); } } } }}
package ; import edreader;import ;import ption;import treamreader;import streamwriter;import riter;import accessfile;import ;import ist;import p;import ;import ;import .entry;import ; import nt;import t;import der; import a;import ; /** * 該客戶端運(yùn)行在給用戶提供unix服務(wù)的.服務(wù)器上。 * 用來(lái)讀取并收集該服務(wù)器上用戶的上下線信息，并 * 進(jìn)行配對(duì)整理后發(fā)送給服務(wù)端匯總。 * @author administrator * */public class dmsclient { //屬性定義 //第一步:解析日志所需屬性 //unix系統(tǒng)日志文件 private file logfile; //保存解析后日志的文件 private file textlogfile; //書(shū)簽文件 private file lastpositionfile; //每次解析日志的條目數(shù) private int batch; //第二步:配對(duì)日志所需要屬性 //保存配對(duì)日志的文件 private file logrecfile; //保存未配對(duì)日志的文件 private file loginlogfile; //第三步:發(fā)送日志所需要屬性 //服務(wù)端地址 private string serverhost; //服務(wù)端端口 private int serverport; /** * 構(gòu)造方法，用來(lái)初始化客戶端 * @throws exception */ public dmsclient() throws exception{ try { //1 解析配置文件 mapconfig = loadconfig(); //打樁 n(config); //2 根據(jù)配置文件內(nèi)容初始化屬性 init(config); } catch (exception e) { n("初始化失敗!"); throw e; } } /** * 構(gòu)造方法初始化第二步,根據(jù)配置項(xiàng)初始化屬性 * @param config * @throws exception */ private void init(map
config) throws exception{ try { logfile = new file( ("logfile") ); textlogfile = new file( ("textlogfile") ); lastpositionfile = new file( ("lastpositionfile") ); batch = nt( ("batch") ); logrecfile = new file( ("logrecfile") ); loginlogfile = new file( ("loginlogfile") ); serverhost = ("serverhost"); serverport = nt( ("serverport") ); } catch (exception e) { n("初始化屬性失敗!"); tacktrace(); throw e; } } /** * 構(gòu)造方法初始化第一步，解析配置文件 * @return 返回的map中保存的是配置文件中的 * 每一條內(nèi)容，其中key:標(biāo)簽的名字， * value為標(biāo)簽中間的文本 * @throws exception */ private map
loadconfig() throws exception{ try { saxreader reader = new saxreader(); document doc = (new file("")); element root = telement(); map
config = new hashmap
(); /* * 獲取
標(biāo)簽中的所有子標(biāo)簽 * 并將每一個(gè)子標(biāo)簽的名字作為key,中間的 * 文本作為value存入map集合 */ list
list = ts(); for(element e : list){ string key = e(); string value = ttrim(); (key, value); } return config; } catch (exception e) { n("解析配置文件異常!"); tacktrace(); throw e; } } /** * 客戶端開(kāi)始工作的方法 * 循環(huán)執(zhí)行三步: * 1:解析日志 * 2:配對(duì)日志 * 3:發(fā)送日志 */ public void start(){ parselogs(); matchlogs(); sendlogs();// while(true){// //解析日志// if(!parselogs()){// continue;// }// //配對(duì)日志// if(!matchlogs()){// continue;// }// //發(fā)送日志// sendlogs();// } } /** * 第三步:發(fā)送日志 * @return true:發(fā)送成功 * false:發(fā)送失敗 */ private boolean sendlogs(){ /* * 實(shí)現(xiàn)思路: * 將logrecfile文件中的所有配對(duì)日志讀取 * 出來(lái)然后連接上服務(wù)端并發(fā)送過(guò)去，若服務(wù)端 * 全部接收，就可以將該文件刪除，表示發(fā)送 * 完畢了。 * 實(shí)現(xiàn)步驟: * 1:logrecfile文件必須存在 * 2:將所有配對(duì)日志讀取出來(lái)并存入一個(gè)集合 * 等待發(fā)送 * 3:通過(guò)socket連接服務(wù)端 * 4:創(chuàng)建輸出流 * 5:順序?qū)⑺信鋵?duì)日志按行發(fā)送給服務(wù)端 * 6:單獨(dú)發(fā)送一個(gè)字符串"over"表示所有日志 * 均已發(fā)送完畢 * 7:創(chuàng)建輸入流 * 8:讀取服務(wù)端發(fā)送回來(lái)的響應(yīng)字符串 * 9:若響應(yīng)的字符串為"ok",表示服務(wù)端正常 * 接收了所有日志,這時(shí)就可以將logrecfile * 文件刪除并返回true表示發(fā)送完畢。 * */ socket socket = null; try { //1 if(!()){ n(logrecfile+"不存在!"); return false; } //2 list
matches = grec(logrecfile); //3 socket = new socket(serverhost,serverport); //4 printwriter pw = new printwriter( new outputstreamwriter( putstream(),"utf-8" ) ); //5 for(string log : matches){ n(log); } //6 n("over"); (); //7 bufferedreader br = new bufferedreader( new inputstreamreader( utstream(),"utf-8" ) ); //8 string response = ne(); //9 if("ok".equals(response)){ logrecfile.(); return true; }else{ n("發(fā)送日志失敗!"); return false; } } catch (exception e) { n("發(fā)送日志失敗!"); tacktrace(); } finally{ if(socket != null){ try { (); } catch (ioexception e) { tacktrace(); } } } return false; } /** * 第二步:配對(duì)日志 * @return true:配對(duì)成功 * false:配對(duì)失敗 */ private boolean matchlogs(){ /* * 實(shí)現(xiàn)思路: * 將第一步解析的新日志，與上次為配對(duì)成功 * 的登入日志全部讀取出來(lái)，然后再按照user, * pid相同，type一個(gè)是7，一個(gè)是8進(jìn)行配對(duì)。 * 只要能找到類(lèi)型為8的，一定可以找到一個(gè) * 能與之配對(duì)的登入日志。 * * 實(shí)現(xiàn)步驟: * 1:必要的判斷 * 1.1:logrecfile是否存在，存在則不再 * 進(jìn)行新的配對(duì)工作，避免覆蓋。 * 1.2:textlogfile文件必須存在。 * 2:讀取textlogfile將日志讀取出來(lái)，并 * 存入到集合中。(若干logdata實(shí)例) * 3:若loginlogfile文件若存在，則說(shuō)明 * 有上次未配對(duì)成功的日志，也將其讀取 * 出來(lái)存入集合等待一起配對(duì) * 4:配對(duì)工作 * 4.1:創(chuàng)建一個(gè)集合，用于保存所有配對(duì)日志 * 4.2:創(chuàng)建兩個(gè)map分別保存登入日志與登出日志 * 4.3:遍歷所有待配對(duì)的日志，按照登入與登出 * 分別存入兩個(gè)map中， * 其中key:user,pid * value:logdata實(shí)例 * 4.4:遍歷登出map,并根據(jù)每條登出日志的key * 去登入map中找到對(duì)應(yīng)的登入日志，并 * 以一個(gè)logrec實(shí)例保存該配對(duì)日志，然后 * 存入配對(duì)日志的集合中。并將該配對(duì)日志 * 中的登入日志從登入map中刪除。這樣一來(lái) * 登入map中應(yīng)當(dāng)只剩下沒(méi)有配對(duì)的了。 * 5:將配對(duì)日志寫(xiě)入到logrecfile中 * 6:將所有未配對(duì)日志寫(xiě)入到loginlogfile中 * 7:將textlogfile文件刪除 * 8:返回true,表示配對(duì)完畢 * */ try { //1 //1.1 if(()){ return true; } //1.2 if(!text()){ n(textlogfile+"不存在!"); return false; } //2 list
list = gdata(textlogfile); //3 if(login()){ all( gdata(loginlogfile) ); } //4 //4.1 list
matches = new arraylist
(); //4.2 map
loginmap = new hashmap
(); map
logoutmap = new hashmap
(); //4.3 for(logdata logdata : list){ string key = r()+","+ (); if(e()==_login){ (key, logdata); }else if(e()==_logout){ (key, logdata); } } //4.4 set<entry
> entryset = et(); for(entry
e : entryset){ logdata logout = ue(); logdata login = (()); logrec logrec = new logrec(login,logout); (logrec); } //5 llection(matches, logrecfile); //6 llection( (),loginlogfile ); //7 textlogfile.(); //8 return true; } catch (exception e) { n("配對(duì)日志失敗!"); tacktrace(); } return false; } /** * 第一步:解析日志 * @return true:解析成功 * false:解析失敗 */ private boolean parselogs(){ /* * 實(shí)現(xiàn)思路: * 循環(huán)讀取batch條日志，然后將每條日志中的 * 5個(gè)信息解析出來(lái)，最終組成一個(gè)字符串，以 * 行為單位，寫(xiě)入到textlogfile文件中 * * 實(shí)現(xiàn)步驟： * 1:必要的判斷工作 * 1.1:為了避免解析的日志還沒(méi)有被使用，而 * 第一步又重復(fù)執(zhí)行導(dǎo)致之前日志被覆蓋 * 的問(wèn)題，這里需要判斷，若保存解析后 * 的日志文件存在，則第一步不再執(zhí)行。 * 該日志文件會(huì)在第二步配對(duì)完畢后刪除。 * 1.2:logfile文件必須存在(wtmpx文件) * 1.3:是否還有日志可以解析 * 2:創(chuàng)建randomaccessfile來(lái)讀取logfile * 3:將指針移動(dòng)到上次最后讀取的位置，準(zhǔn)備 * 開(kāi)始新的解析工作 * 4:解析工作 * 4.1:創(chuàng)建一個(gè)list集合，用于保存解析后 * 的每一條日志(logdata實(shí)例) * 4.2:循環(huán)batch次，解析每條日志中的 * 5項(xiàng)內(nèi)容(user,pid,type,time,host) * 并用一個(gè)logdata實(shí)例保存，然后將 * 該logdata實(shí)例存入集合 * 5:將集合中的所有的日志以行為單位保存到 * textlogfile中 * 6:保存書(shū)簽信息 * 7:返回true,表示工作完畢 * */ randomaccessfile raf = null; try { //1 //1.1 if(text()){ return true; } //1.2 if(!()){ n(logfile+"不存在!"); return false; } //1.3 long lastposition = haslogs(); //打樁// n(// "lastposition:"+lastposition// ); if(lastposition<0){ n("沒(méi)有日志可以解析了!"); return false; } //2 raf = new randomaccessfile(logfile,"r"); //3 (lastposition); //4 list
list = new arraylist
(); for(int i=0;i<batch;i++){ //每次解析前都判斷是否還有日志可以解析 if(()-lastposition
=_length){ return lastposition; } } catch (exception e) { tacktrace(); } return -1; } public static void main(string[] args) { try { dmsclient client = new dmsclient(); (); } catch (exception e) { n("客戶端運(yùn)行失敗!"); } }}
package ; import edreader;import ;import inputstream;import treamreader;import riter;import accessfile;import ist;import tion;import ; import a; /** * 該類(lèi)是一個(gè)工具類(lèi)，負(fù)責(zé)客戶端的io操作 * @author administrator * */public class ioutil { /** * 從給定的文件中讀取每一行字符串(配對(duì)日志) * 并存入一個(gè)集合后返回 * @param file * @return * @throws exception */ public static listloadlogrec(file file) throws exception{ bufferedreader br = null; try { br = new bufferedreader( new inputstreamreader( new fileinputstream( file ) ) ); list
list = new arraylist
(); string line = null; while((line = ne())!=null){ (line); } return list; } catch (exception e) { tacktrace(); throw e; } finally{ if(br != null){ (); } } } /** * 從給定的文件中讀取每一條配對(duì)日志，并存入 * 一個(gè)集合中然后返回。 * @param file * @return * @throws exception */ public static list
loadlogdata(file file) throws exception{ bufferedreader br = null; try { br = new bufferedreader( new inputstreamreader( new fileinputstream( file ) ) ); list
list = new arraylist
(); string line = null; while((line = ne())!=null){ logdata logdata = new logdata(line); (logdata); } return list; } catch (exception e) { tacktrace(); throw e; } finally{ if(br!=null){ (); } } } /** * 將指定的long值以字符串的形式寫(xiě)入到 * 給定文件的第一行 * @param l * @param file * @throws exception */ public static void savelong( long lon,file file) throws exception{ printwriter pw = null; try { pw = new printwriter(file); n(lon); } catch (exception e) { tacktrace(); throw e; } finally{ if(pw != null){ (); } } } /** * 將集合中每個(gè)元素的tostring方法返回的字符串 * 以行為單位寫(xiě)入到指定文件中。 * @param c * @param file * @throws exception */ public static void savecollection( collection c,file file) throws exception{ printwriter pw = null; try { pw = new printwriter(file); for(object o : c){ n(o); } } catch (exception e) { tacktrace(); throw e; } finally{ if(pw != null){ (); } } } /** * 從給定的randomaccessfile當(dāng)前位置開(kāi)始連續(xù) * 讀取length個(gè)字節(jié)，并轉(zhuǎn)換為字符串后返回 * @param raf * @param length * @return * @throws exception */ public static string readstring( randomaccessfile raf,int length) throws exception{ try { byte[] data = new byte[length]; (data); return new string(data,"iso8859-1"); } catch (exception e) { tacktrace(); throw e; } } /** * 從給定文件中讀取第一行字符串，然后將其 * 轉(zhuǎn)換為一個(gè)long值后返回 * @param file * @return * @throws exception */ public static long readlong(file file) throws exception{ bufferedreader br = null; try { br = new bufferedreader( new inputstreamreader( new fileinputstream( file ) ) ); string line = ne(); return ong(line); } catch (exception e) { tacktrace(); throw e; } finally{ if(br != null){ (); } } }}
<"1.0" encoding="utf-8">wtmpx
10
localhost
8088
5. server-<"1.0" encoding="utf-8">
30
8088
s("content_relate");
【java讀取用戶登入退出日志上傳服務(wù)端】相關(guān)文章：
java如何讀取csv
09-29
java讀取郵件的方法
09-27
java讀取csv的方法大全
12-04
java如何通過(guò)url讀取文件
09-28
java如何讀取圖片exif信息
09-27
java讀取解析xml文件實(shí)例
09-25
java讀取郵件的方法有哪些
12-03
講述java讀取properties文件的方法
12-02
java讀取圖片exif信息的代碼
11-30
【本文地址：http://www.aiweibaby.com/zuowen/2807029.html】
