# -*- coding:utf8 -*-
# 客戶端
import socket
client = socket.socket()    # 聲明socket協議類型，同時生成socket鏈接對象
client.connect(("localhost", 6996))     # 連接伺服器的ip和埠號
client.send("hello你好".encode(encoding="utf8"))   # 在python3中，發送的數據都是二進位數據流，所以需要將字元串轉化為二進位
data = client.recv(1024)    # 接收伺服器端發送過來的數據，大小上線為1024位元組
print(data.decode())
client.close()

# -*- coding:utf8 -*-
# 伺服器端
import socket
server = socket.socket()    # 聲明socket協議類型，同時生成socket鏈接對象
server.bind(("localhost", 6996))    # 綁定需要監聽的 網卡ip 和 埠號
server.listen()     # 監聽
print("我要開始等電話了")
"""
等待電話打進來
conn:就是客戶端連接進來，伺服器端為其生成的一個鏈接實例
addr:客戶端ip
"""
conn, addr = server.accept()
print(conn, addr)
print("電話來了")
data = conn.recv(1024)  # 1024為接收客戶端發送過來數據的上限為1024位元組
print("reve", data.decode())
conn.send(data.upper())  # 發送數據給客戶端
server.close()  # 關閉伺服器端

import os
import socket
server = socket.socket()
server.bind(("localhost", 6996))
server.listen(5)  # 設置客戶端連接上限
while True:
    print("等待連接")
    conn, addr = server.accept()
    while True:
        data_1 = conn.recv(1024)
        if not data_1:
            print("客戶端斷開了...", conn.getpeername())
            break  # 這裡斷開就會再次回到第一次外層的loop
        data_2 = os.popen(data_1.decode()).read()
        conn.send(str((len(data_2.encode()))).encode()) # 提醒客戶端將會發送數據的長度
        conn.send(data_2.encode())
        print("已將消息發送給：", conn.getpeername())
server.close()

import socket
client = socket.socket()
client.connect(("localhost", 6996))
while True:
    str_input = input("請輸入命令").strip()
    if len(str_input) == 0: continue
    client.send(str_input.encode())
    data_len = client.recv(1024)
    pd_len = 0
    data_1 = b""
    while pd_len < int(data_len):
        data = client.recv(1024)
        data_1 += data
        pd_len += len(data)
    print(pd_len, data_len)
    print(data_1.decode())

client.close()

# -*- coding:UTF-8 -*-
import socketserver
# 創建請求類
class MySocketServer(socketserver.BaseRequestHandler):
    # 與客戶端所有的交互都重寫在這個方法中
    def handle(self) :
        while True:
            try:
                # 在Python3中客戶端斷開鏈接，伺服器端會拋出異常
                self.data = self.request.recv(1024).strip()
                print("客戶端地址為：{}".format(self.client_address[0]))
                print(self.data.decode())
                self.request.send(self.data.upper())
            except ConnectionResetError as reason:
                print(reason)
                break

if __name__ == "__main__":
    HOST, PORK = "localhost", 999
    # 這句程式碼可以實現伺服器與客戶端的一對一，但是不能一對多
    #server = socketserver.TCPServer((HOST, PORK), MySocketServer)
    # 把程式碼改為下面的程式碼，則可以實現，一對多
    server = socketserver.ThreadingTCPServer((HOST, PORK), MySocketServer)
    server.serve_forever()
    server.server_close()

# # -*- coding:utf8 -*-
# 客戶端
import socket
client = socket.socket()    # 聲明socket協議類型，同時生成socket鏈接對象
client.connect(("localhost", 999))     # 連接伺服器的ip和埠號
while True:
    a = input("請輸入")
    client.send(a.encode(encoding="utf8"))   # 在python3中，發送的數據都是二進位數據流，所以需要將字元串轉化為二進位
    data = client.recv(1024)    # 接收伺服器端發送過來的數據，大小上線為1024位元組
    print(data.decode())
client.close()