如何在Python中使用Unix套接字？

Question

我想为同一系统上的两个Python程序使用Unix套接字来相互通信。你知道吗

这里有绑定到套接字文件的示例：https://gist.github.com/jmhobbs/11276249

常用的socketserver库还有一个UnixStreamServer和一个UnixDatagramServer，听起来它也处理unix套接字，但是没有任何一个示例，据我所知，在初始化UnixStreamServer或UnixDatagramServer时，它需要一个IP和端口，而不是一个文件。你知道吗

UnixDatagramServer和UnixStreamServer是演示here的不同类型的unix套接字吗？或者我只是没有看到如何使用它们来正确地连接到套接字文件？有例子吗？为什么有人会像在我的链接中那样直接使用UnixDatagramServer/UnixStreamServer绑定到socket文件？你知道吗

当谈到IP套接字时，TCP/UDP之间的区别是有意义的——一个是可靠的，而另一个不是，没有开销。在一个套接字的世界里，我假设没有不可靠的通信，为什么还有两种不同的类型（数据报和流）？你知道吗

Answer 1

正如@green斗篷guy指出的，您可能希望使用管道，但是如果您打算使用Unix套接字，下面是一个使用StreamRequestHandler的粗略示例：

服务器：

#!/usr/bin/env python3

from socketserver import UnixStreamServer, StreamRequestHandler, ThreadingMixIn
import os

os.unlink("/tmp/test")

class Handler(StreamRequestHandler):
    def handle(self):
        while True:
            msg = self.rfile.readline().strip()
            if msg:
                print("Data Recieved from client is: {}".format(msg))
            else:
                return

class ThreadedUnixStreamServer(ThreadingMixIn, UnixStreamServer):
    pass

with ThreadedUnixStreamServer('/tmp/test', Handler) as server:
    server.serve_forever()

客户：

#!/usr/bin/env python3

import socket
import sys 
import time

with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as client:
    client.connect("/tmp/test")

    while True:
        client.send(b"Client 1: hi\n")
        time.sleep(1)

    client.close()

ThreadingMixIn不是必需的，但它允许您运行两个客户端，并同时从这两个客户端接收消息。将客户机代码复制到“client1.py”和“client2.py”中，并将client2.py中的“client1”更改为“client2”，同时运行这两个命令，以在实践中看到这一点。你知道吗

我不是专家，但听起来虽然管道效率更高，但它们的缺点是只有一个程序链接到另一个程序。如果您有多个客户机和一台服务器，那么Unix套接字（如本文所示）可能是您的最佳选择。你知道吗