python 網路程式設計常用程式碼

高洛峰
發布: 2017-02-27 16:59:22
原創
1262 人瀏覽過

伺服器端程式碼:

# -*- coding: cp936 -*-
import socket 
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)#初始化socket 
sock.bind(("127.0.0.1", 8001))#绑定本机地址,8001端口
sock.listen(5)#等待客户连接 
while True:
  print "waiting client connection..."
  connection,address = sock.accept()#接收客户连接请求
  print "a client have connected..."
  while True:
    try: 
      connection.settimeout(5) #设置超时时间
      buf = connection.recv(1024) #接收数据
      if buf == "1": 
        connection.send("you have send me 1!welcome to server!")
      elif buf=="2":
        connection.send("you have send me 2!I have recv!")
      elif buf=="3":
        connection.send("close the connection!")
        break
      else: 
        connection.send("unknow command!") 
    except socket.timeout: 
      print "time out" 
  connection.close()
  print "a client exit..."
登入後複製

#用戶器端程式碼:

import socket 
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
sock.connect(("127.0.0.1", 8001)) 
import time 
time.sleep(2)
while True:
  data=raw_input("input command:");
  sock.send(data)
  print sock.recv(1024)
  if data=="3":
    break
sock.close()
登入後複製




##

import socket
s=socket.socket()
host = socket.gethostname()
port = 1234
s.connect((host, port))
print s.recv(1024)
登入後複製

python 网络编程常用代码1.先開兩個IDLE,分別開啟伺服器端和客戶器端程式碼。

2.F5執行伺服器端程式碼,會出現waiting client connection...

3.F5執行客戶端程式碼,會出現input command:;

4.這時伺服器和用戶端就連線上了,可以正常的通訊啦,如圖:

5.再次運行伺服器端程式碼時會出現錯誤,這時可以透過任務管理器,將其中的pythonw .exe進程結束,重新打開,編譯就可以啦!

客戶端:

import socket
s = socket.socket()
host = socket.gethostname()
port = 1234
s.bind((host, port))
 
s.listen(5)
while True:
 c, addr = s.accept()
 print 'Got connection from', addr
 c.send('Thank you for connecting')
 c.close()
登入後複製

服務端:

from urllib import urlopen
webpage = urlopen('http://www.python.org')
登入後複製

http程式設計

import re
text = webpage.read()
m = re.search(&#39;<a href="([^"]+)" .*?>about</a>&#39;, text, re.IGNORECASE)
m.group(1)
登入後複製

加上正規表示式


#

from SocketServer import TCPServer, StreamRequestHandler
>>> class Handler(StreamRequestHandler):
	def handle(self):
		addr = self.request.getpeername()
		print &#39;Got connection from&#39;, addr
		self.wfile.write(&#39;Thank you for connecting&#39;)
 
>>> server = TCPServer((&#39;&#39;,1234), Handler)
>>> server.serve_forever()
登入後複製

urllib

urllib2

一個基於SocketServer的小型伺服器範例:

from SocketServer import TCPServer,ForkingMinIn, StreamRequestHandler
class Server(ForkingMinIn, TCPServer):pass
class Handler(StreamRequestHandler):
 def handle(self):
  addr = self.request.getpeername()
  print &#39;Got connection from&#39;,addr
  self.wfile.write(&#39;Thank you for connection&#39;)
server = Server((&#39;&#39;,1234),Handler)
server.serve_forever()
登入後複製

使用SocketServer進行分叉和執行緒處理

分叉Server:

from SocketServer import TCPServer, ThreadingMixIn, StreamRequestHandler
class Server(ThreadingMixIn, TCPServer):pass
class Handler(StreamRequestHandler):
 def handle(self):
  addr = self.request.getpeername()
  print &#39;Got connection from&#39;,addr
  self.wfile.write(&#39;Thank you for connecting&#39;)
server = Server((&#39;&#39;,1234),Handler)
server.serve_forever()
登入後複製

線程Server:

#

import socket, select
s = socket.socket()
host = socket.gethostname()
prot = 1234
s.bind((host,port))
 
s.listen(5)
inputs = [s]
while True:
 rs,ws,es = select.select(inputs,[],[])
 for r in rs:
  if r is s:
  c, addr = s.accept()
  print &#39;Got connection from&#39;,addr
  inputs.append(c)
 else:
  try:
   data = r.recv(1024)
   disconnected = not data
  except socket.error:
   disconnected = True
   
  if disconnected:
   print r.getpeername(), &#39;disconnected&#39;
   inputs.remove(r)
  else:
   print data
登入後複製

帶有select和pool的非同步I/O

select服務:

import socket, select
s = socket.socket()
host = socket.gethostname()
port = 1234
s.bind((host, port))
 
fdmap = {s.fileno():s}
 
s.listen(5)
p = select.poll()
p.register(s)
while True:
 events = p.poll()
 for fd, event in events:
  if fd in fdmap:
   c, addr = s.accept()
   print &#39;Got connection from&#39;, addr
   p.register(c)
   fdmap[c.fileno()]=c
  elif event & select.POLLIN:
   data = fdmap[fd].recv(1024)
   if not data:
    print fdmap[fd].getpeername(),&#39;disconnected&#39;
    p.unregister(fd)
    del fdmap[fd]
  else:
   print data
登入後複製

pool伺服器:

rrreee


# #####更多python 網路程式設計常用程式碼相關文章請關注PHP中文網! ############
相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板