第7-10天java高級(jí)技術(shù)4網(wǎng)絡(luò)編程socket

1、網(wǎng)絡(luò)編程 - SocketC/S結(jié)構(gòu)網(wǎng)絡(luò)通訊流程服務(wù)器開始監(jiān)聽客戶端申請(qǐng)連接服務(wù)器接受連接（此時(shí)連接已經(jīng)建立）服務(wù)器與客戶端開始通訊通訊條件服務(wù)器IP或主機(jī)名或域名通過IP來定位要連接的服務(wù)器所在位置127.0.0.1表示本機(jī)IPLocalhost表示本機(jī)服務(wù)器監(jiān)聽的服務(wù)端口通過IP找到要連接的服務(wù)器主機(jī)，但是服務(wù)器上運(yùn)行著多個(gè)程序都監(jiān)聽著網(wǎng)絡(luò)而每個(gè)程序都監(jiān)聽著不同的端口任何程序都必須通過端口來與網(wǎng)絡(luò)通訊這時(shí)，必須通過端口來定位服務(wù)器上要連接的程序通訊條件服務(wù)器 單用戶public static void main(String args) ServerSocket serverSocket

2、= null;InputStream is = null;InputStreamReader isr = null;BufferedReader br = null;Socket socket = null;try serverSocket = new ServerSocket( 6789 );/ 開始監(jiān)聽socket = serverSocket.accept();/ 等待接收數(shù)據(jù)is = socket.getInputStream();/ 獲得通向Socket的低端流isr = new InputStreamReader( is );/ 高端流綁定低端流br = new BufferedR

3、eader( isr );/ 緩沖流綁定高端流while ( true ) / 循環(huán)讀取String line = br.readLine();/ 接收數(shù)據(jù)if ( null = line ) / 如果客戶端已經(jīng)斷開break;System.out.println( line ); catch ( Exception e ) e.printStackTrace();客戶端public static void main(String args) Socket socket = null;OutputStream os = null;PrintStream ps = null;try socket

4、 = new Socket( “127.0.0.1”, 6789 );/ 申請(qǐng)連接os = socket.getOutputStream();/ 獲得通向Socket的低端流ps = new PrintStream( os );/ 高端流綁定低端流ps.println( “把犯人給我押上!” );/ 發(fā)送數(shù)據(jù)ps.flush(); catch ( Exception e ) e.printStackTrace();服務(wù)器 多用戶serverSocket = new ServerSocket( 6789 );/ 開始監(jiān)聽while ( true ) / 循環(huán)接收用戶請(qǐng)求socket = serv

5、erSocket.accept();/ 等待接收數(shù)據(jù)is = socket.getInputStream();isr = new InputStreamReader( is );br = new BufferedReader( isr );while ( true ) String line = br.readLine();if ( null = line ) break;System.out.println( line );socket.close();服務(wù)器 多用戶 并發(fā)原理：每次acept到一個(gè)Socket，都啟動(dòng)一個(gè)線程，把這個(gè)Socket交給這個(gè)線程進(jìn)行處理每個(gè)Socket象征著一個(gè)

6、客戶端，因?yàn)槲覀冋J(rèn)為，我們將每個(gè)客戶交給一個(gè)線程來處理這種線程稱為“客戶線程”服務(wù)器 多用戶 并發(fā)public class ServerThread extends Thread private Socket socket = null;public ClientThread( Socket socket ) this.socket = socket;public void run() InputStream is = null;InputStreamReader isr = null;BufferedReader br = null;try is = socket.getInputStrea

7、m();isr = new InputStreamReader( is );br = new BufferedReader( isr );while ( true ) String line = br.readLine();if ( null = line ) break;System.out.println( line ); catch ( Exception e ) e.printStackTrace();服務(wù)器 多用戶 并發(fā)public static void main(String args) ServerSocket serverSocket = null;InputStream i

8、s = null;InputStreamReader isr = null;BufferedReader br = null;Socket socket = null;try serverSocket = new ServerSocket( 6789 );/ 開始監(jiān)聽while ( true ) socket = serverSocket.accept();/ 等待接收數(shù)據(jù)ServerThread serverThread = new ServerThread ( socket );serverThread.start();/ 啟動(dòng)一個(gè)客戶線程 catch ( Exception e ) e.

9、printStackTrace();客戶端 多用戶 并發(fā)下面是模擬10個(gè)并發(fā)客戶端的程序：public static void main(String args) for ( int i = 0 ; i 10 ; i + ) Socket socket = null;OutputStream os = null;PrintStream ps = null;try socket = new Socket( 127.0.0.1, 6789 );os = socket.getOutputStream();ps = new PrintStream( os );ps.println( 把犯人給我押上! );p