使用python實現(xiàn)tcp自動重連
操作系統(tǒng): CentOS 6.9_x64
python語言版本: 2.7.13
問題描述
現(xiàn)有一個tcp客戶端程序,需定期從服務(wù)器取數(shù)據(jù),但由于種種原因(網(wǎng)絡(luò)不穩(wěn)定等)需要自動重連。
測試服務(wù)器示例代碼:
https://github.com/mike-zhang/pyExamples/blob/master/socketRelate/tcpServer1_multithread.py
解決方案
'''
tcp client with reconnect
E-Mail : Mike_Zhang@live.com
'''
#! /usr/bin/env python
#-*- coding:utf-8 -*-
import os,sys,time
import socket
def doConnect(host,port):
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try :
sock.connect((host,port))
except :
pass
return sock
def main():
host,port = "127.0.0.1",12345
print host,port
sockLocal = doConnect(host,port)
while True :
try :
msg = str(time.time())
sockLocal.send(msg)
print "send msg ok : ",msg
print "recv data :",sockLocal.recv(1024)
except socket.error :
print "\r\nsocket error,do reconnect "
time.sleep(3)
sockLocal = doConnect(host,port)
except :
print '\r\nother error occur '
time.sleep(3)
time.sleep(1)
if __name__ == "__main__" :
main()
運行效果:
(py27env) [root@local t1]# python tcpClient1_reconnect.py 127.0.0.1 12345 send msg ok : 1498891374.98 recv data : 1498891374.98 send msg ok : 1498891375.98 recv data : 1498891375.98 send msg ok : 1498891376.98 recv data : socket error,do reconnect send msg ok : 1498891381.99 recv data : 1498891381.99 send msg ok : 1498891382.99 recv data : 1498891382.99
討論
這里只是個簡單的示例代碼,實現(xiàn)了python的tcp自動重連。
相關(guān)文章
教你如何使用Python實現(xiàn)二叉樹結(jié)構(gòu)及三種遍歷
什么是二叉樹:每個節(jié)點最多有兩個子樹的樹結(jié)構(gòu),通常子樹被稱作“左子樹”(left subtree)和“右子樹”(right subtree) 二叉樹由兩個對象組成,一個是節(jié)點對象,一個是樹對象,需要的朋友可以參考下2021-06-06
Pandas中常用的七個時間戳處理函數(shù)使用總結(jié)
在零售、經(jīng)濟和金融等行業(yè),數(shù)據(jù)總是由于貨幣和銷售而不斷變化,生成的所有數(shù)據(jù)都高度依賴于時間。如果這些數(shù)據(jù)沒有時間戳或標(biāo)記,實際上很難管理所有收集的數(shù)據(jù)。本文為大家準(zhǔn)備了Pandas中常用的七個時間戳處理函數(shù),需要的可以參考一下2022-04-04
pyx文件 生成pyd 文件用于 cython調(diào)用的實現(xiàn)
這篇文章主要介紹了pyx文件 生成pyd 文件用于 cython調(diào)用的實現(xiàn)方式,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-03-03
python實現(xiàn)ModBusTCP協(xié)議的client功能
Modbus TCP 是一種基于 TCP/IP 協(xié)議棧的 Modbus 通信協(xié)議,它用于在工業(yè)自動化系統(tǒng)中進行設(shè)備之間的通信,只要通過pymodbus或pyModbusTCP任意模塊就可以實現(xiàn),本文采用pymodbus,感興趣的朋友跟隨小編一起看看吧2023-10-10
python+Django實現(xiàn)防止SQL注入的辦法
這篇文章主要介紹了python+Django實現(xiàn)防止SQL注入的辦法,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-10-10

