Android網路程式設計（使用socket進行通訊）
網路程式設計的基本模型就是c/s模型，簡單的理解是兩個程序之間相互通訊，其中一個必須提供一個固定的位置，而另一個則只需要知道這個固定的位置，並去建立兩者之間的聯絡，然後完成資料的通訊就可以了。提供固定位置的通常稱為伺服器，而建立聯絡的通常叫做客戶端。
Java提供了ServerSocket，事實上當你建立該類的物件並提供一個埠資源你就建立了一個固定位置可以讓計算機來訪問。ServerSocket server=new ServerSocket(8888)；埠的分配必須是唯一的，它是唯一標識每臺計算機每一個服務的。埠號必須是從0~65535之間的，前1024個埠已經被Tcp/Ip 作為保留埠，因此你所分配的埠只能是1024個之後的。Java同樣提供了一個Socket，客戶方建立一個Socket的物件就可以了。Socket client
=new Socket(InetAddress.getLocalHost(),5678)；客戶機必須知道有關伺服器的IP地址。
上面建立了一個連線讓兩臺計算機相互交流了。BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
PrintWriter out=new PrintWriter(server.getOutputStream());；前面兩句就是建立緩衝並把原始的位元組流轉變為Unicode可以操作。
服務端:
|
import java.io.*; import java.net.*; public class MyServer { public static void main(String[] args) throws IOException{ ServerSocket server=new ServerSocket(5678); Socket client=server.accept(); BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out=new PrintWriter(client.getOutputStream()); while(true){ String str=in.readLine(); System.out.println(str); out.println("has receive...."); out.flush(); if(str.equals("end")) break; } client.close(); } } |
這個程式的主要目的在於伺服器不斷接收客戶機所寫入的資訊。客戶機發送"End"字串就退出程式，並且伺服器也會做出"Receive"為迴應.告知客戶機已接收到訊息.
客戶端程式碼:
|
import java.net.*; import java.io.*; public class Client{ static Socket server; public static void main(String[] args)throws Exception{ server=new Socket(InetAddress.getLocalHost(),5678); BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream())); PrintWriter out=new PrintWriter(server.getOutputStream()); BufferedReader wt=new BufferedReader(new InputStreamReader(System.in)); while(true){ String str=wt.readLine(); out.println(str); out.flush(); if(str.equals("end")){ break; } System.out.println(in.readLine()); } server.close(); } } |
客戶端程式碼則是接受客戶鍵盤輸入，並把該資訊輸出,然後輸出"End"用來做退出標識.
這個程式只是簡單的兩臺計算機之間的通訊.如果是多個客戶同時訪問一個伺服器呢?你可以試著再執行一個客戶端,結果是會丟擲異常的.那麼多個客戶端如何實現呢?
其實,簡單的分析一下,就可以看出客戶和服務通訊的主要通道就是Socket本身.而伺服器通過accept方法就是同意和客戶建立通訊.這樣當客戶建立Socket的同時.伺服器也會使用這一根連線來先後通訊.那麼既然如此只要我們存在多條連線就可以了.那麼我們的程式可以變為如下:
伺服器:
|
import java.io.*; import java.net.*; public class MyServer { public static void main(String[] args) throws IOException{ ServerSocket server=new ServerSocket(5678); while(true){ Socket client=server.accept(); BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out=new PrintWriter(client.getOutputStream()); while(true){ String str=in.readLine(); System.out.println(str); out.println("has receive...."); out.flush(); if(str.equals("end")) break; } client.close(); } } } |
這裡僅僅只是加了一個外層的While迴圈.這個迴圈的目的就是當一個客戶進來就為它分配一個Socket直到這個客戶完成一次和伺服器的互動,這裡也就是接受到客戶的"End"訊息.那麼現在就實現了多客戶之間的互動了.但是.問題又來了.這樣做雖然解決了多客戶,可是是排隊執行的.也就是說當一個客戶和伺服器完成一次通訊之後下一個客戶才可以進來和伺服器互動.無法做到同時服務.那麼要如何才能同時達到既能相互之間交流又能同時交流呢?很顯然這是一個並行執行的問題了.所以執行緒是最好的解決方案.
那麼下面的問題是如何使用執行緒.首先要做的事情是建立執行緒並使得其可以和網路連線取得聯絡.然後由執行緒來執行剛才的操作.要建立執行緒要麼直接繼承Thread要麼實現Runnable介面,要建立和Socket的聯絡只要傳遞引用就可以了.而要執行執行緒就必須重寫run方法.而run方法所做的事情.就是剛才單執行緒版本main所做的事情.因此我們的程式變成了這樣:
|
import java.net.*; import java.io.*; public class MultiUser extends Thread{ private Socket client; public MultiUser(Socket c){ this.client=c; } public void run(){ try{ BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out=new PrintWriter(client.getOutputStream()); //Mutil User but can't parallel while(true){ String str=in.readLine(); System.out.println(str); out.println("has receive...."); out.flush(); if(str.equals("end")) break; } client.close(); }catch(IOException ex){ }finally{ } } public static void main(String[] args)throws IOException{ ServerSocket server=new ServerSocket(5678); while(true){ //transfer location change Single User or Multi User MultiUser mu=new MultiUser(server.accept()); mu.start(); } } } |
我的類直接從Thread類繼承了下來.並且通過建構函式傳遞引用和客戶Socket建立了聯絡.這樣每個執行緒就有了.一個通訊管道.同樣我們可以填寫run方法.把之前的操作交給執行緒來完成.這樣多客戶並行的Socket就建立起來了.