Python socket.error: [Errno 104] Conexiune resetată de către omolog (Programare, Python, Prize)

potockan a intrebat.
a intrebat.

Am un cod în care există 13 clienți care trebuie să se conecteze la server. Apoi serverul face o numărătoare pe baza datelor date de client. După aceea rolurile se întorc – serverul devine client și clienții devin servere pentru a primi datele. chestia este că atunci când încerc să fac prima conexiune, adică atunci când cei 13 clienți încearcă să se conecteze la server, tot primesc această eroare: [Errno 104] Connection reset by peer. Am încercat câteva soluții de rezolvare, de exemplu, am încercat să mă conectez de 5 ori într-un interval de o secundă, dar nimic nu funcționează.

Iată codul meu:

server.py

import socket, pickle, numpy as np
import struct
import math


while 1:
    HOST = ''
    PORT = 50007
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))
    s.listen(13)

adresses = []
ports = []

i = 0
print("receiving...")
while i < 13:
    i += 1    
    #wait to accept a connection - blocking call
    conn, addr = s.accept()
    print ('Connected with ', addr)
    adresses.append(addr[0])
    buf = b''
    while len(buf) < 4:
        buf += conn.recv(4 - len(buf))
    length = struct.unpack('>I', buf)[0]
    data = b''
    l = length

    while l > 0:

        d = conn.recv(l)
        l -= len(d)
        data += d

    if not data: break

    M = np.loads(data)

    if i == 1:
        L = M[0]
    else:
        L += M[0]
    ports.append(M[1])
    conn.close() 
s.close()


L /= 993040

packet = pickle.dumps(L)
length = struct.pack('>I', len(packet))
packet = length + packet

print("sending...")
for kl, addr in enumerate(adresses):
    HOST = addr
    PORT = 50007 + ports[kl]
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((HOST, PORT))
    s.sendall(packet)
    s.close()

client.py

def connection(centers, kl):

    HOST = "192.168.143.XX"
    PORT = 50007
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.settimeout(3600)
    try:
        s.connect((HOST, PORT)) # HERE IS AN ERROR
        s.settimeout(None)
        packet = pickle.dumps([centers, kl]) ## ???
        length = struct.pack('>I', len(packet))
        packet = length + packet
        s.sendall(packet) # OR HERE IS AN ERROR
        s.close()
    except Exception as e:
        print(e)
        print('error ', kl)
        s.close()
        return np.zeros(centers.shape)    


    HOST = ''
    PORT = 50007 + kl
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))

    s.listen(2)

    i = 0
    while i < 1:
        #wait to accept a connection - blocking call
        conn, addr = s.accept()
        i += 1
        print ('Connected with ', addr)
        buf = b''
        while len(buf) < 4:
            buf += conn.recv(4 - len(buf))

        length = struct.unpack('>I', buf)[0]
        data = b''
        l = length
        while l > 0:
            d = conn.recv(l)
            l -= len(d)
            data += d
        if not data: break

        new_centers = np.loads(data)
        conn.close()

    s.close()
    return new_centers

aa = 0
for k in range(99):
    print(k)
    centers = some_function(centers)
    time.sleep(60)
    centers1 = connection(centers, i)
    aa = 0
    while not (centers1.any()) and aa < 5:
        time.sleep(1)
        centers1 = connection(centers, i)
        aa += 1
    centers = centers1

Problema este că toți cei 13 clienți TREBUIE să se conecteze la server, altfel nu va trece la următoarea iterație.Folosesc Python 3.4.Vă rog să mă ajutați.

Actualizare:

Am adăugat fire, dar eroarea rămâne:

[Errno 104] Conexiune resetată de către omolog

server.py

import socket, pickle, numpy as np
import struct
import math
from multiprocessing.pool import ThreadPool

def clientthread(conn, L):
    buf = b''
    while len(buf) < 4:
        buf += conn.recv(4 - len(buf))
    length = struct.unpack('>I', buf)[0]
    data = b''
    l = length
    while l > 0:
        d = conn.recv(l)
        l -= len(d)
        data += d
    M = np.loads(data)


    return(M)


