<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        
Dict.CN 在線詞典, 英語學(xué)習(xí), 在線翻譯
 
 


 
 
 


    
	

    都市淘沙者
    

    荔枝FM Everyone can be host
    

    


    
	
		

    統(tǒng)計(jì)
    
	
		

    留言簿(23)
    


        

    積分與排名
    


		
		
    優(yōu)秀學(xué)習(xí)網(wǎng)站
    
		
				
			
	
		
    友情連接
    
		
				
			
	

        

    閱讀排行榜
    


		

    評(píng)論排行榜
    


	

    

    
	
					
	
    
		
    
			網(wǎng)絡(luò)編程中的異步編程
		
    
		該文章對(duì)編寫客戶服務(wù)器應(yīng)用的java程序員有所幫助,可以解決程序在對(duì)方出現(xiàn)故障的時(shí)候繼續(xù)穩(wěn)定運(yùn)行.
    
　　目前java平臺(tái)已經(jīng)廣泛應(yīng)用于各類客戶/服務(wù)器系統(tǒng)中，在實(shí)際編程中，往往需要網(wǎng)絡(luò)的異步處理。比如客戶程序，如果客戶程序運(yùn)行先于服務(wù)程序，則客戶程序則需要在服務(wù)程序啟動(dòng)后再自動(dòng)連接服務(wù)程序；在客戶程序運(yùn)行中如果服務(wù)程序中途停止，則也需要在不停止的條件下，等待服務(wù)程序運(yùn)行并重新連接。下面提供了一類異步編程的方法。
    
網(wǎng)絡(luò)異步應(yīng)用涉及到如下幾個(gè)關(guān)鍵點(diǎn)： 
    
　　客戶應(yīng)用啟動(dòng)后，檢測(cè)服務(wù)應(yīng)用是否存在。如果不存在，則等待服務(wù)應(yīng)用啟動(dòng)，同時(shí)不堵塞客戶應(yīng)用其他任務(wù)的執(zhí)行。一旦服務(wù)應(yīng)用啟動(dòng)，客戶應(yīng)用應(yīng)該及時(shí)的與其建立連接。 
    
　　客戶應(yīng)用和服務(wù)應(yīng)用在數(shù)據(jù)通信中，服務(wù)應(yīng)用異常退出后，客戶應(yīng)用應(yīng)可以檢測(cè)到服務(wù)應(yīng)用的退出。同時(shí)客戶應(yīng)用自動(dòng)清除該通信鏈路，回到初始狀態(tài)，等待服務(wù)應(yīng)用重新啟動(dòng)。
    
　　該網(wǎng)絡(luò)異步編程首先涉及到一個(gè)定時(shí)器和定時(shí)器事件。該定時(shí)器用于不斷的檢測(cè)網(wǎng)絡(luò)中客戶應(yīng)用和服務(wù)應(yīng)用是否連通，同時(shí)在服務(wù)應(yīng)用出現(xiàn)異常時(shí)中止數(shù)據(jù)通信，返回到初始狀態(tài)。網(wǎng)絡(luò)的故障可以通過網(wǎng)絡(luò)方法的異常處理獲知。
    
　　定時(shí)器包含在網(wǎng)絡(luò)通信類中，使得使用該類的應(yīng)用感知不到定時(shí)器的存在，而方便的處理網(wǎng)絡(luò)信息。
    
