Python socket如何實現服務端和客戶端數據傳輸(TCP)

socket服務端和客戶端數據傳輸(TCP)

服務器端:

import socket
#創建一個socket對象
socket_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = "127.0.0.1"
port = 9999
#綁定地址
socket_server.bind((host, port))
#設置監聽
socket_server.listen(5)
# socket_server.accept()返回一個元組, 元素1為客戶端的socket對象, 元素2為客戶端的地址(ip地址,端口號)
client_socket, address = socket_server.accept()
#while循環是為瞭讓對話持續
while True:
	#接收客戶端的請求
    recvmsg = client_socket.recv(1024)
    #把接收到的數據進行解碼
    strData = recvmsg.decode("utf-8")
    #設置退出條件
    if strData == 'q':
        break
    print("接收: %s" % strData)
    #輸入
    msg = input("發送: ")
    #發送數據,需要進行編碼
    client_socket.send(msg.encode("utf-8"))
#關閉服務器端
socket_server.close()

客戶端:

import socket
#創建一個socket對象
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = "127.0.0.1"
port = 9999
#連接服務端
client.connect((host, port))
while True:
    send_msg = input("發送: ")
    #設置退出條件
    if send_msg == "q":
        break
    send_msg = send_msg
    #發送數據,編碼
    client.send(send_msg.encode("utf-8"))
    #接收服務端返回的數據
    msg = client.recv(1024)
    #解碼
    print("接收:%s", % msg.decode("utf-8"))
#關閉客戶端
client.close()

流程圖

在這裡插入圖片描述

socket服務端,客戶端互相通信

利用socket傳遞參數,把運行的程序與客戶端結合,先啟動服務端,再啟動客戶端。基礎代碼如下:

服務端代碼

import socket
import time
print("服務端開啟")
#創建套接字
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#設置IP和端口
#host = socket.gethostname()
host = '127.0.1.1'
port = 3333
#bind綁定該端口
mySocket.bind((host, port))
#監聽
mySocket.listen(10)
while True:
    #接收客戶端連接
    print("等待連接....")
    client, address = mySocket.accept()
    print("新連接")
    print("IP is %s" % address[0])
    print("port is %d\n" % address[1]) 
    while True:
        #發送消息
        msg = input("服務端發送:")
        client.send(msg.encode(encoding='utf-8'))
        print("發送完成")
        print (time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time())))#格式化時間戳為標準格式
        if msg == "EOF":
            break
        if msg == "quit":
            client.close()
            mySocket.close()
            print("程序結束\n")
            exit()
        
        #讀取消息
        msg = client.recv(1024)
        print("服務端接收:",msg.decode("utf-8"))#把接收到的數據進行解碼
        print("讀取完成")
        if msg == b"EOF":
            break
        if msg == b"quit":
            client.close()
            mySocket.close()
            print("程序結束\n")
            exit()

客戶端代碼:

import socket
print("客戶端開啟")
#創建套接字
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#設置ip和端口
#host = socket.gethostname()
host = '127.0.1.1'
port = 3333
 
try:
    mySocket.connect((host, port)) ##連接到服務器
    print("連接到服務器")
except :                           ##連接不成功,運行最初的ip
    print ('連接不成功')
 
while 1:
    #接收消息
    msg = mySocket.recv(1024)  
    print("客戶端接收:%s" % msg.decode("utf-8"))#把接收到的數據進行解碼
    print("讀取完成")	
    if msg == b"EOF":
        break
    if msg == b"quit":
        mySocket.close()
        print("程序結束\n")
        exit()
    
    #發送消息
    msg = input("客戶端發送:")
    mySocket.send(msg.encode(encoding='utf-8'))
    print("發送完成")
    if msg == "EOF":
        break
    if msg == "quit":
        mySocket.close()
        print("程序結束\n")
        exit()       
print("程序結束\n")

以上為個人經驗,希望能給大傢一個參考,也希望大傢多多支持WalkonNet。

推薦閱讀: