Java串口通信

串口通信原理

• 串口通信指串口按位（bit）发送和接收字节。尽管比按字节（byte）的并行通信慢，但是串口可以在使用一根线发送数据的同时用另一根线接收数据。

• 串口是计算机上一种非常通用的设备通信协议（不要与通用串行总线Universal SerialBus或者USB混淆）

• 典型地，串口用于ASCII码字符的传输。通信使用3根线完成：（1）地线，（2）发送，（3）接收。由于串口通信是异步的，端口能够在一根线上发送数据同时在另一根线上接收数据。其他线用于握手，但是不是必须的。串口通信最重要的参数是比特率、数据位、停止位和奇偶校验。对于两个进行通信的端口，这些参数必须匹配

• RS-232（ANSI/EIA-232标准）是IBM-PC及其兼容机上的串行连接标准、RS-422（EIA RS-422-AStandard）是Apple的Macintosh计算机的串口连接标准。RS-485（EIA-485标准）是RS-422的改进。
  在一台电脑完成串口通信及调试所需的准备工作

• 由于笔记本或台式机上基本上都没有成对的串口提供给我们调试使用，我们就需要下载虚拟串口软件来实现串口调试。

• 下载虚拟串口软件 http://pan.baidu.com/s/1hqhGDbI, （这里提供的还是比较好用）。下载安装完成后先不要急着运行，把压缩包中的vspdctl.dll文件复制到安装目录下如：我的目录为–>D:SoftWareInstallVirtual Serial Port Driver 7.2 替换原有文件即可成功激活。
  打开软件添加虚拟串口，一般都是成对添加的（添加COM3、COM4）后如图所示：

   

  • 添加完成后到设备管理器中查看，发现多了两个虚拟串口如图：
    在这里插入图片描述

  • 下载串口调试软件 http://pan.baidu.com/s/1c0AVaXq ,这里提供的是比较老的调试软件了，但还是比较好用的哦。直接解压点击打开就ok了。
    可以直接先打开两个调试窗口，分别用来表示COM3和COM4串口。两个串口的参数一定要设置的一样才可以正常的收发数据。（若调试可以正常收发数据后，可以关掉一个调试器，而用java程序代替）如图：

• 

  程序代码编写

  **
  这一部分将是我们的重点，要与串口通信首先要在项目添加RXTXcomm.jar包（放在项目中的lib目录下，并添加到build Path中）（win64位下载地址：http://pan.baidu.com/s/1o6zLmTc） ； 安装完成之后；
  拷贝 RXTXcomm.jar 到 JAVA_HOMEjrelibext目录中；
  拷贝 rxtxSerial.dll 到 JAVA_HOMEjrein目录中；
  拷贝 rxtxParallel.dll 到 JAVA_HOMEjrein目录中；
  JAVA_HOME为jdk安装路径
  在运行代码之前，需要将RXTXcomm.jar导入到程序包中。

• 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;
          }
      }
  }