Python进阶篇：Socket多线程

1. 初识Socket

server和clinet之间的交互方式

2. 客户端和服务端的单次交互

====================================
服务端

import socket


host = '127.0.0.1'
port = 8090
sk=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sk.bind((host,port))
sk.listen(1)

conn,addr = sk.accept()
accept_data = conn.recv(1024).decode('UTF-8', 'ignore')
print(accept_data)
feedback_data =("回复""+accept_data+"":
	你好，我是Server端").encode("utf8")
conn.send(feedback_data)

======================================
客户端

import socket


host = '127.0.0.1'
port = 8090

sk=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sk.connect((host,port))

sk.sendall(("你好，我是Client @Simple").encode("utf8"))
data = sk.recv(1024)
print(data.decode('UTF-8', 'ignore'))

3. 客户端和服务端单线程交互

服务端

import socket


host = '127.0.0.1'
port = 8090
sk=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sk.bind((host,port))
sk.listen(1)

while True:
    conn,addr = sk.accept()
    while True:
        accept_data = conn.recv(1024).decode('UTF-8', 'ignore')
        if not accept_data:
            break
        print(accept_data)
        feedback_data =("回复""+accept_data+"":
	你好，我是Server端").encode("utf8")
        conn.sendall(feedback_data)

    conn.close()

客户端

import socket,time


host = '127.0.0.1'
port = 8090

sk=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sk.connect((host,port))

for i in range(10):
    sk.sendall(("你好，我是Client No.%d" %i).encode("utf8"))
    data = sk.recv(1024)
    print(data.decode('UTF-8', 'ignore'))
    time.sleep(2)
    i = i + 1
sk.close()

4. 多个客户端和服务端的多线程交互

服务端

import socketserver

class myTCPhandler(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            self.data = self.request.recv(1024).decode('UTF-8', 'ignore').strip()
            if not self.data : break
            print(self.data)
            self.feedback_data =("回复""+self.data+"":
	你好，我是Server端").encode("utf8")
            self.request.sendall(self.feedback_data)

host = '127.0.0.1'
port = 9090
server = socketserver.ThreadingTCPServer((host,port),myTCPhandler)
server.serve_forever()

客户端1-n

import socket,time


host = '127.0.0.1'
port = 9090

sk=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sk.connect((host,port))

for i in range(10):
    sk.sendall(("你好，我是Client No.%d" %i).encode("utf8"))
    data = sk.recv(1024)
    print(data.decode('UTF-8', 'ignore'))
    time.sleep(2)
    i = i + 1
sk.close()