from socket import *
# 1.創(chuàng)建套接字
tcp_socket = socket(AF_INET,SOCK_STREAM)
# 2.準備連接服務(wù)器，建立連接
serve_ip = "服務(wù)器端（主機B）的IP"
serve_port = 8000  #端口，比如8000
tcp_socket.connect((serve_ip,serve_port))  # 連接服務(wù)器，建立連接,參數(shù)是元組形式

#準備需要傳送的數(shù)據(jù)
send_data = "今天是2021年08月29日，辰哥給服務(wù)器端發(fā)送數(shù)據(jù)了"
tcp_socket.send(send_data.encode("gbk"))
#從服務(wù)器接收數(shù)據(jù)
#注意這個1024byte，大小根據(jù)需求自己設(shè)置
from_server_msg = tcp_socket.recv(1024)
#加上.decode("gbk")可以解決亂碼
print(from_server_msg.decode("gbk"))
#關(guān)閉連接
tcp_socket.close()

from socket import  *
#創(chuàng)建套接字
tcp_server = socket(AF_INET,SOCK_STREAM)
#綁定ip，port
#這里ip默認本機
address = ('',8000)
tcp_server.bind(address)
# 啟動被動連接
#多少個客戶端可以連接
tcp_server.listen(128)
#使用socket創(chuàng)建的套接字默認的屬性是主動的
#使用listen將其變?yōu)楸粍拥?，這樣就可以接收別人的鏈接了

# 創(chuàng)建接收
# 如果有新的客戶端來鏈接服務(wù)器，那么就產(chǎn)生一個新的套接字專門為這個客戶端服務(wù)
client_socket, clientAddr = tcp_server.accept()

client_socket用來為這個客戶端服務(wù)，相當于的tcp_server套接字的代理
tcp_server_socket就可以省下來專門等待其他新客戶端的鏈接
這里clientAddr存放的就是連接服務(wù)器的客戶端地址
#接收對方發(fā)送過來的數(shù)據(jù)
from_client_msg = client_socket.recv(1024)#接收1024給字節(jié),這里recv接收的不再是元組，區(qū)別UDP
print("接收的數(shù)據(jù)：",from_client_msg.encode("gbk"))
#發(fā)送數(shù)據(jù)給客戶端
send_data = client_socket.send("客戶端你好，服務(wù)器端收到，公眾號【Python研究者】".encode("gbk"))
#關(guān)閉套接字
#關(guān)閉為這個客戶端服務(wù)的套接字，就意味著為不能再為這個客戶端服務(wù)了
#如果還需要服務(wù)，只能再次重新連
client_socket.close()

while(1):
    send_data = input("請輸入內(nèi)容：")
    #send_data = "今天是2021年08月29日，辰哥給服務(wù)器端發(fā)送數(shù)據(jù)了"
    tcp_socket.send(send_data.encode("gbk"))
    if send_data == "exit":
         break;
    #從服務(wù)器接收數(shù)據(jù)
    #注意這個1024byte，大小根據(jù)需求自己設(shè)置
    from_server_msg = tcp_socket.recv(1024)
    #加上.decode("gbk")可以解決亂碼
    print(from_server_msg.decode("gbk"))
#關(guān)閉連接
tcp_socket.close()

while(1):
    #接收對方發(fā)送過來的數(shù)據(jù)
    from_client_msg = client_socket.recv(1024)#接收1024給字節(jié),這里recv接收的不再是元組，區(qū)別UDP
    if(from_client_msg=="exit"):
        break
    print("接收的數(shù)據(jù)：",from_client_msg.decode("gbk"))
    now_time = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
    #發(fā)送數(shù)據(jù)給客戶端
    send_data = client_socket.send((str(now_time)+" 服務(wù)端：客戶端你好，服務(wù)器端收到，公眾號【Python研究者】").encode("gbk"))
    #關(guān)閉套接字
    #關(guān)閉為這個客戶端服務(wù)的套接字，就意味著為不能再為這個客戶端服務(wù)了
    #如果還需要服務(wù)，只能再次重新連
client_socket.close()