以太网无障碍捕获

珍惜时间，勤奋学习！今天给大家带来《以太网无障碍捕获》，正文内容主要涉及到等等，如果你正在学习Golang，或者是对Golang有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

我使用此代码捕获以太网数据包：

var snapshotLen int32 = 102400
var promiscuous bool = true
var timeout time.Duration = 1 * time.Second
var handle *pcap.Handle
handle, err = pcap.OpenLive(device, snapshotLen, promiscuous, timeout)
err = handle.SetBPFFilter(filter)

packetSource := gopacket.NewPacketSource(handle, handle.LinkType())
for packet := range packetSource.Packets() {

}

问题是 packetsource.packets() 阻塞：如果没有收到数据包，则会出现无限循环。我该如何设置超时？

解决方案

来自the docs：

func (p *packetsource) packets() chan packet

packets 返回一个数据包通道，允许轻松迭代 数据包。数据包将从底层异步读入 packetdatasource 并写入返回的通道。如果 底层 packetdatasource 返回 io.eof 错误，通道将 被关闭。如果遇到任何其他错误，它将被忽略。

for packet := range packetsource.packets() {   handlepacket(packet) 
// do something with each packet. }

如果多次调用，则返回同一通道。

因此，由于 gopacket.packetsource.packets() 返回一个通道，因此您可以在两个通道上采用 selecting 的常用策略 - 其中一个通道上的操作由超时控制。

在最简单的情况下，类似这样的事情：

timer := time.NewTicker(2 * time.Second)
defer timer.Stop()

src := gopacket.NewPacketSource(handle, handle.LinkType())
for {
    select {
        case pkt := <- src.Packets():
            // process a packet in pkt
        case <- timer.C:
            // timed out waiting for 2 seconds
    }
}

根据具体用例，第二个通道可以来自其他来源，例如 context。

以上就是《以太网无障碍捕获》的详细内容，更多关于的资料请关注golang学习网公众号！