亚洲AV无码一区二区二三区入口,亚洲色欲色欱wwW在线,亚洲人成网亚洲欧洲无码

網(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ù)程序啟動(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)后，檢測服務(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)可以檢測到服務(wù)應(yīng)用的退出。同時(shí)客戶應(yīng)用自動(dòng)清除該通信鏈路，回到初始狀態(tài)，等待服務(wù)應(yīng)用重新啟動(dò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 都市淘沙者閱讀(372) 評論(0) 編輯收藏所屬分類: Java Basic/Lucene/開源資料

新用戶注冊刷新評論列表


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




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關(guān)文章: BeanComparator實(shí)現(xiàn)ArrayList復(fù)合排序[轉(zhuǎn)] 開源中最好的Web開發(fā)的資源 java中傳輸對象時(shí)候的問題（轉(zhuǎn)） Java Float類型減法運(yùn)算時(shí)精度丟失問題 ConcurrentHashMap原理分析 http請求的詳細(xì)過程【推薦】既有魚肉又有熊掌——ListOrderedMap JAVA異常詳解 javaIO總結(jié) j2ee的性能調(diào)優(yōu)

都市淘沙者

導(dǎo)航

公告

隨筆分類

文章分類

隨筆檔案

文章檔案

相冊

統(tǒng)計(jì)

留言簿(23)

積分與排名

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

友情連接

閱讀排行榜

評論排行榜

網(wǎng)絡(luò)編程中的異步編程