写一个项目上python 线程池modbustcp连接多个设备读写

好的，我来为你详细解答。

首先，我们需要导入相关的模块：

import threading
import queue
import time
from pymodbus.client.sync import ModbusTcpClient

接着，我们需要定义一些全局变量：

SERVER_IP = '192.168.1.100' # 服务器IP地址
SERVER_PORT = 502 # 服务器端口
DEVICE_IDS = [1, 2, 3] # 设备ID列表
READ_ADDRS = [0, 10, 20] # 读取地址列表
WRITE_ADDRS = [0, 10, 20] # 写入地址列表
READ_DATA = [0]*len(READ_ADDRS) # 读取数据列表
WRITE_DATA = [1]*len(WRITE_ADDRS) # 写入数据列表
THREAD_NUM = 3 # 线程池大小

其中，SERVER_IP 和 SERVER_PORT 分别为服务器的IP地址和端口，DEVICE_IDS 为需要连接的设备ID列表，READ_ADDRS 和 WRITE_ADDRS 分别为需要读取和写入的地址列表，READ_DATA 和 WRITE_DATA 分别为读取和写入的数据列表，THREAD_NUM 为线程池大小。

接下来，我们需要定义一个连接Modbus TCP服务器的函数：

def connect_to_server():
    client = ModbusTcpClient(SERVER_IP, port=SERVER_PORT)
    client.connect()
    return client

然后，我们需要定义一个读取数据的函数：

def read_data(device_id, read_addr, read_data):
    client = connect_to_server()
    data = client.read_holding_registers(read_addr, len(read_data), unit=device_id)
    client.close()
    if data.isError():
        print(f"Device {device_id} read error: {data}")
        return False
    else:
        for i in range(len(read_data)):
            read_data[i] = data.registers[i]
        print(f"Device {device_id} read successfully: {read_data}")
        return True

在这个函数中，我们首先连接到Modbus TCP服务器，然后使用设备ID读取指定地址的数据，并将结果保存到全局变量 READ_DATA 中。如果读取成功，则打印读取成功的信息并返回 True；否则，打印错误信息并返回 False。

接下来，我们需要定义一个写入数据的函数：

def write_data(device_id, write_addr, write_data):
    client = connect_to_server()
    response = client.write_registers(write_addr, write_data, unit=device_id)
    client.close()
    if response.isError():
        print(f"Device {device_id} write error: {response}")
        return False
    else:
        print(f"Device {device_id} write successfully: {write_data}")
        return True

在这个函数中，我们首先连接到Modbus TCP服务器，然后使用设备ID写入指定地址的数据，并将写入的数据保存到全局变量 WRITE_DATA 中。如果写入成功，则打印写入成功的信息并返回 True；否则，打印错误信息并返回 False。

接下来，我们需要定义一个线程函数：

def worker():
    while True:
        task = task_queue.get()
        if task is None:
            break
        device_id, task_type, addr, data = task
        if task_type == 'read':
            read_data(device_id, addr, data)
        elif task_type == 'write':
            write_data(device_id, addr, data)
        task_queue.task_done()

在这个函数中，我们首先从任务队列中获取任务，然后根据任务类型调用相应的函数。最后，标记任务为已完成。

最后，我们定义一个主函数：

if __name__ == '__main__':
    task_queue = queue.Queue()
    threads = []
    for i in range(THREAD_NUM):
        t = threading.Thread(target=worker)
        t.start()
        threads.append(t)
    for device_id in DEVICE_IDS:
        for addr in READ_ADDRS:
            task_queue.put((device_id, 'read', addr, READ_DATA))
        for addr in WRITE_ADDRS:
            task_queue.put((device_id, 'write', addr, WRITE_DATA))
    task_queue.join()
    for i in range(THREAD_NUM):
        task_queue.put(None)
    for t in threads:
        t.join()

在这个函数中，我们首先创建一个任务队列和多个线程，然后将读取和写入任务依次加入任务队列。接着，等待所有任务执行完成后，关闭所有线程。

这样，我们就成功地实现了在Python中使用线程池连接多个设备并进行读写操作的功能。