python 实现 TCPServer

[sbmzhcn]

用Python写了一个简单的TCPServer，放到一台Linux服务器上，目前可以从设备通过TCP连接接收十六进制消息.
我的最终目的是使得TCPServer能够接收上万台设备发来的十六进制消息，然后解析并存到数据库里。
当然目前仅仅需要接收几台设备的信息，但现在遇到了一些问题：
（设备都用DTU代替，放在服务器上的脚本用DSC代替）
1、 当多个DTU向DSC建立链接并发送数据包时，需要把当前连接保存起来，并最好有一个序号，保存到dtu_list中。当该连接断开时可以从dtu_list中根据序号删除。
2、 这是一个基本的示例 https://docs.python.org/2/library/socketserver.html#SocketServer.BaseServer.RequestHandlerClass
，但实际情形比这复杂多。 在ThreadedTCPServer中能不能根据当前连接的ID，有选择的发送数据。

大家如果有这方面的编程例子，感谢能提供一个链接或者参考。

[sbmzhcn]

@mengzhuo 再次提问，不好意思。在示例process_message 中的 process_message， 我如果直接把数据写入mysql会不会出现问题，比如性能问题？

[sbmzhcn]

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
print '------------ END MESSAGE ------------'

指以上代码中。

[mengzhuo]

@sbmzhcn 看你用什么Mysql驱动了
如果是gevent patch之后的话 某些Mysql驱动应该会实现移步了

性能问题是很多方面的，你先做一个能跑的版本，再慢慢调优吧

[sbmzhcn]

@mengzhuo 现在已经能跑了，各方面都测试没问题，就差最后的存储数据了。python操作mysql还不清楚哪个好，想用上面有人推荐的txmysql，不知道怎么和你这结合。你有什么推荐的吗？

[sbmzhcn]

@mengzhuo 能帮我回答下上面的问题吗，再次感谢！

[mengzhuo]

@sbmzhcn

我不用Mysql。。。。所以不知道

[sbmzhcn]

@mengzhuo 谢谢了，无论什么数据库都行的，就是存储这块。

[sbmzhcn]

@mengskysama 有这方面的代码没？

[wuyadong]

存手工写异步的tcpserver，好麻烦的说...找到一个非阻塞的TCPServer的DEMO
https://github.com/JobsDong/SimpleServer