socket服务端和客户端

Posted 2020-06-10

#!/usr/bin/env python
#encoding: utf-8
import socket
def 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 socket
obj_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端数据，最多接收size
print client_data
    conn.send(‘this is server‘)    #发送数据给client
conn.close()                  #端口连接

##############socket client#####################
import socket
obj_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()