使用Go语言发送带有以太网报头的Raw数据包

使用Go语言发送带有以太网报头的Raw数据包

问题描述:

我正尝试通过Go语言的原始套接字使用自定义以太网报头发送原始TCP数据包。我试图在c language中重现类似的代码。使用Go语言发送带有以太网报头的Raw数据包

package main 

import (
    "fmt" 
    "syscall" 
) 

func main() { 

    fmt.Println("=============================================================================") 
    fmt.Println("= Start sending                =") 
    fmt.Println("=============================================================================") 

    pkt := []byte{ 
     0x6c, 0x62, 0x6d, 0x50, 0xe6, 0xe4, 0x94, 0xde, 0x80, 0xa5, 0xec, 0x79, 0x08, 0x00, 0x45, 0x00, 
     0x00, 0x3c, 0x47, 0xd9, 0x40, 0x00, 0x40, 0x06, 0xb5, 0x94, 0xc0, 0xa8, 0x34, 0x7b, 0x36, 0xe7, 
     0x11, 0x44, 0xc3, 0x66, 0x00, 0x50, 0x09, 0x58, 0x6b, 0xeb, 0x00, 0x00, 0x00, 0x00, 0xa0, 0x02, 
     0x72, 0x10, 0x26, 0x38, 0x00, 0x00, 0x02, 0x04, 0x05, 0xb4, 0x04, 0x02, 0x08, 0x0a, 0x0d, 0x3d, 
     0x2c, 0x32, 0x00, 0x00, 0x00, 0x00, 0x01, 0x03, 0x03, 0x07, 
    } 

    fd, err := syscall.Socket(syscall.AF_PACKET, syscall.SOCK_RAW, syscall.ETH_P_ALL) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 1                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    addr := syscall.SockaddrInet4{ 
     Port: 0, 
     Addr: [4]byte{127, 0, 0, 1}, 
    } 

    err = syscall.Bind(fd, &addr) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 2                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    err = syscall.SetLsfPromisc("eth0", true) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 3                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    n, err := syscall.Write(fd, pkt) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 4                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
     fmt.Println(n) 
    } else { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Packet is sent               =") 
     fmt.Println("=============================================================================") 
     fmt.Println(n) 
    } 
} 

但是我得到以下错误:

============================================================================= 
= Start sending                = 
============================================================================= 
============================================================================= 
= Error 2                 = 
============================================================================= 
invalid argument 
============================================================================= 
= Error 4                 = 
============================================================================= 
no such device or address 
-1 

请指导我,如果您有任何知识。

+0

您是否尝试过使用标准库进行连接?像[net](https://golang.org/pkg/net/)软件包或[crypto/tls](https://golang.org/pkg/crypto/tls/)软件包一样?他们都有一个'Dial'方法,可以处理原始的TCP。 – sargas

+0

@sargas感谢您的重播。是的,我确实使用拨号方式。不过,我需要更改以太网部分。不仅是IP层。 – Khamidulla

你想完成什么更复杂。

  1. 不能使用内核绑定系统调用绑定到一个原始套接字:err = syscall.Bind(fd, &addr)
  2. 你想以太网帧写入原始套接字。为了做到这一点,您需要自己组装以太网帧和TCP报头。在该级别上使用原始套接字的关键不在于内核为您执行此操作。

C中的一些工作示例可以在here找到。他们可能很容易移植到Go

+0

你看过这个例子吗? http://yusufonlinux.blogspot.kr/2010/11/data-link-access-and-zero-copy.html – Khamidulla

+0

我试过syscall.BindToDev(name)函数,它没有错误地工作。但错误4仍然存在。 – Khamidulla

+0

我找到了解决方案。我会在今天晚些时候发布。其实我能够使用syscall.Bind()系统调用来绑定一个原始套接字。 – Khamidulla

这是我的问题的工作代码。我将在稍后添加解释。

package main 

import (
    "fmt" 
    "net" 
    "syscall" 
) 

func main() { 

    fmt.Println("=============================================================================") 
    fmt.Println("= Start sending                =") 
    fmt.Println("=============================================================================") 

    pkt := []byte{ 
     0x6c, 0x62, 0x6d, 0x50, 0xe6, 0xe4, 0x94, 0xde, 0x80, 0xa5, 0xec, 0x79, 0x08, 0x00, 0x45, 0x00, 
     0x00, 0x3c, 0x4b, 0x72, 0x40, 0x00, 0x40, 0x06, 0x44, 0x7d, 0xc0, 0xa8, 0x34, 0x7b, 0xd8, 0x3a, 
     0xdd, 0x6e, 0xa6, 0x37, 0x01, 0xbb, 0x32, 0xf3, 0x21, 0xa9, 0x00, 0x00, 0x00, 0x00, 0xa0, 0x02, 
     0x72, 0x10, 0xae, 0xa5, 0x00, 0x00, 0x02, 0x04, 0x05, 0xb4, 0x04, 0x02, 0x08, 0x0a, 0x15, 0x13, 
     0x6a, 0xdb, 0x00, 0x00, 0x00, 0x00, 0x01, 0x03, 0x03, 0x07, 
    } 

    fd, err := syscall.Socket(syscall.AF_PACKET, syscall.SOCK_RAW, syscall.ETH_P_ALL) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 1                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    if_info, err := net.InterfaceByName("eth0") 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 2                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    var haddr [8]byte 
    copy(haddr[0:7], if_info.HardwareAddr[0:7]) 
    addr := syscall.SockaddrLinklayer{ 
     Protocol: syscall.ETH_P_IP, 
     Ifindex: if_info.Index, 
     Halen: uint8(len(if_info.HardwareAddr)), 
     Addr:  haddr, 
    } 

    err = syscall.Bind(fd, &addr) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 3                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    err = syscall.SetLsfPromisc("eth0", true) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 4                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 

    n, err := syscall.Write(fd, pkt) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 5                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
     fmt.Println(n) 
    } else { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Packet is sent               =") 
     fmt.Println("=============================================================================") 
     fmt.Println(n) 
    } 

    err = syscall.SetLsfPromisc("eth0", false) 
    if err != nil { 
     fmt.Println("=============================================================================") 
     fmt.Println("= Error 6                 =") 
     fmt.Println("=============================================================================") 
     fmt.Println(err) 
    } 
}