#!/usr/bin/env python#encoding: utf-8import socketdef handle_request(client): buf = client.recv(1024) client.send("HTTP/1.1 200 OK\r\n\r\n") client.send("Hello, World")
def main(): sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) #创建sock对象sock.bind((‘localhost‘,8080)) #监听端口sock.listen(5) #开始监听
while True: connection, address = sock.accept() handle_request(connection) connection.close()
if __name__ == ‘__main__‘: main()
socket服务端和客户端
##############socket server####################import socketobj_server = socket.socket() #创建socket对象obj_server.bind((‘localhost‘,8080)) #监听端口obj_server.listen(5) #开始监听while True: print ‘waiting .......‘conn,addr = obj_server.accept() client_data = conn.recv(1024) #接收client端数据，最多接收sizeprint client_data conn.send(‘this is server‘) #发送数据给clientconn.close() #端口连接
##############socket client#####################import socketobj_client = socket.socket()obj_client.connect((‘localhost‘,8080)) #要连接的地址和端口obj_client.send(‘我是客户‘) #发送数据给server端server_data = obj_client.recv(1024) #接收server端数据print server_data #输出server发来的数据obj_client.close()
socket常用方法
sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM,0) 创建socket对象
obj_server = socket.socket()
sk.bind(address) 监听地址和端口
s.bind(address) 将套接字绑定到地址。address地址的格式取决于地址族。在AF_INET下，以元组（host,port）的形式表示地址。
obj_server.bind((‘localhost‘,8080))sk.listen(backlog) 开始监听
obj_server.listen(5)开始监听传入连接。backlog指定在拒绝连接之前，可以挂起的最大连接数量。
backlog等于5，表示内核已经接到了连接请求，但服务器还没有调用accept进行处理的连接个数最大为5
这个值不能无限大，因为要在内核中维护连接队列sk.setblocking(bool)
是否阻塞（默认True），如果设置False，那么accept和recv时一旦无数据，则报错。
sk.accept()
conn,addr = obj_server.accept()接受连接并返回（conn,address）,其中conn是新的套接字对象，可以用来接收和发送数据。address是连接客户端的地址。
接收TCP 客户的连接（阻塞式）等待连接的到来
sk.connect(address)
连接到address处的套接字。一般，address的格式为元组（hostname,port）,如果连接出错，返回socket.error错误。
sk.connect_ex(address)
同上，只不过会有返回值，连接成功时返回 0 ，连接失败时候返回编码，例如：10061
sk.close()
关闭套接字
sk.recv(bufsize[,flag]) 最多接收的size
client_data = conn.recv(1024)接受套接字的数据。数据以字符串形式返回，bufsize指定最多可以接收的数量。flag提供有关消息的其他信息，通常可以忽略。
sk.recvfrom(bufsize[.flag])
与recv()类似，但返回值是（data,address）。其中data是包含接收数据的字符串，address是发送数据的套接字地址。
sk.send(string[,flag]) 发送数据给客户端
conn.send(‘this is server‘)将string中的数据发送到连接的套接字。返回值是要发送的字节数量，该数量可能小于string的字节大小。
sk.sendall(string[,flag])
将string中的数据发送到连接的套接字，但在返回之前会尝试发送所有数据。成功返回None，失败则抛出异常。
sk.sendto(string[,flag],address)
将数据发送到套接字，address是形式为（ipaddr，port）的元组，指定远程地址。返回值是发送的字节数。该函数主要用于UDP协议。
sk.settimeout(timeout)
设置套接字操作的超时期，timeout是一个浮点数，单位是秒。值为None表示没有超时期。一般，超时期应该在刚创建套接字时设置，因为它们可能用于连接的操作（如 client 连接最多等待5s ）
sk.getpeername() clinet端用于返回server端的ip和端口
返回连接套接字的远程地址。返回值通常是元组（ipaddr,port）。
sk.getsockname() server端用于返回自己的ip和端口
返回套接字自己的地址。通常是一个元组(ipaddr,port)
sk.fileno()
套接字的文件描述符
socket实现单线程聊天机器人
#单线程聊天机器人##############server端####################
import socket
ip_port = (‘127.0.0.1‘,8888)
sk = socket.socket()
sk.bind(ip_port)
sk.listen(5)
while True:
conn,address = sk.accept()
conn.sendall(‘欢迎致电 10086，请输入1xxx,0转人工服务.‘)
Flag = True
while Flag:
#阻塞，等待客户端发送数据
data = conn.recv(1024)
print data
if data == ‘exit‘:
Flag = False
elif data == ‘0‘:
conn.sendall(‘通话可能会被录音.balabala一大推‘)
else:
conn.sendall(‘请重新输入.‘)
conn.close()
#单线程聊天机器人##############client端####################
import socket
ip_port = (‘127.0.0.1‘,8888)
sk = socket.socket()
sk.connect(ip_port)
sk.settimeout(5)
while True:
data = sk.recv(1024)
print ‘receive:‘,data
inp = raw_input(‘please input:‘)
#客户端输入数据，发送给客户端
sk.sendall(inp)
if inp == ‘exit‘:
break
sk.close()
单线程，只能同时接收1个client连接，第1个clinet退出后，第2个clinet才能连接上
SocketServer使用多线程实现Socket服务端
#多线程server
import SocketServer
class MyServer(SocketServer.BaseRequestHandler):
def handle(self): #必须是handle函数
# print self.request,self.client_address,self.server
conn = self.request
client_ip = self.client_address
print client_ip #客户端连接后，返回客户端的IP和端口
conn.sendall(‘欢迎致电 10086，请输入1xxx,0转人工服务.‘)
Flag = True
while Flag:
data = conn.recv(1024)
if data == ‘exit‘:
Flag = False
elif data == ‘0‘:
conn.sendall(‘通话可能会被录音.balabala一大推‘)
else:
conn.sendall(‘请重新输入.‘)
if __name__ == ‘__main__‘:
server = SocketServer.ThreadingTCPServer((‘127.0.0.1‘,8888),MyServer)
server.serve_forever()
现在可以多线程同时连入多个clinet
SocketServer使用多线程远程执行命令，并接收结果
#远程执行命令，并输出结果##############server端####################
import SocketServer
import os
class MyServer(SocketServer.BaseRequestHandler):
def handle(self):
print ‘client ip address:‘,self.client_address #连过来的client的IP和port
while True:
data = self.request.recv(1024) #接收用户发送的消息
print ‘client 执行cmd命令：%s‘%data #打印客户端执行的命令
cmd_res = os.popen(data).read() #执行命令，并打印结果
print ‘cmd命令执行结果大小为：‘,len(cmd_res) #输出命令的结果有多大
self.request.send(str(len(cmd_res))) #把命令size发送给client
#self.request.recv(1024) #隔开上下2条发送的数据，不然容易出bug
self.request.sendall(cmd_res) #把命令结果全部发送给client
if __name__ == ‘__main__‘:
server = SocketServer.ThreadingTCPServer((‘127.0.0.1‘,8888),MyServer)
server.serve_forever()
#远程执行命令，并输出结果##############client端####################
import socket
ip_port = (‘127.0.0.1‘,8888)
sk = socket.socket()
sk.connect(ip_port)
sk.settimeout(5)
while True:
inp = raw_input(‘请输入你要执行的命令(cmd):‘) #客户端输入数据，发送给客户端
sk.sendall(inp) #把要执行的命令传送给server端
res_size = sk.recv(1024) #接收server端告知的总size
print ‘命令结果大小为：‘,res_size
total_size = int(res_size) #server端告知的总size
received_size = 0 #接收总size
while True: #正式开始接收命令结果，每次接收1024，直到接收完毕
print ‘开始接收命令结果.....................................‘
data = sk.recv(1024) #接收server发送的结果，每次接收1024
received_size += len(data) #每接收一次，把本次接收的size累加
print ‘本次接收size为‘,len(data)
if total_size == received_size:
#接收总size=服务端告知总size,则表示本次接收为最后一次
print data #接收最后一次数据
break #最后一次接收，所以要break跳出循环
print data #接收数据
if inp == ‘exit‘:
break
sk.close()