java串口通信的实现方法,详细图解

上次我们已经说过java中串口通信的原理,今天再来为大家介绍一下如何实现java串口通信,并且通过详细的图片来为大家呈现具体流程。

首先是准备工作。因为笔记本或台式机上基本上都没有成对的串口提供给我们调试使用,所以需要下载虚拟串口软件来实现串口调试。

一、下载虚拟串口软件。下载安装完成后先把压缩包中的vspdctl.dll文件复制到安装目录下如:目录为–>D:\SoftWareInstall\Virtual Serial Port Driver7.2替换原有文件即可成功激活。

二、打开软件添加虚拟串口,一般都是成对添加的(添加COM3、COM4)后如图所示:

java串口通信的实现

三、添加完成后到设备管理器中查看,会发现多了两个虚拟串口如图所示:

java串口通信的实现

到这一步,创建虚拟串口的工作就全部完成了。

四、下载串口调试软件;

五、直接先打开两个调试窗口,分别用来表示COM3和COM4串口。两个串口的参数一定要设置相同才可以正常的收发数据。(如果调试可以正常收发数据后,可以关掉一个调试器,而用java程序代替)如图所示:

java串口通信的实现

六、java程序代码编写

这个步骤特别重要,要与串口通信,首先要在项目添加RXTXcomm.jar包(放在项目中的lib目录下,并添加到build Path中)。除此之外,还需要将解压后的rxtxParallel.dll和rxtxSerial.dll两个文件放在%JAVA_HOME%/jre/bin目录下,这样这个包才能被正常的加载和调用。

下面是程序代码展示:

package comm;
import java.io.*;
import java.util.*;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import gnu.io.*;
public class ContinueRead extends Thread implements SerialPortEventListener
{ // SerialPortEventListener
    // 监听器,我的理解是独立开辟一个线程监听串口数据
    static CommPortIdentifier portId; // 串口通信管理类
    static Enumeration < ? > portList; // 有效连接上的端口的枚举
    InputStream inputStream; // 从串口来的输入流
    static OutputStream outputStream; // 向串口输出的流
    static SerialPort serialPort; // 串口的引用
    // 堵塞队列用来存放读到的数据
    private BlockingQueue < String > msgQueue = new LinkedBlockingQueue < String > ();
    @Override
    /**
     * SerialPort EventListene 的方法,持续监听端口上是否有数据流
     */
    public void serialEvent(SerialPortEvent event)
    { //
        switch (event.getEventType())
        {
        case SerialPortEvent.BI:
        case SerialPortEvent.OE:
        case SerialPortEvent.FE:
        case SerialPortEvent.PE:
        case SerialPortEvent.CD:
        case SerialPortEvent.CTS:
        case SerialPortEvent.DSR:
        case SerialPortEvent.RI:
        case SerialPortEvent.OUTPUT_BUFFER_EMPTY:
            break;
        case SerialPortEvent.DATA_AVAILABLE: // 当有可用数据时读取数据
            byte[] readBuffer = new byte[20];
            try
            {
                int numBytes = -1;
                while (inputStream.available() > 0)
                {
                    numBytes = inputStream.read(readBuffer);
                    if (numBytes > 0)
                    {
                        msgQueue.add(new Date() + "真实收到的数据为:-----" +
                            new String(readBuffer));
                        readBuffer = new byte[20]; // 重新构造缓冲对象,否则有可能会影响接下来接收的数据
                    }
                    else
                    {
                        msgQueue.add("额------没有读到数据");
                    }
                }
            }
            catch (IOException e)
            {}
            break;
        }
    }
    /**
     * 
     * 通过程序打开COM4串口,设置监听器以及相关的参数
     * 
     * @return 返回1 表示端口打开成功,返回 0表示端口打开失败
     */
    public int startComPort()
    {
        // 通过串口通信管理类获得当前连接上的串口列表
        portList = CommPortIdentifier.getPortIdentifiers();
        while (portList.hasMoreElements())
        {
            // 获取相应串口对象
            portId = (CommPortIdentifier) portList.nextElement();
            System.out.println("设备类型:--->" + portId.getPortType());
            System.out.println("设备名称:---->" + portId.getName());
            // 判断端口类型是否为串口
            if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL)
            {
                // 判断如果COM4串口存在,就打开该串口
                if (portId.getName()
                    .equals("COM4"))
                {
                    try
                    {
                        // 打开串口名字为COM_4(名字任意),延迟为2毫秒
                        serialPort = (SerialPort) portId.open("COM_4", 2000);
                    }
                    catch (PortInUseException e)
                    {
                        e.printStackTrace();
                        return 0;
                    }
                    // 设置当前串口的输入输出流
                    try
                    {
                        inputStream = serialPort.getInputStream();
                        outputStream = serialPort.getOutputStream();
                    }
                    catch (IOException e)
                    {
                        e.printStackTrace();
                        return 0;
                    }
                    // 给当前串口添加一个监听器
                    try
                    {
                        serialPort.addEventListener(this);
                    }
                    catch (TooManyListenersException e)
                    {
                        e.printStackTrace();
                        return 0;
                    }
                    // 设置监听器生效,即:当有数据时通知
                    serialPort.notifyOnDataAvailable(true);
                    // 设置串口的一些读写参数
                    try
                    {
                        // 比特率、数据位、停止位、奇偶校验位
                        serialPort.setSerialPortParams(9600
                            , SerialPort.DATABITS_8, SerialPort.STOPBITS_1
                            , SerialPort.PARITY_NONE);
                    }
                    catch (UnsupportedCommOperationException e)
                    {
                        e.printStackTrace();
                        return 0;
                    }
                    return 1;
                }
            }
        }
        return 0;
    }
    @Override
    public void run()
    {
        // TODO Auto-generated method stub
        try
        {
            System.out.println("--------------任务处理线程运行了--------------");
            while (true)
            {
                // 如果堵塞队列中存在数据就将其输出
                if (msgQueue.size() > 0)
                {
                    System.out.println(msgQueue.take());
                }
            }
        }
        catch (InterruptedException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    public static void main(String[] args)
    {
        ContinueRead cRead = new ContinueRead();
        int i = cRead.startComPort();
        if (i == 1)
        {
            // 启动线程来处理收到的数据
            cRead.start();
            try
            {
                String st = "哈哈----你好";
                System.out.println("发出字节数:" + st.getBytes("gbk")
                    .length);
                outputStream.write(st.getBytes("gbk"), 0
                    , st.getBytes("gbk")
                    .length);
            }
            catch (IOException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        else
        {
            return;
        }
    }
}

七、java程序与串口通信调试

程序调试截图展示如下:

java串口通信的实现

以上就是关于java串口通信的实现方法的大致内容,并且通过详细的图片为大家展示。想要了解更多java基础,敬请关注奇Q工具网。

推荐阅读:

java虚拟机是什么?Java虚拟机基本结构是怎样的?

jvm虚拟机怎么使用?工作原理解析

java字节码是什么?字节码是虚拟机的机器吗?