GNU/Linux下Go实现多播风格Unix域SOCK_DGRAM套接字及报错排查

你的代码存在两个核心问题：

1. 错误使用syscall.Mkfifo创建套接字
   syscall.Mkfifo的作用是创建命名管道（FIFO），属于文件系统中的管道类文件，不是Unix域套接字。你将syscall.SOCK_DGRAM、syscall.AF_UNIX这类套接字类型常量和文件权限位做或运算属于无效操作：这些常量的数值不属于文件权限位的有效范围，最终只会创建出一个权限异常的FIFO文件，而非套接字。
   当net.ListenUnixgram执行绑定时，会检测到指定路径已经存在非套接字类型的文件，无法完成套接字绑定，因此抛出address already in use错误——这个报错和其他程序占用无关，就是你提前创建的FIFO文件阻塞了绑定流程。
2. 对Unix域DGRAM套接字的语义认知错误
   原生SOCK_DGRAM类型的Unix域套接字不支持多播/广播能力，内核不会自动将发送到套接字的报文复制分发给多个连接的客户端，默认是一对一的无连接数据报传输，无法直接实现N个客户端同时读取同一条消息的效果。

要实现多客户端同时接收服务端消息的Unix域套接字服务，最通用的方案是服务端维护客户端地址列表，手动遍历分发消息：

服务端代码 #

package main

import (
	"log"
	"net"
	"os"
	"time"
)

func main() {
	sockPath := "multicast.sock"
	// 绑定前删除残留的旧套接字文件，避免绑定冲突
	_ = os.Remove(sockPath)

	serverAddr, err := net.ResolveUnixAddr("unixgram", sockPath)
	if err != nil {
		panic(err)
	}

	conn, err := net.ListenUnixgram("unixgram", serverAddr)
	if err != nil {
		panic(err)
	}
	defer os.Remove(sockPath)
	defer conn.Close()

	// 存储所有订阅消息的客户端地址
	clientSet := make(map[string]*net.UnixAddr)

	// 单独协程处理客户端订阅请求
	go func() {
		buf := make([]byte, 1024)
		for {
			n, clientAddr, err := conn.ReadFromUnix(buf)
			if err != nil {
				log.Printf("read from client error: %v", err)
				return
			}
			// 客户端发送任意内容即视为订阅
			clientSet[clientAddr.String()] = clientAddr
			log.Printf("new client subscribed: %s, recv register msg: %s", clientAddr.String(), string(buf[:n]))
		}
	}()

	// 定时向所有订阅客户端推送消息
	ticker := time.NewTicker(time.Second)
	defer ticker.Stop()
	for range ticker.C {
		msg := []byte("hello, world!")
		for addrStr, clientAddr := range clientSet {
			_, err := conn.WriteToUnix(msg, clientAddr)
			if err != nil {
				log.Printf("write to client %s failed, remove from client set: %v", addrStr, err)
				delete(clientSet, addrStr)
			}
		}
		log.Printf("message sent to %d clients", len(clientSet))
	}
}

客户端示例代码 #

package main

import (
	"log"
	"net"
)

func main() {
	serverAddr, err := net.ResolveUnixAddr("unixgram", "multicast.sock")
	if err != nil {
		panic(err)
	}

	// 客户端绑定临时路径的Unixgram套接字，用于接收服务端推送
	conn, err := net.DialUnix("unixgram", nil, serverAddr)
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	// 发送订阅请求
	_, err = conn.Write([]byte("subscribe"))
	if err != nil {
		panic(err)
	}

	buf := make([]byte, 1024)
	for {
		n, err := conn.Read(buf)
		if err != nil {
			panic(err)
		}
		log.Printf("received server message: %s", string(buf[:n]))
	}
}

关键注意点 #

• 不需要提前手动创建套接字文件，ListenUnixgram会自动在指定路径生成正确类型的Unix域套接字，你只需要在启动服务前删除路径下可能残留的旧套接字文件即可，禁止用Mkfifo创建FIFO文件占用路径。
• Unix域DGRAM套接字通信时，接收方必须绑定一个可访问的路径地址，发送方才能将报文投递到对应地址，因此客户端不能使用完全匿名的套接字连接服务端。
• 如果需要更高效的多播能力，不建议使用Unix域套接字，可以考虑本地回环的UDP多播，或者使用消息队列、共享内存等IPC机制。

内容的提问来源于stack exchange，提问作者raspi