package com.ruoyi.fuzhou.utils.waterdept;
|
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.fuzhou.utils.hj1239.StringToHexUtil;
|
import org.apache.ibatis.executor.ExecutorException;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.net.ServerSocket;
|
import java.net.Socket;
|
|
/**
|
* 水深数据接入
|
*/
|
public class ModbusWaterDeptUtils {
|
|
public static void main(String[] args) {
|
String value = getDept("0.0.0.0", 8320);
|
System.out.println(value);
|
}
|
/**
|
* @param ip ip
|
* @param port 端口
|
*/
|
public static String getDept(String ip, int port) {
|
// 服务端配置
|
String SERVER_IP = ip;// 监听所有网络接口
|
int SERVER_PORT = port;// 端口号
|
ServerSocket serverSocket = null;
|
try {
|
serverSocket = new ServerSocket(SERVER_PORT);
|
System.out.println("🛡️ 服务端已启动，正在监听 " + SERVER_IP + ":" + SERVER_PORT + "...");
|
serverSocket.setSoTimeout(8000);
|
Socket clientSocket = serverSocket.accept();
|
System.out.println("🔌 客户端已连接: " + clientSocket.getInetAddress().getHostAddress() + ":" + clientSocket.getPort());
|
try (InputStream inputStream = clientSocket.getInputStream()) {
|
// 接收设备响应
|
while (true) {
|
byte[] response = new byte[1024];
|
int bytesRead = inputStream.read(response);
|
if (bytesRead == -1) {
|
System.out.println("❌ 未收到设备响应");
|
return null;
|
}
|
// 打印响应数据
|
byte[] responseData = new byte[bytesRead];
|
System.arraycopy(response, 0, responseData, 0, bytesRead);
|
String resultData = bytesToHex(responseData);
|
System.out.println("📥 收到设备响应: " + StringToHexUtil.convertHexToString(resultData));
|
}
|
//return StringToHex.convertHexToString(resultData);
|
} catch (IOException e) {
|
System.out.println("⚠️ 客户端异常断开: " + e.getMessage());
|
} finally {
|
clientSocket.close();
|
}
|
} catch (IOException e) {
|
if (serverSocket != null) {
|
try {
|
System.out.println("设备不在线" + e.getMessage());
|
serverSocket.close();
|
} catch (IOException ex) {
|
System.out.println("❌ 服务端关闭失败: " + ex.getMessage());
|
}
|
} else {
|
System.out.println("❌ 服务端启动失败: " + e.getMessage());
|
}
|
}
|
return null;
|
}
|
|
/**
|
* @param ip ip
|
* @param port 端口
|
*/
|
public static String getWaterDept(String ip, int port) {
|
// 服务端配置
|
String SERVER_IP = ip;// 监听所有网络接口
|
int SERVER_PORT = port;// 端口号
|
ServerSocket serverSocket = null;
|
try {
|
serverSocket = new ServerSocket(SERVER_PORT);
|
System.out.println("🛡️ 服务端已启动，水深正在监听 " + SERVER_IP + ":" + SERVER_PORT + "...");
|
serverSocket.setSoTimeout(4000);
|
Socket clientSocket = serverSocket.accept();
|
System.out.println("🔌 客户端已连接: " + clientSocket.getInetAddress().getHostAddress() + ":" + clientSocket.getPort());
|
try (InputStream inputStream = clientSocket.getInputStream()) {
|
// 接收设备响应
|
byte[] response = new byte[1024];
|
int bytesRead = inputStream.read(response);
|
if (bytesRead == -1) {
|
System.out.println("❌ 未收到设备响应");
|
return null;
|
}
|
// 打印响应数据
|
byte[] responseData = new byte[bytesRead];
|
System.arraycopy(response, 0, responseData, 0, bytesRead);
|
String resultData = bytesToHex(responseData);
|
return resultData;
|
} catch (IOException e) {
|
System.out.println("⚠️ 客户端异常断开: " + e.getMessage());
|
} finally {
|
clientSocket.close();
|
}
|
} catch (IOException e) {
|
if (serverSocket != null) {
|
try {
|
System.out.println("设备不在线" + e.getMessage());
|
serverSocket.close();
|
throw new ServiceException("设备不在线");
|
} catch (IOException ex) {
|
System.out.println("❌ 服务端关闭失败: " + ex.getMessage());
|
}
|
} else {
|
System.out.println("❌ 服务端启动失败: " + e.getMessage());
|
}
|
}
|
return null;
|
}
|
// 将字节数组转换为十六进制字符串
|
public static String bytesToHex(byte[] bytes) {
|
StringBuilder sb = new StringBuilder();
|
for (byte b : bytes) {
|
sb.append(String.format("%02X", b));
|
}
|
return sb.toString();
|
}
|
}
|
