Android客户端通过Socket连接服务器

Android客户端通过Socket连接服务器。

Android互联网项目中，绝大部分都有连接远程服务器的需求，连接的方式有多种，可以是TCP的方式，当然也可以通过Socket的方式。

相对于TCP的方式，Socket的方式略显的较为原始，对于客户端来说，复杂度反而比TCP的方式还要高一些，毕竟TCP的连接有现成的框架可以使用，

比如Spring等。 而使用socket方式这些工作完全需要客户端来做，也增加了客户端的工作量，不过凡事有利弊，通过socket的方式，流量上

相对于TCP等的方式更加可控，毕竟少了很多没有用的信息传递。

大概思路如下：

客户端首次连接服务器：

[java]
view plain
copy

print?

socket = new Socket();  
                SocketAddress address = new InetSocketAddress(svrHost, svrPort);  
                socket.connect(address, TIME_OUT);  
                socket.setSoTimeout(TIME_OUT);  
                in = new BufferedReader(new InputStreamReader(  
                        socket.getInputStream()));  
                  
                out = new PrintWriter(new BufferedWriter(  
                        new OutputStreamWriter(socket.getOutputStream())), true);  





[java]
view plain
copy

print?

socket = new Socket();  
                SocketAddress address = new InetSocketAddress(svrHost, svrPort);  
                socket.connect(address, TIME_OUT);  
                socket.setSoTimeout(TIME_OUT);  
                in = new BufferedReader(new InputStreamReader(  
                        socket.getInputStream()));  
                  
                out = new PrintWriter(new BufferedWriter(  
                        new OutputStreamWriter(socket.getOutputStream())), true);  

socket = new Socket();
SocketAddress address = new InetSocketAddress(svrHost, svrPort);
socket.connect(address, TIME_OUT);
socket.setSoTimeout(TIME_OUT);
in = new BufferedReader(new InputStreamReader(
socket.getInputStream()));

out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())), true);

连接服务器之后，调用注册或者登录，获取连接的token。 以后每次的连接获取信息都要带上约定的token。

连接建立以后，socket不必关闭，毕竟每次connect也浪费资源，可以一直挂住等待服务端的推送或者心跳等消息。

 

[java]
view plain
copy

print?

while (!exitSocket) {  
                try {  
                    if (!socket.isClosed() && socket.isConnected()  
                            && !socket.isInputShutdown()) {  
  
                        char[] lenBuffer = new char[13];  
                        int len = 0;  
                        try  {  
                            len = in.read(lenBuffer);  
                        } catch (Exception e) {  
                            Utils.debug("SocketSvr socket read timeout");  
                            stopSocketByException(true);  
                        }  





[java]
view plain
copy

print?

while (!exitSocket) {  
                try {  
                    if (!socket.isClosed() && socket.isConnected()  
                            && !socket.isInputShutdown()) {  
  
                        char[] lenBuffer = new char[13];  
                        int len = 0;  
                        try  {  
                            len = in.read(lenBuffer);  
                        } catch (Exception e) {  
                            Utils.debug("SocketSvr socket read timeout");  
                            stopSocketByException(true);  
                        }  

while (!exitSocket) {
try {
if (!socket.isClosed() && socket.isConnected()
&& !socket.isInputShutdown()) {

char[] lenBuffer = new char[13];
int len = 0;
try  {
len = in.read(lenBuffer);
} catch (Exception e) {
Utils.debug("SocketSvr socket read timeout");
stopSocketByException(true);
}

每次的请求，server端返回的数据都包含在lenBuffer中，一般是约定好的json或者是其他格式的信息。

整体思路是和TCP是一样的，更多的问题出现在细节处理上和socket的生命周期的维护上。

比如如果断网或者出现异常导致socket出现exception，这时可能需要把当前的socket关闭(timeoutException应该不需要重启)，然后重新启动新的socket，

但是对于终端用户来说，应当避免的是让用户感觉到有界面的异动，需要立即重新连接server。

以上是一个简单的socket客户端的模型。供参考。