本文主要講解安卓(Android)TCP Socket通訊客戶端(Client)和服務器(Server)Demo的實現(附源碼)，要注意BufferedReader的readLine()方法【((line = br.readLine()) != null)】 的阻塞問題，以及對接硬件的項目數據在十六進制&&byte&&int的轉換處理。
大坑
最近有個項目需要用到TCP Socket通訊，遇到了一個大坑，所以做了這個Demo。
讀取socket輸入流的時候很多代碼都會這么寫，一般也不會有什么問題，但是readLine()方法讀取不到換行和回車時會阻塞！
String line = null;
while ((line = br.readLine()) != null) {
}
readLine()是個阻塞函數，可以點進去查看源碼，只有遇到換行或者回車回車符(’\n’,’\r’ 對應十六進制是 0D 0A)才會返回，而有些模塊返回給你的數據不帶這兩個結束符，所以導致阻塞，程序不能走下去。這種情況一般如果模塊那邊願意修改加上結束符，那就沒問題。如果模塊那邊又不方便改，那就不能用這種方式了，得換種寫法。
調試工具
調試的實時我們可以借助一些PC端的工具，TCP調試助手、TCP測試工具類似的，度娘下很多，操作也是傻瓜式的，填寫IP和端口然后建立或者連接。
Demo演示及實現
廢話少說，直接 進入今天的主題，下面就看看如何在Android上利用TCP/IP協議使用Socket與Server進行通訊吧！
一、權限
<uses-permission android:name="android.permission.INTERNET"/>
二、服務端實現，簡單來說就3步
1、 創建ServerSocket ,監聽端口，等待客戶端Socket連接
2、從Socket里獲取的客戶端發來的消息
3、通過Socket給客戶端發消息
核心代碼如下
class ServerSocketThread extends Thread {
@Override
public void run() {
try {
// 創建ServerSocket
ServerSocket serverSocket = new ServerSocket(9999);
System.out.println("--開啟服務器，監聽端口 9999--");
// 監聽端口，等待客戶端連接
while (true) {
System.out.println("--等待客戶端連接--");
Socket socket = serverSocket.accept(); //等待客戶端連接
System.out.println("得到客戶端連接：" + socket);
startReader(socket);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* 從參數的Socket里獲取消息
*/
private static void startReader(final Socket mSocket) {
new Thread(){
@Override
public void run() {
try {
// 獲取讀取流
BufferedReader in = new BufferedReader(new InputStreamReader(mSocket.getInputStream(),"utf-8"))
String line="";
while ((line = in.readLine()) != null) {// 讀取數據
System.out.println("*等待客戶端輸入*");
System.out.println("獲取到客戶端的信息：" + line);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
//通過socket來給客戶端發送消息
private void serverSendMessage(String mServerSendMessage) {
new Thread() {
@Override
public void run() {
PrintWriter out;
try {
out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(mSocket.getOutputStream())), true);
out.println(mServerSendMessage);
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
三、客戶端實現，跟服務器端流程類似
1、與服務器建立Socket連接
2、獲取到輸入輸出流
3、收/發送消息
//與服務器建立連接
Socket mClientSocket = new Socket(mClientIp, mClientPort);
//從socket獲取輸入輸出流
BufferedReader mClientIn = new BufferedReader(new InputStreamReader(mClientSocket.getInputStream()));
PrintWriter mClientOut = new PrintWriter(new BufferedWriter(new OutputStreamWriter(mClientSocket.getOutputStream())), true);
//監聽服務端下發的消息
String clientReceiverMessage;
if ((clientReceiverMessage = mClientIn.readLine()) != null) {
if (mOnConnectListener != null) {
mOnConnectListener.onMessage(clientReceiverMessage);
}
}
//給服務端發消息
mClientOut.println(mClientSendMessage);
代碼封裝Listener接口
在實際開發過程中，我們一般會把Socket這塊封裝起來，然后對外設置Listener接口，在其它模塊里處理業務邏輯，也有的需要處理多個socket連接和通訊，
服務器端代碼實現示例
public class TcpServer {
private static final String TAG = "TcpServer";
private static TcpServer mTcpServer = new TcpServer();
private OnListener mOnListener;
private ServerSocketThread mServerSocketThread;
public static TcpServer getInstance() {
return mTcpServer;
}
public void setOnListener(OnListener onListener) {
mOnListener = onListener;
}
public interface OnListener {
void onStart();
void onNewClient(String serverIp, String clientIp, int count);
void onError(Throwable e, String message);
void onMessage(String ip, String message);
void onAutoReplyMessage(String ip, String message);
void onClientDisConnect(String ip);
void onConnectTimeOut(String ip);
}
public void setPort(int port) {
mServerPort = port;
}
………………………………
………………………………
………………………………
}
十六進制收發處理
對接硬件的項目通訊協議有可能是用十六進制的，所以數據要在字符串\byte\int 十六進制轉換，不過通訊部分本質一樣，代碼如下
//十六進制 發送
try {
//byte[] msg = {(byte) 0xaa,(byte) 0xbb,(byte) 0x0d,(byte) 0x0a};
byte[] msg = IntByteStringHexUtil.hexStrToByteArray("AABB0D0A");
OutputStream socketWriter = socket.getOutputStream();
socketWriter.write(msg);
} catch (IOException e) {
e.printStackTrace();
}
//十六進制 接收
InputStream socketReader = socket.getInputStream();
byte buf[] = new byte[1024];
int len = socketReader.read(buf);
byte data[] = new byte[len];
System.arraycopy(buf, 0, data, 0, len);
logClient(len+","+IntByteStringHexUtil.byteArrayToHexStr(data));
Demo源碼下載地址
源碼也都放在CSDN上了，有需要的可以借鑒