1、網(wǎng)絡(luò)編程 - Socket,C/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ī)IP Localhost表示本機(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) ServerS

2、ocket serverSocket = 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 );/

3、 高端流綁定低端流 br = new BufferedReader( 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(); finally try is.close(); catch ( Exception e ) e.printStackTrace(); try isr.close()

4、; catch ( Exception e ) e.printStackTrace(); try br.close(); catch ( Exception e ) e.printStackTrace(); try socket.close(); catch ( Exception e ) e.printStackTrace(); try serverSocket.close(); catch ( Exception e ) e.printStackTrace(); ,客戶端,public static void main(String args) Socket socket = null;

5、OutputStream os = null; PrintStream ps = null; try socket = 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(); finally try ps.close(); catch

6、 ( Exception e ) e.printStackTrace(); try os.close(); catch ( Exception e ) e.printStackTrace(); try socket.close(); catch ( Exception e ) e.printStackTrace(); ,服務(wù)器 多用戶, serverSocket = new ServerSocket( 6789 );/ 開始監(jiān)聽 while ( true ) / 循環(huán)接收用戶請(qǐng)求 socket = serverSocket.accept();/ 等待接收數(shù)據(jù) is = socket.getIn

7、putStream(); 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è)客戶端，因?yàn)槲覀冋J(rèn)為，我們將每個(gè)客戶交給一個(gè)線程來處理 這種線程

8、稱為“客戶線程”,服務(wù)器 多用戶 并發(fā),public class ClientThread 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.getInputStream(); isr = new InputStre

9、amReader( is ); br = new BufferedReader( isr ); while ( true ) String line = br.readLine(); if ( null = line ) break; System.out.println( line ); catch ( Exception e ) e.printStackTrace(); finally try is.close(); catch ( Exception e ) e.printStackTrace(); try isr.close(); catch ( Exception e ) e.pri

10、ntStackTrace(); try br.close(); catch ( Exception e ) e.printStackTrace(); try socket.close(); catch ( Exception e ) e.printStackTrace(); ,服務(wù)器 多用戶 并發(fā),public static void main(String args) ServerSocket serverSocket = null; InputStream is = null; InputStreamReader isr = null; BufferedReader br = null;

11、Socket socket = null; try serverSocket = new ServerSocket( 6789 );/ 開始監(jiān)聽 while ( true ) socket = serverSocket.accept();/ 等待接收數(shù)據(jù) ClientThread clientThread = new ClientThread( socket ); clientThread.start();/ 啟動(dòng)一個(gè)客戶線程 catch ( Exception e ) e.printStackTrace(); finally try is.close(); catch ( Exception

12、 e ) e.printStackTrace(); try isr.close(); catch ( Exception e ) e.printStackTrace(); try br.close(); catch ( Exception e ) e.printStackTrace(); try socket.close(); catch ( Exception e ) e.printStackTrace(); try serverSocket.close(); catch ( Exception e ) e.printStackTrace(); ,客戶端 多用戶 并發(fā),下面是模擬10個(gè)并發(fā)客

13、戶端的程序： 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( 把犯人給我押上! ); ps.flush(); catch ( Exception e ) e.printStackTrace(); finally try ps.close(); catch ( Exception e ) e.printStackTrace(); try os.close();