該客戶程序類如下結(jié)構(gòu)： 
    

    /*
    
 * Classname       : NetComm.java
    
 * Create Date     : 5:04:00 PM
    
 * Author          : Administrator
    
 * Product Name    : tagApp
    

    
     */
    

    
    package jdom;
    

    
    import java.awt.event.ActionEvent;
    
    import java.awt.event.ActionListener;
    
    import java.io.BufferedReader;
    
    import java.io.BufferedWriter;
    
    import java.io.IOException;
    
    import java.io.InputStreamReader;
    
    import java.io.OutputStream;
    
    import java.io.OutputStreamWriter;
    
    import java.net.InetAddress;
    
    import java.net.Socket;
    

    
    public class NetComm implements ActionListener {
    

    
    javax.swing.Timer timer     = new javax.swing.Timer(3000, this);
    

    
    Socket sock;
    

    
        private EventNotifier en;
    

    
        public static int net_state = 0;
    

    
    InetAddress ServerAddr;
    

    
        int ServerPort;
    

    
        public NetComm(InetAddress addr, int port) {
    
        ServerAddr     = addr;
    
        ServerPort     = port;
    
    }
    

    
        //初始化并創(chuàng)建socket連接
    
        public void NetComm_Init() {
    

    
        net_state     = 1;
    
            try {
    
            sock     = new Socket(ServerAddr, ServerPort);
    
        }     catch (IOException e) {
    
            net_state     = 0;
    
        }
    
        timer.start();
    
    }
    
    
    
        //創(chuàng)建socket連接
    
        public void NetComm_Data() {
    

    
            try {
    
            OutputStream outputstream     = sock.getOutputStream();
    
            BufferedWriter out     = new BufferedWriter(new OutputStreamWriter(
    
                    outputstream));
    

    
            out.write(    "java by ghf@china.com");
    
            out.flush();
    

    
            BufferedReader in     = new BufferedReader(new InputStreamReader(sock
    
                    .getInputStream()));
    

    
                boolean more = true;
    
                while (more) {
    
                String str     = in.readLine();
    
                    if (str == null) {
    
                    more     = false;
    
                }     else {
    
                        // 處理數(shù)據(jù)
    
                        System.out.println(str);
    
                }
    
            }
    
            in.close();
    

    
        }     catch (IOException e) {
    
            NetComm_Close();
    
            net_state     = 0;
    
        }
    
        timer.start();
    
    }
    

    
        public void NetComm_Close() {
    
            if (sock != null)
    
                try {
    
                sock.close();
    
            }     catch (IOException e) {
    
            }
    
    }
    

    
        public void actionPerformed(ActionEvent e) {
    
            if (net_state == 0) {
    
            NetComm_Init();
    
        }     else {
    
            NetComm_Data();
    
        }
    
    }
    
}
    

    

    

    在以上程序中，也可以為外部應(yīng)用提供一個(gè)回調(diào)函數(shù)，以便在網(wǎng)絡(luò)異常或恢復(fù)正常時(shí)通知應(yīng)用。服務(wù)應(yīng)用的網(wǎng)絡(luò)通信類類似，可以放在同一類中。
    

		
    
			posted on 2008-03-27 16:58 都市淘沙者 閱讀(363) 評(píng)論(0)  編輯  收藏  所屬分類: Java Basic/Lucene/開源資料 
		
    
	
    
	
	


	


    
	    
    




    








    

				

    



    







    
        
	



主站蜘蛛池模板：
亚洲最大视频网站|
国产成人精品久久亚洲|
免费99精品国产自在现线|
69影院毛片免费观看视频在线|
久久久久久免费一区二区三区
|
亚洲狠狠久久综合一区77777|
亚洲国产另类久久久精品小说|
国产亚洲美日韩AV中文字幕无码成人|
亚洲国产一区二区三区|
av在线亚洲欧洲日产一区二区|
中文字幕亚洲综合久久菠萝蜜|
相泽亚洲一区中文字幕|
亚洲精品中文字幕乱码三区|
久久精品国产亚洲AV麻豆王友容|
亚洲三级电影网站|
亚洲午夜精品一区二区公牛电影院
|
好男人视频社区精品免费|
午夜精品在线免费观看|
免费看男女下面日出水视频|
亚洲一本大道无码av天堂|
亚洲精品乱码久久久久久蜜桃不卡|
亚洲va在线va天堂va四虎|
亚洲人成电影在线观看青青|
亚洲综合精品第一页|
深夜福利在线免费观看|
GOGOGO免费观看国语|
3344永久在线观看视频免费首页|
一级女人18毛片免费|
国产大片线上免费看|
亚洲熟女少妇一区二区|
亚洲精品国产专区91在线|
亚洲精品无码久久久久A片苍井空|
美女的胸又黄又www网站免费|
三年在线观看免费观看完整版中文|
久久精品免费电影|
成年美女黄网站18禁免费|
免费大黄网站在线看|
亚洲AV第一页国产精品|
亚洲熟妇无码av另类vr影视|
国产A∨免费精品视频|
亚洲黄色片免费看|