第一次接触固定式扫描的项目,项目背景:在流水线的某处安装一个固定式扫描的设备及程序,如扫描到条码,且程序能通过该条码的检验,即流水线正常流水。否则(没有扫描到或者程序不通过该条码的检验)将做停线处理,此处对接plc设备。处理完后用扫描枪补扫该条码,并恢复流水线。
?设备:安卓工业平板,扫描器和扫描器配套的控制盒,plc控制盒(简化plc的控制程序,如停线发送一个ng指令即可),各种串口线、接线等。
2021-08,使用两个串口通信的方式开发,一个串口用于接收固定式扫描器扫到的数据,另一个串口用于对接plc控制盒发送停线及复位的指令。
遇到的问题:无法同时使用两个串口通讯,所以用到了一个不治本的方法,每次使用到另一个串口的时候,先提前重连该串口。比如在需要发送停线的指令之前先重新连接plc的串口,发送复位指令后就重新连接固定扫描的串口。但是该方式不能治本,偶尔会出现程序闪退的情况等等。也有一些程序逻辑问题,但是在代码上根本看不到有任何逻辑问题。使用了两三个月后,出现了设备刚开机,扫描枪补扫扫不进去的情况,页面也卡死不动。观察了几天,再代码上找不到原因,后续更换了工业平板才不会出现扫不进去卡死的情况。
2021-11,前面两三个月出现的各种各样的问题,迫使我更换通讯方式,固定式扫描的原串口方式改为tcp通讯。记录一下tcp的代码。
package com.maiot.tcp;
import java.net.*;
import java.io.*;
import java.util.Date;
/**
*
* @params
* @remarks 客户端接收数据,设置回调是为了给前台html重写得到监听的数据做处理
* @return
* @author yxf
* @date 2021-11-02 11:27
*/
public class Client {
public Socket socket = null;
public OutputStream os = null;
public InputStream is = null;
public SocketThread socketThread = new SocketThread();
String heartbeat = "ping";//心跳
public static void main(String[] args) {
Client client = new Client();
client.setTcpCallback(new TcpCallback() {
@Override
public void onReceiveData(String data) {
System.out.println(new Date()+data);
}
@Override
public void msg(String msg) {
}
});
client.new SocketThread().start();
}
/**
* 数据回调
*/
public TcpCallback tcpCallback;
public void setTcpCallback(TcpCallback tcpCallback){
this.tcpCallback = tcpCallback;
}
// ip,端口
public String host="192.168.12.201";
public int port=51235;
public void setHost(String host){this.host=host;}
public void setPort(int port){this.port=port;}
public int out_time=3;//超过多少秒没有收到服务端数据,就重连, 固扫的心跳包1-2秒
public int timeout=3000;//连接服务器的超时时间,毫秒
public void setTimeout(int timeout){this.timeout=timeout;}
/**
* 发送心跳包
*/
public void sendHeartbeat() {
try {
new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(10 * 1000);// 10s发送一次心跳
os.write(heartbeat.getBytes());//经测试,这里端口不对就会报错空指针异常
os.flush();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}).start();
} catch (Exception e) {
e.printStackTrace();
}
}
public class SocketThread extends Thread {
@Override
public void run() {
long startTime = System.currentTimeMillis();
// sendHeartbeat();
while (true) {
try {
if (socket == null || socket.isClosed()) {//如未开启,就执行连接
socket = new Socket();
SocketAddress endpoint = new InetSocketAddress(host, port);// 连接socket
try {
socket.connect(endpoint, timeout);//设定一个超时时间,如果在该时间端未连接,就抛出异常
} catch (SocketTimeoutException e) {
e.printStackTrace();
tcpCallback.msg("连接超时,请确认该IP是否开启");//执行回调函数
break;
}
os = socket.getOutputStream();
}
Thread.sleep(100);
try {
is = socket.getInputStream();//
} catch (SocketException e) {//Socket is not connected 不是连接状态
e.printStackTrace();
tcpCallback.msg("未连接成功,请检查IP和端口是否正确");//执行回调函数
break;
}
int size = is.available();
if (size <= 0) {
if ((System.currentTimeMillis() - startTime) > out_time * 1000) { // 如果超过多少秒没有收到服务器发回来的信息,说明socket连接可能已经被远程服务器关闭
System.out.println("开始重连了");
socket.close(); // 这时候可以关闭socket连接,前面会检测到并重新连接
startTime = System.currentTimeMillis();
}
continue;
} else {
startTime = System.currentTimeMillis();
}
byte[] resp = new byte[size];
is.read(resp);
String response = new String(resp, "GB2312");//以防乱码
System.out.println(response);
System.out.println(response.length());//心跳长度是7
// 有粘包情况,粘包条码和心跳一起了 如6705331421115413#189\r\n
if(!response.contains("#189")){
tcpCallback.onReceiveData(response);//执行回调函数
}else {
if(response.length()>7){//粘包条码和心跳一起了 如6705331421115413#189,长度是16+7,,,也有心跳加NG的情况,长度是2+7
System.out.println("粘包了,长度:"+response.length());
tcpCallback.onReceiveData("NG");//模拟发送ng
}
}
}
catch (ConnectException e){//捕获服务器ip可能不开通监听状态的异常,不捕获会闪退
e.printStackTrace();
tcpCallback.msg("请选择正确的固扫IP和端口");//执行回调函数
break;
}
catch (NoRouteToHostException e){//捕获没有该主机ip存在的异常,不捕获会闪退
e.printStackTrace();
tcpCallback.msg("局域网内没有该IP:"+host);//执行回调函数
break;
}
catch (Exception e) {
e.printStackTrace();
try {
if(socket!=null&&is!=null&&os!=null){
socket.close();
is.close();
os.close();
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
}
}
package com.maiot.tcp;
/**
*
* @params
* @remarks 设置回调函数
* @return
* @author yxf
* @date 2021-11-02 11:27
*/
public interface TcpCallback {
// 收到的数据
void onReceiveData(String data);
// 返回异常提示
void msg(String msg);
}
工业平板端的程序作为tcp客户端,贴出其主要代码。
到现场调设备的时候。跟现场内部人员协调要把平板和固定式扫描器的ip固定。
哎呀,先不写了。
|