亚洲成a人片在线网站,91亚洲va在线天线va天堂va国产,亚洲欧洲综合在线

網絡編程中的異步編程

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

* 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;

}

//初始化并創建socket連接

public void NetComm_Init() {

net_state = 1;

try {

sock = new Socket(ServerAddr, ServerPort);

} catch (IOException e) {

net_state = 0;

}

timer.start();

}

//創建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 {

// 處理數據

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();

}

在以上程序中，也可以為外部應用提供一個回調函數，以便在網絡異常或恢復正常時通知應用。服務應用的網絡通信類類似，可以放在同一類中。

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

新用戶注冊刷新評論列表


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




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: BeanComparator實現ArrayList復合排序[轉] 開源中最好的Web開發的資源 java中傳輸對象時候的問題（轉） Java Float類型減法運算時精度丟失問題 ConcurrentHashMap原理分析 http請求的詳細過程【推薦】既有魚肉又有熊掌——ListOrderedMap JAVA異常詳解 javaIO總結 j2ee的性能調優

都市淘沙者

導航

公告

隨筆分類

文章分類

隨筆檔案

文章檔案

相冊

統計

留言簿(23)

積分與排名

優秀學習網站

友情連接

閱讀排行榜

評論排行榜

網絡編程中的異步編程