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+"\":\n\t你好，我是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+"\":\n\t你好，我是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+"\":\n\t你好，我是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()

巴特西

Python进阶篇：Socket多线程

最新文章

热门文章