基于tcpip協(xié)議的socketjava編程-資料下載頁(yè)
2025-05-14 13:29本頁(yè)面
【正文】 ent傳來(lái)的字符串(s)。if(().equals(BYE)) {(通話結(jié)束 )。break。}}()。()。()。()。()。}catch(IOException e){(Error + e)。//若端口已被占用，則拋出異常(1)。}}}程序分析:程序首先在端口2000上創(chuàng)建一個(gè)等待連接請(qǐng)求的ServerSocket對(duì)象sever:server=new ServerSocket(2000)。接著調(diào)用Server對(duì)象的accept()方法等待某客戶程序發(fā)出的連接請(qǐng)求。該方法一直阻塞直到有客戶連接到該端口。一旦有客戶發(fā)送正確請(qǐng)求，則連接成功，accept()方法返回一個(gè)Socket對(duì)象,于是得到一個(gè)新的用于通信的Socket對(duì)象,()和getOutputStream()方法創(chuàng)建與Socket對(duì)象綁定的輸入/,直到客戶端斷開(kāi)連接即關(guān)閉各個(gè)流結(jié)束通信.n2．import .*。import .*。public class talkclient{public static void main(String args[]){Socket socket。String s。int port = 2000。try{//向本地服務(wù)器申請(qǐng)連接//注意端口號(hào)要和服務(wù)器的一致socket = new Socket(localhost,port)。//localhost=(連接成功)。(=========================================)。()。//獲得對(duì)應(yīng)Socket的輸入/輸出流InputStream in = ()。DataInputStream din = new DataInputStream(in)。//獲取輸入流，并創(chuàng)建相應(yīng)的數(shù)據(jù)輸入流OutputStream out = ()。DataOutputStream dout = new DataOutputStream(out)。//獲取輸出流，并創(chuàng)建相應(yīng)的數(shù)據(jù)輸出流BufferedReader sin = new BufferedReader(new InputStreamReader())。while(true){(請(qǐng)輸入要發(fā)送的信息: )。//顯示字符串s = ()。//讀入從client傳來(lái)的字符串(s)。if(().equals(BYE)) {(通話結(jié)束 )。break。}()。s = ()。//讀入從client傳來(lái)的字符串(從服務(wù)器接收的信息為: + s)。//顯示字符串if(().equals(BYE)) {(通話結(jié)束 )。break。}()。}()。()。()。()。()。}catch(IOException e){(Error + e)。//若端口已被占用，則拋出異常(1)。}}}運(yùn)行結(jié)果:(1)(2)(3)客戶端向服務(wù)端發(fā)送信息(4)結(jié)束連接n【例 6】多客戶/服務(wù)器程序。n1．服務(wù)器端程序（1）：線程類的子類，為客戶提供服務(wù)的所有操作都封裝在該類中，該類的構(gòu)造函數(shù)ServerSocketThread(Socket s)接收一個(gè)Socket對(duì)象,用來(lái)與客戶進(jìn)行數(shù)據(jù)通信。import .*。import .*。public class ServerSocketThread extends Thread{private Socket socket。private DataInputStream din。private DataOutputStream dout。public ServerSocketThread(Socket s) throws IOException{socket = s。din = new DataInputStream(())。dout = new DataOutputStream(())。start()。}public void run(){String str。try{(連接成功)。(=========================================)。(請(qǐng)等待客戶發(fā)送信息...)。()。while(true){BufferedReader sin = new BufferedReader(new InputStreamReader())。()。str = ()。//讀入從client傳來(lái)的字符串(從客戶端接收的信息為: + str)。//顯示字符串if(().equals(BYE)) {(通話結(jié)束 )。break。}()。(請(qǐng)輸入要發(fā)送的信息: )。//顯示字符串str = ()。//讀入從鍵盤(pán)傳來(lái)的字符串(str)。()。//if(().equals(BYE)) {(通話結(jié)束 )。break。}}()。()。()。}catch(IOException e){(Error + e)。//若端口已被占用，則拋出異常(1)。}
規(guī)章制度相關(guān)推薦
鄂ICP備17016276號(hào)-1