一個使用Java讀取串口的程序(1)

2019-11-18 13:24:42

字體：大中小

來源：轉載

供稿：網友

　　以下是我寫的用java讀取串口的程序，應一些網友的要求在這里貼出來。這個程序里面還有一些問題，也希望有經驗的網友能夠給我提點意見。
　　
　　這個簡單的程序包括以下文件：
　　
　　 IMU.java (主程序)
　　 ReadBuffer.java (從緩沖區讀取一個消息)
　　 ReadSerial.java (讀取串口數據并放入緩沖區)
　　 SerialBuffer.java (緩沖區)
　　 WriteSerial.java (不斷的往串口送星號'*')
　　
　　測試程序：
　　
　　 SendCom.java (將一個數據文件往串口發送)
　　 SEND.TXT (供測試用的數據文件)
　　
　　在這個通訊程序中使用了一個簡單的協議，既不同的消息之間用星號'*'作為分隔。這個程序中的問題是ReadSerial進程和WriteSerial進程不能夠同時啟動，出錯信息是不能夠打開串口，因為同樣一個串口不能夠同時被打開兩次(在ReadSerial中聲明了FileReader
　　
　　測試程序：
　　
　　 SendCom.java (將一個數據文件往串口發送)
　　 SEND.TXT (供測試用的數據文件)
　　
　　在這個通訊程序中使用了一個簡單的協議，既不同的消息之間用星號'*'作為分隔。這個程序中的問題是ReadSerial進程和WriteSerial進程不能夠同時啟動，出錯信息是不能夠打開串口，因為同樣一個串口不能夠同時被打開兩次(在ReadSerial中聲明了FileReader和在WriteSerial中聲明了FileWriter)。這樣是不能夠實現全雙工通訊的。不知道有沒有做過的大俠能夠講講處理的辦法。
　　
　　/*
　　*
　　* IMU.java 1.0
　　* Main PRogram for Serial Communication
　　*
　　* Created: March 27, 2001
　　*
　　* Author : Qingye Jiang (John)
　　* American GNC Corporation
　　* 888 Easy St, Simi Valley CA 93065-1812
　　*
　　* Contact: (805) 582-0582 (Tel), (805) 582-0098 (Fax)
　　* qjiang@tsinghua.edu
　　*
　　*/
　　
　　import java.io.*;
　　
　　class IMU
　　{
　　 public static void main(String[] args)
　　 {
　　 //TO DO: Add your JAVA codes here
　　
　　 File ComPort = new File("COM1");
　　
　　 SerialBuffer SB = new SerialBuffer();
　　 ReadSerial r1 = new ReadSerial(SB, ComPort);
　　 ReadBuffer r2 = new ReadBuffer(SB);
　　 WriteSerial r3 = new WriteSerial(ComPort);
　　
　　 r1.start();
　　 r2.start();
　　 r3.start();
　　 }
　　}
　　
　　/*
　　*
　　* ReadBuffer.java 1.0
　　* Program to Read the Serial Buffer
　　*
　　* Created: March 27, 2001
　　*
　　* Author : Qingye Jiang (John)
　　* American GNC Corporation
　　* 888 Easy St, Simi Valley CA 93065-1812
　　*
　　* Contact: (805) 582-0582 (Tel), (805) 582-0098 (Fax)
　　* qjiang@tsinghua.edu
　　
　　*
　　*/
　　
　　import java.io.*;
　　
　　public class ReadBuffer extends Thread
　　{
　　 private SerialBuffer ComBuffer;
　　
　　 public ReadBuffer(SerialBuffer SB)
　　 {
　　 ComBuffer = SB;
　　 }
　　
　　 public void run()
　　 {
　　 String Msg;
　　
　　 while (true)
　　 {
　　 Msg = ComBuffer.GetMsg();
　　 System.out.println(Msg);
　　 }
　　
　　 }
　　}
　　
　　/*
　　*
　　* ReadSerial.java 1.0
　　* Program to read characters from the serial port and put it
　　* to the buffer
　　*
　　* Created: March 27, 2001
　　*
　　* Author : Qingye Jiang (John)
　　* American GNC Corporation
　　* 888 Easy St, Simi Valley CA 93065-1812
　　*
　　* Contact: (805) 582-0582 (Tel), (805) 582-0098 (Fax)
　　* qjiang@tsinghua.edu
　　*
　　*/
　　
　　import java.io.*;
　　
　　public class ReadSerial extends Thread
　　{
　　 private SerialBuffer ComBuffer;
　　 private File ComPort;
　　
　　 public ReadSerial(SerialBuffer SB, File Port)
　　 {
　　 ComBuffer = SB;
　　 ComPort = Port;
　　 }
　　
　　 public void run()
　　 {
　　 int c;
　　 try
　　 {
　　 FileReader in = new FileReader(ComPort);
　　 while (true)
　　 {
　　 c = in.read();
　　 ComBuffer.PutChar(c);
　　 }
　　 try
　　 {
　　 FileReader in = new FileReader(ComPort);
　　 while (true)
　　 {
　　 c = in.read();
　　
　　 ComBuffer.PutChar(c);
　　 }
　　 } catch (IOException e) {}
　　 }
　　}
　　
　　
　　/*
　　*
　　* SerialBuffer.java 1.0
　　* Class that implements the serial buffer
　　*
　　* Created: March 27, 2001
　　*
　　* Author : Qingye Jiang (John)
　　* American GNC Corporation
　　* 888 Easy St, Simi Valley CA 93065-1812
　　*
　　* Contact: (805) 582-0582 (Tel), (805) 582-0098 (Fax)
　　* qjiang@tsinghua.edu
　　
　　*
　　*/
　　
　　public class SerialBuffer
　　{
　　 private String Content = "";
　　 private String CurrentMsg, TempContent;
　　 private boolean available = false;
　　
　　 public synchronized String GetMsg()
　　 {
　　 int SepMark;
　　
　　 if ((SepMark = Content.indexOf('*')) == -1)
　　{
　　 available = false;
　　 while (available == false)
　　 {
　　 try
　　 {
　　 wait();
　　 } catch (InterruptedException e) { }
　　 }
　　 SepMark = Content.indexOf('*');
　　 }
　　
　　 CurrentMsg = Content.substring(0, SepMark);
　　 TempContent = Content.substring(SepMark+1);
　　 Content = TempContent;
　　 notifyAll();
　　 return CurrentMsg;
　　 }
　　
　　 public synchronized void PutChar(int c)
　　 {
　　 Character d = new Character((char) c);
　　 Content = Content.concat(d.toString());
　　 if (c == '*')
　　 {
　　 available = true;
　　 }
　　 notifyAll();
　　 }
　　}
　　
　　
　　/*
　　*
　　* WriteSerial.java 1.0
　　* Program to send a character to the serial port
　　*
　　* Created: March 27, 2001
　　*
　　* Author : Qingye Jiang (John)
　　* American GNC Corporation
　　* 888 Easy St, Simi Valley CA 93065-1812
　　*
　　* Contact: (805) 582-0582 (Tel), (805) 582-0098 (Fax)
　　* qjiang@tsinghua.edu
　　*
　　*/
　　
　　import java.io.*;
　　
　　public class WriteSerial extends Thread
　　{
　　 private SerialBuffer ComBuffer;
　　 private File ComPort;
　　
　　 public WriteSerial(File Port)
　　 {
　　 ComPort = Port;
　　 }
　　
　　 public void run()
　　 {
　　 int c;
　　 try
　　 {
　　 FileWriter out = new FileWriter(ComPort);
　　 while (true)
　　 {
　　 out.write('*');
　　 }
　　 } catch (IOException e)
　　 {
　　 System.out.println(e.getMessage());
　　 }
　　 }
　　}
　　/*
　　*
　　* SendCom.java 1.0
　　*
　　* Project: Java Based Information Exchange Support System
　　* Onboard Plug-in System
　　* Sending data through serial port
　　*
　　* Created: March 15, 2001
　　*
　　* Author : Qingye Jiang (John)
　　* American GNC Corporation
　　* 888 Easy St, Simi Valley CA 93065-1812
　　*
　　* Contact: (805) 582-0582 (Tel), (805) 582-0098 (Fax)
　　*
　　*/
　　
　　import java.io.*;
　　
　　public class SendCom
　　{

上一篇：判斷兩個密碼框里的值是否相等

下一篇：J組件