test1

messageClass.py

@@ -14,7 +14,7 @@ class ClickMessage:
             self.button = "right"
 
     def getMessage(self):
-        return json.dumps(self)
+        return json.dumps(self.__dict__)
 
 
 class ScrollMessage:
@@ -26,4 +26,4 @@ class ScrollMessage:
         self.dy = dy
 
     def getMessage(self):
-        return json.dumps(self)
+        return json.dumps(self.__dict__)

monitorTest.py

@@ -1,10 +1,15 @@
 #!/usr/bin/env python
 import os
-import pika
 import signal
 import sys
+import time
+
+import pika
+
 import queueFunc
+import win32Test
 
+middle_point, base_width, base_height = win32Test.arrange_windows()
 connection = pika.BlockingConnection(pika.ConnectionParameters(host='192.168.0.13', port=5672))
 channel = connection.channel()
 
@@ -12,6 +17,8 @@ channel = connection.channel()
 def callback(ch, method, properties, body):
     # 处理消息的逻辑
     print(f"Received message: {body.decode('utf-8')}")
+    print(time.time())
+
     # 执行其他操作，例如记录日志、更新数据库等
     queueFunc.handleMessage(properties, body)
     # 确认收到消息
@@ -21,11 +28,11 @@ def callback(ch, method, properties, body):
 def main():
     # 定义一个交换机（exchange）
     exchange_name = 'sync'
-    channel.exchange_declare(exchange=exchange_name, exchange_type='fanout', durable=True)
+    channel.exchange_declare(exchange=exchange_name, exchange_type='fanout',durable=True)
 
     # 定义一个队列
     queue_name = 'hello'
-    channel.queue_declare(queue=queue_name, durable=True)
+    channel.queue_declare(queue=queue_name)
 
     # 绑定队列到交换机
     routing_key = ''

queueFunc.py

@@ -7,23 +7,22 @@ mouseController = Controller()
 
 def handleMessage(properties, body):
     jsonObject = json.loads(body)
-    print(jsonObject)
-    print(time.time())
     if jsonObject['function'] == 0:
         on_click(jsonObject['x'], jsonObject['y'], jsonObject['button'])
     else:
         on_scroll(jsonObject['x'], jsonObject['y'], jsonObject['dx'], jsonObject['dy'])
 
 
-
 def on_click(x, y, button):
     mouseController.position = (x, y)
     if 'left' in button:
         print('w')
         mouseController.click(Button.left, 1)
+        time.sleep(0.1)
     else:
         print('2')
         mouseController.click(Button.right, 1)
+        time.sleep(0.1)
 
 
 def on_scroll(x, y, dx, dy):

win32Test.py

@@ -56,6 +56,10 @@ def arrange_windows():
 
     return middle_point, base_width, base_height
 
+
+# def arrange_windows_6():
+
+
 # arrange_windows()
 # Example usage:
 # Assume chrome_hwnds is a list of Chrome window handles