MQTT を使用し、インターネット経由でマウスを遠隔操作｜ Raspberry Pi Zero 2 W を USB マウスに変える（記事第 3 弾）

sudo chmod 644 /home/pi/emqxsl-ca.crt

# mqtt-tx.py: キーボードのイベントをMQTTブローカーに送信するプログラム
import evdev
import paho.mqtt.client as mqtt
import json

# MQTTブローカーの設定
MQTT_BROKER = 'xxxx1234.ala.asia-southeast1.emqxsl.com'
MQTT_PORT = 8883
MQTT_TOPIC = 'keyboard/movement'
MQTT_USER = 'zero-1'
MQTT_PASSWORD = 'password'
MQTT_CAFILE = '/home/pi/emqxsl-ca.crt'

# MQTTクライアントの設定
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASSWORD)
client.tls_set(MQTT_CAFILE, tls_version=mqtt.ssl.PROTOCOL_TLSv1_2)
client.connect(MQTT_BROKER, MQTT_PORT, 60)

# デバイスのevent番号を指定（キーボードのイベントデバイス）
device = evdev.InputDevice('/dev/input/event0')

# キーボードイベントの読み取りと送信
try:
    for event in device.read_loop():
        if event.type == evdev.ecodes.EV_KEY:
            # データの送信 (JSON形式)
            data = json.dumps({'type': event.type, 'code': event.code, 'value': event.value})
            client.publish(MQTT_TOPIC, data)
            print(f"Sent: {data}")  # 送信したデータを表示
except Exception as e:
    print(f"An error occurred: {e}")
finally:
    client.disconnect()

# mqtt-rx.py - MQTTメッセージを受信して、マウスの移動やクリックを行う
import paho.mqtt.client as mqtt
import json
import sys
import termios
import tty

# MQTTブローカーの設定
MQTT_BROKER = 'xxxx1234.ala.asia-southeast1.emqxsl.com'
MQTT_PORT = 8883
MQTT_TOPIC = 'keyboard/movement'
MQTT_USER = 'zero-2'
MQTT_PASSWORD = 'password'
MQTT_CAFILE = '/home/pi/emqxsl-ca.crt'

# HIDファイルのパス
MOUSE_DEV = "/dev/hidg0"

# 初期設定
movement_amount = 10
min_movement = 1
max_movement = 127

# MQTTメッセージのコールバック関数
def on_message(client, userdata, msg):
    global movement_amount  # ここでグローバル変数として宣言

    try:
        obj = json.loads(msg.payload)
        if obj['type'] == 1:  # EV_KEY
            if obj['value'] in (1, 2):  # キーが押された、または押し続けられている
                if obj['code'] == 103:  # 上方向キー
                    move_mouse(0, -movement_amount)
                elif obj['code'] == 108:  # 下方向キー
                    move_mouse(0, movement_amount)
                elif obj['code'] == 105:  # 左方向キー
                    move_mouse(-movement_amount, 0)
                elif obj['code'] == 106:  # 右方向キー
                    move_mouse(movement_amount, 0)
                elif obj['code'] == 44:  # Zキー
                    movement_amount = max(min_movement, movement_amount - 4)
                elif obj['code'] == 45:  # Xキー
                    movement_amount = min(max_movement, movement_amount + 4)
                elif obj['code'] == 30:  # Aキーで左クリック
                    move_mouse(0, 0, buttons=1)
                elif obj['code'] == 31:  # Sキーで右クリック
                    move_mouse(0, 0, buttons=2)
                elif obj['code'] == 16:  # Qキー
                    print("Q key pressed. Exiting...")
                    client.disconnect()
                    sys.exit()
            elif obj['value'] == 0:  # キーが離されたとき、クリックを解除
                if obj['code'] in (30, 31):  # AキーまたはSキー
                    move_mouse(0, 0, buttons=0)
        print(f"Received: {obj}")
    except json.JSONDecodeError:
        pass

# マウスの移動やクリックを送信する関数
def move_mouse(dx, dy, buttons=0):
    report = bytearray([buttons, dx & 0xFF, dy & 0xFF])
    with open(MOUSE_DEV, "wb") as f:
        f.write(report)

# MQTTクライアントの設定
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASSWORD)
client.tls_set(MQTT_CAFILE, tls_version=mqtt.ssl.PROTOCOL_TLSv1_2)
client.on_message = on_message

# MQTTブローカーに接続し、トピックを購読
client.connect(MQTT_BROKER, MQTT_PORT, 60)
client.subscribe(MQTT_TOPIC)

try:
    print("Waiting for MQTT messages...")
    client.loop_forever()
except KeyboardInterrupt:
    client.disconnect()
    print("終了しました。")

sudo apt-get install python3-paho-mqtt

pip3 install paho-mqtt

sudo python3 mqtt-tx.py

sudo python3 mqtt-rx.py