思路超簡單的Android Socket 通訊  Demo 註釋詳細

demo下載  http://download.csdn.net/detail/menglele1314/9280379

服務端往Socket的輸出流裡面寫東西，客戶端就可以通過Socket的輸入流讀取對應的內容。Socket與Socket之間是雙向連通的，所以客戶端也可以往對應的Socket輸出流裡面寫東西，然後服務端對應的Socket的輸入流就可以讀出對應的內容。

Socket型別為流套接字（streamsocket）和資料報套接字(datagramsocket)。

Socket基本實現原理

TCP與UDP
1基於TCP協議的Socket
伺服器端首先宣告一個ServerSocket物件並且指定埠號，然後呼叫Serversocket的accept（）方法接收客戶端的資料。accept（）方法在沒有資料進行接收的處於堵塞狀態。（Socketsocket=serversocket.accept()）,一旦接收到資料，通過inputstream讀取接收的資料。
客戶端建立一個Socket物件，指定伺服器端的ip地址和埠號（Socketsocket=newSocket("172.168.10.108",8080);）,通過inputstream讀取資料，獲取伺服器發出的資料（OutputStreamoutputstream=socket.getOutputStream()），最後將要傳送的資料寫入到outputstream即可進行TCP協議的socket資料傳輸。
2基於UDP協議的資料傳輸
伺服器端首先建立一個DatagramSocket物件，並且指點監聽的埠。接下來建立一個空的DatagramSocket物件用於接收資料（bytedata[]=newbyte[1024;]DatagramSocketpacket=newDatagramSocket（data，data.length））,使用DatagramSocket的receive方法接收客戶端傳送的資料，receive（）與serversocket的accepet（）類似，在沒有資料進行接收的處於堵塞狀態。
客戶端也建立個DatagramSocket物件，並且指點監聽的埠。接下來建立一個InetAddress物件，這個物件類似與一個網路的傳送地址（InetAddressserveraddress=InetAddress.getByName（"172.168.1.120"））.定義要傳送的一個字串，建立一個DatagramPacket物件，並制定要講這個資料報包傳送到網路的那個地址以及埠號，最後使用DatagramSocket的物件的send（）傳送資料。*（Stringstr="hello";bytedata[]=str.getByte();DatagramPacketpacket=new DatagramPacket(data,data.length,serveraddress,4567);socket.send(packet);）
TCP使用的是流的方式傳送，UDP是以包的形式傳送。

上點程式碼

新增許可權
<!--允許應用程式改變網路狀態-->    
<uses-permission android:name="android.permission.CHANGE_NETWORK_STATE"/>    
    
<!--允許應用程式改變WIFI連線狀態-->    
<uses-permission android:name="android.permission.CHANGE_WIFI_STATE"/>    
    
<!--允許應用程式訪問有關的網路資訊-->    
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>    
    
<!--允許應用程式訪問WIFI網絡卡的網路資訊-->    
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE"/>    
    
<!--允許應用程式完全使用網路-->    
<uses-permission android:name="android.permission.INTERNET"/> 
 

package com.client;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

import org.apache.commons.io.IOUtils;

public class AbsClient {

	public static void main(String[] args) {
		request("registered");// login
	}

	public static String request(String params) {
		Socket socket = null;
		String object = null;
		try {
			// 1.連線伺服器
			String ip = InetAddress.getLocalHost().getHostAddress();// 伺服器Ip地址
			System.out.println("AbsClient*****連線伺服器");
			socket = new Socket("127.0.0.1", 8485);
			System.out.println("AbsClient*****已經建立連線");
			// 2.傳送請求資料
			System.out.println("AbsClient*****傳送請求");
			sendRequest(socket.getOutputStream(), params);
			socket.isInputShutdown();
			System.out.println("AbsClient*****請求傳送成功*****接收響應");
			// 3.接收並解析響應資料
			object = receiveResponse(socket.getInputStream());
			System.out.println("AbsClient*****響應接收完成*****伺服器返回結果");
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (null != socket) {
				try {
					// 4.斷開連線
					socket.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
		// 5.返回接收的資料
		return object;
	}

	/******** 生成併發送請求資料 ***************************************************/
	public static void sendRequest(OutputStream out, String params) throws Exception {
		out.write(params.getBytes());
		out.flush();
		System.out.println("AbsClient我傳送到服務端去》》》" + params);
	}

	/*********** 接收並解析響應資料 ***********************************/
	public static String receiveResponse(InputStream in) throws Exception {
		String data = IOUtils.toString(in);// 儲存從伺服器響應的結果
		System.out.println("AbsClient我是收到服務端的》》》" + data);
		return data;
	}

}
 

服務端

package com.server;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class AbsServer {

	public static void main(String[] args) {
		thread.start();
	}

	static Thread thread = new Thread() {
		private ServerSocket ss;

		public void run() {
			try {
				ss = new ServerSocket(8485);
				System.out.println("AbsServer伺服器已經啟動");
				while (true) {
					Socket socket = ss.accept();
					try {
						socket.setSoTimeout(5 * 1000);
						// 1.接收並解析請求資料
						String type = receiveRequest(socket.getInputStream());
						String result = null;
						if ("login".equals(type)) {
							result = "AbsServer恭喜你註冊成功,我是服務端返回的訊息";
						} else {
							result = "AbsServer我是服務端返回的登入資訊";
						}
						// 2.生成併發送響應資料
						sendRespnose(socket.getOutputStream(), result);
					} catch (Exception e) {
						System.out.println("AbsServer通訊失敗");
						e.printStackTrace();
					} finally {
						try {
							// 3.斷開連線
							socket.close();
						} catch (IOException e) {
							e.printStackTrace();
						}
					}
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
			System.out.println("AbsServer伺服器已經停止");
		}

		/********** 接收請求資訊 ***************************************/
		public String receiveRequest(InputStream in) throws Exception {
			// 接收，解析請求
			byte[] buf = new byte[4096];
			in.read(buf);
			String type = new String(buf);
			System.out.println("AbsServer我從客戶端來《《《" + type);
			return type;
		}

		/********** 返回請求要的資訊 **************************************************/
		public void sendRespnose(OutputStream out, String result) throws Exception {
			out.write(result.getBytes());
			out.flush();
			System.out.println("AbsServer我發客戶端去》》》" + result);
		}

	};

}