我想做什么

我想用不同的 IP 和 PORT 再次使用 sTCP.connect()

我的问题

在 while 的下一个交互中(当我有一个与上一个不同的 IP 和 PORT 时)，我得到一个错误:“这个连接已经在使用中” 我该怎么做才能让它发挥作用？ 套接字在 while 循环之前声明。为了清楚起见，我将只显示 while 循环:

while y != numero_de_lineas:
        print "Interaccion numero", y

        if reintentar == 1:
            print y
            reintentar = 0


        tupla = (str(iplista[y]),int(portlista[y]))
        sUDP.sendto(mensaje1,tupla)
        try:
            if reintentar != 1:  #si estoy reintentando no quiero otro timeout
                sUDP.settimeout(time_out)
                respuesta1 , address1 = sUDP.recvfrom(BUFFER_SIZE)

            #si todo va bien tengo respuesta1
            #print(respuesta1) #recibo ni ok ni no
            if (respuesta1 == "ok") or (reintentar != 1):




                sTCP.connect((iplista[y],int(portlista[y])))  #SE CONECTA N VECES, HAY QUE ACCEPTAR OTRA CONEXION CON .accept()
                contenido_fichero = fichero.read()  #lo que hay dentro de ./fichero.txt
                sTCP.send(contenido_fichero)
                try:

                    sTCP.settimeout(time_out_TCP) #esperamos 10 segundos
                    respuesta2 = sTCP.recv(BUFFER_SIZE)
                    #LIBERAMOS LA CONEXION TCP

                    #print(respuesta2) #recibo transferdone
                    #si recibe respuesta1 y respuesta2 paramos
                    #empezamos con el calculo de la huella con el server aceptado iplista[y],portlista[y]
                    huella_md5 = md5.new() #creamos la huella
                    huella_md5.update(contenido_fichero) #actualicamos su contenido (le podemos meter mas strings despues)
                    huella_md5_calculada = huella_md5.hexdigest() #huella en string



                    sUDP.sendto(huella_md5_calculada,tupla)
                    try:
                        sUDP.settimeout(time_out_TCP) #porque son 10 segundos
                        respuesta3 , address3 = sUDP.recvfrom(BUFFER_SIZE)

                        if respuesta3 == "md5sum ok":
                            print "Copia de fichero en servidor",iplista[y],"correcta"

                        if respuesta3 == "md5sum error":
                            print "Error en la copia del fichero en el servidor",iplista[y],"Se vuelve a intentar" #REINTENTAR
                            reintentar = 1



                    except socket.timeout:
                        print "Error en la copia del fichero en el servidor",iplista[y],". Finalizado el intento"


                except socket.timeout:
                    print "Error en la transferencia con el servidor",str(iplista[y])
            if respuesta1 == "no":
                print "Error. El servidor",iplista[y],"no acepta el fichero"

        except socket.timeout:
            print "Error: no hay respuesta por parte del servidor",  iplista[y] , "en el puerto", portlista[y]
            #if y == (numero_de_lineas-1):  #-1 porque para y el cero cuenta
                #sys.exit()  #si todos fallaron al conectar udp nos salimos

编辑:

这是套接字声明(位于while循环之前)

 try: #tenemos que crear el socket tcp en cada interaccion porque sino ya esta en uso
    sUDP = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)     #UDP
    sTCP = socket.socket(socket.AF_INET,socket.SOCK_STREAM)    #TCP
except socket.error :
    print "Error al crear socket TCP"
    sys.exit()

最佳答案

您不能在同一个 socket 实例上连接两次。您必须每次都创建一个新的 socket 对象，即您需要

sTCP = socket.socket(...)

每次调用 .connect(...) 之前。

不要忘记 .close() 和/或 .shutdown() 旧套接字实例。

关于python - 如何重用 TCP 套接字 python，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47854150/