python socket单线程通信

注意 socket通信默认的情况下是属于阻塞形式通信，在recv与accept函数会进行阻塞

　　1.客户端正常退出的情况下，server端的con的通道会正常的关闭，recv直接赋值为空

　　2.在windows下，使用pycharm的强制终端客户端，会造成，con通道的破坏，造成服务器端的异常（可以通过捕获异常来避免），在linux程序端，不会出现该问题

　　3.在发送数据的时候，send为空的情况下，在recv下，默认就是不处理，还处在阻塞的状态。因此规定不能发送为空

　　4.socket通信的在py3里面，只能发送bytes类型 str-->bytes: bytes(str,"utf-8")

　　　　　　　　　　　　　　　　　　　　　　　bytes-->str:str(bytes"utf-8")

一.基础代码

server端：

import socket

server = socket.socket()

server.bind(("127.0.0.1",6969))

server.listen()

con,addr=server.accept()

while True:

    data=con.recv(1024)

    data_uper=str(data,"utf-8").upper()

    con.send(bytes(data_uper,"utf-8"))

client端

import socket

client = socket.socket()

client.connect(('127.0.0.1',6969))

x=input(">>:")

client.send(bytes("good 你好",encoding="utf-8"))

data=client.recv(1024)

print(str(data,"utf-8"))

二.不间断聊天代码实现：

server

import socket

server = socket.socket()

server.bind(("127.0.0.1",6969))

server.listen()

while True:

    con,addr=server.accept()

    print(addr)

    while True:

        try:

            data=con.recv(1024)#在程序正常退出，也就是con的tcp连接正常中断，data直接为0执行下一步

        except Exception as e:

            break   #防止在windows下，强制关闭，con通道错误而报错，linux下不用这样

        if not data:break

        print(str(data,"utf8"))

        x=input(">：")

        con.send(bytes(x,"utf-8"))

client

import socket

client = socket.socket()

client.connect(('127.0.0.1',6969))

while True:

    x=input(">>:")

    if not x:continue #解决在阻塞模型下，直接回车卡住的bug

    client.send(bytes(x,encoding="utf-8"))

    data=client.recv(1024)

    print(str(data,"utf-8"))

三.实现类似ssh的命令。实现大数据发送的基础以及粘包的问题：

在send的时候，缓存区会不断的发送数据，但是recv接受的数据大小每次都有界限。也就是说每次发送的数据过量，一次recv是接受不完的，因为调用了解决办法：

　　1.在发送端，先发送要发送的数据的大小

　　2.在接受端，通过接受的数据与接受的数据大小进行比较而接入不断的接受

　　　　坑：1.int 与 bytes 不能直接转换。 2.len的大小在str类型与 bytes类型之间的大小是不一致的 3.在两次send直接会出现粘包的问题（通过一次recv最来解决）

　　　　　　　　　　粘包是因为两次send在缓存区，会一次性发送

server端

import os

import socket

server = socket.socket()

server.bind(("127.0.0.1",6969))

server.listen()

while True:

    con,addr=server.accept()

    print(addr)

    while True:

        try:

            data=con.recv(1024)#在程序正常退出，也就是con的tcp连接正常中断，data直接为0执行下一步

        except Exception as e:

            break   #防止在windows下，强制关闭，con通道错误而报错，linux下不用这样

        if not data:break

        cmd_line=str(data,"utf-8")

        cmd_result=os.popen(cmd_line,"r").read()

        if not cmd_result: #当os.popen执行非系统命令时，返回值为空

            cmd_result = "未知命令"

        cmd_result=bytes(cmd_result,"utf-8")

        cmd_result_len=bytes(str(len(cmd_result)),"utf-8")

        #int与bytes之间不能直接转换。

        #len 在str与bytes类型之间的长度是不一致的！！！

        print("发送数据长度",str(cmd_result_len,"utf-8"))

        con.send(cmd_result_len)

        flag=con.recv(1024)  #通过一次recv来解决两个send之间粘包的问题。

        con.send(cmd_result)

clinet端

import socket

client = socket.socket()

client.connect(('127.0.0.1',6969))

while True:

    x=input(">>:")

    if not x:continue

    client.send(bytes(x,encoding="utf-8"))

    recv_len=int(str(client.recv(1024),"utf-8"))

    client.send(bytes("ok","utf-8"))

    print(recv_len)

    data=bytes()

    while len(data) != recv_len:

        data += client.recv(1024)

    print(str(data,"utf-8"))

四、实现文件下载：

　　在python中数据都是bytes类型，打开文件以rb，wb的类型打开。

　　1.在服务方：

　　　　通过os模块，读取文件的大小，使用f.read(size)读取指定数量，通过该大小来循环发送数据

2.在客户端

　　　　先接受数据的大小，通过已经接受的数据与文件大小来判断大小

服务器端

import os

import socket

server = socket.socket()

server.bind(("127.0.0.1",6969))

server.listen()

while True:

    con,addr = server.accept()

    while True:

        cmd=str(con.recv(1024),"utf-8")

        print(cmd)

        cmd = cmd.split()

        if cmd[0] == "push":

            print(cmd[0])

            f = open(cmd[1], "rb")

            file_size = os.stat(cmd[1]).st_size

            print(file_size)

            con.send(bytes(str(file_size), encoding="utf-8"))

            flag=con.recv(1024)

            # for line in f:

            #     con.send(line)

            data_size=0

            while file_size != data_size:

                data=f.read(1024)

                con.send(data)

                data_size += len(data)

            print(data_size)

            print("发送完毕")

            f.close()

客户端

import socket

import os

client = socket.socket()

client.connect(("127.0.0.1",6969))

while True:

    cmd=bytes(input("->:"),"utf8")

    client.send(cmd)

    file_size = int(str(client.recv(1024), "utf-8"))

    client.send("ok".encode("utf-8"))

    data_len = 0

    f = open("1.new.avi","wb")

    while file_size != data_len:

        data = client.recv(1024)

        data_len += len(data)

        f.write(data)

        print(data_len)

    f.close()

　五、多client并发连接 sockserver

创建sockserver四大步骤：

First, you must create a request handler class by subclassing the BaseRequestHandlerclass and overriding its handle() method; this method will process incoming requests. 　　
Second, you must instantiate one of the server classes, passing it the server’s address and the request handler class.
Then call the handle_request() orserve_forever() method of the server object to process one or many requests.
Finally, call server_close() to close the socket.

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):

    """

    The request handler class for our server.

    It is instantiated once per connection to the server, and must

    override the handle() method to implement communication to the

    client.

    """

    def handle(self):

        # self.request is the TCP socket connected to the client

        self.data = self.request.recv(1024).strip()

        print("{} wrote:".format(self.client_address[0]))

        print(self.data)

        # just send back the same data, but upper-cased

        self.request.sendall(self.data.upper())

if __name__ == "__main__":

    HOST, PORT = "localhost", 9999

    # Create the server, binding to localhost on port 9999

    server = socketserver.TCPServer((HOST, PORT), MyTCPHandler)

    # Activate the server; this will keep running until you

    # interrupt the program with Ctrl-C

    server.serve_forever()

这里还不能直接使用：

　　我们调用多线程的类就可以使用了

    server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler)

巴特西

python socket单线程通信

最新文章

热门文章