
本文详细探讨了在go语言中实现udp ping以检测服务器端口可达性的方法。核心内容包括理解icmp目标不可达消息的结构(特别是类型3、代码3),以及如何在接收到icmp数据包后,通过解析其前两个字节来识别“端口不可达”错误。文章同时指出标准udp套接字在直接捕获icmp错误方面的局限性,并引入了原始套接字(raw sockets)作为获取icmp数据的潜在途径。
在客户端/服务器应用中,有时需要通过UDP协议来探测远程服务器上特定端口的可达性。与TCP的握手机制不同,UDP是无连接的,发送数据包后无法直接获得确认。然而,当UDP数据包发送到一个不可达的端口时,操作系统通常会响应一个ICMP(Internet Control Message Protocol)“目标不可达”消息,其中包含“端口不可达”的特定代码。通过捕获并解析这个ICMP消息,我们可以判断目标端口是否开放。
然而,标准的Go语言net.ListenUDP和conn.ReadFromUDP方法主要用于处理UDP数据包本身。当远程端口不可达时,内核会生成ICMP错误,但这些ICMP错误通常不会直接通过UDP套接字作为数据返回给应用程序。应用程序的ReadFromUDP调用可能只是超时或返回一个不包含具体ICMP信息的错误(例如,在某些情况下,错误可能为nil但读取到0字节)。因此,要精确地捕获并识别ICMP端口不可达错误,需要更底层的机制。
ICMP目标不可达消息(Destination Unreachable Message)是RFC 792中定义的一种ICMP类型,用于指示数据包无法送达目的地。其结构如下:
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Type | Code | Checksum |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| unused |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| Internet Header + 64 bits of Original Data Datagram |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+对于目标不可达消息:
其他常见的代码包括:
因此,要识别“端口不可达”错误,我们需要检查接收到的ICMP消息的前两个字节:第一个字节为 3,第二个字节为 3。
如前所述,使用net.ListenUDP创建的UDP套接字,其ReadFromUDP方法通常不会直接接收到内核生成的ICMP错误消息。这些错误通常由操作系统内核在内部处理,并可能以套接字操作错误(如ECONNREFUSED,尽管这在UDP中不常见且通常与TCP相关)或超时的方式间接通知应用程序。在Go语言中,如果ReadFromUDP返回nil错误和0字节,这通常意味着在设定的读取时间内没有收到任何UDP数据包,但并不直接表明收到了ICMP错误。
芝士饼
芝士饼是一个一站式AI原生应用开发平台,简单几步即可完成应用的创建与发布。
84
查看详情
为了直接捕获ICMP数据包,应用程序通常需要使用原始套接字(Raw Sockets)。原始套接字允许应用程序绕过传输层(如UDP或TCP),直接在网络层(IP层)上发送和接收数据包,包括ICMP数据包。
在Go语言中,可以通过syscall包或更高级的golang.org/x/net/icmp包来操作原始套接字。然而,使用原始套接字通常需要:
捕获ICMP错误的基本流程是:
假设我们已经通过原始套接字成功捕获了一个ICMP数据包,并将其存储在一个字节切片中(例如icmpReply)。我们可以通过检查其前两个字节来判断是否为“端口不可达”错误。
package main
import (
"fmt"
"net"
"time"
"errors"
"golang.org/x/net/icmp"
"golang.org/x/net/ipv4"
"syscall"
)
// simulateSendUDPPing 模拟发送UDP数据包,实际中会发送到目标
func simulateSendUDPPing(conn *net.UDPConn, dst *net.UDPAddr) error {
_, err := conn.WriteTo([]byte("PING"), dst)
if err != nil {
return fmt.Errorf("failed to send UDP ping request: %w", err)
}
fmt.Printf("Sent UDP PING to %s\n", dst.String())
return nil
}
// listenForICMPError 尝试监听ICMP错误,这通常需要原始套接字
// 注意:此函数是一个简化示例,实际生产环境需要更健壮的错误处理和权限管理
func listenForICMPError(network string, listenAddr *net.IPAddr, timeout time.Duration) ([]byte, error) {
// 使用 ip4:icmp 协议创建原始套接字
// 在非Linux系统上,可能需要不同的方法或更高的权限
// Windows下,通常不能直接监听ICMP,需要使用更高级的API
// macOS下,也需要root权限
conn, err := icmp.ListenPacket(network, listenAddr.String())
if err != nil {
return nil, fmt.Errorf("failed to listen for ICMP packets: %w. On Linux, this often requires root privileges.", err)
}
defer conn.Close()
fmt.Printf("Listening for ICMP packets on %s...\n", listenAddr.String())
conn.SetReadDeadline(time.Now().Add(timeout))
rb := make([]byte, 1500) // 足够大的缓冲区来接收ICMP消息
n, peer, err := conn.ReadFrom(rb)
if err != nil {
if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
return nil, errors.New("ICMP read timeout, no ICMP error received")
}
return nil, fmt.Errorf("failed to read from ICMP socket: %w", err)
}
fmt.Printf("Received %d bytes from %s\n", n, peer)
return rb[:n], nil
}
// parseICMPDestinationUnreachable 解析ICMP目标不可达消息
func parseICMPDestinationUnreachable(icmpReply []byte) (bool, error) {
if len(icmpReply) < ipv4.HeaderLen + icmp.HeaderLen { // 至少包含IP头和ICMP头
return false, errors.New("ICMP reply too short to be a valid ICMP message")
}
// 假设icmpReply已经移除了IP头,只包含ICMP数据
// 如果是原始套接字直接接收,可能包含IP头,需要先解析IP头
// 这里我们使用golang.org/x/net/icmp包来解析,它会处理IP头
msg, err := icmp.ParseMessage(syscall.IPPROTO_ICMP, icmpReply)
if err != nil {
return false, fmt.Errorf("failed to parse ICMP message: %w", err)
}
if msg.Type == ipv4.ICMPTypeDestinationUnreachable {
if msg.Code == 3 { // Code 3 for Port Unreachable
fmt.Println("Detected ICMP Port Unreachable error!")
return true, nil
} else {
fmt.Printf("Detected ICMP Destination Unreachable with code %d (not port unreachable)\n", msg.Code)
return false, nil
}
} else {
fmt.Printf("Received ICMP message of type %s (not Destination Unreachable)\n", msg.Type)
}
return false, nil
}
func main() {
// 1. 设置源和目标地址
srcAddr := &net.UDPAddr{IP: net.ParseIP("0.0.0.0"), Port: 0} // 任意本地端口
dstAddr := &net.UDPAddr{IP: net.ParseIP("127.0.0.1"), Port: 9999} // 目标地址和不可达端口
// 2. 创建UDP连接用于发送PING
udpConn, err := net.ListenUDP("udp4", srcAddr)
if err != nil {
fmt.Printf("Failed to listen UDP: %v\n", err)
return
}
defer udpConn.Close()
// 3. 准备ICMP监听器 (需要root权限)
// 在Windows上,ListenPacket("ip4:icmp", ...)可能不工作,需要更底层的API或管理员权限
// 在macOS/Linux上,需要sudo运行
icmpListenAddr, err := net.ResolveIPAddr("ip4", "0.0.0.0")
if err != nil {
fmt.Printf("Failed to resolve ICMP listen address: %v\n", err)
return
}
// 4. 发送UDP PING
if err := simulateSendUDPPing(udpConn, dstAddr); err != nil {
fmt.Printf("Error sending UDP ping: %v\n", err)
return
}
// 5. 监听ICMP错误
// 注意:这里需要并行运行,因为UDP发送和ICMP接收是异步的
// 实际应用中,你可能需要在一个goroutine中发送,另一个goroutine中监听ICMP
// 为了示例清晰,这里简化处理,假设ICMP会在短时间内返回
icmpResponse, err := listenForICMPError("ip4:icmp", icmpListenAddr, 500*time.Millisecond)
if err != nil {
fmt.Printf("Error listening for ICMP: %v\n", err)
// 如果是超时,可能是端口可达,或者防火墙阻止了ICMP
return
}
// 6. 解析ICMP响应
isPortUnreachable, err := parseICMPDestinationUnreachable(icmpResponse)
if err != nil {
fmt.Printf("Error parsing ICMP response: %v\n", err)
return
}
if isPortUnreachable {
fmt.Println("Conclusion: Target UDP port is likely unreachable.")
} else {
fmt.Println("Conclusion: No ICMP Port Unreachable error detected (might be reachable, or other ICMP error).")
}
}
代码说明:
重要提示: 上述listenForICMPError函数中的icmp.ListenPacket在大多数Linux系统上需要root权限才能成功创建原始套接字。在Windows或macOS上,原始套接字的操作可能有所不同,或者也需要管理员权限。这是实现这种低级别网络探测的关键挑战。
通过UDP ping探测远程端口的可达性,并解析ICMP“端口不可达”错误,是诊断网络问题和验证服务状态的有效方法。虽然标准的Go UDP套接字无法直接捕获这些ICMP错误,但通过使用原始套接字(如golang.org/x/net/icmp包),我们可以监听并解析ICMP消息。理解ICMP目标不可达消息的结构,特别是类型3、代码3的含义,是正确识别“端口不可达”错误的关键。在实际实现时,务必考虑权限、防火墙以及操作系统兼容性等因素。
以上就是Go语言中实现UDP Ping并解析ICMP端口不可达错误的详细内容,更多请关注其它相关文章!
# 芝士
# 平江SEO网站优化软件
# 建设商务网站公司
# 瑶海区网站建设
# 时代传媒品牌营销推广
# seo快速刷烹饪等级
# 昆明网站建设行业
# 惠州团购推广招聘网站
# 律师seo搜索流量多少
# 不花钱做网站推广
# 焦作seo招聘
# 能不
# 发送到
# 时间内
# 是一个
# 我们可以
# linux
# 应用程序
# 数据包
# 可达
# 端
# ipad
# 字节
# internet
# 防火墙
# cad
# go语言
# 操作系统
# golang
# windows
# go
相关栏目:
【
Google疑问12 】
【
Facebook疑问10 】
【
优化推广96088 】
【
技术知识133117 】
【
IDC资讯59369 】
【
网络运营7196 】
【
IT资讯61894 】
相关推荐:
《i莞家》修改昵称方法
基于键值条件高效映射 Pandas DataFrame 多列数据
b站如何剪辑视频_b站必剪app使用教程
蜻蜓FM如何设置移动流量播放
如何测试您的网站全球打开速度-网站海外测速工
《全民k歌》网页版最新登录入口一览
Python中深度嵌套字典与列表的数据提取与条件过滤指南
解决 Vue 3 组件未定义错误:理解 createApp 与根组件的正确使用
键盘声音异常怎么回事_键盘异响怎么处理
苹果手机缓存怎么清除_苹果手机缓存如何清除iphone各版本操作步骤
作业帮网页版不用下载入口 在线问老师快速答疑
search中maxlength属性用法解析
嘴唇干裂起皮怎么办 唇部护理与预防干裂的方法【详解】
抖音赚钱快速入门_新手必看的抖音赚钱步骤
在Django单元测试中优雅处理信号:基于环境的条件执行策略
大熊猫抓取竹子的“大拇指”其实是什么?蚂蚁庄园课堂今天答案最新11月30日
windows10怎么更改下载路径_windows10默认存储位置修改教程
腾讯QQ邮箱官方入口 QQ邮箱网页版登录平台
京东快递包裹信息查询入口 京东快递官方查询平台入口
厨房地面防滑垫的油污怎么洗? 机洗和手洗防滑垫的注意事项
抖音如何解除|直播|权限绑定_抖音关闭并解绑|直播|功能的方法
C++ cast类型转换总结_C++ reinterpret_cast与const_cast的使用
全球各国上班时间表外贸邮件时间
无人机考证官网 中国民航无人机考证官网登录入口
在PySimpleGUI中实现键盘按键绑定按钮事件
XPath动态元素定位:如何精准选择文本内容变化的元素
AO3中文入口稳定分享_AO3官网HTTPS看文详解
《360浏览器》设置摄像头权限方法
Win11如何分屏操作_Win11多窗口分屏技巧
Vue 3中独立响应式实例的创建与应用
网页版网易云音乐入口_网易云音乐在线官网登录
J*a中的值传递到底指什么_值传递模型在参数传递中的真正含义说明
Linux如何开发轻量级数据服务模块_Linux服务化设计
Win10输入法不见了怎么办 Win10找回语言栏图标教程
晓晓优选app支付宝绑定方法
折叠屏手机充不进电是什么问题? 特殊结构带来的维修难点
研招网官方网站招生平台入口_中国研究生招生信息网官网登录
《偃武》甘宁技能详解
word怎么将图片设置为页面背景并不影响打印_Word图片背景设置方法
《七读免费小说》开通会员方法
Win11怎么录屏_Windows 11自带Xbox Game Bar录制视频
修复UI元素交互障碍:从“开始”按钮到信息框的平滑过渡实现
POKI小游戏在线免费入口链接 POKI小游戏无下载秒玩玩
百度网盘如何设置上传限额
追剧达人如何发弹幕
VS Code中的Tailwind CSS IntelliSense插件使用技巧
如何配置VS Code作为您Git操作的默认编辑器
苹果电脑如何快速查看电池状态 苹果电脑电池信息快捷方法
《procreate》绘制渐变效果教程
ToDesk远程摄像头功能使用方法_ToDesk远程视频画面查看设置教程
2025-11-01
运城市盐湖区信雨科技有限公司是一家深耕海外推广领域十年的专业服务商,作为谷歌推广与Facebook广告全球合作伙伴,聚焦外贸企业出海痛点,以数字化营销为核心,提供一站式海外营销解决方案。公司凭借十年行业沉淀与平台官方资源加持,打破传统外贸获客壁垒,助力企业高效开拓全球市场,成为中小企业出海的可靠合作伙伴。