投稿
  1. 首页
  2. 系统运维

Linux系统下运用开源RXTX库实现JAVA串口通讯

筑路机械 • 2022-5-23 • 系统运维 • 阅读 33

Linux系统下运用开源RXTX库实现JAVA串口通讯,第1张

概述分享一下我老师大神的人工智能教程吧。零基础！通俗易懂！风趣幽默！还带黄段子！希望你也加入到我们人工智能的队伍中来！http://www.captainbed.net 概述     一个嵌入式系统通常需要通过串口与其主控系统进行全双工通讯，譬如我们的环境在线监测系统下的各类监测仪器如流量计，PH计，电机状态检测仪器就需要定时的接受控制系统发送来的查询和控制信息，并将执行结果或查询结果发送回控制系统。

分享一下我老师大神的人工智能教程吧。零基础！通俗易懂！风趣幽默！还带黄段子！希望你也加入到我们人工智能的队伍中来！http://www.captainbed.net

概述@H_301_13@
    一个嵌入式系统通常需要通过串口与其主控系统进行全双工通讯，譬如我们的环境在线监测系统下的各类监测仪器如流量计，PH计，电机状态检测仪器就需要定时的接受控制系统发送来的查询和控制信息，并将执行结果或查询结果发送回控制系统。

一.java的串口通讯扩展包javax.comm@H_301_13@
　  Sun的J2SE中并没有直接提供任何一种串行通讯协议的开发包，而是以独立的jar包形式发布在java.sun.com网站上----即comm.jar，称之为Javatm Communications API，它是J2SE的标准扩展。comm.jar并不是最近才有，早在1998年时，sun就已经发布了这个开发包。comm.jar分别提供了对常用的RS232串行端口和IEEE1284并行端口通讯的支持。目前sun发布的comm.jar只有windows和Solaris平台两个版本，如果需要linux平台下的，可以在http://users.frii.com/jarvi/rxtx/index.HTML找到。
　　所有的comm API位于javax.comm包下面。其中比较重要的类和接口如下，
        javax.comm.CommDriver
        javax.comm.CommPort
        javax.comm.ParallelPort
        javax.comm.SerialPort
        javax.comm.CommPortIDentifIEr
        javax.comm.CommPortOwnershipListener
        javax.comm.ParallelPortEvent
        javax.comm.SerialPortEvent
        javax.comm.ParallelPortEventListener (extends java.util.EventListener)
        javax.comm.SerialPortEventListener (extends java.util.EventListener)
        javax.comm.NoSuchPortException
        javax.comm.PortInUseException
        javax.comm.UnsupportedCommOperationException 
　　通讯方式，CommPort的输入流的读取方式与文件的输入流有些不一样，那就是可能永远不知这个inputStream何时结束，除非对方的OutputStream发送了一个特定数据表示发送结束，收到这个特定字符后，再行关闭inputStream。而comm.jar提供了两种灵活的方式让我们读取数据：
        1.轮询方式(Polling)
        2.监听方式(Listening)。Comm API支持标准的Java Bean型的事件模型。也就是说，可以使用类似AddXXXListener这样的方法为一个串口注册自己的监听器，以监听方式进行数据读取。


二.RXTX项目@H_301_13@
    RXTX是一个提供串口和并口通信的开源java类库，由该项目发布的文件均遵循LGPL协议。该项目的主页位于http://users.frii.com/jarvi/rxtx/index.HTML。
    RXTX项目提供了windows,linux,Mac os X,Solaris *** 作系统下的兼容javax.comm串口通讯包API的实现，为其他开发人员在此类系统下开发串口应用提供了相当的方便。
    针对x86体系结构的Linux *** 作系统平台，RXTX的部署包括下面几个文件：
    * RXTXcomm.jar        RXTX自己的javax.comm实现
    * librxtxSerial.so    由RXTXcomm.jar调用的底层串口库文件
    * librxtxParallel.so    由RXTXcomm.jar调用的底层并口库文件
    * javax.comm.propertIEs    RXTX驱动的类配置文件,内容是Driver=gnu.io.RXTXCommDriver
    

