RS232串口通讯模块

jimeper
关注文章
TinyMind专栏频道

应为工作需要自己编写的RS232通讯模块，该模块已经编写了蛮久，在实际使用中可能有没有考虑和不完善的地方。

//=================================================================================

//如果使用该模块请保留该注释，如果被修改或编辑请将修改后的代码发送一份给我

//编写：戴琪英

//E_Mail:qiyingdai@163.com

//2000-09-01

//=================================================================================

unit R232Comm;

interface
uses
Windows,SysUtils;
const
INITR12COMM_SUCCESS=0;
INITR12COMM_FAILURE=-1;
var
bSendFinish:boolean=True;//发送完标志
iRecvLen:DWORD=0;
RecvBuff,TempBuff:PChar;
SendCommand,RecvCommand:String;//发送和接收到的命令
RecvFinish:BOOL=False;
RecvBuffInit:BOOL=False;
SendCommandSuccess:BOOL; //切换台命令被成功发送标志

function InitR12CommDev(comNo:PChar):String; //初始化切换台串口，返回状态字符
procedure SwitchR12(WriteBuffer:PChar);//对切换台进行切换函数
procedure SwitchR12Byte(WriteBuffer:Byte);
procedure CommSendNotify;//串口接收到字符事件响应过程
procedure CommRecvNotify; //串口发送缓冲区空事件响应过程
procedure CommWatchThread(var lpdwParam:DWORD);//通信口监视线程
function ConInfo :String;

implementation
var
//comMask,comBuf,ComState:Integer;
dcb:_DCB; //DCB结构用于配置串口，程序中涉及各域含义如下：
//DWORD DCBlength :DCB结构大小
//DWORD BaudRate : 波特率
//DWORD fBinary : 1 二进制模式
//DWORD fParity : 1 进行奇偶校验
//BYTE ByteSize: 字符位数 4~8
//BYTE Parity: 奇偶校验位 0-4分别表示无、奇、偶、传号、空号校验
//BYTE StopBits: 停止位数 0-2分别表示 1、1.5、2个停止位
//WORD XonLim ：XON 阈值
//WORD XoffLim XOFF 阈值
//char XonChar： XON 字符
//char XoffChar: XOFF 字符
//char EvtChar: 事件字符
comStat:_COMSTAT; //COMSTAT结构用于存放有关通信设备的当前信息
//程序中涉及各域含义如下：
//cbInQue :接收缓冲区中字符个数
//cbOutQue:发送缓冲区中字符个数
dwErrorFlag:LongWord;
hCommDev,comThreadHwnd:Thandle;//通信串口句柄和通信监视线程句柄
comMask,comBuf,comState:BOOL;
read_os,write_os:_OVERLAPPED; //OVERLAPPED 结构，用于异步操作的Win32函数中
//程序中涉及各域含义如下：
//DWORD Interval 保留给操作系统使用
//DWORD IntervalHigh 保留给操作系统使用
//DOWD hEvent 当I/O操作完成时被设置为有信号状态
//的事件；当调用ReadFile和WriteFile函数之前，调
//用进程设置该事件
postRecvEvent,postSendEvent:Thandle;//发送缓冲区空和接收到字符事件句柄
dwThreadID1:DWORD; //通信监视线程ID号

///串口初始化函数
//该函数主要完成串口初始化设置和通信线程的启动
//入口参数：串口号
//返回值；初始化是否成功的状态字符
function InitR12CommDev(comNo:PChar) :String;
begin
///打开串口
hCommDev:=CreateFile(comNo, //串口好
GENERIC_READ or GENERIC_WRITE,//对串口以读写方式打开
0,
nil,
OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL or FILE_FLAG_OVERLAPPED,//允许重叠操作
0
);
if hCommDev=INVALID_HANDLE_VALUE then
InitR12CommDev:='切换台通讯端口初始化失败.'
else
InitR12CommDev:='切换台通讯端口初始化成功.';
comMask:=SetCommMask(hCommDev,EV_RXFLAG);//设置事件掩码
//comBuf:=SetupComm(hCommDev,4096,4096);//设置接收和发送缓冲区大小皆为4096字节
comBuf:=SetupComm(hCommDev,1,1);//设置接收和发送缓冲区大小皆为4096字节
if comBuf=False then
InitR12CommDev:='切换台通讯端口初始化失败.'
else
begin
InitR12CommDev:='切换台通讯端口初始化成功.';
//清空缓冲区
PurgeComm(hCommDev,PURGE_TXABORT or PURGE_RXABORT or
PURGE_TXCLEAR or PURGE_RXCLEAR ) ;
end;

