手机应用/服务器开发的一些总结(二)
上一篇文章聊了下数据存储和常用的传输协议,不过对于自定义传输协议这里留了个坑,正好有点时间,就抓紧填上:)
既然选择原生socket,那么有个基本的选择就是tcp/udp的问题.
这个其实还是看业务自己的选择,只是如果选择了udp的话,那么很多问题都可以不用考虑,比如粘包问题。但是udp有个限制是每次传输的数据大小不能超过64K,这个要注意。
为了考虑复杂的情况,我们还是主要说tcp的实现,这篇文章先说下socket使用相关的一些库和代码吧
Android端开发
对于android端,我们有两个主要选择:阻塞socket和非阻塞socket。
阻塞socket就是正常的socket,当调用recv的时候,会阻塞住直到返回数据。
非阻塞socket在android上可以直接使用nio,因为自己之前一直是做c++和python,所以其实一开始nio的时候真心有些不太使用,把几个要注意的点列一下:
1. 当网络断线的时候,有些手机如S4,会出现这个问题,channel.finishConnect()会一直等超时 60秒。之后会抛出一个 TimeoutException.
解决方法是:
channel.socket().setSoTimeout(5)
来设置成只等5秒。
比较诡异的是,明明是异步io了,为什么还是会有等待超时的情况。还要在研究下。
2. 当网络不在线的时候,启动connect,依然可以进入isConnectable的判断中,并且可以调用finishconnect。
解决方案:finishConnect之后,调用write一个空字符串进去,如果抛出异常就证明没有链接成功
另外,与linux原生的非阻塞socket的recv不同,nio下channel的 read 结果及意义如下
-1: socket被关闭,关闭channel,并取消key
0: 没有数据可读,直接返回即可
大于0: 读取到的数据长度
Server端开发
server端的选择就更加丰富一些了,也是分阻塞和非阻塞socket来说吧
阻塞socket
阻塞socket的最简单即标准库自带的 ThreadingTCPServer,这个会在每个请求来的时候启动一个线程。这种server与预分配进程等方法其实是一个性质,性能是比较大的问题
非阻塞socket
非阻塞socket的选择也有不少,比如python标准库里的asyncore和asynchat,但是这真的是个很老的库了,只支持select和poll,连epoll都支持不了。但是使用是没有任何问题的
而作为asyncore的一个替代,tornado提供了一个更好的选择。当然很多人知道tornado是因为他是一个高性能的http server,但是其实他底层封装的ioloop那套异步io库也是可以单独使用的。
但是基于异步io的server用起来其实是比较痛苦的,因为所有的业务操作都不能阻塞。当然,可以使用类似celery之类的任务分派工具,但是多一层进程通信会导致性能更加下降。
还好python世界还有另一个选择:gevent,基于gevent写的tcp server在兼顾了性能的同时,大部分的阻塞请求代码都可以直接使用。
tornado 和 gevent实现的server我都比较喜欢,所以我之前分别在其基础上封装了 tkola 和 gkola,他们的底层都是依赖 kola的。
之所以要做这样的封装,是因为自己对flask @route 式的写法情有独钟,而这样的封装就是实现了这种风格的编码,当然还有一些更有意思的东西在里面。
gkola的示例代码如下:
from gkola import Kola, logger app = Kola() @app.create_conn def create_conn(conn): logger.error('create_conn') @app.close_conn def close_conn(conn): logger.error('close_conn') @app.before_first_request def before_first_request(request): logger.error('before_first_request') @app.before_request def before_request(request): logger.error('before_request') @app.after_request def after_request(request, exc): logger.error('after_request') @app.before_response def before_response(conn, rsp): logger.error('rsp: %s', rsp) @app.repeat_timer(5) def repeat_timer(): logger.error('repeat_timer') @app.route() def index(request): request.write(dict( ret=0,index=True )) app.run('127.0.0.1', 5500)
建议继续学习:
- 实时监控Android设备网络封包 (阅读:4983)
- 手机应用/服务器开发的一些总结(一) (阅读:3393)
- iOS设备唯一标识获取策略 (阅读:2497)
- Android桌面应用的设计探讨 (阅读:1887)
扫一扫订阅我的微信号:IT技术博客大学习
- 作者:Dante 来源: Vimer
- 标签: APP开发
- 发布时间:2014-11-30 23:16:14
- [68] Go Reflect 性能
- [68] 如何拿下简短的域名
- [67] Oracle MTS模式下 进程地址与会话信
- [62] IOS安全–浅谈关于IOS加固的几种方法
- [61] 图书馆的世界纪录
- [60] 【社会化设计】自我(self)部分――欢迎区
- [58] android 开发入门
- [56] 视觉调整-设计师 vs. 逻辑
- [49] 给自己的字体课(一)——英文字体基础
- [48] 读书笔记-壹百度:百度十年千倍的29条法则