Modbus 数据传输的方式,可以简单地理解成打电话。并且是单向通信的打电话
主机发送数据,首先需要从机的电话号码(区分每个从机,每个地址必须唯一),告诉从机打电话要干什么事情,然后是需要发送的内容,最后再问问从机,我说的话你都听清楚了没有呀,没有听错吧?
然后从机这里,得到了主机打过来的电话,从机回复主机需要的内容,主机得到从机数据,这样就是一个主机到从机的通信过程
忘记从哪找的了hhh
从机存储数据 -> 存储区
Modbus 协议规定了 4 个存储区,分别是 0 1 3 4 区 其中 1 区和 4 区是可读可写,1 区和 3 区是只读
区号 | 名称 | 读写 | 地址范围 |
---|---|---|---|
0 区 | 输出线圈 | 可读可写布尔量 | 00001-09999 |
1 区 | 输入线圈 | 只读布尔量 | 10001-19999 |
3 区 | 输入寄存器 | 只读寄存器 | 30001-39999 |
4 区 | 保持寄存器 | 可读可写寄存器 | 40001-49999 |
Modbus 给每个区都划分了地址范围,主机向从机获取数据时,只需要告诉从机数据的起始地址,还有获取多少字节的数据,从机就可以发送数据给主机
每一个从机,都有实际的物理存储,跟 modbus 的存储区相对应,主机读写从机的存储区,实际上就是对从机设备对应的实际存储空间进行读写
报文帧结构
> | > | > | MBAP 报文头(7 bytes) | > | 协议数据单元(PDU) |
---|---|---|---|---|---|
事务处理标识符 | 协议标识符 | 长度 | 单元标识符 | 功能码 | 数据 |
2 bytes | 2 bytes | 2 bytes | 1 byte | 1 byte | N bytes |
MBAP 报文头
域 | 长度 | 说明 | 客户机 | 服务器 |
---|---|---|---|---|
事务处理标识符 | 2 字节 | Modbus 请求/响应事务处理的标识 | 客户机启动 | 复制响应 |
协议标识符 | 2 字节 | 0=Modbus 协议 | 客户机启动 | 复制响应 |
长度 | 2 字节 | 长度之后的字节总数 | 客户机启动 | 服务器启动 |
单元标识符 | 1 字节 | 串行链路或其它总线的从站识别 | 客户端启动 | 复制响应 |
事务处理标识符 and 协议标识符 正常使用设置为 0 即可,长度为 4 个字节 -> 0x00000000
功能码
功能码 | 功能说明 |
---|---|
01H | 读取输出线圈 |
02H | 读取输入线圈 |
03H | 读取保持寄存器 |
04H | 读取输入寄存器 |
05H | 写入单线圈 |
06H | 写入单寄存器 |
0FH | 写入多线圈 |
10H | 写入多寄存器 |
每次可读数据最长长度(260 字节 - 9 字节 = 251 字节)
> | > | 返回报文编码格式详解 |
---|---|---|
字节位 | 结构 | 编码格式 |
前 6 个字节 | 事务/协议和数据长度 | ‘>HHH’ |
第 7 个字节 | 单元标识 | ‘>B’ |
第 8 个字节 | 功能码 | ‘>B’ |
第 9 个字节 | 数据长度 | ‘>B’ |
剩余字节 | 数据 | data_format(default or 自定义) |
timestamp | lon | lat | cog |
---|---|---|---|
1651924800 | 108.6030967 | 20.57094167 | 169.9 |
1651925400 | 108.6061227 | 20.56535943 | 170.7 |
1651926000 | 108.6091487 | 20.5597772 | 171.7 |
1651926600 | 108.6121746 | 20.55419496 | 143.8 |
1651927200 | 108.6152006 | 20.54861273 | 203.8 |
1651927800 | 108.6182266 | 20.5430305 | 207.8 |
1651928400 | 108.6212526 | 20.53744826 | 181.4 |
1651929000 | 108.6242786 | 20.53186603 | 180.6 |
1651929600 | 108.6273046 | 20.52628379 | 179.2 |
1651930200 | 108.6303306 | 20.52070156 | 172.9 |
1651930800 | 108.6333566 | 20.51511933 | 172.6 |
1651931400 | 108.6363826 | 20.50953709 | 173 |
import modbus_tk
import modbus_tk.defines as cst
from modbus_tk import modbus_tcp, hooks
import numpy as np
import pandas as pd
master = modbus_tcp.TcpMaster()
master.set_timeout(5.0)
print("connected")
# 连接从站读取数据,一次最多读取125个寄存器,由于2个寄存器为一个数据,故 size 设置为124
data = [] # 存放读取的数据
data += master.execute( # 向从站发报文读取[0,123]区间的寄存器数据
1, # 从站标识符
cst.READ_HOLDING_REGISTERS, # 功能码
0, # 起始寄存器地址
124, # 读取的寄存器数量
data_format='62f', # 数据解码格式
)
data += master.execute( # 向从站发送报文读取[124,247]区间的寄存器数据
1, cst.READ_HOLDING_REGISTERS, 124, 124, data_format='62f'
)
# 将数据保存到csv文件中
if len(data) % 4 != 0: # 如果数据长度不是4的倍数,则用 0 补齐
for i in range(0, 4 - len(data) % 4):
data.append(0)
data = np.reshape(data, (-1, 4)) # 将数据重新转为4列的二维数组
# print(data, data.shape) # 打印数据
df = pd.DataFrame(
data, columns=['timestamp', 'lon', 'lat', 'cog']
) # 将数据转为DataFrame,设置列名
df.to_csv('data_recv.csv', index=False) # 将数据保存到csv文件中
Modbus Error: Exception code = 3
: 看看是不是接收的数据超出最大长度了
struct.error: unpack requires a buffer of xx bytes
: 如果在master.execute()
时设置了data_format
,注意data_format
必须与接收到的数据长度匹配!
data_format
必须为'6f'
modbut_tk
库已经集成好了这些功能,所有从站的代码非常简单。pi_bytes = [int(a_byte) for a_byte in struct.pack("f", num)]
pi_register1 = pi_bytes[0] * 256 + pi_bytes[1]
pi_register2 = pi_bytes[2] * 256 + pi_bytes[3]
registers_list.append(pi_register1)
registers_list.append(pi_register2)
import sys
import modbus_tk
import modbus_tk.defines as cst
from modbus_tk import modbus_tcp, hooks
import struct
import pandas as pd
'''
可使用的函数:
创建从站: server.add_slave(slave_id)
slave_id(int):从站id
为从站添加存储区: slave.add_block(block_name, block_type, starting_address, size)
block_name(str):block名
block_type(int):block类型,COILS = 1,DISCRETE_INPUTS = 2,HOLDING_REGISTERS = 3,ANALOG_INPUTS = 4
starting_address(int):起始地址
size(int):block大小
设置block值:slave.set_values(block_name, address, values)
block_name(str):block名
address(int):开始修改的地址
values(a list or a tuple or a number):要修改的一个(a number)或多个(a list or a tuple)值
获取block值:slave.get_values(block_name, address, size)
block_name(str):block名
address(int):开始获取的地址
size(int):要获取的值的数量
'''
# 创建从站总服务器
server = modbus_tcp.TcpServer(address='127.0.0.1') # address必须设置,port默认为502
print("running...")
print("enter 'quit' for closing the server")
server.start()
# 创建从站
slave_1 = server.add_slave(1) # slave_id = 1
# 为从站添加存储区
slave_1.add_block(
'0', cst.HOLDING_REGISTERS, 0, 1200
) # block_name = '0', block_type = cst.HOLDING_REGISTERS, starting_address = 0, size = 1200
# 将数据存入寄存器
data = pd.read_csv('modbus_tcp.csv').values # 读取数据data
num_array = data.flatten() # 将data压为一维数组
registers_list = [] # 要存入寄存器的数据
# 将数据转化为32位float格式,每个数据4个字节 -> 占2个寄存器
for num in num_array:
pi_bytes = [int(a_byte) for a_byte in struct.pack("f", num)]
pi_register1 = pi_bytes[0] * 256 + pi_bytes[1]
pi_register2 = pi_bytes[2] * 256 + pi_bytes[3]
registers_list.append(pi_register1)
registers_list.append(pi_register2)
slave_1.set_values(
'0', 0, registers_list
) # 将数据存入寄存器, block_name = '0', address = 0, values = registers_list
while True:
cmd = sys.stdin.readline() # input
args = cmd.split(' ') # 按空格分割输入
if cmd.find('quit') == 0: # 指令 quit -> 退出服务器
print('bye-bye')
break
while True
),当主站发送请求时,从站就会自动处理请求def on_before_connect(args):
'''
钩子函数,连接前输出主站信息
Args:
args (tuple): (self(主站对象),)
'''
master = args[0]
print("host: {0},port: {1}".format(master._host, master._port))
hooks.install_hook("modbus_tcp.TcpMaster.before_connect", on_before_connect)
def on_after_recv(args):
'''
钩子函数,在收到报文后输出报文总长度
Args:
args (tuple): (self(主站对象), response(从站返回的数据))
'''
response = args[1]
print("{0} bytes received".format(len(response)))
hooks.install_hook("modbus_tcp.TcpMaster.after_recv", on_after_recv)
args
是一个元组,是主站/从站在执行完某个操作,如发送数据,后使用hook函数时传入的参数,元祖中包含的参数不固定,可以自己查看源码hooks.install_hook('触发hook函数的操作名',函数名)
modbus_tk.hooks
中定义了哪些操作可以触发hook
,具体请自行查看源码!有问题随时留言!