//以下对串口进行配置
dcb.DCBlength:=sizeof(_DCB);
comState:=GetCommState(hCOmmDev,dcb); //得到缺省设置
if comState=False then
InitR12CommDev:='切换台通讯端口初始化失败.'
else
InitR12CommDev:='切换台通讯端口初始化成功.';
dcb.BaudRate:=9600; //波特率 9600
dcb.ByteSize:=8;//7; //数据长度7位
dcb.Parity:=NOPARITY;//ODDPARITY; //校验方式 奇校验
dcb.StopBits:=ONESTOPBIT; //停止位 1 位

dcb.Flags := 0; // Enable fBinary
dcb.Flags := dcb.Flags or 2; // Enable parity check
dcb.XonChar:= chr($00) ;
dcb.XoffChar:= chr($00) ;
dcb.XonLim:= 100 ;
dcb.XoffLim:= 100 ;
dcb.EvtChar := Char($ff);

comState:=SetCommState(hCommDev,dcb); //设置串口
if comState=False then
InitR12CommDev:='切换台通讯端口初始化失败.'
else
InitR12CommDev:='切换台通讯端口初始化成功.';
//设置通信接收到字符事件句柄
postRecvEvent:=CreateEvent(NIL,
TRUE,//手工重置事件
TRUE, //初始化为有信号状态
NIL
);
//设置读异步I/O操作事件句柄
read_os.hEvent:=CreateEvent(NIL,
TRUE,//手工重置事件
FALSE, //初始化为无信号状态
NIL
);
//设置发送缓冲区空事件句柄
postSendEvent:=CreateEvent(NIL,
TRUE,//手工重置事件
TRUE, //初始化为有信号状态
NIL);
//设置写异步I/O操作事件句柄
write_os.hEvent:=CreateEvent(NIL,
TRUE,//手工重置事件
FALSE,//初始化为无信号状态
NIL);
//创建通信监视线程
comThreadHwnd:=CreateThread(NIL,
0,
@CommWatchThread, //通信线程函数的地址
nil,
0, //创建后立即运行
dwThreadID1);//通信线程ID号
if comThreadHwnd=INVALID_HANDLE_VALUE then
InitR12CommDev:='INITR12COMM_FAILURE'
else
InitR12CommDev:='切换台通讯端口初始化成功.';
end;

///切换台切换控制函数
///输入参数；切换命令字符串
procedure SwitchR12(WriteBuffer:PChar);
var
dwWriteByte,TxCount:DWORD;
bl:BOOL;
dwError:DWORD;

begin
//WriteBuffer:=chr($0D)+'03A00';
TxCount:=StrLen(WriteBuffer);
if bSendFinish=True then //发送缓冲区空发送
begin
dwWriteByte:=0;
bSendFinish:=False;
bl:=WriteFile(hCommDev,Byte(WriteBuffer^),TxCount,dwWriteByte,@write_os);
if bl=True then
begin
bSendFinish:=True;
PurgeComm(hCommDev,PURGE_TXCLEAR );//如果发送完成，置缓冲区空标志，并清空缓冲区
end;
if bl=False then
begin
dwError:=GetLastError();
if (dwError=ERROR_IO_PENDING) or (dwError=ERROR_IO_INCOMPLETE) then
begin
bl:=GetOverLappedResult(hCommDev,
write_os,dwWriteByte,TRUE);//如果未发送完命令字符
//等待发送完成
if bl=True then
begin
bSendFinish:=True;
PurgeComm(hCommDev,PURGE_TXCLEAR ); //发送完成 置缓冲区空标志，并清空缓冲区
//Result:=True;
end;
end;
end;
end;
//Result:=True;
end;

procedure SwitchR12Byte(WriteBuffer:Byte);
var
dwWriteByte,TxCount:DWORD;
bl:BOOL;
dwError:DWORD;

