如何收听通过UDP发送到IP的数据？

Question

有一个远程系统通过UDP向我的服务器发送数据，我想“捕获”这些数据，并将它发送到非特定的端口。我知道发件人（IP：端口），但他们发送给的端口是可变的。

我不知道应该用哪种语言来完成，但我向任何人开放。服务器运行CentOS。最终目标是接收数据，然后通过PHP输出处理。

（！我要澄清我选择要发送的数据，它不是恶意的）

编辑：我要提的是，该端口是可变的，不是我的问题，我不知道如何捕获任何数据通过UDP发送到任何端口，我仍然需要知道如何捕获和处理数据，一旦我可以指示它。

Answer 1

您只需编写一个iptables规则将所有流量从该IP：端口转发到系统上的给定端口，然后在该端口上监听该数据。 （您可能会发现CentOS IPTables manual有用）

如果您正在与服务器通话，则必须使用NAT表，以便在返回路径上进行正确的重写。即使不需要，也可以在任何情况下方便地执行此操作，因为那样您就不必做任何事情来让听众不会惊讶它正在接收它未在监听的端口的数据包数据。

一旦你有一个端口上的流量登陆，你可以写一个简单的UDP服务器实现，像在PHP手册：

http://us3.php.net/manual/en/function.stream-socket-server.php

Answer 2

您需要使用libpcap。借助该库，您可以非常直接地完成您想要的任务。

您肯定可以使用C/C++。但我猜想其他语言也有约束力，因为它是一个非常受欢迎的图书馆。

Answer 3

我最近一直在做类似的事情，在蟒蛇结帐验证码：

#!/usr/bin/python 

import socket, sys, io 
from struct import * 
from time import localtime, strftime 

#------------------------------------------------------------------------------- 
class ETHHeader: # ethernet header 
    def __init__(self, s): 
    data = s.read(14) 
    hdr = unpack("!6s6sH", data) 
    self.destination_addr = data[0:6] # mac address 
    self.source_addr  = data[6:12] # mac address 
    self.protocol   = socket.ntohs(hdr[2]) 

    def src_addr(self): 
    return addr_to_str(self.srouce_addr) 

    def dst_addr(self): 
    return addr_to_str(self.destination_addr) 

    def is_IP(self): return self.protocol == 8 

    #Convert a string of 6 characters of ethernet address into a dash separated hex string 
    def addr_to_str (a) : 
     b = "%.2x:%.2x:%.2x:%.2x:%.2x:%.2x" % (ord(a[0]), ord(a[1]) , ord(a[2]), \ 
             ord(a[3]), ord(a[4]) , ord(a[5])) 
     return b 

#------------------------------------------------------------------------------- 
class IPHeader: 
    def __init__(self, s): 
    iph = unpack('!BBHHHBBH4s4s', s.read(20)) 
    self.protocol = iph[6] 
    self.src_addr = socket.inet_ntoa(iph[8]); 
    self.dst_addr = socket.inet_ntoa(iph[9]); 

    def __str__(self): 
    return "(" + self.proto() + " " + self.src_addr + " -> " + self.dst_addr + ")" 

    def proto(self): 
    return { 6: "TCP", 1: "ICMP", 17: "UDP" }.get(self.protocol, "???") 

#------------------------------------------------------------------------------- 
class UDPHeader: 
    def __init__(self, s): 
    hdr = unpack("!HHHH", s.read(8)) 
    self.source_port  = hdr[0] 
    self.destination_port = hdr[1] 
    self.length   = hdr[2] 
    self.checksum   = hdr[3] 

#------------------------------------------------------------------------------- 
try: 
    #s = socket.socket(socket.AF_INET, socket.SOCK_RAW, socket.IPPROTO_UDP) 
    # Using this instead of the above we will get: 
    # Also incoming packets. 
    # Ethernet header as part of the received packet. 
    # TCP, UDP, ... 
    s = socket.socket(socket.AF_PACKET, socket.SOCK_RAW, socket.ntohs(0x0003)) 
except socket.error, msg: 
    print "Socket could not be created. Error Code : " + str(msg[0]) + ' Message ' + msg[1] 
    sys.exit() 

#------------------------------------------------------------------------------- 
def communication_between_ports(udp_header, ports): 
    src = udp_header.source_port 
    dst = udp_header.destination_port 
    return src in ports and dst in ports 

def communication_between_ips(ip_header, ips): 
    src = ip_header.src_addr 
    dst = ip_header.dst_addr 
    return src in ips and dst in ips 

#------------------------------------------------------------------------------- 

while True: 
    packet = s.recvfrom(65535) # buffer size 

    data = io.BytesIO(packet[0]) 
    eth = ETHHeader(data) 

    if not eth.is_IP(): 
    continue 

    iph = IPHeader(data) 
    udph = UDPHeader(data) 

    if not communication_between_ips(iph, ["192.168.1.3", "192.168.1.102"]): 
    continue 

    if iph.proto() != "UDP": 
    continue 

    ## To filter by port: 
    #if udph.source_port != <PORT-YOU-WANT> 
    # continue 

    time = localtime() 
    timestr = strftime("%H:%M:%S", time) 

    a = iph.src_addr 
    b = iph.dst_addr 
    direction = " -> " 

    if a > b: 
    tmp = a 
    a = b 
    b = tmp 
    direction = " <- " 

    print timestr + ": " + a + str(direction) + b 

我只提取，我从每一层需要（ETH，IP，...），但你的数据应该能够轻松地扩展它。

得到了this blog post的大部分信息。