如何将外部命令输出绑定到Unix Socket？求可被外部客户端访问的实现示例

我来帮你搞定这个问题！你之前遇到的核心问题是UNIXSocket.pair创建的是匿名的进程间内部套接字对——它们并没有绑定到文件系统的可见路径上，所以外部客户端根本找不到连接的入口。下面给你一个完整的可行方案，把xkb-switch -W的实时输出转发到一个可被外部程序访问的Unix Socket上：

完整实现代码 #

require 'socket'

class XkbSocket
  def initialize(socket_path = '/tmp/xkb-switch.sock')
    @socket_path = socket_path
    # 清理残留的旧套接字文件，避免启动报错
    File.unlink(@socket_path) if File.exist?(@socket_path)

    # 创建可被外部访问的Unix服务器套接字
    @server = UNIXServer.new(@socket_path)
    # 设置套接字文件权限，允许其他用户连接（可根据需求调整为0600仅限当前用户）
    File.chmod(0666, @socket_path)

    # 程序退出时清理资源
    at_exit do
      @server.close if @server
      File.unlink(@socket_path) if File.exist?(@socket_path)
    end

    begin
      # 启动xkb-switch子进程并捕获其标准输出
      @child_stdout = IO.popen(["xkb-switch", "-W"], "r")
      pid = @child_stdout.pid

      # 启动线程处理客户端连接，实时转发输出
      Thread.new do
        loop do
          client = @server.accept
          # 把xkb-switch的输出逐行转发给客户端
          while line = @child_stdout.gets
            client.puts(line)
            client.flush
            # 客户端断开则停止转发
            break unless client.closed?
          end
          client.close
        end
      ensure
        Process.wait(pid) if pid
        @child_stdout.close if @child_stdout
      end
    rescue Errno::ENOENT
      # 如果xkb-switch不存在，给所有连接的客户端返回N/A
      Thread.new do
        loop do
          client = @server.accept
          client.puts("N/A")
          client.close
        end
      end
    end
  end
end

# 启动服务并保持运行
XkbSocket.new
sleep

关键设计点说明 #

• 用UNIXServer替代套接字对：UNIXServer.new(socket_path)会在文件系统上创建一个可见的套接字文件，外部客户端可以通过这个路径直接连接（比如UNIXSocket.new('/tmp/xkb-switch.sock')）。
• 资源清理机制：启动前删除旧套接字，退出时关闭服务器并删除套接字文件，避免资源残留。
• 实时输出转发：通过IO.popen捕获xkb-switch -W的标准输出，再用单独线程处理每个客户端连接，把输出实时转发过去。
• 权限控制：File.chmod(0666, @socket_path)让所有用户都能连接，如果你只希望当前用户访问，可以改成0600。
• 异常处理：如果系统中没有安装xkb-switch，捕获Errno::ENOENT异常，之后给所有连接的客户端返回"N/A"。

测试客户端示例 #

你可以用下面的代码测试这个服务：

require 'socket'
socket = UNIXSocket.new('/tmp/xkb-switch.sock')
puts "Connected to xkb-switch socket, waiting for layout changes..."
while line = socket.gets
  puts "Current keyboard layout: #{line.strip}"
end

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