1. 如何用java實現伺服器確認後客戶端才能發送下一條信息。
Server代碼
packagecom.javacodegeeks.android.androidsocketserver;
importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.net.ServerSocket;
importjava.net.Socket;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.os.Handler;
importandroid.util.Log;
importandroid.widget.TextView;
{
;
;
privateThreadserverThread=null;
privateTextViewtext;
=6000;
@Override
publicvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
text=(TextView)findViewById(R.id.text2);
updateConversationHandler=newHandler();
this.serverThread=newThread(newServerThread());
this.serverThread.start();
}
@Override
protectedvoidonStop()
{
super.onStop();
try
{
serverSocket.close();
}
catch(IOExceptione)
{
e.printStackTrace();
}
}
{
publicvoidrun()
{
Socketsocket=null;
try
{
serverSocket=newServerSocket(SERVERPORT);
}
catch(IOExceptione)
{
e.printStackTrace();
}
while(!Thread.currentThread().isInterrupted())
{
try
{
socket=serverSocket.accept();//TODO
CommunicationThreadcommThread=newCommunicationThread(socket);
newThread(commThread).start();
}
catch(IOExceptione)
{
Log.i("liu","socket.accept()失敗");
e.printStackTrace();
}
}
}
}
{
privateSocketclientSocket;
privateBufferedReaderinput;
publicCommunicationThread(SocketclientSocket)
{
this.clientSocket=clientSocket;
Log.i("liu","獲取到了client的Socket");
try
{
this.input=newBufferedReader(newInputStreamReader(this.clientSocket.getInputStream()));//TODO
}
catch(IOExceptione)
{
Log.i("liu","input獲取失敗");
e.printStackTrace();
}
}
publicvoidrun()
{
while(!Thread.currentThread().isInterrupted())
{
try
{
Stringread=input.readLine();//TODO
Log.i("liu",read);
updateConversationHandler.post(newupdateUIThread(read));
}
catch(IOExceptione)
{
Log.i("liu","input讀取失敗");
e.printStackTrace();
}
}
}
}
{
privateStringmsg;
publicupdateUIThread(Stringstr)
{
this.msg=str;
}
@Override
publicvoidrun()
{
text.setText(text.getText().toString()+"ClientSays:"+msg+" ");
}
}
}
2. Client代碼：
packagecom.javacodegeeks.android.androidsocketclient;
importjava.io.BufferedWriter;
importjava.io.IOException;
importjava.io.OutputStreamWriter;
importjava.io.PrintWriter;
importjava.net.InetAddress;
importjava.net.Socket;
importjava.net.UnknownHostException;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.util.Log;
importandroid.view.View;
importandroid.widget.EditText;
{
privateSocketsocket;
=4000;
_IP="10.0.2.2";
@Override
publicvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
newThread(newClientThread()).start();
}
publicvoidonClick(Viewview)
{
try
{
EditTextet=(EditText)findViewById(R.id.EditText01);
Stringstr=et.getText().toString();
Log.i("liu","點擊按鈕");
PrintWriterout=newPrintWriter(newBufferedWriter(newOutputStreamWriter(socket.getOutputStream())),true);//TODO
out.println(str);
}
catch(Exceptione)
{
Log.i("liu","write失敗");
e.printStackTrace();
}
}
{
@Override
publicvoidrun()
{
try
{
InetAddressserverAddr=InetAddress.getByName(SERVER_IP);
socket=newSocket(serverAddr,SERVERPORT);
}
catch(UnknownHostExceptione1)
{
e1.printStackTrace();
}
catch(IOExceptione1)
{
e1.printStackTrace();
}
}
}
}
2. Android上實現TCP服務端
之前已經講過了tcp客戶端的實現了，大家有興趣的話，可以參看文章
Android上實現TCP客戶端
那麼，今天我們就來講講tcp之服務端的封裝吧。我已經將tcp服務端封裝成了一個類—TcpServer，下面就來講講它的使用吧。
今天涉及內容：
先來波效果圖
在 tcp服務端 建立 ServerSocket 的時候，我們通常是這樣的：
其實以上方法調用的是
其中涉及到的參數：
鑒於tcp服務端 ServerSocket 一般運行在 "本機" 上，則快速初始化 ServerSocket 運用上面的方法：
意思是建立的ServerSocket IP地址為本機，可容納socket個數為 50 。
在理解了 ServerSocket 初始化問題後，讓我們來看看封裝類TcpServer的幾個主要方法：
TcpServer 主要是在 java 上運行，所以就讓我們在 Androidstudio 上模擬下在 Java 中運行tcp服務端的場景：
這里涉及到的兩個類 SocketConfig 和 SocketHelper 和之前的一樣，大家可以參考文章 Android上實現TCP客戶端 中與之相關的介紹，這里就不贅述了。
tcp服務端主要容易出現以下兩個問題：
對於第一個問題，這里需要強調的是 TcpServer 的接收方法 receiveMessage(String charsetName) 是以 (result = bufferedReader.readLine()) != null 做判斷讀取 stream 的，所以客戶端向 TcpServer 發送消息時，需要在結尾加上\n,這樣 TcpServer 的receiveMessage(String charsetName)方法才能將傳過來的數據接收完整。
對於第二個問題，則需要客戶端與服務端設置相同的字元集以保證數據不亂碼。
封裝類 TcpServer 源碼如下: