socket服务端和客户端

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了socket服务端和客户端相关的知识,希望对你有一定的参考价值。

#!/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()

  

 
 
 
 

 

以上是关于socket服务端和客户端的主要内容,如果未能解决你的问题,请参考以下文章

Socket(套接字)在服务器端和客户端之间的基本工作原理

51. Socket服务端和客户端使用TCP协议通讯 | 厚土Go学习笔记

socket创建服务端和客户端

Android Socket通讯 分离服务端和客户端发送表情消息

Android Socket通讯 分离服务端和客户端发送表情消息

Android Socket通讯 分离服务端和客户端发送表情消息