0

私のプロキシ プロジェクトでは、サーバー プロセス (教師が指定) がエラー (404 で始まる文字列) で終了することがあるため、リクエストを送信したスレッドを停止して続行しないようにしたいと考えています。「return」または「sys.exit()」を試してみましたが、これはすべてをブロックしているようで、プロキシはリクエストの受信とスレッドの作成を停止します。なんで？ 

from socket import *
from threading import *
import sys
import colors 
import os
import time

def startPrefetch(pagesToPrefetch, mutex):
    for i in pagesToPrefetch:
        print i

def receivePage(conn, addr, request, mutex):
    HOSTSERVER = "127.0.0.1"
    SERVERPORT = 55555
    socketRequestServer = socket(AF_INET, SOCK_STREAM)
    socketRequestServer.connect((HOSTSERVER, SERVERPORT))
    socketRequestServer.send(request)

    finalResponse = ''

    while True:
        partialResponse = socketRequestServer.recv(64)
        if (not partialResponse): break
        finalResponse = finalResponse+partialResponse        

    if (finalResponse[0] == '4'):
        c = colors.colors()
        print c.ERROR + finalResponse + "INTERNAL SERVER ERROR"
        print c.WHITE
        return
        #sys.exit(1)


    socketRequestServer.close()      
    conn.sendall(finalResponse)
    conn.close()

    pagesToPrefetch = []

    sourceToString = finalResponse.split(' ')
    for i in sourceToString:
        if (len(i) != 0):
            if (i[0] == '<'):
                pagesToPrefetch.append(i)

    startPrefetch(pagesToPrefetch, mutex)


if __name__ == '__main__':
    HOST = '127.0.0.1'
    PORT = 55554

    print 'Creating socket'
    socketProxy = socket(AF_INET, SOCK_STREAM)

    print 'bind()'
    socketProxy.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
    socketProxy.bind((HOST, PORT))

    #Cache directory and mutex for it
    mutex = Semaphore(1)
    try:
        os.mkdir("cache")
    except OSError:
        print 'Created cache directory'

    while True:
        print 'Waiting for connection request'
        socketProxy.listen(1)
        conn, addr = socketProxy.accept()

        print 'Connected to ', addr

        request = conn.recv(512)        

        receiver = Thread(target = receivePage, args = (conn, addr, request, mutex))
        receiver.start()
4

1 に答える 1

1

使用returnするのが正しい方法です（ただし、それを行う前に接続を閉じる必要があります）。

デビッドがこの行を提案したように：

request = conn.recv(512)

おそらく犯人です。接続が確立されてもデータが送信されない場合、メインスレッドはロックされます。リクエストが512より大きくなる可能性があることは言うまでもありません。

その行を関数内に移動し（コンストラクターにreceivePageは渡さないでください）、機能するかどうかをお知らせください。requestThread

于 2013-02-15T12:30:18.813 に答える