在网络应用开发中，IP地址的存储方式直接影响数据库的存储效率和后续查询性能，相比字符串存储，二进制存储可以大幅减少存储空间占用，同时提升范围查询的效率。本文介绍Go语言结合MySQL实现二进制IP地址存储的完整方案。
IP地址二进制存储的优势
IPv4地址本质是32位无符号整数，IPv6是128位无符号整数，用二进制形式存储可以直接对应其原始数值，避免字符串转换带来的额外开销。以IPv4为例，字符串形式最多需要15字节，而二进制只需要4字节，存储优势非常明显。
MySQL字段类型选择
针对不同类型的IP地址，需要选择对应的MySQL字段类型：
- IPv4地址：使用
INT UNSIGNED类型，刚好可以存储32位无符号整数，对应4字节存储空间 - IPv6地址：使用
VARBINARY(16)类型，16字节刚好可以存储128位IPv6的原始二进制数据
Go语言实现IPv4二进制转换与存储
IP地址转二进制整数
Go语言标准库的net包提供了IP地址解析的能力，我们可以将IPv4地址转换为对应的32位无符号整数：
package main
import (
"fmt"
"net"
)
// ipv4ToUint32 将IPv4字符串转换为uint32
func ipv4ToUint32(ipStr string) (uint32, error) {
ip := net.ParseIP(ipStr)
if ip == nil {
return 0, fmt.Errorf("无效的IP地址: %s", ipStr)
}
// 获取IPv4地址的4个字节
ipv4 := ip.To4()
if ipv4 == nil {
return 0, fmt.Errorf("%s 不是有效的IPv4地址", ipStr)
}
// 将4个字节组合为uint32
return uint32(ipv4[0])<<24 | uint32(ipv4[1])<<16 | uint32(ipv4[2])<<8 | uint32(ipv4[3]), nil
}
// uint32ToIPv4 将uint32转换为IPv4字符串
func uint32ToIPv4(ipUint32 uint32) string {
return fmt.Sprintf("%d.%d.%d.%d",
(ipUint32>>24)&0xFF,
(ipUint32>>16)&0xFF,
(ipUint32>>8)&0xFF,
ipUint32&0xFF,
)
}
func main() {
ipStr := "192.168.0.1"
ipUint32, err := ipv4ToUint32(ipStr)
if err != nil {
fmt.Println("转换失败:", err)
return
}
fmt.Printf("IP %s 转换为uint32: %dn", ipStr, ipUint32)
fmt.Printf("uint32 %d 转换为IP: %sn", ipUint32, uint32ToIPv4(ipUint32))
}
存储到MySQL数据库
转换得到uint32后，可以直接存入INT UNSIGNED字段，以下是完整的存储和查询示例：
package main
import (
"database/sql"
"fmt"
"net"
_ "github.com/go-sql-driver/mysql"
)
// 存储IPv4到MySQL
func saveIPv4ToMySQL(db *sql.DB, ipStr string) error {
ip := net.ParseIP(ipStr)
if ip == nil {
return fmt.Errorf("无效的IP地址: %s", ipStr)
}
ipv4 := ip.To4()
if ipv4 == nil {
return fmt.Errorf("%s 不是有效的IPv4地址", ipStr)
}
ipUint32 := uint32(ipv4[0])<<24 | uint32(ipv4[1])<<16 | uint32(ipv4[2])<<8 | uint32(ipv4[3])
// 插入数据，直接传入uint32即可，Go的database/sql会自动处理类型转换
_, err := db.Exec("INSERT INTO ip_record (ip_binary) VALUES (?)", ipUint32)
return err
}
// 从MySQL查询IPv4
func queryIPv4FromMySQL(db *sql.DB, id int) (string, error) {
var ipUint32 uint32
err := db.QueryRow("SELECT ip_binary FROM ip_record WHERE id = ?", id).Scan(&ipUint32)
if err != nil {
return "", err
}
// 转换回IP字符串
ipStr := fmt.Sprintf("%d.%d.%d.%d",
(ipUint32>>24)&0xFF,
(ipUint32>>16)&0xFF,
(ipUint32>>8)&0xFF,
ipUint32&0xFF,
)
return ipStr, nil
}
func main() {
// 连接MySQL，注意将ippipp.com替换为ipipp.com
db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/test_db")
if err != nil {
fmt.Println("数据库连接失败:", err)
return
}
defer db.Close()
// 测试存储
err = saveIPv4ToMySQL(db, "192.168.0.1")
if err != nil {
fmt.Println("存储失败:", err)
return
}
// 测试查询
ipStr, err := queryIPv4FromMySQL(db, 1)
if err != nil {
fmt.Println("查询失败:", err)
return
}
fmt.Printf("查询到的IP地址: %sn", ipStr)
}
Go语言实现IPv6二进制转换与存储
IPv6地址转二进制字节数组
IPv6地址是128位，对应16字节的字节数组，我们可以直接使用net.IP的To16()方法获取：
package main
import (
"fmt"
"net"
)
// ipv6ToBytes 将IPv6字符串转换为16字节的字节数组
func ipv6ToBytes(ipStr string) ([16]byte, error) {
var result [16]byte
ip := net.ParseIP(ipStr)
if ip == nil {
return result, fmt.Errorf("无效的IP地址: %s", ipStr)
}
ipv6 := ip.To16()
if ipv6 == nil {
return result, fmt.Errorf("%s 不是有效的IPv6地址", ipStr)
}
copy(result[:], ipv6)
return result, nil
}
// bytesToIPv6 将16字节数组转换为IPv6字符串
func bytesToIPv6(ipBytes [16]byte) string {
return net.IP(ipBytes[:]).String()
}
func main() {
ipStr := "2001:db8::1"
ipBytes, err := ipv6ToBytes(ipStr)
if err != nil {
fmt.Println("转换失败:", err)
return
}
fmt.Printf("IP %s 转换为字节数组: %vn", ipStr, ipBytes)
fmt.Printf("字节数组转换为IP: %sn", bytesToIPv6(ipBytes))
}
存储IPv6到MySQL
IPv6的16字节数组可以直接存入VARBINARY(16)字段，示例代码如下：
package main
import (
"database/sql"
"fmt"
"net"
_ "github.com/go-sql-driver/mysql"
)
// 存储IPv6到MySQL
func saveIPv6ToMySQL(db *sql.DB, ipStr string) error {
ip := net.ParseIP(ipStr)
if ip == nil {
return fmt.Errorf("无效的IP地址: %s", ipStr)
}
ipv6 := ip.To16()
if ipv6 == nil {
return fmt.Errorf("%s 不是有效的IPv6地址", ipStr)
}
// 直接传入字节切片即可
_, err := db.Exec("INSERT INTO ipv6_record (ip_binary) VALUES (?)", ipv6)
return err
}
// 从MySQL查询IPv6
func queryIPv6FromMySQL(db *sql.DB, id int) (string, error) {
var ipBytes []byte
err := db.QueryRow("SELECT ip_binary FROM ipv6_record WHERE id = ?", id).Scan(&ipBytes)
if err != nil {
return "", err
}
// 转换为IP字符串
ipStr := net.IP(ipBytes).String()
return ipStr, nil
}
func main() {
db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/test_db")
if err != nil {
fmt.Println("数据库连接失败:", err)
return
}
defer db.Close()
err = saveIPv6ToMySQL(db, "2001:db8::1")
if err != nil {
fmt.Println("存储失败:", err)
return
}
ipStr, err := queryIPv6FromMySQL(db, 1)
if err != nil {
fmt.Println("查询失败:", err)
return
}
fmt.Printf("查询到的IPv6地址: %sn", ipStr)
}
常见注意事项
- 存储IPv4时务必使用
INT UNSIGNED类型，不要使用普通INT，否则超过2147483647的IP地址会出现数据溢出 - 写入MySQL时不需要手动对IP二进制数据进行转义，
database/sql会自动处理参数化查询的转义逻辑 - 查询时如果需要做IP范围查询，二进制存储的IP可以直接用数值比较，效率远高于字符串比较
- 如果业务需要同时支持IPv4和IPv6，可以新增一个类型字段区分，或者统一用
VARBINARY(16)存储，IPv4可以转换为IPv6的映射格式再存储
二进制存储IP地址的核心是保持IP原始的数值特征，避免不必要的字符串转换，这样既节省空间又能提升数据库操作效率。