j = 0
while 1:
    HOST = ''
    PORT = 50007
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))
    s.listen(2)
    #print('0')

    adresses = []
    ports = []

    i = 0
    print("receiving...")
    while i < 13:
        i += 1    
        #wait to accept a connection - blocking call
        conn, addr = s.accept()
        print ('Connected with ', addr)
        adresses.append(addr[0])
        pool = ThreadPool(processes=13)
        async_result = pool.apply_async(clientthread, (conn, i,))
        M = async_result.get()  
        conn.close() 

        if i == 1:
            L = M[0]
        else:
            L += M[0]
        ports.append(M[1])
    s.close()


    L /= 993040

    packet = pickle.dumps(L)
    length = struct.pack('>I', len(packet))
    packet = length + packet

    for kl, addr in enumerate(adresses):
        HOST = addr
        PORT = 50007 + ports[kl]
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.connect((HOST, PORT))
        s.sendall(packet)
        s.close()

3 răspunsuri
Mahyar Hosseini

Se pare că clienții au fost conectați la server, dar s-au întâlnit cu ” [Errno 104] Connection reset by peer” atunci când au încercat să trimită date. Pentru prima dată, Python ridică excepția „[Errno 104] Connection reset by peer”, apoi, pentru a doua oară și mai mult, veți obține excepția „[Errno 32] Broken pipe” pe partea clientului.

Acest lucru poate însemna că serverul este activat și ascultă pe port (altfel, ați obține „[Errno 111] Connection refused" exception on the client side„. Acest lucru înseamnă, de asemenea, că serverul s-a prăbușit înainte de a închide conexiunea, deoarece dacă conexiunea ar fi fost închisă pe partea serverului înainte de a trimite date pe partea clientului, clientul ar fi întâmpinat „[Errno 32] Broken pipe„.

„Connection reset by peer” este echivalentul TCP/IP al faptului de a închide din nou telefonul în cârlig. Este mai politicos decât să nu răspunzi, lăsându-l pe unul suspendat. Dar nu este FIN-ACK, așa cum se așteaptă de la un interlocutor TCP/IP cu adevărat politicos. (dintr-un alt răspuns de pe stackoverflow)

Rolf din Saxonia

Va trebui să folosiți threading pe server.
Pentru o explicație simplă, consultați: http://www.binarytides.com/python-socket-server-code-example/
Miezul exemplului simplu dat acolo este:

import socket
import sys
from thread import *

HOST = ''   # Symbolic name meaning all available interfaces
PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print 'Socket created'

#Bind socket to local host and port
try:
    s.bind((HOST, PORT))
except socket.error as msg:
    print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1]
    sys.exit()

print 'Socket bind complete'

#Start listening on socket
s.listen(10)
print 'Socket now listening'

#Function for handling connections. This will be used to create threads
def clientthread(conn):
    #Sending message to connected client
    conn.send('Welcome to the server. Type something and hit enter
') #send only takes string

    #infinite loop so that function do not terminate and thread do not end.
    while True:

        #Receiving from client
        data = conn.recv(1024)
        reply = 'OK...' + data
        if not data: 
            break

        conn.sendall(reply)

    #came out of loop
    conn.close()

#now keep talking with the client
while 1:
    #wait to accept a connection - blocking call
    conn, addr = s.accept()
    print 'Connected with ' + addr[0] + ':' + str(addr[1])

    #start new thread takes 1st argument as a function name to be run, second is the tuple of arguments to the function.
    start_new_thread(clientthread ,(conn,))

s.close()

Comentarii

  • Am încercat asta, dar problema este că mai întâi trebuie să primesc datele de la toți clienții. Apoi trebuie să fac o renumărare (de fapt, să număr media datelor) și să le trimit înapoi. Funcția clientthred nu poate returna nimic. Cum se poate rezolva acest lucru? În Python3 este threading.Thread(target=clientthread, args=(conn,)).start() în loc de start_new_thread(clientthread ,(conn,)) –  > Por potockan.
StingyJack

Am avut exact această eroare când am încercat să mă conectez la o instanță redis la distanță din python, pentru că lăsasem din greșeală Fiddler să ruleze și acesta interfera cu cererile.