2017-10-25 11 views
0

http://www.binarytides.com/programming-udp-sockets-in-python/の例に基づいて、Python 3で実行するように変更し、クライアントとサーバーで2つの対向ポートを使用したため、それぞれからの返信がこれらのポートに送られます。ここに私の例は異なる入力ポートを持つPython UDPクライアントサーバー

サーバーです:

''' 
    Simple udp socket server 
''' 

import socket 
import sys 

HOST = 'localhost' 
PORT_IN = 8889 # Arbitrary non-privileged port 
PORT_OUT = 8888 

# Datagram (udp) socket 
try : 
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 
    print('Socket created') 
except socket.error as e: 
    print(e) 
    sys.exit() 


# Bind socket to local host and port 
try: 
    s.bind((HOST, PORT_IN)) 
except socket.error as e: 
    print(e) 
    sys.exit() 

print('Socket bind complete') 

#now keep talking with the client 
while 1: 
    # receive data from client (data, addr) 
    d = s.recvfrom(1024) 
    data = d[0] 
    addr = d[1] 

    if not data: 
     break 

    reply = 'OK...' + str(data) 

    s.sendto(reply.encode('UTF-8'), ('localhost', PORT_OUT)) 
    print('Message[' + addr[0] + ':' + str(addr[1]) + '] - ' + str(data).strip()) 

s.close() 

クライアント:

''' 
    udp socket client 
    Silver Moon 
''' 

import socket #for sockets 
import sys #for exit 

# create dgram udp socket 
try: 
    s1 = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 
    s2 = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 
except socket.error: 
    print('Failed to create socket') 
    sys.exit() 

host = 'localhost' 
port_out = 8889 
port_in = 8888 

counter = 0 
while(1) : 
    # msg = b'aoua' 
    msg = 'aoua' + str(counter) 

    try : 
     #Set the whole string 
     s1.sendto(msg.encode('UTF-8'), (host, port_out)) 

     # receive data from client (data, addr) 
     s2.bind(('localhost', port_in)) 
     d = s2.recvfrom(1472) 
     reply = d[0] 
     addr = d[1] 

     print('Server reply : ' + str(reply)) 

    except socket.error as e: 
     print(e) 
     # sys.exit() 
    counter += 1 

問題は、サーバーとエラー[WinError 10022] An invalid argument was suppliedd = s2.recvfrom(1472)ハングからの応答を受信できないクライアントです。 sock.settimeout(seconds)と少し違う動作に気付きましたが、なぜそれほど難しいのですか? d = s2.recvfrom(buffer)は受信データを待つことはありませんか? 私はここで何が欠けていますか?

答えて

0

くそ...ちょうどそれを見ました。愚かな間違い。ループ内のクライアントでs2.bind(('localhost', port_in))を呼び出します。

関連する問題