文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

python模块SocketServer

2023-01-31 01:14

关注

参考http://my.oschina.net/u/1433482/blog/190612

参考http://fantefei.blog.51cto.com/2229719/1282377

服务器类型

5种类型:BaseServer,TCPServer,UnixStreamServer,UDPServer,UnixDatagramServer。 注意:BaseServer不直接对外服务。

服务器对象

服务器类支持下面的类变量:

请求队列的大小。如果单个请求需要很长的时间来处理,服务器忙时请求被放置到队列中,最多可以放request_queue_size个。一旦队列已满,来自客户端的请求将得到 “Connection denied”错误。默认值通常为5 ,但可以被子类覆盖。

下面方法可以被子类重载,它们对服务器对象的外部用户没有影响。

请求处理器

处理器接收数据并决定如何操作。它负责在socket层之上实现协议(i.e., HTTP, XML-RPC, or AMQP),读取数据,处理并写反应。可以重载的方法如下:

通常只需要重载handle。self.request的类型和数据报或流的服务不同。对于流服务,self.request是socket 对象;对于数据报服务,self.request是字符串和socket 。可以在子类StreamRequestHandler或DatagramRequestHandler中重载,重写setup()和finish() ,并提供self.rfile和self.wfile属性。 self.rfile和self.wfile可以读取或写入,以获得请求数据或将数据返回到客户端。

例子:

server端代码

[root@python day5]# cat tcpserver.py 
#!/usr/bin/env python
import SocketServer,time
import sys

class Myserver(SocketServer.BaseRequestHandler):
        #定义了一个用户信息字典,key是用户名,value是密码
	userinfo = {'fan':'123','te':'234','fei':'345'}
	def handle(self):
		print 'Now connect from ', self.client_address[0]
		while True:
		        #循环接收客户端发来的数据
			recvdata = self.request.recv(1024)
			if not recvdata:
				continue
			elif recvdata == 'Now client connect to Server':
				self.request.sendall('OK,I am ready')
			#如果数据是以username开头
			elif recvdata.startswith('username'):
			    #以:为分隔符,取出最后一段赋值给self.username
				self.username = recvdata.split(':')[-1]
				#判断self.username是否在字典中
				if Myserver.userinfo.has_key(self.username):
				    #用户名存在发送valid给客户端
					self.request.sendall('valid')
				else:
					self.request.sendall('invalid')
			#如果数据是以userpasswd开头
			elif recvdata.startswith('userpasswd'):
			    #以:为分隔符,取出最后一段赋值给self.userpasswd
				self.userpasswd = recvdata.split(':')[-1]
				print self.userpasswd
				#判断self.userpasswd是否正确
				if Myserver.userinfo[self.username] == self.userpasswd:
					self.request.sendall('valid')
					time.sleep(0.5)
					self.request.sendall('%s broken connect with server ' % time.strftime("5Y-%m-%d %x",time.localtime()))
					break
				else:
					self.request.sendall('invalid')
		print "broken connect with %s" % self.client_address[0]	

if __name__ == '__main__':
	try:
	    #创建一个sockerserver连接
		srv = SocketServer.ThreadingTCPServer(('127.0.0.1',8123),Myserver)
		#在后台一直运行
		srv.serve_forever()
	except	KeyboardInterrupt:
		print "CTRL+C,break"
		sys.exit()

client端代码:

[root@python day5]# cat tcpclient.py 
#!/usr/bin/env python
import socket
import time

ss = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
ss.connect(('127.0.0.1',8123))
ss.sendall('Now client connect to Server')        #发送数据到server端
aa = ss.recv(1024)                                #接收server端发过来的数据
print aa

while True:
	username = raw_input('-->username: ').strip()    #输入用户名
	ss.sendall('username:' + username )    #将用户名以特定格式发送给server端
	re = ss.recv(1024)                     #接收server端反馈回来的数据
	if re == 'valid':                      #判断输入的用户名是否正确
		break
	else:
		print "username Erroe,try again"
		continue

while True:
	userpasswd = raw_input('-->userpasswd: ').strip()
	ss.sendall('userpasswd:' + userpasswd)
	re = ss.recv(1024)
	if re == 'valid':
		print ss.recv(1024)
		break
	else:
		print 'userpasswd Error,try again'
		continue


阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