三.RXTX的配置方法及部分源代码@H_301_13@
    为了使我们的程序使用RXTX作为串口通讯的底层API，需要配置它的环境。仍然以Linux系统平台为例：
    1.复制librxtxSerial.so，librxtxParallel.so到$JAVA_HOME/lib/$(ARCH)/
    2.复制RXTXcomm.jar到$JAVA_HOME/ext/,或在应用程序启动的CLAsspATH中包含RXTXcomm.jar
    3.定义驱动类后将javax.comm.propertIEs放在应用程序的根目录下
    RXTX的使用上与sun提供的comm.jar基本相同,编程时最明显的不同是要包含的包名由javax.comm.*改成了gnu.io.*。下面是我们环境监测系统中封装的一个232串口驱动类部分源代码，使用RXTX作为串口通讯类库。
    
    下面的driver232类是监测点子系统以开源的rxtx项目提供的串口通讯扩展包为基础自己封装的一个RS232串口驱动类库（部分代码），为系统的其它部分提供简易的访问本机串口的方法。类的前面部分是各个串口参数的声明，后面是读取，写入串口的具体方法实现。

引入 rxtx java 类库包RXTXcomm.jar

package com.kasumi.site.physicalservice;

//import javax.comm.*;
import gnu.io.*;
import java.io.*;
import com.kasumi.util.format.*;
import java.awt.*;
import java.awt.event.*;
import org.apache.log4j.*;
import com.kasumi.site.infrastructure.*;
import com.kasumi.util.misc.*;


 实现已定义好的 ISerial 接口，提供 ISerial 规定的各个方法的实现。

/**
 *

该程序实现 ISerial 接口, 提供 RS-232C 的驱动
 * @author lhh
 * @version 3.0
 * @see com.kasumi.site.publicservice.measuredev
 */
