yudao
/
spring-cloud
mirror of https://gitee.com/zhijiantianya/yudao-cloud.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

【同步】BOOT 和 CLOUD 的功能（IoT）

pull/244/head
YunaiV 2026-02-14 16:52:20 +08:00
parent 6ca2c97849
commit 1fca0acc92
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
yudao-module-iot/yudao-module-iot-gateway/src/test/java/cn/iocoder/yudao/module/iot/gateway/protocol/modbus/ModbusRtuOverTcpDemo.java
View File

@ -6,6 +6,8 @@ import com.ghgande.j2mod.modbus.procimg.*;
import com.ghgande.j2mod.modbus.slave.ModbusSlave; import com.ghgande.j2mod.modbus.slave.ModbusSlave;
import com.ghgande.j2mod.modbus.slave.ModbusSlaveFactory; import com.ghgande.j2mod.modbus.slave.ModbusSlaveFactory;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket; import java.net.ServerSocket;
import java.net.Socket; import java.net.Socket;
@ -156,8 +158,8 @@ public class ModbusRtuOverTcpDemo {
private static void bridge(Socket src, Socket dst) { private static void bridge(Socket src, Socket dst) {
try { try {
byte[] buf = new byte[1024]; byte[] buf = new byte[1024];
var in = src.getInputStream(); InputStream in = src.getInputStream();
var out = dst.getOutputStream(); OutputStream out = dst.getOutputStream();
int len; int len;
while ((len = in.read(buf)) != -1) { while ((len = in.read(buf)) != -1) {
out.write(buf, 0, len); out.write(buf, 0, len);