ModbusTCP的简单实现读取和写寄存器值

pidtfork

1. 
   
2. /**
   
3. * @description ModbusTCP 的简单实现,读取和写寄存器值,并将寄存器状态值本地保存
   
4. *              当某地址的寄存器值变化后触发 event 函数处理
   
5. * @author pidtfork
   
6. * @date 2021-08-30
   
7. * @param {String} address  从机或网关的IP地址
   
8. * @param {Number|String} port 从机或网关的端口 (协议默认为502)
   
9. * @param {Number} slaveID  从机或网关的 ID
   
10. */
    
11. function ModbusTCP(address, port, slaveID) {
    
12.     this.msgID = 0;
    
13.     this.version = "\x00\x00";
    
14.     this.slaveID = slaveID || 1;
    
15.     this.statusList = {};
    
16.     var self = this;
    
17.     // 1 事务处理标识   两个字节高字节在前
    
18.     // 2 协议标识       两个字节高字节在前
    
19.     // 3 长度           两个字节高字节在前
    
20.     // 4 单元标识       1个字节0x00 ¡ 0xff
    
21.     // 6 功能码         1个字节0x03
    
22.     // 7 起始寄存器地址 两个字节高字节在前
    
23.     // 8 寄存器个数     两个字节高字节在前
    
24.     this.read = function (addr) {
    
25.         var len = arguments[1] || 1;
    
26.         // 事务标识用用要读的寄存器起始地址为标识,方便响应数据处理
    
27.         // 读寄存器 第一个长度固定为6
    
28.         var code = this.doubleByte(addr) + this.version + this.doubleByte(6);
    
29.         code = code + this.byte(this.slaveID) + "\x03";
    
30.         code = code + this.doubleByte(addr) + this.doubleByte(len);
    
31.         // 发送数据
    
32.         dev.sendCodeString(code);
    
33.     }
    
34.     // 寄多个存器地址, 数组类型数值
    
35.     // 1 事务处理标识两个字节高字节在前
    
36.     // 2 协议标识两个字节高字节在前
    
37.     // 3 长度两个字节高字节在前
    
38.     // 4 单元标识1个字节0x00 ¡ 0xff
    
39.     // 5 功能码1个字节0x10
    
40.     // 6 起始寄存器地址两个字节高字节在前
    
41.     // 7 寄存器个数两个字节　高字节在前
    
42.     // 8 数据长度　1个字节　寄存器个数£2　
    
43.     // 9 数据寄存器个数£2个字节每个寄存器高字节在前
    
44.     this.write = function (addr, arrValue) {
    
45.         var len = arrValue.length * 2;
    
46.         var code = this.getMsgID() + this.version + this.doubleByte(len + 7);
    
47.         code = code + this.byte(this.slaveID) + "\x10";
    
48.         code = code + this.doubleByte(addr) + this.doubleByte(arrValue.length) + this.byte(len);
    
49.         for (var i = 0; i < arrValue.length; i++) {
    
50.             var element = arrValue[i];
    
51.             code = code + this.doubleByte(element);
    
52.         }
    
53.         // 发送数据
    
54.         dev.sendCodeString(code);
    
55.     }
    
56.     this.getMsgID = function () {
    
57.         if (this.msgID > 0xFFFE) {
    
58.             this.msgID = 0;
    
59.         }
    
60.         this.msgID++;
    
61.         return this.doubleByte(this.msgID);
    
62.     }
    
63.     this.byte = function (value) {
    
64.         return String.fromCharCode(value);
    
65.     }
    
66.     this.doubleByte = function (value) {
    
67.         if (value > 255) {
    
68.             return this.byte(value >> 8) + this.byte(value & 0xFF);
    
69.         }
    
70.         return "\x00" + this.byte(value);
    
71.     }
    
72.     this.emit = function (addr, value) {
    
73.         if (self.statusList[addr] != value) {
    
74.             self.event(addr, value, self.statusList[addr] || 0);
    
75.             self.statusList[addr] = value;
    
76.         }
    
77.     }
    
78.     this.event = function (addr, value, old) { }
    
79.     var receiveData = function (data) {
    
80.         //任何响应都应大于10个字节
    
81.         if (data.length > 10) {
    
82.             var id = data.charCodeAt(6);
    
83.             var funCode = data.charCodeAt(7);
    
84.             // id为当前设备ID,功能码为读取寄存器状态的响应时处理数据
    
85.             if (id == self.slaveID && funCode == 3) {
    
86.                 // 每个寄存器的数据长度为2个字节 number 为寄存器个数
    
87.                 var number = data.charCodeAt(8) / 2;
    
88.                 // 事务标识为读寄存器的起始地址
    
89.                 var startAddr = data.charCodeAt(0) * 256 + data.charCodeAt(1);
    
90.                 var index = 9, addr, value;
    
91.                 for (var i = 0; i < number; i++) {
    
92.                     value = data.charCodeAt(index) * 256 + data.charCodeAt(index + 1);
    
93.                     addr = startAddr + i;
    
94.                     index = index + 2;
    
95.                     self.emit(addr, value)
    
96.                 }
    
97.             }
    
98.         }
    
99.     }
    
100.     var dev = new _TCP(address + ":" + port, receiveData);
     
101. }
     
