本函数望串口缓冲区中写入一个字符,参数c是需要写入的字符。
在往缓冲区写入数据或者是从缓冲区读取数据的时候,必须保证数据的同步,因此GetMsg和PutChar函数均被声明为synchronized并在具体实现中采措施实现的数据的同步。
SerialBuffer的源代码如下:
packageserial;
/**
*
*Thisclassimplementsthebufferareatostoreincomingdatafromtheserial
*port.
*
*/
publicclassSerialBuffer
{
privateStringContent="";
privateStringCurrentMsg,TempContent;
privatebooleanavailable=false;
privateintLengthNeeded=1;
/**
*
*Thisfunctionreturnsastringwithacertainlengthfromtheincoming
*messages.
*
*@paramLengthThelengthofthestringtobereturned.
*
*/
publicsynchronizedStringGetMsg(intLength)
{
LengthNeeded=Length;
notifyAll();
if(LengthNeeded>Content.length())
{
available=false;
while(available==false)
{
try
{
wait();
}catch(InterruptedExceptione){}
}
}
CurrentMsg=Content.substring(0,LengthNeeded);
TempContent=Content.substring(LengthNeeded);
Content=TempContent;
LengthNeeded=1;
notifyAll();
returnCurrentMsg;
}
/**
*
*Thisfunctionstoresacharactercapturedfromtheserialporttothe
*bufferarea.
*
*@paramtThecharvalueofthecharactertobestored.
*
*/
publicsynchronizedvoidPutChar(intc)
{
Characterd=newCharacter((char)c);
Content=Content.concat(d.toString());
if(LengthNeeded<Content.length())
{
available=true;
}
notifyAll();
}
}
3.ReadSerial
ReadSerial是一个进程,它不断的从指定的串口读取数据并将其存放到缓冲区中。
publicReadSerial(SerialBufferSB,InputStreamPort)
本函数构造一个ReadSerial进程,参数SB指定存放传入数据的缓冲区,参数Port指定从串口所接收的数据流。
publicvoidrun()
ReadSerial进程的主函数,它不断的从指定的串口读取数据并将其存放到缓冲区中。
ReadSerial的源代码如下:
packageserial;
importjava.io.*;
/**
*
*Thisclassreadsmessagefromthespecificserialportandsave
*themessagetotheserialbuffer.
*
*/
publicclassReadSerialextendsThread
{
privateSerialBufferComBuffer;
privateInputStreamComPort;
/**
*
*Constructor
*
*@paramSBThebuffertosavetheincomingmessages.
*@paramPortTheInputStreamfromthespecificserialport.
*
*/
publicReadSerial(SerialBufferSB,InputStreamPort)
{
ComBuffer=SB;
ComPort=Port;
}
publicvoidrun()
{
intc;
try
{
while(true)
{
c=ComPort.read();
ComBuffer.PutChar(c);
}
}catch(IOExceptione){}
}
}
4.SerialExample
SerialExample是本类库所提供的一个例程。它所实现的功能是打开串口COM1,对其进行初始化,从串口读取信息对其进行处理后将处理结果发送到串口。
importserial.*;
importjava.io.*;
/**
*
*ThisisanexampleofhowtousetheSerialBean.ItopensCOM1andreads
*sixmessageswithdifferentlengthformtheserialport.
*
*/
classSerialExample
{
publicstaticvoidmain(String[]args)
{
//TODO:AddyourJAVAcodeshere
SerialBeanSB=newSerialBean(1);
StringMsg;
SB.Initialize();
for(inti=5;i<=10;i++)
{
Msg=SB.ReadPort(i);
SB.WritePort("Reply:"+Msg);
}
SB.ClosePort();
}
}
5.编译与调试
本类库中使用了JavaCommunicationAPI(javax.comm)。这是一个Java扩展类库,并不包括在标准的JavaSDK当中。如果你尚未安装这个扩展类库的话,你应该从Sun公司的Java站点下载这个类库并将其安装在你的系统上。在所下载的包里面包括一个安装说明,如果你没有正确安装这个类库及其运行环境的话,运行这个程序的时候你会找不到串口。
正确安装JavaCommunicationAPI并将上述程序编译通过以后,你可以按如下方法测试这个程序。如果你只有一台机器,你可以利用一条RS-232电缆将COM1和COM2连接起来,在COM1上运行SerialExample,在COM2上运行Windows提供的超级终端程序。如果你有两台机器的话,你可以利用一条RS-232电缆将两台机器的COM1(或者是COM2)连接起来,在一端运行例程,另外一端运行Windows提供的超级终端程序。如果有必要的
话,可以对SerialExample中所声明的串口进行相应改动。
本程序在Windows2000+JavaSDK1.3环境下编译通过并成功运行。 上一页 [1] [2] |