【发布时间】：2019-04-06 16:51:37
【问题描述】：
我想在我的程序的服务器部分有多个连接。当我发送“Cikis()”命令并以与这些客户端的通信结束时，我想在所有客户端都关闭时关闭我的程序。但它仍然停留在“sockt.accept()”中，我的程序没有关闭。
程序：
import socket
import sys
import traceback
from threading import Thread
bağlanan =0
sayac =0
bağlanan_sayaç_liste = [-1]
def main():
while True:
print("""
**********************************
Haberleşme Uygulaması (TCP)
**********************************
Client mi oksa Server mi?:
__________________________
1- Client
2- Server
'q' ile çıkış yapınız.
""")
seçim=input("Seçim Yapınız: ")
if seçim == "1":
client()
break
elif seçim == "2":
baslat_server()
break
elif seçim == "q":
break
else:
print("Doğru Seçim Yapınız.")
return seçim
def baslat_server():
global bağlanan
global sayac
global bağlanan_sayaç_liste
global sockt
global socket
ip = "192.168.100.85"
port = 77
sockt = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sockt.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
print("Server Açıldı")
try:
sockt.bind((ip, port))
except:
print("Bağlantı Hatası: " + str(sys.exc_info()))
sys.exit()
while True:
sockt.listen(5)
print("Dinleniyor")
bağlantı, adres = sockt.accept()
gelen_ip, gelen_port = str(adres[0]), str(adres[1])
print("Bağlanan: {}:{} ".format(gelen_ip,gelen_port))
bağlanan += 1
bağlanan_sayaç_liste.append(bağlanan)
try:
Thread(target=takıl_client, args=(bağlantı, gelen_ip, gelen_port)).start()
except:
print(sockt, "Client (%s, %s) is offline" % adres)
print("Başlatılamadı.")
sockt.close()
traceback.print_exc()
continue
sockt.close()
def takıl_client(bağlantı, gelen_ip, gelen_port, max_buffer_size = 5120):
global bağlanan
global sayac
global bağlanan_sayaç_liste
global sockt
global socket
acikmi = True
while acikmi:
client_giris = beklenen_giris(bağlantı, max_buffer_size)
if "Cikis()" in client_giris:
print("Client çıkmak istiyor.")
bağlanan -= 1
sayac += 1
if bağlanan == 0 and sayac == (int(bağlanan_sayaç_liste[(len(bağlanan_sayaç_liste))-1])):
socket.getdefaulttimeout()
socket.setdefaulttimeout(2)
bağlantı.close()
print("Bağlantı {}:{} Kapatıldı.".format(gelen_ip, gelen_port))
acikmi = False
else:
print("İşlem Sonucu: {}".format(client_giris))
gonderilen = input("Gönderilecek Yazınız: ")
bağlantı.sendall(gonderilen.encode("utf-8"))
return gonderilen
def beklenen_giris(bağlantı, max_buffer_size):
client_giris = bağlantı.recv(max_buffer_size)
client_giris_boyu = sys.getsizeof(client_giris)
if client_giris_boyu > max_buffer_size:
print("Giriş boyutu beklenenden büyük {}".format(client_giris_boyu))
sifrele_giris = client_giris.decode("utf-8").rstrip()
sonuc = islem_giris(sifrele_giris)
return sonuc
def client():
#hedef_adres=str(input("Bağlanılacak ip Giriniz: ")) #ip yi elle değiştirmek için bunu açın aşağıdakini kapatın
#hedef_port=int(input("Bağlanılacak port Giriniz: ")) #portu elle değiştirmek için bunu açın aşağıdakini kapatın
hedef_adres="192.168.100.71"
hedef_port=77
döndürülen=list()
client = socket.socket()
client.connect((hedef_adres, hedef_port))
print ("q ile çıkabilirsiniz")
gönderilen = input("Gönderilecek veri yazın:")
if gönderilen != 'q':
client.send(gönderilen.encode('utf-8'))
cevap = client.recv(1024).decode('utf-8')
print('Gelen Mesaj: ' + cevap)
client.close()
döndürülen.append(gönderilen)
döndürülen.append(cevap)
return döndürülen
def islem_giris(giris_metin):
print("Clientten işlem girişi Bekleniyor")
return "" + str(giris_metin)
if __name__ == "__main__":
main()
程序打开后，按“2”打开服务器通讯。然后我连接客户端并提供通信。然后我通过发送“Cikis()”命令结束客户端。我希望她在 2 秒后在程序中关闭，但它没有。
很抱歉我的程序是土耳其语的。我试图尽可能公开地写作。
提前感谢您的帮助。
【问题讨论】：
-
我其实是想和电脑通信（同时也和其他电脑通信），我会发送和接收数据。然后，当与所有客户端的连接丢失时，程序将结束，我会将我提供的数据保存为 sql lite 数据库。这么多。但更多的通信在客户端关闭程序无法完成这项工作。有人知道谁能帮忙吗？
标签： python-3.x sockets tcp timeout