<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)站
    
		
				
			
	
		
    友情連接
    
		
				
			
	

        

    閱讀排行榜
    


		

    評論排行榜
    


	

    

    
	
					
	
    
		
    
			網(wǎng)絡(luò)編程中的異步編程
		
    
		該文章對編寫客戶服務(wù)器應(yīng)用的java程序員有所幫助,可以解決程序在對方出現(xiàn)故障的時(shí)候繼續(xù)穩(wěn)定運(yùn)行.
    
　　目前java平臺已經(jīng)廣泛應(yīng)用于各類客戶/服務(wù)器系統(tǒng)中，在實(shí)際編程中，往往需要網(wǎng)絡(luò)的異步處理。比如客戶程序，如果客戶程序運(yùn)行先于服務(wù)程序，則客戶程序則需要在服務(wù)程序啟動后再自動連接服務(wù)程序；在客戶程序運(yùn)行中如果服務(wù)程序中途停止，則也需要在不停止的條件下，等待服務(wù)程序運(yùn)行并重新連接。下面提供了一類異步編程的方法。
    
網(wǎng)絡(luò)異步應(yīng)用涉及到如下幾個(gè)關(guān)鍵點(diǎn)： 
    
　　客戶應(yīng)用啟動后，檢測服務(wù)應(yīng)用是否存在。如果不存在，則等待服務(wù)應(yīng)用啟動，同時(shí)不堵塞客戶應(yīng)用其他任務(wù)的執(zhí)行。一旦服務(wù)應(yīng)用啟動，客戶應(yīng)用應(yīng)該及時(shí)的與其建立連接。 
    
　　客戶應(yīng)用和服務(wù)應(yīng)用在數(shù)據(jù)通信中，服務(wù)應(yīng)用異常退出后，客戶應(yīng)用應(yīng)可以檢測到服務(wù)應(yīng)用的退出。同時(shí)客戶應(yīng)用自動清除該通信鏈路，回到初始狀態(tài)，等待服務(wù)應(yīng)用重新啟動。
    
　　該網(wǎng)絡(luò)異步編程首先涉及到一個(gè)定時(shí)器和定時(shí)器事件。該定時(shí)器用于不斷的檢測網(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) 評論(0)  編輯  收藏  所屬分類: Java Basic/Lucene/開源資料 
		
    
	
    
	
	


	


    
	    
    




    








    

				

    



    







    
        
	



主站蜘蛛池模板：
日日躁狠狠躁狠狠爱免费视频|
亚洲av网址在线观看|
手机看片久久国产免费|
国内自产少妇自拍区免费|
成年女人色毛片免费看|
日本成人免费在线|
国产视频精品免费|
亚洲AV日韩精品一区二区三区
|
亚洲欧美中文日韩视频|
亚洲综合色婷婷在线观看|
亚洲色欲色欲www在线播放|
亚洲精品中文字幕|
MM1313亚洲精品无码久久|
最好2018中文免费视频|
一级毛片正片免费视频手机看
|
国产精品亚洲av色欲三区|
亚洲精品在线免费观看视频|
亚洲日韩在线观看免费视频|
亚洲免费无码在线|
a级在线免费观看|
无码人妻丰满熟妇区免费|
免费观看美女用震蛋喷水的视频|
中文字幕无码视频手机免费看
|
在线毛片片免费观看|
91热成人精品国产免费|
18禁无遮挡无码网站免费|
国产成人免费手机在线观看视频
|
91久久成人免费|
性做久久久久免费看|
亚洲天堂在线视频|
亚洲国产高清在线|
亚洲熟妇AV一区二区三区浪潮
|
亚洲另类自拍丝袜第五页|
一级成人a免费视频|
特级精品毛片免费观看|
久久久久久99av无码免费网站|
亚洲AⅤ永久无码精品AA|
久久精品国产亚洲av麻|
亚洲熟妇久久精品|
中国一级特黄的片子免费|
真人做人试看60分钟免费视频|