begin
//WriteBuffer:=chr($0D)+'03A00';
TxCount:= 1 ;//StrLen(WriteBuffer);
if bSendFinish=True then //发送缓冲区空发送
begin
dwWriteByte:=0;
bSendFinish:=False;
bl:=WriteFile(hCommDev,WriteBuffer,TxCount,dwWriteByte,@write_os);
if bl=True then
begin
bSendFinish:=True;
PurgeComm(hCommDev,PURGE_TXCLEAR );//如果发送完成，置缓冲区空标志，并清空缓冲区
end;
if bl=False then
begin
dwError:=GetLastError();
if (dwError=ERROR_IO_PENDING) or (dwError=ERROR_IO_INCOMPLETE) then
begin
bl:=GetOverLappedResult(hCommDev,
write_os,dwWriteByte,TRUE);//如果未发送完命令字符
//等待发送完成
if bl=True then
begin
bSendFinish:=True;
PurgeComm(hCommDev,PURGE_TXCLEAR ); //发送完成 置缓冲区空标志，并清空缓冲区
//Result:=True;
end;
end;
end;
end;
//Result:=True;
end;

////通信监视线程
procedure CommWatchThread(var lpdwParam:DWORD);
var
dwTransfer,dwEvtMask,dwError:DWORD;
os:_OVERLAPPED;
bl:boolean;

begin
os.hEvent:=CreateEvent(nil,
TRUE,
FALSE,
NIL);

comMask:=SetCommMask(hCommDev,EV_RXCHAR or EV_TXEMPTY);//设置监视的事件为接
//收到字符或发送缓冲区空
if comMask=True then
begin
while True do
begin
dwEvtMask:=0;
bl:=WaitCommEvent(hCommDev,dwEvtMask,@os); //查询所监视的通信事件是否
//已经发生
if bl=False then
begin
dwError:=GetLastError();
if dwError=ERROR_IO_PENDING then
GetOverlappedResult(hCOmmDev,os,dwTransfer,TRUE);//若未监测到通信事件
//则在此等待事件发生
end;
//有事件，进行如下处理
if (dwEvtMask and EV_RXCHAR)=EV_RXCHAR then //判断是否为接收到 字符事件
begin
WaitForSingleObject(postRecvEvent,$FFFFFFFF);//等待接收事件句柄为有
//信号状态
ResetEvent(postRecvEvent); //置接收事件句柄为无信号状态，以免接收
//缓冲区被覆盖
CommRecvNotify; //调用接收到字符处理函数
continue; //处理完接收字符，继续监测通信事件
end;
if (dwEvtMask and EV_TXEMPTY)=EV_TXEMPTY then //判断是否为发送缓冲区空事件
begin
WaitForSingleObject(postSendEvent,$FFFFFFFF);//等待发送事件句柄为有
//信号状态
ResetEvent(postSendEvent); //置发送事件句柄为无信号状态，，以免发送
//缓冲区被覆盖
CommSendNotify; //调用发送缓冲区空处理函数
continue;//处理完，继续监测通信事件
end;
end;
end;
CloseHandle(os.hEvent);
end;

//发送缓冲区空处理过程
procedure CommSendNotify;
begin
SetEvent(postSendEvent);//置发送事件未有信号状态，以便进行下一次发送
end;

///接收到字符处理函数
procedure CommRecvNotify;
var
RxCount,dwReadByte:DWORD;
inData :Byte;
begin
ClearCommError(hCommDev,dwErrorFlag,@ComStat);
RxCount:=ComStat.cbInQue; //获取接收缓冲区的字符个数
if RxCount>0 then
begin
if not RecvBuffInit then
begin
StrCopy(RecvBuff,'');
RecvBuffInit:=True;
end;
StrCopy(TempBuff,'');
ReadFile(hCommDev,Byte(TempBuff^),RxCount,dwReadByte,@read_os);//读字符存入
//临时缓冲区中
iRecvLen:=iRecvLen+dwReadByte; //接收到字符个数统计

if iRecvLen >=1 then
begin
inData := Byte(TempBuff^);
if inData = $D9 then
begin
SendCommandSuccess:=True; //如果状态一致，则置该标志为真，标志切换成功
end
else
begin
SendCommandSuccess:=False;//否则，置该标志为假，表示切换失败
end;

iRecvLen:=0;
StrCopy(RecvBuff,'');
RecvBuffInit:=False;
PurgeComm(hCommDev,PURGE_RXCLEAR ); //清空接收缓冲区
end
end;
////////////////
SetEvent(postRecvEvent); //置接收事件句柄为有信号状态，以便接收新字符

