Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1405763
  • 博文数量: 247
  • 博客积分: 10147
  • 博客等级: 上将
  • 技术积分: 2776
  • 用 户 组: 普通用户
  • 注册时间: 2008-01-24 15:18
文章分类

全部博文(247)

文章存档

2013年(11)

2012年(3)

2011年(20)

2010年(35)

2009年(91)

2008年(87)

我的朋友

分类: Python/Ruby

2009-12-21 19:50:56

用Python实现socket是一件十分的简单,比PHP容易简单多了。下面我们利用SocketServer
模块来实现网络客户端与服务器并发连接非阻塞socket。

首先,先了解下SocketServer模块中可供使用的类:
BaseServer:包含服务器的核心功能与混合(mix-in)类挂钩;这个类只用于派生,所以不会生成这个类的实例;可以考虑使用TCPServer和UDPServer。
TCPServer/UDPServer:基本的网络同步TCP/UDP服务器。
UnixStreamServer/ UnixDatagramServer:基本的基于文件同步TCP/UDP服务器。
ForkingMixIn/ ThreadingMixIn:实现了核心的进程化或线程化的功能;作为混合类,与服务器类一并使用以提供一些异步特性;这个类不会直接实例化。
ForkingTCPServer/ ForkingUDPServer:ForkingMixIn和TCPServer/UDPServer的组合。
BaseRequestHandler:包含处理服务请求的核心功能。这个类只用于派生,所以不会生成这个类的实例可以考虑使用StreamRequestHandler或DatagramRequestHandler。
StreamRequestHandler/ DatagramRequestHandler:用于TCP/UDP服务器的服务处理工具。

下面我们正式进入主题,这里我们采用StreamRequestHandler和ThreadingTCPServer来实现客户端与服务器并发连接非阻塞socket。
ThreadingTCPServer派生自ThreadingMixIn,主要实现核心的进程化合线程化功能。
StreamRequestHandler主要用于用于TCP/UDP服务器的服务处理工具。

一、创建SocketServerTCP服务器:

  1. import SocketServer
  2. from SocketServer import StreamRequestHandler as SRH
  3. from time import ctime
  4. host = ''
  5. port = 3130
  6. addr = (host,port)
  7. class Servers(SRH):
  8. def handle(self):
  9. print 'got connection from ',self.client_address
  10. self.wfile.write('connection %s:%s at %s succeed!' % (host,port,ctime()))
  11. while True:
  12. data = self.request.recv(1024)
  13. if not data: break
  14. print data
  15. self.request.send(data)
  16. print 'server is running....'
  17. server = SocketServer.ThreadingTCPServer(addr,Servers)
  18. server.serve_forever()

二、创建SocketServerTCP客户端

  1. from socket import *
  2. host = 'localhost'
  3. port = 3130
  4. bufsize = 1024
  5. addr = (host,port)
  6. client = socket(AF_INET,SOCK_STREAM)
  7. client.connect(addr)
  8. while True:
  9. data = raw_input()
  10. if not data or data=='exit':
  11. break
  12. client.send('%s\r\n' % data)
  13. data = client.recv(bufsize)
  14. if not data:
  15. break
  16. print data.strip()
  17. client.close()

三、执行服务器和客户端
服务器端:
D:\pycode\socket>s2.py
server is running….
got connection from (’127.0.0.1′, 2141)

客户端:
D:\pycode\socket>c2.py
hello
connection :3130 at Mon Apr 20 02:44:17 2009 succeed!
who are u?
hello

参考:

阅读(4962) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~