树莓派上Python evdev摇杆数据与Java游戏的快速传输方案咨询

针对你的摇杆数据实时传输需求，以下几个本地进程通信方案比文件读写高效得多，适合游戏场景：

1. Unix域套接字（推荐） #

这是本地进程间通信的首选方案，比TCP套接字快很多（不用走网络协议栈），延迟极低，适合实时游戏。

Python端（摇杆数据发送） #

import socket
import os

# 定义套接字文件路径
SOCKET_PATH = "/tmp/joystick_socket"

# 清理旧的套接字文件
try:
    os.unlink(SOCKET_PATH)
except OSError:
    if os.path.exists(SOCKET_PATH):
        raise

# 创建并启动Unix域套接字服务
server = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
server.bind(SOCKET_PATH)
server.listen(1)

conn, _ = server.accept()
print("Java程序已连接")

# 替换为你的evdev摇杆数据读取逻辑
while True:
    # 示例：模拟摇杆按钮和轴数据
    joystick_data = "BTN_UP:1;AXIS_X:0.35\n"
    conn.sendall(joystick_data.encode('utf-8'))
    # 根据实际需求调整发送频率，避免过度占用资源
    # time.sleep(0.01)

Java端（数据接收处理） #

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
import java.nio.charset.StandardCharsets;

public class JoystickReceiver {
    public static void main(String[] args) throws Exception {
        String socketPath = "/tmp/joystick_socket";
        try (Socket socket = new Socket(socketPath)) {
            BufferedReader reader = new BufferedReader(
                new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8)
            );
            String dataLine;
            while ((dataLine = reader.readLine()) != null) {
                // 解析数据并调用你的游戏逻辑
                System.out.println("收到摇杆数据: " + dataLine);
            }
        }
    }
}

2. 命名管道（FIFO） #

Linux原生的进程通信方式，实现简单，读写效率高，适合实时性要求高的场景。

Python端（写入管道） #

import os

FIFO_PATH = "/tmp/joystick_fifo"

# 创建命名管道
if not os.path.exists(FIFO_PATH):
    os.mkfifo(FIFO_PATH)

# 持续写入摇杆数据
with open(FIFO_PATH, 'w') as fifo:
    while True:
        joystick_data = "BTN_UP:1;AXIS_X:0.35\n"
        fifo.write(joystick_data)
        fifo.flush()  # 强制刷新缓冲区，确保Java能立即收到
        # time.sleep(0.01)

Java端（读取管道） #

import java.io.BufferedReader;
import java.io.FileReader;
import java.nio.charset.StandardCharsets;

public class JoystickPipeReader {
    public static void main(String[] args) throws Exception {
        String fifoPath = "/tmp/joystick_fifo";
        try (BufferedReader reader = new BufferedReader(
            new FileReader(fifoPath, StandardCharsets.UTF_8)
        )) {
            String dataLine;
            while ((dataLine = reader.readLine()) != null) {
                System.out.println("收到摇杆数据: " + dataLine);
                // 处理游戏逻辑
            }
        }
    }
}

3. 共享内存（极致速度） #

如果追求零拷贝的极致速度，共享内存是最优选择，进程直接访问同一块内存区域，但需要额外处理数据同步问题。

Python端（写入共享内存） #

import mmap
import os
import struct

SHM_PATH = "/tmp/joystick_shm"
SHM_SIZE = 1024  # 足够存储摇杆数据的内存大小

# 创建共享内存文件
with open(SHM_PATH, 'wb') as f:
    f.write(b'\x00' * SHM_SIZE)

# 映射内存并写入数据
with open(SHM_PATH, 'r+b') as f:
    shm = mmap.mmap(f.fileno(), SHM_SIZE, access=mmap.ACCESS_WRITE)
    while True:
        # 用struct打包数据：按钮状态（int）+ X轴值（float）
        data = struct.pack('if', 1, 0.35)
        shm.seek(0)
        shm.write(data)
        shm.flush()
        # time.sleep(0.01)

Java端（读取共享内存） #

import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

public class JoystickSharedMemory {
    public static void main(String[] args) throws Exception {
        String shmPath = "/tmp/joystick_shm";
        try (RandomAccessFile file = new RandomAccessFile(shmPath, "rw")) {
            MappedByteBuffer buffer = file.getChannel()
                .map(FileChannel.MapMode.READ_WRITE, 0, 1024);
            while (true) {
                buffer.position(0);
                int btnState = buffer.getInt();
                float axisX = buffer.getFloat();
                System.out.printf("按钮状态: %d, X轴值: %.2f%n", btnState, axisX);
                // 处理游戏逻辑
                Thread.sleep(10); // 避免过度轮询
            }
        }
    }
}

方案选择建议 #

• 优先选Unix域套接字：兼顾简单性和高效性，无需额外处理同步；
• 追求极简实现选命名管道；
• 极致速度需求选共享内存，但要注意用标志位或信号量保证数据完整性。

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