IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 网络协议 -> 固定式扫描,串口通讯,tcp通讯 -> 正文阅读

[网络协议]固定式扫描,串口通讯,tcp通讯

第一次接触固定式扫描的项目,项目背景:在流水线的某处安装一个固定式扫描的设备及程序,如扫描到条码,且程序能通过该条码的检验,即流水线正常流水。否则(没有扫描到或者程序不通过该条码的检验)将做停线处理,此处对接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固定。

哎呀,先不写了。

  网络协议 最新文章
使用Easyswoole 搭建简单的Websoket服务
常见的数据通信方式有哪些?
Openssl 1024bit RSA算法---公私钥获取和处
HTTPS协议的密钥交换流程
《小白WEB安全入门》03. 漏洞篇
HttpRunner4.x 安装与使用
2021-07-04
手写RPC学习笔记
K8S高可用版本部署
mySQL计算IP地址范围
上一篇文章      下一篇文章      查看所有文章
加:2021-11-16 19:11:36  更:2021-11-16 19:13:58 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/26 6:55:13-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码