前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >python模块SocketServer

python模块SocketServer

作者头像
py3study
发布2020-01-15 12:32:48
4950
发布2020-01-15 12:32:48
举报
文章被收录于专栏:python3python3

参考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端代码

代码语言:javascript
复制
[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端代码:

代码语言:javascript
复制
[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
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2019-07-09 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 请求处理器
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档