问题遇到的现象和发生背景
无法写入数据库
用代码块功能插入代码，请勿粘贴截图
//设置串口的listener
SerialPortUtil.setListenerToSerialPort(serialPort, event -> {
//数据通知
if (event.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
byte[] bytes = SerialPortUtil.readData (serialPort);
System.out.println("收到的数据：" + new String(bytes));
String s = new String(bytes);
// 解析属性
String record_time = new SimpleDateFormat("yyyy-MM-dd HH:ss:mm").format(new Date());
String[] split = s.split(";");
String vege_no = split[0].split(":")[100];
String temperature = split[1].split(":")[100];
String humidity = split[2].split(":")[100];
String beam = split[3].split(":")[100];
String nutrient = split[4].split(":")[100];
String ph_value = split[5].split(":")[100];
String name = "";
if (Objects.equals(vege_no, "1")) {
name = "辣椒";
} else if (Objects.equals(vege_no, "2")) {
name = "空心菜";
} else if (Objects.equals(vege_no, "3")) {
name = "上海青";
} else if (Objects.equals(vege_no, "4")) {
name = "黄瓜";
} else if (Objects.equals(vege_no, "5")) {
name = "萝卜";
} else if (Objects.equals(vege_no, "6")) {
name = "西红柿";
}
// 封装属性
VegeEnvi vegeEnvi = new VegeEnvi();
vegeEnvi.setRecordTime(record_time);
vegeEnvi.setVegeNo(Integer.parseInt(vege_no));
vegeEnvi.setVegeName(name);
vegeEnvi.setTemperature(temperature);
vegeEnvi.setHumidity(humidity);
vegeEnvi.setBeam(beam);
vegeEnvi.setNutrient(nutrient);
vegeEnvi.setPhValue(ph_value);
// 保存至数据库
vegeEnviDao.insert(vegeEnvi);
}
});
} catch (NoSuchPortException | PortInUseException | UnsupportedCommOperationException | TooManyListenersException e) {
e.printStackTrace();
}
}
}).start();
/**
* @Description 获得系统可用的端口名称列表(COM0 、 COM1 、 COM2等等)
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:22
* @return java.util.List<java.lang.String> 可用端口名称列表
*/
@SuppressWarnings("unchecked")
public static List<String> getSerialPortList() {
List<String> systemPorts = new ArrayList<>();
//获得系统可用的端口
Enumeration<CommPortIdentifier> portList = CommPortIdentifier.getPortIdentifiers();
while (portList.hasMoreElements()) {
String portName = portList.nextElement().getName();//获得端口的名字
systemPorts.add(portName);
}
return systemPorts;
}
/**
* @Description 打开串口(设置串口名称)
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:25
* @param serialPortName: 串口名称
* @throws NoSuchPortException 对应串口不存在
* @throws PortInUseException 串口在使用中
* @throws UnsupportedCommOperationException 不支持操作操作
* @return gnu.io.SerialPort 串口对象
*/
public static SerialPort openSerialPort(String serialPortName)
throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {
SerialPortParameterVO parameter = new SerialPortParameterVO(serialPortName);
return openSerialPort(parameter);
}
/**
* @Description 打开串口(设置串口名称与波特率)
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:38
* @param serialPortName: 串口名称
* @param baudRate: 波特率
* @throws NoSuchPortException 对应串口不存在
* @throws PortInUseException 串口在使用中
* @throws UnsupportedCommOperationException 不支持操作操作
* @return gnu.io.SerialPort 串口对象
*/
public static SerialPort openSerialPort(String serialPortName, int baudRate)
throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {
SerialPortParameterVO parameter = new SerialPortParameterVO(serialPortName, baudRate);
return openSerialPort(parameter);
}
/**
* @Description 打开串口(设置串口名称、波特率与超时时间)
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:41
* @param serialPortName: 串口名称
* @param baudRate: 波特率
* @param timeout: 串口打开超时时间
* @throws NoSuchPortException 对应串口不存在
* @throws PortInUseException 串口在使用中
* @throws UnsupportedCommOperationException 不支持操作操作
* @return gnu.io.SerialPort 串口对象
*/
public static SerialPort openSerialPort(String serialPortName, int baudRate, int timeout)
throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {
SerialPortParameterVO parameter = new SerialPortParameterVO(serialPortName, baudRate);
return openSerialPort(parameter, timeout);
}
/**
* @Description 打开串口(设置2s超时)
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:43
* @param parameter: 串口参数对象
* @return gnu.io.SerialPort 串口对象
*/
public static SerialPort openSerialPort(SerialPortParameterVO parameter) throws UnsupportedCommOperationException, NoSuchPortException, PortInUseException {
return openSerialPort(parameter, 2000);
}
/**
* @Description 打开串口(通过设置好的参数)
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:49
* @param parameter: 串口参数对象
* @param timeout: 串口打开超时时间
* @throws NoSuchPortException 对应串口不存在
* @throws PortInUseException 串口在使用中
* @throws UnsupportedCommOperationException 不支持操作操作
* @return gnu.io.SerialPort 串口对象
*/
public static SerialPort openSerialPort(SerialPortParameterVO parameter, int timeout)
throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {
//通过端口名称得到端口
CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(parameter.getSerialPortName());
//打开端口，（自定义名字，打开超时时间）
CommPort commPort = portIdentifier.open(parameter.getSerialPortName(), timeout);
//判断是不是串口
if (commPort instanceof SerialPort) {
SerialPort serialPort = (SerialPort) commPort;
//设置串口参数（波特率，数据位8，停止位1，校验位无）
serialPort.setSerialPortParams(parameter.getBaudRate(), parameter.getDataBits(), parameter.getStopBits(), parameter.getParity());
System.out.println("开启串口成功，串口名称：" + parameter.getSerialPortName());
return serialPort;
} else {
//是其他类型的端口
throw new NoSuchPortException();
}
}
/**
* @Description 关闭串口
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:54
* @param serialPort: 要关闭的串口对象
*/
public static void closeSerialPort(SerialPort serialPort) {
if (serialPort != null) {
serialPort.close();
System.out.println("关闭了串口：" + serialPort.getName());
}
}
/**
* @Description 向串口发送数据
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:54
* @param serialPort: 串口对象
* @param data: 发送的数据
*/
public static void sendData(SerialPort serialPort, byte[] data) {
OutputStream os = null;
try {
//获得串口的输出流
os = serialPort.getOutputStream();
os.write(data);
os.flush();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (os != null) {
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* @Description 从串口读取数据
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:55
* @param serialPort: 要读取的串口对象
* @return byte[] 读取出的数据
*/
public static byte[] readData(SerialPort serialPort) {
InputStream is = null;
byte[] bytes = null;
try {
//获得串口的输入流
is = serialPort.getInputStream();
try {
Thread.sleep(50);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
//获得数据长度
int bufflenth = is.available();
System.out.println (bufflenth);
while (bufflenth != 0) {
//初始化byte数组
bytes = new byte[bufflenth];
is.read(bytes);
bufflenth = is.available();
}
} catch (IOException e) {
e.printStackTrace ();
} finally {
try {
if (is != null) {
is.close ();
}
} catch (IOException e) {
e.printStackTrace ();
}
}
return bytes;
}
public static byte[] readData1(SerialPort serialPort) {
InputStream is = null;
byte[] bytes = null;
try {
//获得串口的输入流
is = serialPort.getInputStream();
//获得数据长度
int bufflenth = is.available();
while (bufflenth != 0) {
//初始化byte数组
bytes = new byte[100];
is.read(bytes);
bufflenth = is.available();
}
} catch (IOException e) {
e.printStackTrace ();
} finally {
if (is != null) {
try {
is.close ();
} catch (IOException e) {
e.printStackTrace ();
}
}
}
return bytes;
}
/**
* @Description 给串口设置监听
* @Author LuoJiaLei
* @Date 2020/6/10
* @Time 9:57
* @param serialPort: 要读取的串口
* @param listener: SerialPortEventListener监听对象
* @throws TooManyListenersException 监听对象太多
*/
public static void setListenerToSerialPort(SerialPort serialPort, SerialPortEventListener listener) throws TooManyListenersException {
//给串口添加事件监听
serialPort.addEventListener(listener);
//设置串口有数据的事件true有效,false无效
serialPort.notifyOnDataAvailable(true);
//设置中断事件true有效,false无效
serialPort.notifyOnBreakInterrupt(true);
}
运行结果及报错内容
没有报错
dug一下 报这里
我想要达到的结果
写入数据库
