快捷導(dǎo)航

Python實(shí)現(xiàn)TCP通信的示例代碼

更新時(shí)間：2019年09月09日 09:42:50 作者：蓬蒿人

這篇文章主要介紹了Python實(shí)現(xiàn)TCP通信的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

使用socket實(shí)現(xiàn)tcp通信，需導(dǎo)入socket模塊

1、服務(wù)端

主要步驟：

（1）創(chuàng)建socket：socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)

family：AF_INET , AF_INET6, AF_UNIX, AF_CAN, AF_PACKET, AF_RDS

type：SOCK_STREAM , SOCK_DGRAM, SOCK_RAW,或者其他SOCK_*

proto：一般使用默認(rèn)值0

fileno：一般使用默認(rèn)值

（2）綁定IP和端口號(hào)：socket.bind(address)

address：使用(host,port)元組即可

（3）監(jiān)聽(tīng)：socket.listen([backlog])

backlog：就理解為最大連接數(shù)

（4）接受連接：socket.accept()

返回(conn,address)元組，分別是已連接客戶端的socket對(duì)象和地址

（5）發(fā)送/接受數(shù)據(jù)：socket.recv(bufsize[, flags])/socket.send(bytes[, flags])

bufsize：接收的數(shù)據(jù)最大字節(jié)數(shù)

bytes：需要發(fā)送的數(shù)據(jù)字節(jié)數(shù)

（6）關(guān)閉連接：socket.close()

#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 文件名：tcpserver.py
 
import socket
import time
MaxBytes=1024*1024
 
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.settimeout(60)
host = '127.0.0.1'
#host = socket.gethostname()
port = 11223
server.bind((host, port))    # 綁定端口
 
server.listen(1)           # 監(jiān)聽(tīng)
try:
  client,addr = server.accept()     # 等待客戶端連接
  print(addr," 連接上了")
  while True:
    data = client.recv(MaxBytes)
    if not data:
      print('數(shù)據(jù)為空，我要退出了')
      break
    localTime = time.asctime( time.localtime(time.time()))
    print(localTime,' 接收到數(shù)據(jù)字節(jié)數(shù):',len(data))
    print(data.decode())
    client.send(data)
except BaseException as e:
  print("出現(xiàn)異常：")
  print(repr(e))
finally:
  server.close()          # 關(guān)閉連接
  print("我已經(jīng)退出了，后會(huì)無(wú)期")

這個(gè)實(shí)例沒(méi)有創(chuàng)建其他線程，也只接收一個(gè)客戶端的連接；為了能手動(dòng)結(jié)束或自動(dòng)結(jié)束accept和recv的阻塞，設(shè)置了超時(shí)60秒，并將主體部分放入到try語(yǔ)句中；將socket的關(guān)閉放到finally塊中，可以防止程序異常退出，而導(dǎo)致沒(méi)有調(diào)用close函數(shù)。

2、客戶端

主要步驟：

（1）創(chuàng)建socket：socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)

（2）連接：socket.connect(address)

address：使用(host,port)元組即可

（3）發(fā)送/接受數(shù)據(jù)：socket.recv(bufsize[, flags])/socket.send(bytes[, flags])

（4）關(guān)閉連接：socket.close()

#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 文件名：tcpclient.py
 
import socket
import time
MaxBytes=1024*1024
host ='127.0.0.1'
port = 11223
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.settimeout(30)
client.connect((host,port))
while True:
  inputData=input();     #等待輸入數(shù)據(jù)
  if(inputData=="quit"):
    print("我要退出了，再見(jiàn)")
    break
  sendBytes = client.send(inputData.encode())
  if sendBytes<=0:
    break;
  recvData = client.recv(MaxBytes)
  if not recvData:
    print('接收數(shù)據(jù)為空，我要退出了')
    break
  localTime = time.asctime( time.localtime(time.time()))
  print(localTime, ' 接收到數(shù)據(jù)字節(jié)數(shù):',len(recvData))
  print(recvData.decode())
client.close()
print("我已經(jīng)退出了，后會(huì)無(wú)期")

以上客戶端連接成功后等待用戶輸入，然后將輸入信息發(fā)送到服務(wù)端，服務(wù)端將數(shù)據(jù)原樣返回給客戶端，如果客戶端輸入quit就會(huì)跳出循環(huán)并關(guān)閉socket，這時(shí)服務(wù)端recv會(huì)返回空從而跳出循環(huán)并關(guān)閉socket。希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: