Python TCPServer编程如何保存数据这块的问题
我在v2ex上提了一个问题:
用Python写了一个简单的TCPServer,放到一台Linux服务器上,目前可以从设备通过TCP连接接收十六进制消息.
我的最终目的是使得TCPServer能够接收上万台设备发来的十六进制消息,然后解析并存到数据库里。
当然目前仅仅需要接收几台设备的信息,但现在遇到了一些问题:
(设备都用DTU代替,放在服务器上的脚本用DSC代替)
1、 当多个DTU向DSC建立链接并发送数据包时,需要把当前连接保存起来,并最好有一个序号,保存到dtu_list中。当该连接断开时可以从dtu_list中根据序号删除。
http://www.v2ex.com/t/154857#reply25
下面也有人回答了,我用这个项目的源码已经实现了部分功能,包括服务器的建立,还能保存数据,但我是直接用pymysql直接在process_message保存的。
https://github.com/34nm/gsmtpd
但是还是有问题需要解决:
1、虽然可以建立服务器,比如使用下面的代码
python
from gevent import monkey monkey.patch_all() from gsmtpd.server import SMTPServer class DebuggingServer(SMTPServer): # Do something with the gathered message def process_message(self, peer, mailfrom, rcpttos, data): inheaders = 1 lines = data.split('\n') print '---------- MESSAGE FOLLOWS ----------' for line in lines: # headers first if inheaders and not line: print 'X-Peer:', peer[0] inheaders = 0 print line # 我在这儿直接保存line到数据库,使用的pymysql print '------------ END MESSAGE ------------' if __name__ == "__main__": server = DebuggingServer() server.serve_forever() # 以下的代码是无法执行的
1、但是server.serve_forever()下的代码是无法执行的,服务器建立了(bind),还是需要一些操作的,比如我需要服务器主动发送一些数据到客户端去操作一些指令,那应该如何组织代码呢?
(可以这样了解在linux下执行server.py
,转入后台运行,然后我还想主动操作server,我再执行server.py option value
时,是另执行一个进程,如何解决呢?)
2、每次客户端发起的连接我都需要保存起来,因为服务器主动发送数据时,一定需要根据客户端的id有选择的回复。这个如何操作?
关于如何保存数据这块,如果有人知道就更好了,但这个问题是其次的,上面的两个问题很重要。我想参考一些代码,看有没有这方面的例子,如果有人能提供更好了,我上网查了不少代码,关于这方面的还是不多。而且大多数就建立一个测试的例子,和我这儿的需求不太一样。
建议去看 shadowsocks 的 python 源码.
不太了解gevent,但是Twisted Socket Server的做法是使用Factory,需要持久化的放在Factory,这样所有的DeviceID, SNR都可以查得到。尤其使用Long pull TCP connections的话,直接发给对方就好了。
不过既然分为Client/Server模式,那么Server就应该听为主,尽量不要自己去Push,让Client来Pull就好了。
不过Twisted比较难调试。Tornado也是如此。如果涉及到SQL DB和NoSQL DB操作,需要仔细编写代码。
不过我现在完成了基本的框架,下一步准备加上CoAP和TLS。其中CoAP也可以解决Push的需求。
玩蛇网文章,转载请注明出处和文章网址:https://www.iplaypy.com/wenda/wd19140.html
相关文章 Recommend
- • 2019年3月最新消息: Python 3.4.10 现已推出
- • [上海]招Python量化系统开发工程师
- • 优集品网络科技有限公司招Python中/高级工程师
- • 爱因互动科技发展有限公司招募Python开发攻城狮
- • mozio招聘Python/Django工程师
- • Kavout金融科技公司招Python研发工程师
- • Python数组逆向输出,编程练习题实例四十
- • Python数组插入排序,编程练习题实例三十九
- • Python矩阵for循环应用,编程练习题实例三十八
- • Python操作Redis数据库方面的问题
- • 请python高手帮我看看这段python代码中函数setter的
- • Python什么方法可以快速将两个队列变成字典
必知PYTHON教程 Must Know PYTHON Tutorials
- • python 解释器
- • python idle
- • python dir函数
- • python 数据类型
- • python type函数
- • python 字符串
- • python 整型数字
- • python 列表
- • python 元组
- • python 字典
- • python 集合
- • python 变量
- • python print
- • python 函数
- • python 类定义
- • python import
- • python help
- • python open
- • python 异常处理
- • python 注释
- • python continue
- • python pass
- • python return
- • python global
- • python assert
- • python if语句
- • python break
- • python for循环
- • python while循环
- • python else/elif
- • lambda匿名函数
必知PYTHON模块 Must Know PYTHON Modules
- • os 模块
- • sys 模块
- • re 正则表达式
- • time 日期时间
- • pickle 持久化
- • random 随机
- • csv 模块
- • logging 日志
- • socket网络通信
- • json模块
- • urlparse 解析URL
- • urllib 模块
- • urllib2 模块
- • robotparser 解析
- • Cookie 模块
- • smtplib 邮件
- • Base64 编码
- • xmlrpclib客户端
- • string 文本
- • Queue 线程安全
- • math数学计算
- • linecache缓存
- • threading多线程
- • sqlite3数据库
- • gzip压缩解压
最新内容 NEWS
- • django app提供pv信息的方法是什么
- • Django项目版本升级如何操作?
- • django较多数据传递如何优雅的呈现
- • django1.7获取参数问题求助
- • Django1.7使用内置comment遇到问题
- • python mysql数据库做insert操作时报_mysql_ex
- • 关于python mysql的duplicate insert机制的疑问
- • pymongo使用insert函数批量插入被中断要怎么
- • Python程序员解决棘手问题的常用库
- • 求助关于restfull api接口几个问题
图文精华 RECOMMEND
-
django1.7获取参数问题求助
-
Python程序员解决棘手问题的常用库
-
求问str()同__str__原理上有什么不同
-
scrapy框架里面用link extractor怎么能
-
python {}.fromkeys创建字典append添加操
-
python3 类型Type str doesn't support th
热点文章 HOT
- 学习Python有什么好的书籍推荐?
- Python匿名函数 Lambda表达式作用
- Python与Java、C、Ruby、PHP等编程语言有什么
- Python 正则中文网页字符串提取问题
- 如何为实时性应用存取经纬度?django my
- 想用python做个客户端,在二维码登录这个地
- 有让IDE可识别Python函数参数类型的方法吗
- Python字符串转换成列表正则疑问