通过脚本与Unix-domain Socket通信：写入总线错误排查求助

Bash 调试命令 #

如果简单的echo无法和Unix Socket通信，推荐用以下工具：

• socat：功能强大的套接字调试工具，支持Unix Socket交互
  • 交互式连接：socat UNIX-CONNECT:/path/to/your/socket -
  • 管道发送数据：echo "test_message" | socat UNIX-CONNECT:/path/to/your/socket -
• netcat（nc）：部分版本支持Unix Socket，使用方式：
  • 交互式连接：nc -U /path/to/your/socket

调试时先检查Socket文件权限：ls -l /path/to/your/socket，确保当前用户有读写权限。

Python 实现Unix Socket通信 #

标准库 socket（无需额外安装） #

Python标准库的socket模块原生支持Unix Socket，足够满足基础调试需求，示例脚本：

import socket

SOCKET_PATH = "/path/to/your/target/socket"

def communicate_with_unix_socket(message):
    sock = None
    try:
        # 创建AF_UNIX类型的套接字
        sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
        sock.connect(SOCKET_PATH)
        
        # 发送数据（注意需转为字节）
        sock.sendall(message.encode('utf-8'))
        print(f"已发送数据: {message}")
        
        # 接收响应（按需调整缓冲区大小）
        response = sock.recv(4096)
        if response:
            print(f"收到响应: {response.decode('utf-8')}")
    except Exception as e:
        print(f"通信错误: {str(e)}")
    finally:
        if sock:
            sock.close()

# 测试调用
communicate_with_unix_socket("Hello Unix Socket")

易用的第三方包 #

如果需要更简洁的API或高级功能（如异步通信），可以考虑：

• asyncio：Python3.4+内置的异步库，适合异步Unix Socket通信，示例：

import asyncio

async def async_unix_socket_client(message, socket_path):
    reader, writer = await asyncio.open_unix_connection(socket_path)
    
    writer.write(message.encode('utf-8'))
    await writer.drain()
    print(f"已发送: {message}")
    
    data = await reader.read(4096)
    print(f"收到响应: {data.decode()}")
    
    writer.close()
    await writer.wait_closed()

# 运行异步任务
asyncio.run(async_unix_socket_client("Async test message", "/path/to/your/socket"))

• pysocks：API简洁，支持Unix Socket操作，安装后使用：

import socks
import socket

sock = socks.socksocket(socket.AF_UNIX, socket.SOCK_STREAM)
sock.connect("/path/to/your/socket")
sock.send(b"Test data")
response = sock.recv(1024)
print(f"收到响应: {response.decode()}")
sock.close()

总线错误排查提示 #

总线错误通常和以下因素有关：

• Socket文件不存在或路径错误
• 客户端无Socket文件的读写权限
• 服务端未正确处理客户端发送的数据（如内存访问错误）
  调试时可以先通过Bash工具确认连接是否正常，再逐步排查数据格式是否符合服务端要求。

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