Android的串口开发(2)

实现自己引入谷歌官方串口库,能够进行读数据。这边不会放出通讯协议,但是会讲一下自己的思想,解析的过程(当然只是自己的理解,可能中间存在很多错误,也可以进行纠正)

引入谷歌官方串口库

现在市面上几乎所有的Android串口通信库都是用的Google开源的https://github.com/cepr/android-serialport-api封装而成。所以先下载官方源代码,引入到自己的项目中。
下载完后,将压缩包中android-serialport-api下的libs文件夹复制到自己项目下的libs下

libs文件夹路径.png

接着将src下的文件都复制到项目的src/main/java下,其中sample文件夹下面的为官方提供的例子,我们可以拿过来使用也可以不使用。。主要是下方的serialPort.java和SerialPortFinder.java这两个文件.另外因为调用jni有严格的包名控制,谷歌编译后的只能是android-serialport-api包名,要么是放在这个包下,或者是重新编译为你自己选择的包名,二者选其一。另外在build.gradle的defaultConfig下面加入以下代码.

sourceSets {
        main {
            jniLibs.srcDirs = ['libs']
        }
    }
最终的项目路径目录.png

实现串口通讯

这边已经完成了谷歌官方串口代码的引入,接着可以自己进行封装成工具类,给自己的项目使用。也可以直接使用谷歌的官方代码示例,也可以实现功能。这边贴一段别人写的例子,也可以在这个基础上修改使用。

public class SerialPortUtils {
    private final String TAG = "SerialPortUtils";
    private String path = "/dev/ttyS1";
    private int baudrate = 9600;
    public boolean serialPortStatus = false; //是否打开串口标志
    public String data_;
    public boolean threadStatus; //线程状态,为了安全终止线程

    public SerialPort serialPort = null;
    public InputStream inputStream = null;
    public OutputStream outputStream = null;


    /**
     * 打开串口
     * @return serialPort串口对象
     */
    public SerialPort openSerialPort(){
        try {
            serialPort = new SerialPort(new File(path),baudrate,0);
            this.serialPortStatus = true;
            threadStatus = false; //线程状态

            //获取打开的串口中的输入输出流,以便于串口数据的收发
            inputStream = serialPort.getInputStream();
            outputStream = serialPort.getOutputStream();

            new ReadThread().start(); //开始线程监控是否有数据要接收
        } catch (IOException e) {
            Log.e(TAG, "openSerialPort: 打开串口异常:" + e.toString());
            return serialPort;
        }
        Log.d(TAG, "openSerialPort: 打开串口");
        return serialPort;
    }

    /**
     * 关闭串口
     */
    public void closeSerialPort(){
        try {
            inputStream.close();
            outputStream.close();

            this.serialPortStatus = false;
            this.threadStatus = true; //线程状态
            serialPort.close();
        } catch (IOException e) {
            Log.e(TAG, "closeSerialPort: 关闭串口异常:"+e.toString());
            return;
        }
        Log.d(TAG, "closeSerialPort: 关闭串口成功");
    }

    /**
     * 发送串口指令(字符串)
     * @param data String数据指令
     */
    public void sendSerialPort(String data){
        Log.d(TAG, "sendSerialPort: 发送数据");

        try {
            byte[] sendData = data.getBytes(); //string转byte[]
            this.data_ = new String(sendData); //byte[]转string
            if (sendData.length > 0) {
                outputStream.write(sendData);
                outputStream.write('\n');
                //outputStream.write('\r'+'\n');
                outputStream.flush();
                Log.d(TAG, "sendSerialPort: 串口数据发送成功");
            }
        } catch (IOException e) {
            Log.e(TAG, "sendSerialPort: 串口数据发送失败:"+e.toString());
        }

    }

    /**
     * 单开一线程,来读数据
     */
    private class ReadThread extends Thread{
        @Override
        public void run() {
            super.run();
            //判断进程是否在运行,更安全的结束进程
            while (!threadStatus){
                Log.d(TAG, "进入线程run");
                //64   1024
                byte[] buffer = new byte[64];
                int size; //读取数据的大小
                try {
                    size = inputStream.read(buffer);
                    if (size > 0){
                        Log.d(TAG, "run: 接收到了数据:" + ByteUtil.bytes2HexStr(buffer));
                        Log.d(TAG, "run: 接收到了数据大小:" + String.valueOf(size));
                        onDataReceiveListener.onDataReceive(buffer,size);
                    }
                } catch (IOException e) {
                    Log.e(TAG, "run: 数据读取异常:" +e.toString());
                }
            }

        }
    }

    //这是写了一监听器来监听接收数据
    public OnDataReceiveListener onDataReceiveListener = null;
    public static interface OnDataReceiveListener {
        public void onDataReceive(byte[] buffer, int size);
    }
    public void setOnDataReceiveListener(OnDataReceiveListener dataReceiveListener) {
        onDataReceiveListener = dataReceiveListener;
    }
 }
public class TestActivity1 extends AppCompatActivity {
    SerialPortUtils   serialPortUtils=new SerialPortUtils();
    public String TAG = "TestActivity1";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_welcome);

        serialPortUtils.setOnDataReceiveListener(new SerialPortUtils.OnDataReceiveListener() {
            @Override
            public void onDataReceive(byte[] buffer, int size) {
                Log.d(TAG, "进入数据监听事件中。。。" + new String(buffer));
             }
        });
        serialPortUtils.openSerialPort();
    }
}

数据解析思路

我觉得之前这些都可能在网上找到现成的,CV就可以了。但是可能出现粘包或者是分包的情况,这种情况怎么处理网上都没说的很明白。 另外如果出现丢包又如何每次取出的包是一个完整的包呢?根据自己公司的文档和自己查了一些资料。总结了下自己的思路。
1.首先我们需要在缓存区中拿出一个完整的包。可以定义包头和包尾,根据包头和包尾巴取出一个完整的包,虽然是完整的包但是不一定是正确的包。
2.因为我们定义了包头和包尾所以一定要转义,让数据中不会出现包头和包尾这个数据,比如你定义了1A为包头 那你的数据中遇到有1A的数据就要转成其他的。所以解析的时候应该先转义。
3.转义之后要进行校验数据是否正确。校验通过后才是真正的根据通讯协议去解析数据了。
4.解析数据就是根据通讯协议中定义的位置取出数据,然后根据规定的编码去生成就解析完了。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 这一段时间做的项目自动售货机和无线终端设备的通讯,都是通过串口进行对接和通讯。在Android中进行串口通信方式可...
    狮村小孩阅读 18,285评论 5 13
  • 版本号:Serialport@5.0.0-beta3 serialport@5.0.0-beta3英文文档 本文链...
    ZZES_ZCDC阅读 21,773评论 0 9
  • android下的串口通讯,为毛我总遇到这样的变态需求呢。 前言 随着智能化硬件的发展android跟智能硬件打交...
    Souv阅读 37,778评论 108 110
  • 一个浑厚的声音回应着女孩,听得出带着满满溺爱和宠信。 少年并没有太多波动只是静静的看着一切,似一个成熟的看客风...
    冰0柔阅读 150评论 0 0
  • 这段时间,世界杯的比赛正如火如荼的进行着,电视屏幕内的球员你追我赶,电视屏幕外的你看得格外揪心。而币圈的的世界也正...
    美维软件阅读 244评论 0 0