public class driver232
    implements ISitePlugin,IPoolable,ISiteConfigurable,ISerial
{
    /** Clear all buffer data before lent out */
    private boolean clearBufferData = true;


类的前面部分是各个串口参数的声明，在本类中也提供了设置与获取这些参数的方法，运用Ioc技术在运行时根据配置文件plugin.conf的配置注入这些参数，以利于各个不同监测仪器的串口通讯参数设置。

    /** Serial default setting */
    private String portname = "COM1";
    private int baudrate = 2400;
    private int flowControlin = SerialPort.FLOWCONTRol_NONE;
    private int flowControlOut = SerialPort.FLOWCONTRol_NONE;
    private int databits = SerialPort.DATABITS_8;
    private int stopbits = SerialPort.StopBITS_1;
    private int parity = SerialPort.PARITY_NONE;
    private ISiteContext siteContext = null;

    // private SerialParameters parameters;
    private OutputStream os;
    private inputStream is;
    private CommPortIDentifIEr portID;
    private SerialPort sPort;
    private boolean open;
    private String poolname;
    static Logger logger = Logger.getLogger(driver232.class);
    private String domainname=null;


设置串口连接参数的方法

    public voID setConnectionParameters() throws IOException
    {
        // Set connection parameters,if set fails return parameters object
        // to original state.
        try
        {
            sPort.setSerialPortParams(baudrate,databits,stopbits,parity);
        }
        catch (UnsupportedCommOperationException e)
        {
            throw new IOException(getDomainname() + ":" + e.toString());
        }

        // Set flow control.
        try
        {
            sPort.setFlowControlMode(flowControlin|flowControlOut);
        }
        catch (UnsupportedCommOperationException e)
        {
            throw new IOException(getDomainname() + ":" + e.toString());
        }
    }


用已定义好的连接参数"打开"串口连接

    /*
     *    Open the port
     */
    public voID openConnection() throws IOException
    {
        try
        {
            portID = CommPortIDentifIEr.getPortIDentifIEr(portname);
        }
        catch (NoSuchPortException e)
        {
            throw new IOException(getDomainname() + ":" + e.toString());
        }

        try
        {
            sPort = (SerialPort)portID.open("SerialCom",30000);
        }
        catch (PortInUseException e)
        {
            throw new IOException(getDomainname() + ":" + e.toString());
        }

        try
        {
            setConnectionParameters();
        }
        catch (IOException e)
        {
            sPort.close();
            throw e;
        }

        try
        {
            os = sPort.getoutputStream();
            is = sPort.getinputStream();
        }
        catch (IOException e)
        {
            sPort.close();
            throw new IOException(getDomainname() + ":" + e.toString());
        }

        sPort.notifyOnDataAvailable(true);
        open = true;
    }


一次串口通讯结束后关闭当前的串口连接，以让系统其它监测仪器复用串口

    /**
     * Close the port and clean up associated elements.
     * @param
     * @return voID
    */
    public voID closeConnection()
    {
        // If port is alread closed just return.
        if (!open)
        {
            return;
        }

        if (sPort != null)
        {
            try
            {
                // close the I/O streams.
                os.close();
                is.close();
            }
            catch (IOException e)
            {
                logger.error(e.toString());
            }

            // Close the port.
            sPort.close();

            //portID.removePortOwnershipListener(this);
        }

        open = false;
    }


读取串口的方法。读取与写入串口的方法在本类中提供了多个，因为系统中各个仪器的串口通讯要求不同，读取和写入的方法在实现上有一些差异，所以提供了多个方法以适应这类需求

    /**
     *

在指定的时间内从串口读取指定长度的数据


     * 
注意: 如果在指定的时间内未能读取指定长度的数据,     *

      那么将返回实际读取的数据以及对应的长度


     * @param data 用于存放从串口读取的数据的缓冲区
     * @param rdLen 指定要读取的数据的长度
     * @param timeout 指定读取数据的时间长度
     * @return 实际读取的数据的长度
     * @throws  IOException 如果读串口时低层 API 抛出异常
     */
    public int read(byte[] data,int rdLen,int timeout)
        throws IOException {

        try {
            if (!sPort.isReceiveTimeoutEnabled()){
                sPort.enableReceiveTimeout(timeout);
            }
        } catch (UnsupportedCommOperationException e) {
            throw new IOException(e.toString());
        }

        int offset = 0;
        int curRdLen = rdLen;
        long start = System.currentTimeMillis();
        long end = start + timeout;

        while (offset < rdLen && System.currentTimeMillis() < end) {
        //while (offset < rdLen) {
            try {
                int len = is.read(data,offset,curRdLen);
                offset += len;
                curRdLen -= len;
            } catch (IOException e) {
                throw e;
            }
        }
        if (offset > 0)
        {
            HexDumper.dumpLogger(logger,"<< ",data,offset);
        }
        return offset;
    }


往串口写数据的方法

   /**
     * 写串口数据
     *
     * @param outdata 写出数据
     * @param outoffset 开始写出偏移量
     * @param outlen 写出长度
     * @return 实际读入的数据长度
     */
    public int writeData(byte[] outdata,int outoffset,int outlen)
        throws IOException
    {
        HexDumper.dumpLogger(logger,">> ",outdata,outoffset,outlen);
        try
        {
            os.write(outdata,outlen);
            os.flush();
        }
        catch (IOException e)
        {
            throw new IOException(getDomainname() + ":" + e.toString());
        }

        return outlen;
    }

}
  TAG@H_301_13@  rxtx  java  串口

再分享一下我老师大神的人工智能教程吧。零基础！通俗易懂！风趣幽默！还带黄段子！希望你也加入到我们人工智能的队伍中来！http://www.captainbed.net

@H_643_404@ 总结

以上是内存溢出为你收集整理的Linux系统下运用开源RXTX库实现JAVA串口通讯全部内容，希望文章能够帮你解决Linux系统下运用开源RXTX库实现JAVA串口通讯所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/yw/1031560.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
筑路机械 筑路机械 一级用户组
0 0
上一篇 2022-05-23
下一篇 2022-05-23

发表评论

登录后才能评论

评论列表（0条）

保存