快捷導(dǎo)航

Python socket如何實現(xiàn)服務(wù)端和客戶端數(shù)據(jù)傳輸(TCP)

更新時間：2022年05月17日 17:05:43 作者：時光不寫代碼

這篇文章主要介紹了Python socket如何實現(xiàn)服務(wù)端和客戶端數(shù)據(jù)傳輸(TCP)，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

socket服務(wù)端和客戶端數(shù)據(jù)傳輸(TCP)

服務(wù)器端：

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

客戶端：

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

流程圖

在這里插入圖片描述

socket服務(wù)端,客戶端互相通信

利用socket傳遞參數(shù)，把運行的程序與客戶端結(jié)合，先啟動服務(wù)端，再啟動客戶端。基礎(chǔ)代碼如下：

服務(wù)端代碼

import socket
import time
print("服務(wù)端開啟")
#創(chuàng)建套接字
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#設(shè)置IP和端口
#host = socket.gethostname()
host = '127.0.1.1'
port = 3333
#bind綁定該端口
mySocket.bind((host, port))
#監(jiān)聽
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:
        #發(fā)送消息
        msg = input("服務(wù)端發(fā)送:")
        client.send(msg.encode(encoding='utf-8'))
        print("發(fā)送完成")
        print (time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time())))#格式化時間戳為標(biāo)準(zhǔn)格式
        if msg == "EOF":
            break
        if msg == "quit":
            client.close()
            mySocket.close()
            print("程序結(jié)束\n")
            exit()
        
        #讀取消息
        msg = client.recv(1024)
        print("服務(wù)端接收:",msg.decode("utf-8"))#把接收到的數(shù)據(jù)進(jìn)行解碼
        print("讀取完成")
        if msg == b"EOF":
            break
        if msg == b"quit":
            client.close()
            mySocket.close()
            print("程序結(jié)束\n")
            exit()

客戶端代碼：

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

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: