python socket 轻量级服务器
python socket 轻量级服务器
quanwei9958 发表于3年前
python socket 轻量级服务器
  • 发表于 3年前
  • 阅读 247
  • 收藏 11
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

摘要: 使用非阻塞加多线程的方式,轻松实现python网络服务器框架。 工作总结

   由于Python天生的优点,特别适用于快速实现功能。    

#!/usr/bin/python2.7
import sys
import time
import socket
#import modbus
import threading
import select
class thread(threading.Thread):
	def __init__(self,sock):
		threading.Thread.__init__(self)
		#self.commond=modbus.modbus()
		self.sock=sock
	def run(self):
		time1=time.time()-10
		time2=time.time()
		try:
			while True:
				cr,cw,ce=select.select([self.sock],[],[self.sock],1)
				time2=time.time()
				if cr:#//can read
					stream=self.sock.recv(1024)
					if not stream:
						break
					#self.commond.parse(stream)
				if ce:
					break
				if time2-time1>10:#//10s write once
					#self.sock.send(self.commond.get_all_data_by_address(0x01))
					time1=time.time()
		except Exception as error:
			print(error)
		finally:
			self.sock.close()
			print('connect closed')	
		
if __name__=='__main__':
	sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
	sock.bind(('127.0.0.1',8000))
	sock.listen(0)
	thread_list=list()
	try:
		while True:
			s,ip=sock.accept()
			print('new connect :%s:%d'%(ip[0],ip[1]))
			t=thread(s)
			t.start()
			thread_list.append(t)
	finally:
		sock.close()
		for i in thread_list:
			i.sock.close()
		print('\b\blistening exit')


  一个轻量级服务器程序,modbus模块是我进行数据的相关处理的逻辑,注释掉了。



标签: python socket select
共有 人打赏支持
quanwei9958
粉丝 28
博文 75
码字总数 36250
×
quanwei9958
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: