标签：
Python 提供了两个基本的 socket 模块。
第一个是 Socket，它提供了标准的 BSD Sockets API。
第二个是 SocketServer， 它提供了服务器中心类，可以简化网络服务器的开发。
网络上的两个程序通过一个双向的通信连接实现数据的交换，这个连接的一端称为一个socket。通常也称作"套接字"用于描述IP地址和端口，是一个通信链的句
下面看一个简单的例子：
import socket sk = socket.socket() sk.bind((‘127.0.0.1‘,8000,)) sk.listen(5) while True: conn,address = sk.accept() conn.sendall(bytes(‘欢迎光临！‘,encoding=‘utf-8‘)) while True: ret = str(conn.recv(1024),encoding=‘utf-8‘) print(ret) if ret ==‘q‘: break conn.sendall(bytes(ret+‘nice‘, encoding=‘utf-8‘)) sk.close()
import socket obj = socket.socket() obj.connect((‘127.0.0.1‘,8000,)) while True: ret_str = str((obj.recv(1024)), encoding=‘utf-8‘) print(ret_str) inp =input(‘请输入要发送的内容:‘) if inp ==‘q‘: obj.sendall(bytes(inp,encoding=‘utf-8‘)) break else: obj.sendall(bytes(inp, encoding=‘utf-8‘)) obj.close()
通过上面的例子有个很明显的问题例如有客户端和服务器已经连接上正在通讯，如果在有客户端要连过来就只能等待，通过socketserver可以实现多个客户端同时进行连接请看例子:
import socketserver class Mysocket(socketserver.BaseRequestHandler): #要必须继承这个类 def handle(self): #调用的时候会先执行 handle方法 conn = self.request #self.request 指代客户端的连接 conn.sendall(bytes(‘欢迎光临！‘, encoding=‘utf-8‘)) while True: ret = str(conn.recv(1024), encoding=‘utf-8‘) print(ret) if ret == ‘q‘: break conn.sendall(bytes(ret + ‘nice‘, encoding=‘utf-8‘)) if __name__==‘__main__‘: obj = socketserver.ThreadingTCPServer((‘127.0.0.1‘,8000),Mysocket) obj.serve_forever()
客户端code没有改变。下面说一下socket的类型参数。
套接字格式：
socket(family,type[,protocal]) 使用给定的地址族、套接字类型、协议编号（默认为0）来创建套接字。
socket函数：
#######服务端socket函数####### sk.bind(address):将套接字绑定到地址, 在AF_INET下,以元组（host,port）的形式表示地址. sk.listen(backlog):开始监听TCP传入连接。backlog指定在拒绝连接之前，操作系统可以挂起的最大连接数量。该值至少为1，大部分应用程序设为5就可以了。 sk.accept():接受TCP连接并返回（conn,address）,其中conn是新的套接字对象，可以用来接收和发送数据。address是连接客户端的地址。 #######客户端socket函数####### sk.connect(address):连接到address处的套接字。一般address的格式为元组（hostname,port），如果连接出错，返回socket.error错误。 sk.connect_ex(adddress) :功能与connect(address)相同，但是成功返回0，失败返回errno的值。 #######公共socket函数####### sk.recv(bufsize[,flag]):接受TCP套接字的数据。数据以字节形式返回，bufsize指定要接收的最大数据量。flag提供有关消息的其他信息，通常可以忽略。 sk.send(string[,flag]):发送TCP数据。将string中的数据发送到连接的套接字。返回值是要发送的字节数量，该数量可能小于string的字节大小。 sk.sendall(string[,flag]):完整发送TCP数据。将string中的数据发送到连接的套接字，但在返回之前会尝试发送所有数据。成功返回None，失败则抛出异常。 sk.recvfrom(bufsize[.flag]):接受UDP套接字的数据。与recv()类似，但返回值是（data,address）。其中data是包含接收数据的字符串，address是发送数据的套接字地址。 sk.sendto(string[,flag],address):发送UDP数据。将数据发送到套接字，address是形式为（ipaddr，port）的元组，指定远程地址。返回值是发送的字节数。 sk.close():关闭套接字。 sk.getpeername():返回连接套接字的远程地址。返回值通常是元组（ipaddr,port）。 sk.getsockname();返回套接字自己的地址。通常是一个元组(ipaddr,port) sk.setsockopt(level,optname,value):设置给定套接字选项的值。 sk.getsockopt(level,optname[.buflen]):返回套接字选项的值。 sk.settimeout(timeout):设置套接字操作的超时期，timeout是一个浮点数，单位是秒。值为None表示没有超时期。一般，超时期应该在刚创建套接字时设置，因为它们可能用于连接的操作（如connect()） sk.gettimeout():返回当前超时期的值，单位是秒，如果没有设置超时期，则返回None。 sk.fileno():返回套接字的文件描述符。 sk.setblocking(flag):如果flag为0，则将套接字设为非阻塞模式，否则将套接字设为阻塞模式（默认值）。非阻塞模式下，如果调用recv()没有发现任何数据，或send()调用无法立即发送数据，那么将引起socket.error异常。 sk.makefile():创建一个与该套接字相关连的文件
通过socketserver和subprocess 实现执行命令命令格式为 cmd|命令。
import socketserver import subprocess class Myserver(socketserver.BaseRequestHandler): def handle(self): while True: conn=self.request conn.sendall(bytes("欢迎登录","utf8")) while True: client_bytes=conn.recv(1024) if not client_bytes:break client_str=str(client_bytes,"utf8") print(client_str) func,command=client_str.split("|",1) result_str=subprocess.getoutput(command) result_bytes = bytes(result_str,encoding=‘utf8‘) info_str="info|%d"%len(result_bytes) conn.sendall(bytes(info_str,"utf8")) conn.sendall(result_bytes) conn.close() if __name__=="__main__": server=socketserver.ThreadingTCPServer(("127.0.0.1",9998),Myserver) server.serve_forever()
import socket ip_port=("127.0.0.1",9998) sk=socket.socket() sk.connect(ip_port) print("客户端启动...") print(str(sk.recv(1024),"utf8")) while True: inp=input("please input:").strip() if inp.startswith("cmd"): sk.sendall(bytes(inp,"utf8")) basic_info_bytes=sk.recv(1024) print(str(basic_info_bytes,"utf8")) result_length=int(str(basic_info_bytes,"utf8").split("|")[1]) print(result_length) has_received=0 content_bytes=bytes() while has_received<result_length: fetch_bytes=sk.recv(1024) has_received+=len(fetch_bytes) content_bytes+=fetch_bytes cmd_result=str(content_bytes,"utf8") print(cmd_result) sk.close()
标签：
原文地址：http://www.cnblogs.com/yyyg/p/5568441.html
