socket通信程序設(shè)計(jì)(編輯修改稿)
2024-11-12 16:43 本頁面
【文章內(nèi)容簡介】 ing args[]) { try{ Socket soc=new Socket(localhost,8000)。 (Connecting to the Server...)。 InputStream is = ()。 OutputStream os = ()。 DataInputStream in= new DataInputStream(is)。 PrintStream out = new PrintStream(os)。 String strin =()。 (“服務(wù)器端 :+strin)。 byte bmsg[] = new byte[20]。 (bmsg)。 String msg=new String(bmsg,0)。 msg=()。 while(!(quit)){ //從鍵盤循環(huán)讀入，直到輸入 ” quit”為止 (msg)。 (bmsg)。 msg=new String(bmsg,0)。 msg=()。 } (msg)。 } catch (Exception e) { (Error: +e)。 } finally{ ()。 //關(guān)閉輸入流 ()。 //關(guān)閉輸出流 ()。 //關(guān)閉 socket，拆除鏈路 (0)。 } } } 創(chuàng)建指定地址和端口的 Socket對象 建立服務(wù)器與客戶端連接 調(diào)用 getInputStream()或 getOutputStream()方法獲得 Socket對象的輸入流和輸出流 服務(wù)器與客戶端連接根據(jù)協(xié)議交互數(shù)據(jù) 關(guān)閉請求連接，服務(wù)器和客戶端連接終止 客戶機(jī)套接字程序 Socke通信編程 異常處理 ServerSocket和 socket編程需要進(jìn)行 trycatch異常處理 （ 1）服務(wù)器端： ServerSocket server。 Socket socket。 try { server=new ServerSocket(port)。 socket=()。 ……… .. } catch(Exception e) { (“Error occurred： ” +e)。 } （ 2）客戶端 ： Socket socket。 try { socket=new Socket(“Server Name”, port)。 } catch(Exception e) { (“Error occurred： ” +e)。 } 建立 Socket連接后，利用方法 getOutputStream()和getInputStream()建立向 Socket讀寫數(shù)據(jù)的 I/O流。 需要進(jìn)行 trycatch異常處理。 try { InputStream ins = socket. getInputStream()。 OutputStream outs = socket. getOutputStream()。 } catch(Exception e) { (“Error occurred:”+e)。 } Socke通信編程 –建立Ｉ /Ｏ輸出流 獲取 Socket的輸入 /輸出流后，需要對兩個流對象建立數(shù)據(jù)流的讀 /寫操作 InputStream ins = socket. getInputStream()。 OutputStream outs = socket. getOutputStream()。 或 PrintStream out = new PrintStream(outs)。 讀入一個字符串并將其長度寫入輸出流中，則用： String str = ()。 (())。 Socke通信編程 –讀寫數(shù)據(jù)流 無論是服務(wù)器程序還是客戶端程序，通信結(jié)束時，必須斷開連接并釋放所占用的資源。 Java斷開連接方法： close()。 （ 1）關(guān)閉輸入輸出流 – 停止數(shù)據(jù)傳輸 （ 2）關(guān)閉 socket – 終止申請服務(wù) （ 3）關(guān)閉 server socket – 關(guān)閉監(jiān)聽服務(wù) Socke通信編程 – 釋放連接 問題： Socket設(shè)計(jì)輸入流和輸出流的處理，客戶機(jī)與服務(wù)器進(jìn)行數(shù)據(jù)讀取時將引起堵塞。 解決辦法： 服務(wù)器一旦接受到用戶的 Socket，將專門為該用戶建立在一個獨(dú)立的線程，進(jìn)行數(shù)據(jù)的訪問交換操作。 //(2) 服務(wù)器端程序 import .*。 import .*。 import .*。 public class Server { public static void main(String args[]) { ServerSocket server=null。 ServerThread thread。 Socket you=null。 while(true) { try{ server=new ServerSocket(4331)。 } catch(IOException e1) { (“正在監(jiān)聽 ”)。 //Server
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號-1