【移动应用开发技术】Android Socket通信实现简单聊天室

【移动应用开发技术】AndroidSocket通信实现简单聊天室

socket通信是基于底层TCP/IP协议实现的。这种服务端不需要任何的配置文件和tomcat就可以完成服务端的发布，使用纯java代码实现通信。socket是对TCP/IP的封装调用，本身并不是一种协议，我们通过socket来调用协议来跟服务端进行通信和数据的传输。socket就像客户端与服务端之间的一条信息通道，每一个不同的客户端都会建立一个独立的socket，双方都没有关闭连接的话，连接—也就是建立好的这条socket通道将一直保持，服务端要跟那一个客户端通信只需要找到对应的socket对象就可以进行数据传递。第一次握手：客户端发送syn包(syn=j)到服务器，并进入SYN_SEND状态，等待服务器确认;

第二次握手：服务器收到syn包，必须确认客户的SYN(ack=j+1)，同时自己也发送一个SYN包(syn=k)，即SYN+ACK包，此时服务器进入SYN_RECV状态;

第三次握手：客户端收到服务器的SYN+ACK包，向服务器发送确认包ACK(ack=k+1)，此包发送完毕，客户端和服务器进入ESTABLISHED状态，完成三次握手。

一.服务端：在客户端跟服务端通信之前，服务端必须先开启。首先来看一下服务端Socket的编写吧。服务端就是一个简单的java项目，由于聊天室可能会有多个客户端同时连接并发送消息，我们这里使用线程池来处理客户端的请求。首先我们创建了一个大小为5的固定大小线程池，并创建端口号为12345的服务端socket接收客户端请求，通过一个while循环不断轮询来自服务端的连接请求，在while循环里面调用了serverSocket.accept();是线程进入阻塞状态，也就是说在没有接收到客户端的请求时，程序将一直停留在这里，当有客户端连接服务端是，代码开始往下走，我们把接收到的客户端socket放入list里面，这样我们就把所有连接到服务端的socket保存下来了，这样就使得我们可以随时对任一客户端进行数据传递。之后就是线程池调用execute执行一个线程，把连接过来的socket作为参数传进去。接下来分析下service的内容：在service的构造方法中使用了作为参数传进来的socket，在里面我们通过这个socket获取输入流包装成一个BufferedReader，br=newBufferedReader(newInputStreamReader(client.getInputStream()));这里我们是主要是针对聊天，所以使用的是字符流进行数据的传输，这个类里面声明了一个成员变量msg，通过这个变量来给每个客户端发送信息。下面看下sendMsg方法：这里我们通过遍历list里面的每个socket获得它的的输出流并且包装成PrintWriter向客户端发送信息，pw=newPrintWriter(newBufferedWriter(newOutputStreamWriter(client.getOutputStream())));向每一个客户端发送成员变量msg内容，在PrintWriter调用print之后一定要调用flush刷新输出流进行数据的传递，否则客户端无法接收到服务端发送的数据。接下来看这个类的住方法run：与前面类似，也是通过一个while进行无限循环进行读取socket的输入流，如果内容不为空就调用sendmsg对每一个客户端进行信息发送，有个小小的处理就是如果发送过来的信息是bye的时候就断开对应socket的链接，退出聊天室。以上是对服务端的分析，接下来我们来看Android客户端。二.客户端：客户端基本与服务端一样，我们直接上代码吧。首先还是传统的new一个thread来建立与服务端的连接，因为主线程不能访问网络，由于我们客户端肯定是只有当前这一个socket的，所以只有一个线程，不用跟服务端一样使用线程池了。连接一旦建立，获取socket的输入输出流来包装成对应的BufferedReader和PrintWriter：br=newBufferedReader(newInputStreamReader(client.getInputStream()));pw=newPrintWriter(newBufferedWriter(newOutputStreamWriter(client.getOutputStream())));由于这里只会使用一个socket，所以这里的相关变量都可以使用成员变量。然后走下来就是对send按钮的监听，点击发送的话，把内容发送给服务端，服务端接收到之后发送给每一个保持着链接的客户端。这个activity也是实现了runnable接口的，接下来看run方法：这里跟服务端一样，通过一个while无限循环读取来自服务端的信息，一旦读取到信息之后就通过handler从子线程发送消息到主线程，主线程进行数据的更新，其实就是向显示聊天室内容的textview