Python UDP 服务器发送文本文件的行

Question

我需要模拟一个UDP服务器，它无限循环逐行发送文本文件的内容。我写了下面的代码，但在另一端我没有收到任何东西（另一端是 Qt 代码，我确信它有效）：

import socket
import time

# setup UDP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sa = ('localhost', 9763)
sock.bind(sa)

filename = '/home/saeid/Documents/data.txt'  # file to read
numlines = sum(1 for line in open(filename))  # get number of lines in file


# get line of a file
def get_line(line):
    with open(filename) as fp:
        for i, l in enumerate(fp):
            if i == line:
                return l

# main loop
while True:
    currline = 0
    while currline < numlines:
        sock.sendto(get_line(currline), sa)
        currline += 1
        time.sleep(1)

我不是 python 专业人士，无法解决问题:(

Answer 1

您需要更改您对 sendto 的调用中的目标地址或端口：

        peer_address = ('localhost', peer_port)
        sock.sendto(get_line(currline), peer_address)

Qt应用程序绑定到哪个地址和端口？

Answer 2

对于初学者来说，这是一团糟：

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sa = ('localhost', 9763)
sock.bind(sa)
...
sock.sendto(get_line(currline), sa)

通过绑定你基本上说 "I want to listen on that host/port"。但是随后您将数据发送到相同的 host/port。我假设还有其他一些目的地地址，例如sock.sendto(get_line(currline), ('my_host', 1234))。顺便说一句，你为什么要绑定地址？ sock.bind(sa) 行是不必要的，删除它。

另一件事是您的文件读取代码效率极低且难以阅读（我花了一段时间才明白这是怎么回事）。尝试这样的事情：

with open(filename, 'r') as fo:
    while True:
        for line in fo:
            sock.sendto(line, DEST_ADDRESS)
            time.sleep(1)
        fo.seek(0)  # go back to the begining of the file and repeat

并删除 get_line 函数。

至少这是我在阅读您的描述后得出的结论。如果你不想无限地发送相同的文件，那么你可以摆脱 while True: 循环和 fo.seek(0) 调用。

Answer 3

大叔google想出了User Datagram Client and Server

用户数据报客户端和服务器

用户数据报协议 (UDP) 的工作方式与 TCP/IP 不同。 TCP 是面向流的协议，确保所有数据以正确的顺序传输，而 UDP 是面向消息的协议。 UDP 不需要 long-lived 连接，因此设置 UDP 套接字稍微简单一些。另一方面，UDP 消息必须适合单个数据包（对于 IPv4，这意味着它们只能容纳 65,507 字节，因为 65,535 字节的数据包还包含 header 信息）并且不能像 TCP 那样保证交付。

Echo 服务器

由于没有连接，服务器本身不需要监听和接受连接。它只需要使用 bind() 将其套接字与端口相关联，然后等待各个消息。

import socket
import sys

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# Bind the socket to the port
server_address = ('localhost', 10000)
print >>sys.stderr, 'starting up on %s port %s' % server_address
sock.bind(server_address)

使用 recvfrom() 从套接字读取消息，returns 数据以及发送消息的客户端地址。

while True:
    print >>sys.stderr, '\nwaiting to receive message'
    data, address = sock.recvfrom(4096)

    print >>sys.stderr, 'received %s bytes from %s' % (len(data), address)
    print >>sys.stderr, data

    if data:
        sent = sock.sendto(data, address)
        print >>sys.stderr, 'sent %s bytes back to %s' % (sent, address)

Echo 客户端

UDP 回显客户端与服务器类似，但不使用 bind() 将其套接字附加到地址。它使用 sendto() 将其消息直接传递到服务器，并使用 recvfrom() 接收响应。

import socket
import sys

# Create a UDP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

server_address = ('localhost', 10000)
message = 'This is the message.  It will be repeated.'

try:

    # Send data
    print >>sys.stderr, 'sending "%s"' % message
    sent = sock.sendto(message, server_address)

    # Receive response
    print >>sys.stderr, 'waiting to receive'
    data, server = sock.recvfrom(4096)
    print >>sys.stderr, 'received "%s"' % data

finally:
    print >>sys.stderr, 'closing socket'
    sock.close()

客户端和服务器在一起

运行服务器产生：

$ python ./socket_echo_server_dgram.py

starting up on localhost port 10000

waiting to receive message
received 42 bytes from ('127.0.0.1', 50139)
This is the message.  It will be repeated.
sent 42 bytes back to ('127.0.0.1', 50139)

waiting to receive message

客户端输出为：

$ python ./socket_echo_client_dgram.py

sending "This is the message.  It will be repeated."
waiting to receive
received "This is the message.  It will be repeated."
closing socket

$

Python UDP 服务器发送文本文件的行

Python UDP Server send lines of a text file

python

python-2.7

python-sockets