end;

function ConInfo :String;
begin
if SendCommandSuccess =True then
begin
Result := '切换器联机监测成功！';
end
else
begin
Result := '切换器联机监测失败！';
end;
end;

{
procedure CommSendNotify;
begin
SetEvent(postSendEvent);//置发送事件未有信号状态，以便进行下一次发送
end;

///接收到字符处理函数
{procedure CommRecvNotify;
var
RxCount,dwReadByte:DWORD;
inData :Byte;
begin
ClearCommError(hCommDev,dwErrorFlag,@ComStat);
RxCount:=ComStat.cbInQue; //获取接收缓冲区的字符个数
if RxCount>0 then
begin
if not RecvBuffInit then
begin
StrCopy(RecvBuff,'');
RecvBuffInit:=True;
end;
StrCopy(TempBuff,'');
ReadFile(hCommDev,Byte(TempBuff^),RxCount,dwReadByte,@read_os);//读字符存入
//ReadFile(hCommDev,Byte(TempBuff^),RxCount,dwReadByte,@read_os);//读字符存入
//临时缓冲区中
iRecvLen:=iRecvLen+dwReadByte; //接收到字符个数统计
{
if iRecvLen<13 then
begin
strcat(Recvbuff,TempBuff); //若接收到的切换台状态字符小于13个，
//将临时缓冲区中的字符拷贝到接收命令缓冲区，准备继续读
end
else
begin
strcat(Recvbuff,TempBuff);
RecvCommand:=RecvBuff;
//若接收到13个切换台状态字符进行如下处理
if (RecvCommand[7]='P')
and(RecvCommand[8]=SendCommand[7]) //比较读入的切换台端口状态
and (RecvCommand[9]=SendCommand[8]) //是否与切换指令中切换的端口
and (RecvCommand[10]=SendCommand[9]) //一致
and (RecvCommand[11]=SendCommand[10]) then

begin
SendCommandSuccess:=True; //如果状态一致，则置该标志为真，标志切换成功
end
else
begin
SendCommandSuccess:=False;//否则，置该标志为假，表示切换失败
end;
iRecvLen:=0;
StrCopy(RecvBuff,'');
RecvBuffInit:=False;
PurgeComm(hCommDev,PURGE_RXCLEAR ); //清空接收缓冲区
end;
}
{
if iRecvLen >=1 then
begin
inData := Byte(TempBuff^);
if inData = $D9 then
begin
SendCommandSuccess:=True; //如果状态一致，则置该标志为真，标志切换成功

end
else
begin
SendCommandSuccess:=False;//否则，置该标志为假，表示切换失败
end;

iRecvLen:=0;
StrCopy(RecvBuff,'');
RecvBuffInit:=False;
PurgeComm(hCommDev,PURGE_RXCLEAR ); //清空接收缓冲区
end
end;
////////////////
SetEvent(postRecvEvent); //置接收事件句柄为有信号状态，以便接收新字符

end;
}

initialization
RecvBuff:=StrAlloc(50*sizeof(Char));
TempBuff:=StrAlloc(50*sizeof(Char));
Finalization
StrDispose(RecvBuff);
StrDispose(TempBuff);
CloseHandle(PostRecvEvent);
CloseHandle(read_os.hEvent);
CloseHandle(PostSendEvent);
CloseHandle(write_os.hEvent);
end.


优质内容筛选与推荐>>
1、九方格抽奖插件
2、Udp发送端和接收端
3、Java Script 学习笔记 -- Ajax
4、A*地图寻路算法实现
5、重新安装和更新所有的 nuget包


长按二维码向我转账

受苹果公司新规定影响，微信 iOS 版的赞赏功能被关闭，可通过二维码转账支持公众号。

    阅读
    好看
    已推荐到看一看
    你的朋友可以在“发现”-“看一看”看到你认为好看的文章。
    已取消，“好看”想法已同步删除
    已推荐到看一看 和朋友分享想法
    最多200字，当前共字 发送

    已发送

    朋友将在看一看看到

    确定
    分享你的想法...
    取消

    分享想法到看一看

    确定
    最多200字，当前共字

    发送中

    网络异常，请稍后重试

    微信扫一扫
    关注该公众号

    0 │ 收藏 │ 举报