102. 
     
103. 
     
104. //开始使用
     
105. 
     
106. // 实例化 ModbusTCP 传入 从机的IP地址和服务端口,从机的ID值
     
107. var devMode = new ModbusTCP('192.168.25.1', 502, 1);
     
108. 
     
109. 
     
110. // 定时 1S 查询某地址寄存器的值
     
111. // 这里是现场有面板可以改变这个寄存器的值,所以这里做一下同步
     
112. // 定时去读取寄存器地址的值
     
113. setInterval(1, function () {
     
114.     // 读取 从寄存器地址 10005 开始,读 3个 寄存器的值
     
115.     // 即 读 10005 10006 10007 三个寄存器的值
     
116.     // 地址值为10进制值,如果是16进制请先转换
     
117.     devMode.read(10005, 3);
     
118. })
     
119. 
     
120. //写寄存器值时,第一个参数为寄存器地址 地址值为10进制值,如果是16进制请先转换
     
121. // 参数2 必须为数组, 可以连续写多个寄存器,
     
122. // 参数2 即使写一个值也必须为数组
     
123. 
     
124. // devMode.write(10005,[1]); // 写寄存器值,将地址10005值设置为1
     
125. // devMode.write(10006,[1]); // 写寄存器值,将地址10006值设置为1
     
126. // devMode.write(10007,[1]); // 写寄存器值,将地址10007值设置为1
     
127. // devMode.write(10005,[0]); // 写寄存器值,将地址10005值设置为0
     
128. // devMode.write(10006,[0]); // 写寄存器值,将地址10006值设置为0
     
129. // devMode.write(10007,[0]); // 写寄存器值,将地址10007值设置为0
     
130. 
     
131. // devMode.write(10005,[1,1,1]); // 将地址10005 10006 10007值都设置为1
     
132. // devMode.write(10005,[1,0,1]); // 将地址10005 10007值设置为1 10006 设置为0
     
133. 
     
134. 
     
135. // 重写 event  方法, 此方法 读到 在寄存器地址的值变化后主动触发执行
     
136. // event 方法可接收3 个参数
     
137. // 参数1 addr 为 寄存器地址
     
138. // 参数2 value 为 此寄存器的当前值
     
139. // 参数3 old 为 此寄存器的上一次的值
     
140. // 例如 devMode.read(10005, 3); 读取到 10005/10006/10007值都变化时 devMode.event 调用3次
     
141. devMode.event = function (addr, value, old) {
     
142.     switch (addr) {
     
143.         case 10005:
     
144.             if (value) {
     
145.                 setButtonImage("AWM1", "ImageOnStates.png")
     
146.             } else {
     
147.                 setButtonImage("AWM1", "ImageOffStates.png")
     
148.             }
     
149.             break;
     
150.         case 10006:
     
151.             if (value) {
     
152.                 setButtonImage("AWM2", "ImageOnStates.png")
     
153.             } else {
     
154.                 setButtonImage("AWM2", "ImageOffStates.png")
     
155.             }
     
156.             break;
     
157.         case 10007:
     
158.             if (value) {
     
159.                 setButtonImage("AWM3", "ImageOnStates.png")
     
160.             } else {
     
161.                 setButtonImage("AWM3", "ImageOffStates.png")
     
162.             }
     
163.             break;
     
164.         default:
     
165.             break;
     
166.     }
     
167. }

复制代码

附件为此帖子的js文件和modbus tcp协议说明