Java Socket的封装

晨曦之光 发布于 2012/03/09 12:11
阅读 3K+
收藏 1

 摘要: Socket通信几乎无时不在, 当然能够搜集到的信息也大量存在, 为了避免重复的劳作, 抽取了关于客户端和服务端的Socket, 并将其应用到适合JVM(LInux/Windows)或者DVM(Android)平台.  这个封装好的API具有以下优势:

1. 满足具有Socket客户端需求的基本应用.

2. 满足具有Socket服务端的基本应用. 具备并发能力, 能满足可设定个数客户端连接.

 

本文的目的就是为了对Socket做一个封装, 方便客户端和服务端能直接使用Socket.

封装好的API可以从下面的链接获取

 

Java Socket的封装

 

其中src/中的是API源码; usage/目录是使用例程

1客户端Socket API

要点:

1.       客户端和指定的服务端相连, 因此客户端需要指明服务端对应的IP地址和端口号

2.       需要设置超时返回

3.       需要设置循环等待, 因为基本的Socket通信都是一来一回, 这种来回是通过阻塞来完成的。

4.       每个客户端连入服务端的时候, 都具备本身的ID, 类似于HTTP的Session, 这点容易被忽视。在多客户端连接中, 可以重点关注。本文提供的代码也有所提及, 但没有深入, 这点留给读者进一步发掘。

 

代码参照/usage目录下的客户端测试代码, 注意, 先启动服务端,或者你拿着NetAssis 来测试也不错.

  

2 服务端Socket API

要点:

1.       服务端一般是被多个客户端连接的, 并且这些连接要求服务端做相似的处理, 因此这里就将这些相似处理, 抽象成一个SingleTask.java 接口, 具体的业务只需要实现这样的接口, 就可以并行的处理这些Task.

2.       不能无限制的让客户端连入Server,  因此需要设置上限值

3.       启动线程池, 每个线程针对一个具体的客户端连接

4.       注意接收阻塞位置, 需要设置死循环, 读不到数据将死守着等待(但别耽误其它线程处理事情)

5.       注意服务端要在死循环中侦听, 这样保证不错过任何来自客户端的请求。

代码参照:/usage目录下的Server端测试代码。

 

代码中注释很多,因此这里就不详细述说。


常见问题:

1. 客户端Client的时候, 如果存在网络问题, 为了避免网络问题,造成客户端长时间等待, 此时要设置一个TimeOut  


            clientSocket = new Socket();
            //这个TimeOut是连接等待时间
            clientSocket.connect(tcpAddress, timeOut);

2. 当客户端已经连接, 每次收到一个数据, 客户端将启动处理, 假如服务器长久不发数据, 此时客户端会阻塞等待, 为了避免这个时候的等待, 可以设置一个超时


   clientSocket.setSoTimeout(timeOut);



参考文献:

 

参考工具: NetAssis 使用这个工具用来测试C-S之间的通信.

  


原文链接:http://blog.csdn.net/ostrichmyself/article/details/6618349
加载中
返回顶部
顶部