并行控制多个独立浏览器实例并模拟独立鼠标操作的教程

# follower_program.py (simplified)
from selenium import webdriver
from selenium.webdriver.common.action_chains import ActionChains

class BrowserFollower:
    def __init__(self, browser_id):
        self.browser_id = browser_id
        self.driver = self._initialize_driver()
        print(f"Follower {self.browser_id}: Browser initialized.")

    def _initialize_driver(self):
        # 可以配置不同的端口、用户数据目录等，以确保完全独立
        options = webdriver.ChromeOptions()
        # options.add_argument(f"--user-data-dir=/tmp/chrome_profile_{self.browser_id}")
        # options.add_argument("--headless") # 根据需要选择是否无头模式
        driver = webdriver.Chrome(options=options)
        return driver

    def execute_command(self, command):
        action = command.get("action")
        target = command.get("target")
        value = command.get("value")
        selector = command.get("selector")

        try:
            if action == "navigate":
                self.driver.get(value)
                print(f"Follower {self.browser_id}: Navigated to {value}")
            elif action == "click":
                element = self.driver.find_element_by_css_selector(selector)
                element.click()
                print(f"Follower {self.browser_id}: Clicked {selector}")
            elif action == "mouse_move_to_element":
                element = self.driver.find_element_by_css_selector(selector)
                ActionChains(self.driver).move_to_element(element).perform()
                print(f"Follower {self.browser_id}: Mouse moved to {selector}")
            elif action == "mouse_move_by_offset":
                x_offset = command.get("x_offset", 0)
                y_offset = command.get("y_offset", 0)
                ActionChains(self.driver).move_by_offset(x_offset, y_offset).perform()
                print(f"Follower {self.browser_id}: Mouse moved by ({x_offset}, {y_offset})")
            # ... 其他自动化操作
            else:
                print(f"Follower {self.browser_id}: Unknown action {action}")
        except Exception as e:
            print(f"Follower {self.browser_id}: Error executing {action} on {selector}: {e}")

    def close(self):
        self.driver.quit()
        print(f"Follower {self.browser_id}: Browser closed.")

# 实际运行时，每个 follower 进程会实例化一个 BrowserFollower
# follower = BrowserFollower("instance_1")
# follower.execute_command({"action": "navigate", "value": "https://www.google.com"})
# follower.close()

# leader_program.py (simplified with a hypothetical MQ client)
import json
import time
# from some_mq_client import MQProducer # 替换为实际的Kafka/RabbitMQ客户端

class LeaderProgram:
    def __init__(self, mq_producer_client):
        self.producer = mq_producer_client
        self.command_topic = "browser_commands"
        self.feedback_topic = "browser_feedback"

    def send_command(self, browser_id, action, **kwargs):
        command = {
            "browser_id": browser_id,
            "action": action,
            **kwargs
        }
        message = json.dumps(command).encode('utf-8')
        # self.producer.publish(self.command_topic, message, key=browser_id) # Kafka example with key for partitioning
        print(f"Leader: Sent command to {browser_id}: {command}")
        # In a real scenario, you'd send via your MQ client
        # For demonstration, we'll just print

    def run_automation_scenario(self):
        # 场景1: 浏览器1导航并点击
        self.send_command("browser_instance_1", "navigate", value="https://www.bing.com")
        time.sleep(2)
        self.send_command("browser_instance_1", "click", selector="#id_h") # 假设是搜索框

        # 场景2: 浏览器2导航并移动鼠标
        self.send_command("browser_instance_2", "navigate", value="https://www.baidu.com")
        time.sleep(3)
        self.send_command("browser_instance_2", "mouse_move_to_element", selector="#s_lg_img") # 假设是百度logo

        # 可以发送更多指令...

# Example usage (without actual MQ client for simplicity)
# producer = MQProducer(...) # Initialize your MQ producer
# leader = LeaderProgram(producer)
# leader.run_automation_scenario()

# follower_process_n.py (simplified with a hypothetical MQ client)
import json
# from some_mq_client import MQConsumer # 替换为实际的Kafka/RabbitMQ客户端
# Assuming BrowserFollower class is defined as above

def run_follower(browser_id):
    follower = BrowserFollower(browser_id)
    # consumer = MQConsumer(topic="browser_commands", group_id="browser_followers") # Kafka example
    print(f"Follower {browser_id}: Listening for commands...")

    try:
        # In a real scenario, this would be a loop consuming from MQ
        # For demonstration, we'll simulate receiving a few commands
        # For actual MQ, you'd use consumer.poll() or similar
        simulated_commands = [
            {"browser_id": browser_id, "action": "navigate", "value": "https://www.google.com"} if browser_id == "browser_instance_1" else None,
            {"browser_id": browser_id, "action": "click", "selector": "input[name='q']"} if browser_id == "browser_instance_1" else None,
            {"browser_id": browser_id, "action": "navigate", "value": "https://www.example.com"} if browser_id == "browser_instance_2" else None,
            {"browser_id": browser_id, "action": "mouse_move_by_offset", "x_offset": 50, "y_offset": 50} if browser_id == "browser_instance_2" else None,
        ]

        for cmd in simulated_commands:
            if cmd and cmd["browser_id"] == browser_id:
                print(f"Follower {browser_id}: Received command: {cmd}")
                follower.execute_command(cmd)
                time.sleep(1) # Simulate processing time

    except KeyboardInterrupt:
        print(f"Follower {browser_id}: Shutting down...")
    finally:
        follower.close()
        # consumer.close() # Close MQ consumer

if __name__ == "__main__":
    import sys
    if len(sys.argv) > 1:
        run_follower(sys.argv[1])
    else:
        print("Usage: python follower_process_n.py <browser_id>")

# To run:
# python follower_process_n.py browser_instance_1
# python follower_process_n.py browser_instance_2