python中socket与socketserver模块简单入门使用

慧9建

　　一、socket模块
　　socket又叫套接字，是网络编程中的一个基本组件，是两个端点的程序之间的“信息通道”程序可分布在不同的计算机上（通过网络连接），通过socket套接字相互发送信息。python中的大多数的网络编程都 隐藏了socket模块的基本细节。
　　python中通过socket模块完成网络编程的套接字实现，一个套接字就是socket模块中的socket类的一个实例。socket实例化需要三个参数分别是family(ipv4,ipv6,unix)其中默认是ipv4 "socket.AF_INET",第二个参数是流，默认是socket.SOC_STREAM表示tcp，或socket.SOCK_DGRAM,第三个参数是协议，默认是0,使用默认即可。因此实际上实例化出一个套接字，只需要二个参数。
　　socket通讯原理：

　　socket函数
　　python 3.x下发送的内容必须是byte类型，2.x是字符串

　　二、socket简单通讯
　　环境说明：ubuntu 16.04    python 3.5.2    模拟的服务器和客户端均在一台机器上（可以在不同机器上，只要保障网络连接）
　　先来看一个简的服务器与客户端的socket通讯
　　功能：服务器侦听等待连接，客户端连接后发送连接信息，之后客户端发送的任何信息，服务器端原样返回客户端。
　　代码如下：
　　1、srv.py
　　

import socket　　
sk = socket.socket()
　　
#print(sk)
　　
HOST = '127.0.0.1'
　　
PORT = 2222
　　
BUFSIZ = 1024
　　
ADDR = (HOST,PORT)
　　

　　
sk.bind(ADDR)
　　
sk.listen(5)
　　
print("waiting...")
　　

　　
while True:
　　conn,addr = sk.accept()
　　ip,port = addr
　　print("Got connection from",addr)
　　conn.send(bytes("connected from %s:%s." %addr,"utf-8"))
　　while True:
　　data = conn.recv(BUFSIZ)
　　if not data:
　　break                                     #直接回车退出本次连接
　　print(data)
　　conn.send(data)
　　

　　
conn.close()
　　

　　cli.py
　　

import socket　　
HOST = '127.0.0.1'
　　
PORT = 2222
　　
BUFSIZ = 1024
　　
ADDR = (HOST,PORT)
　　
sk = socket.socket()
　　
sk.connect(ADDR)
　　
print(sk.recv(BUFSIZ))
　　
while True:
　　inp = input(">>>")
　　if not inp:                                       #忽略空格回车
　　continue
　　sk.send(bytes(inp,"utf-8"))
　　print(sk.recv(BUFSIZ))
　　

　　

　　运行结果：

　　以上是一个最简单的socket网络通讯。以上可以发现双方通讯时一发一收，或一收一发，总是成对出现,但有一个缺点，就是同时只能给一个客户端提供服务（通讯）其他的客户端只能等待。后面通过socketserver来解决一服务器多客户端同时连接的情况。
　　三、socket上传文件
　　在完成基本的通讯后，我们来做一个文件上传的实例。
　　server端
　　

#coding:utf-8　　
import socket
　　
import os
　　
sk = socket.socket()
　　
#print(sk)
　　
HOST = '127.0.0.1'            #指定ip
　　
PORT = 2222                     #侦听端口
　　
BUFSIZ = 1024                  #缓存大小
　　
ADDR = (HOST,PORT)
　　

　　
sk.bind(ADDR)                   #套接字ip端 口进行绑定
　　
sk.listen(5)                           #连接等待数，默认5
　　
print("waiting....")
　　
BASE_DIR = os.path.dirname(os.path.abspath(__file__))
　　

　　
while True:
　　conn, addr = sk.accept()
　　print(addr)
　　while True:
　　data = conn.recv(1024)
　　cmd,filename,filesize = (str(data,"utf-8")).split("|")
　　path = os.path.join(BASE_DIR,'yuan',filename)
　　filesize = int(filesize)
　　

　　f = open(path,"ab")
　　has_receive = 0
　　while has_receive != filesize:
　　data = conn.recv(1024)
　　f.write(data)
　　has_receive+=len(data)
　　f.close()
　　

　　
sk.close()
　　

　　client端
　　

#coding:utf-8　　
import socket
　　
import os
　　

　　
HOST = '127.0.0.1'
　　
PORT = 2222
　　
BUFSIZ = 1024
　　
ADDR = (HOST,PORT)
　　
sk = socket.socket()
　　
sk.connect(ADDR)
　　

　　
BASE_DIR = os.path.dirname(os.path.abspath(__file__))
　　
while True:
　　inp = input(">>>").strip() #post|12.png
　　cmd,path = inp.split("|")
　　path = os.path.join(BASE_DIR,path)  ##完整文件路径xxx/12.png
　　filename = os.path.basename(path)    ##获取文件名
　　file_size = os.stat(path).st_size    #获取文件大小
　　file_info = "post|%s|%s" %(filename,file_size)
　　sk.sendall(bytes(file_info,"utf-8"))
　　f = open(path,'rb')
　　has_sent = 0
　　while  has_sent != file_size:
　　data = f.read(BUFSIZ)
　　sk.sendall(data)
　　has_sent+=len(data)
　　f.close()
　　print("上传成功~")
　　
sk.close()
　　

　　总结：socket通讯的关键是一发一收，无论是服务端先发还是客户端先发，必须是一端发送另一端接收，如果连续发送会出现粘包现象。
　　四、socketserver实例多并发通讯
　　server.py
　　

#coding:utf-8　　
import socketserver    #能实现并发
　　
#并发聊天
　　
class MyServer(socketserver.BaseRequestHandler):
　　print("服务端启动...")
　　def handle(self):
　　while True:
　　conn = self.request
　　print (self.client_address)
　　while True:
　　client_data=conn.recv(1024)
　　print (str(client_data,"utf8"))
　　print ("waiting...")
　　server_response=input(">>>")
　　conn.sendall(bytes(server_response,"utf8"))
　　conn.close()
　　

　　
if __name__ == '__main__':
　　server = socketserver.ThreadingTCPServer(('127.0.0.1',2223),MyServer)
　　server.serve_forever()
　　

　　

　　client.py
　　

#coding:utf-8　　
import socket
　　

　　
ip_port = ('127.0.0.1',2223)
　　
sk = socket.socket()
　　
sk.connect(ip_port)
　　
print ("客户端启动：")
　　
while True:
　　inp = input('>>>')
　　sk.sendall(bytes(inp,"utf-8"))
　　if inp == 'exit':
　　break
　　server_response=sk.recv(1024)
　　print (str(server_response,"utf-8"))
　　
sk.close()
　　

　　执行结果服务器端通过多线程完成并发多客户端“同时”聊天效果。
　　以上为socket socketserver基本应用。如有不当之处欢迎指正。