Python写一个modbustcp连接多个设备的包

以下是一个Python实现的modbustcp连接多个设备的示例代码：

from pymodbus.client.sync import ModbusTcpClient
from concurrent.futures import ThreadPoolExecutor

class ModbusTcpManager:
    def __init__(self, device_list):
        self.device_list = device_list

    def read_data(self, device_info):
        ip, port, addr, reg_addr, reg_num = device_info
        client = ModbusTcpClient(ip, port)
        client.connect()
        result = client.read_holding_registers(reg_addr, reg_num, unit=addr)
        client.close()
        return result

    def read_all_data(self):
        with ThreadPoolExecutor(max_workers=len(self.device_list)) as executor:
            futures = [executor.submit(self.read_data, device_info) for device_info in self.device_list]
            results = [future.result() for future in futures]
        return results

这里定义了一个ModbusTcpManager类，该类接受一个设备列表device_list作为输入参数。设备列表中每个元素包含了modbus设备的IP地址、端口号、设备地址、寄存器地址和寄存器数量等信息。

在ModbusTcpManager类中，定义了read_data函数，该函数接受一个设备信息device_info作为输入参数，连接modbus设备并读取寄存器数据，最后返回读取的结果。然后，定义了read_all_data函数，该函数使用ThreadPoolExecutor创建多个线程，每个线程连接不同的modbus设备并读取寄存器数据。使用submit()方法提交任务后，将返回一个Future对象，该对象表示该任务的异步计算结果。使用result()方法获取异步计算结果，这里使用列表推导式获取所有线程的计算结果。最后，将结果返回。

使用该类，可以通过以下方式连接多个设备并读取寄存器数据：

DEVICE_LIST = [('127.0.0.1', 502, 1, 0, 10), ('192.168.1.100', 502, 2, 0, 10), ('10.0.0.1', 502, 3, 0, 10)]
manager = ModbusTcpManager(DEVICE_LIST)
results = manager.read_all_data()
print(results)

这里将设备列表传递给ModbusTcpManager类的构造函数，创建一个ModbusTcpManager实例manager。然后，调用manager的read_all_data函数，返回所有设备的寄存器数据。最后，将结果打印出来。