1

プロジェクト用のトレントのようなプログラムを構築しています。いくつかのソースからファイルを取得して、それをマージしたいと考えています。以下のコードは、データ転送用のサーバーとクライアントです (注: メイン プログラムでは、これらのコードはスレッドです)。アドレス、ポート、ディレクトリ、ファイル名、クライアント数などの変数は単なるプレースホルダーです。私が抱えている問題は、半分の時間、クライアントが接続したときに、サーバーが彼を登録しないことです (つまり、送信プロセスを続行するために必要なクライアント情報を提供しません)。これが発生すると、クライアント側は接続されていると主張しますが、この問題がサーバーベースかクライアントベースかはわかりません。誰かが素晴らしい問題を見つけるのを手伝ってくれるなら、私は何日もそれを修正しようとしてきました. 別の副次的な問題は、クライアントがデータを送信するときに、1 つのクライアントで通常の基本的な送信ループを使用する場合よりも大幅に低速で送信します。選択が速度のボトルネックになっていますか? 注：私はpython 2.7を使用しています。プリントはモニター用です。

サーバ：

import random
import select
import socket
portnum=3500
filename="Testvid.avi"
numofclients=2
datalist=[]
for i in range(0,numofclients):
    datalist.append(open("C:/Users/Nitai/Desktop/Metorrent/"+filename+"-tmp"+str(i+1),'wb'))
server_socket = socket.socket()
server_socket.bind(('0.0.0.0', portnum))
server_socket.listen(5)
s, address = server_socket.accept()
open_client_sockets = []
print "receivefile initiated"
def send_waiting_messages (wlist):
    for message in messages_to_send:
        (client_socket, data) = message
        if client_socket in wlist:
            client_socket.send(data)
            messages_to_send.remove(message)
messages_to_send = []
dataindex=0
socketindex=[]
finishedcount=0
while finishedcount<numofclients:
    rlist, wlist, xlist = select.select( [server_socket] + open_client_sockets,  open_client_sockets, [] )
    for current_socket in rlist:
        if current_socket is server_socket:
            print "new client"
            (new_socket,address)=server_socket.accept()
            open_client_sockets.append(new_socket)
            socketindex.append(new_socket)
            print open_client_sockets
            datatosend="IDP "+str(dataindex)+"%"+str(numofclients)
            print datatosend
            messages_to_send.append((new_socket,datatosend))
            print "data sent"
            print dataindex
            dataindex+=1
        else:
            data=current_socket.recv(1024)
            if data.find("EndPacket")!=-1:
                print "connection finished"
                finishedcount+=1
                open_client_sockets.remove(current_socket)
            else:
                datalist[socketindex.index(current_socket)].write(data)
    send_waiting_messages(wlist)
s.close()
print "select exited"
filewriter=open("C:/Users/Nitai/Desktop/Metorrent/"+filename+"-final",'wb')
for i in range(0,numofclients):
    filewriter.write(datalist[i].read())
print "File received"
filewriter.close()
print "transfer finished"

クライアント：

import random
import socket
import os
portnum=3500
filename="Testvid.avi"
address='10.0.0.5'
s= socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((address, portnum))
print "connected"
data=s.recv(1024)
print "data received"
print data
index=int(data[4:data.find("%")])
print index
numofclients=int(data[data.find("%")+1:len(data)])
print numofclients
filetosend=open("C:/Users/Nitai/Desktop/"+filename,'rb')
filelength=int(os.stat("C:/Users/Nitai/Desktop/"+filename).st_size)
startpoint=(filelength/numofclients)*index
if numofclients==index+1:
    print "last part sender"
    endpoint=filelength
else:
    endpoint=(filelength/numofclients)*(index+1)
filetosend.seek(startpoint)
print startpoint
print endpoint
while startpoint+1024<endpoint:
    a=filetosend.read(1024)
    s.send(a)
    startpoint+=1024
l=filetosend.read(endpoint-filetosend.tell())
s.send(l)
filetosend.close()
time.sleep(3)
endpacketdata="EndPacket"
s.send(endpacketdata)
print "File sent"
s.close()
print "data transfer complete"

助けてくれてありがとう！

4

1 に答える 1