【Delphi】modbus-TCP 协议库

        在日常开发中，也会遇到使用modbus的部件，比如温度控制器、读卡器等等，那么使用Delphi开发，也就必须遵守modbus-TCP协议，如果自己使用TCP控件写也没有问题，不过如果有开源的三方库，别人已经调试过了，就不必要自己也造车轮了！

Delphi ModbusTCP components 下载地址

截至 2024-12-02 最新版本为：1.7.3 支持到 Delphi 12 版本。

如果上述连接无法下载，请在这里下载。

源代码如下：

一、ModbusConsts.pas


{$I ModBusCompiler.inc}unit ModbusConsts;interfaceconstMB_PORT = 502;MB_IGNORE_UNITID = 255;MB_PROTOCOL = 0;// Define constants for the ModBus functions
constmbfReadCoils = $01;mbfReadInputBits = $02;mbfReadHoldingRegs = $03;mbfReadInputRegs = $04;mbfWriteOneCoil = $05;mbfWriteOneReg = $06;mbfWriteCoils = $0F;mbfWriteRegs = $10;   mbfReportSlaveID = $11;mbfReadFileRecord = $14;mbfWriteFileRecord = $15;mbfMaskWriteReg = $16;mbfReadWriteRegs = $17;mbfReadFiFoQueue = $18;// Define constants for the ModBus exceptions
constmbeOk = $00;mbeIllegalFunction = $01;mbeIllegalRegister = $02;mbeIllegalDataValue = $03;mbeServerFailure = $04;mbeAcknowledge = $05;mbeServerBusy = $06;mbeGatewayPathNotAvailable = $0A;mbeGatewayNoResponseFromTarget = $0B;constMaxBlockLength = 125;MaxCoils = 2000;constDMB_VERSION = '1.7.3'; {Do not Localize}constDefaultLogTimeFormat = 'yyyy-mm-dd hh:nn:ss.zzz';  {Do not Localize}implementationend.

二、ModbusTypes.pas


{$I ModBusCompiler.inc}unit ModbusTypes;interfacetypeTModBusFunction = Byte;typeTModBusDataBuffer = array[0..260] of Byte;typeTModBusHeader = packed recordTransactionID: Word;ProtocolID: Word;RecLength: Word;UnitID: Byte;end;typeTModBusRequestBuffer = packed recordHeader: TModBusHeader;FunctionCode: TModBusFunction;MBPData: TModBusDataBuffer;end;typeTModBusResponseBuffer = packed recordHeader: TModBusHeader;FunctionCode: TModBusFunction;MBPData: TModBusDataBuffer;end;typeTModBusExceptionBuffer = packed recordHeader: TModBusHeader;ExceptionFunction: TModBusFunction;ExceptionCode: Byte;end;implementationend.

三、ModbusUtils.pas

{$I ModBusCompiler.inc}unit ModbusUtils;interfacefunction BufferToHex(const Buffer: array of Byte): String;
function CalculateCRC16(const Buffer: array of Byte): Word;
function CalculateLRC(const Buffer: array of Byte): Byte;function Swap16(const DataToSwap: Word): Word;procedure GetCoilsFromBuffer(const Buffer: PByte; const Count: Word; var Data: array of Word);
procedure PutCoilsIntoBuffer(const Buffer: PByte; const Count: Word; const Data: array of Word);procedure GetReportFromBuffer(const Buffer: PByte; const Count: Word; var Data: array of Word);procedure GetRegistersFromBuffer(const Buffer: PWord; const Count: Word; var Data: array of Word);
procedure PutRegistersIntoBuffer(const Buffer: PWord; const Count: Word; const Data: array of Word);implementationusesSysUtils;constCRC16Table: array[0..255] of Word = ($0000, $C0C1, $C181, $0140, $C301, $03C0, $0280, $C241,$C601, $06C0, $0780, $C741, $0500, $C5C1, $C481, $0440,$CC01, $0CC0, $0D80, $CD41, $0F00, $CFC1, $CE81, $0E40,$0A00, $CAC1, $CB81, $0B40, $C901, $09C0, $0880, $C841,$D801, $18C0, $1980, $D941, $1B00, $DBC1, $DA81, $1A40,$1E00, $DEC1, $DF81, $1F40, $DD01, $1DC0, $1C80, $DC41,$1400, $D4C1, $D581, $1540, $D701, $17C0, $1680, $D641,$D201, $12C0, $1380, $D341, $1100, $D1C1, $D081, $1040,$F001, $30C0, $3180, $F141, $3300, $F3C1, $F281, $3240,$3600, $F6C1, $F781, $3740, $F501, $35C0, $3480, $F441,$3C00, $FCC1, $FD81, $3D40, $FF01, $3FC0, $3E80, $FE41,$FA01, $3AC0, $3B80, $FB41, $3900, $F9C1, $F881, $3840,$2800, $E8C1, $E981, $2940, $EB01, $2BC0, $2A80, $EA41,$EE01, $2EC0, $2F80, $EF41, $2D00, $EDC1, $EC81, $2C40,$E401, $24C0, $2580, $E541, $2700, $E7C1, $E681, $2640,$2200, $E2C1, $E381, $2340, $E101, $21C0, $2080, $E041,$A001, $60C0, $6180, $A141, $6300, $A3C1, $A281, $6240,$6600, $A6C1, $A781, $6740, $A501, $65C0, $6480, $A441,$6C00, $ACC1, $AD81, $6D40, $AF01, $6FC0, $6E80, $AE41,$AA01, $6AC0, $6B80, $AB41, $6900, $A9C1, $A881, $6840,$7800, $B8C1, $B981, $7940, $BB01, $7BC0, $7A80, $BA41,$BE01, $7EC0, $7F80, $BF41, $7D00, $BDC1, $BC81, $7C40,$B401, $74C0, $7580, $B541, $7700, $B7C1, $B681, $7640,$7200, $B2C1, $B381, $7340, $B101, $71C0, $7080, $B041,$5000, $90C1, $9181, $5140, $9301, $53C0, $5280, $9241,$9601, $56C0, $5780, $9741, $5500, $95C1, $9481, $5440,$9C01, $5CC0, $5D80, $9D41, $5F00, $9FC1, $9E81, $5E40,$5A00, $9AC1, $9B81, $5B40, $9901, $59C0, $5880, $9841,$8801, $48C0, $4980, $8941, $4B00, $8BC1, $8A81, $4A40,$4E00, $8EC1, $8F81, $4F40, $8D01, $4DC0, $4C80, $8C41,$4400, $84C1, $8581, $4540, $8701, $47C0, $4680, $8641,$8201, $42C0, $4380, $8341, $4100, $81C1, $8081, $4040);function BufferToHex(const Buffer: array of Byte): String;
vari: Integer;
beginResult := '';for i := Low(Buffer) to High(Buffer) doResult := Result + IntToHex(Buffer[i], 2);
end;function CalculateCRC16(const Buffer: array of Byte): Word;
vari: Integer;bTemp: Byte;
beginResult := 0;for i := Low(Buffer) to High(Buffer) dobeginbTemp := Buffer[i] xor Result;Result := Result shr 8;Result := Result xor CRC16Table[bTemp];end;
end;function CalculateLRC(const Buffer: array of Byte): Byte;
vari: Integer;CheckSum: Word;
beginCheckSum := 0;for i := Low(Buffer) to High(Buffer) doCheckSum := WordRec(CheckSum).Lo + Buffer[i];Result := - WordRec(CheckSum).Lo;
end;function Swap16(const DataToSwap: Word): Word;
beginResult := (DataToSwap div 256) + ((DataToSwap mod 256) * 256);
end;procedure GetCoilsFromBuffer(const Buffer: PByte; const Count: Word; var Data: array of Word);
varBytePtr: PByte;BitMask: Byte;i: Integer;
beginif (Length(Data) < ((Count div 16) - 1)) or (Length(Data) = 0) or (Count = 0) thenraise Exception.Create('GetCoilsFromBuffer: Data array length cannot be less then Count');BytePtr := Buffer;BitMask := 1;for i := 0 to (Count - 1) dobeginif (i < Length(Data)) thenbeginif ((BytePtr^ and BitMask) <> 0) thenData[i] := 1elseData[i] := 0;if (BitMask = $80) thenbeginBitMask := 1;Inc(BytePtr);endelseBitMask := (Bitmask shl 1);end;end;
end;procedure PutCoilsIntoBuffer(const Buffer: PByte; const Count: Word; const Data: array of Word);
varBytePtr: PByte;BitMask: Byte;i: Word;
beginif (Length(Data) < ((Count div 16) - 1)) or (Length(Data) = 0) or (Count = 0) thenraise Exception.Create('PutCoilsIntoBuffer: Data array length cannot be less then Count');BytePtr := Buffer;BitMask := 1;for i := 0 to (Count - 1) dobeginif (i < Length(Data)) thenbeginif (BitMask = 1) thenBytePtr^ := 0;if (Data[i] <> 0) thenBytePtr^ := BytePtr^ or BitMask;if (BitMask = $80) thenbeginBitMask := 1;Inc(BytePtr);endelseBitMask := (Bitmask shl 1);end;end;
end;procedure GetRegistersFromBuffer(const Buffer: PWord; const Count: Word; var Data: array of Word);
varWordPtr: PWord;i: Word;
beginif (Length(Data) < (Count - 1)) or (Length(Data) = 0) or (Count = 0) thenraise Exception.Create('GetRegistersFromBuffer: Data array length cannot be less then Count');WordPtr := Buffer;for i := 0 to (Count - 1) dobeginData[i] := Swap16(WordPtr^);Inc(WordPtr);end;
end;procedure GetReportFromBuffer(const Buffer: PByte; const Count: Word; var Data: array of Word);
varWordPtr: PByte;i: Word;
beginif (Length(Data) < (Count - 1)) or (Length(Data) = 0) or (Count = 0) thenraise Exception.Create('GetRegistersFromBuffer: Data array length cannot be less then Count');WordPtr := Buffer;i:= 0;for i:= 0 to (Count - 1) dobeginData[i] := Lo(WordPtr^);Inc(WordPtr);end;
end;procedure PutRegistersIntoBuffer(const Buffer: PWord; const Count: Word; const Data: array of Word);
varWordPtr: PWord;i: Word;
beginif (Length(Data) < (Count - 1)) or (Length(Data) = 0) or (Count = 0) thenraise Exception.Create('PutRegistersIntoBuffer: Data array length cannot be less then Count');WordPtr := Buffer;for i := 0 to (Count - 1) dobeginWordPtr^ := Swap16(Data[i]);Inc(WordPtr);end;
end;end.

四、IdModBusClient.pas

{$I ModBusCompiler.inc}unit IdModBusClient;interfaceusesClasses,SysUtils,ModBusConsts,ModbusTypes
{$IFDEF DMB_DELPHI6},Types
{$ENDIF},IdGlobal,IdTCPClient;typeTModBusClientErrorEvent = procedure(const FunctionCode: Byte;const ErrorCode: Byte; const ResponseBuffer: TModBusResponseBuffer) of object;TModBusClientResponseMismatchEvent = procedure(const RequestFunctionCode: Byte;const ResponseFunctionCode: Byte; const ResponseBuffer: TModBusResponseBuffer) of object;type
{$I ModBusPlatforms.inc}TIdModBusClient = class(TIdTCPClient)privateFAutoConnect: Boolean;FBaseRegister: Word;{$IFNDEF DMB_INDY10}FConnectTimeOut: Integer;{$ENDIF}FOnResponseError: TModbusClientErrorEvent;FOnResponseMismatch: TModBusClientResponseMismatchEvent;FLastTransactionID: Word;FReadTimeout: Integer;FTimeOut: Cardinal;FUnitID: Byte;function GetVersion: String;procedure SetVersion(const Value: String);function GetNewTransactionID: Word;protectedprocedure DoResponseError(const FunctionCode: Byte; const ErrorCode: Byte;const ResponseBuffer: TModBusResponseBuffer);procedure DoResponseMismatch(const RequestFunctionCode: Byte; const ResponseFunctionCode: Byte;const ResponseBuffer: TModBusResponseBuffer);{$IFDEF DMB_INDY10}procedure InitComponent; override;{$ENDIF}function SendCommand(const AModBusFunction: TModBusFunction; const ARegNumber: Word;const ABlockLength: Word; var Data: array of Word): Boolean;publicproperty LastTransactionID: Word read FLastTransactionID;{$IFNDEF DMB_INDY10}constructor Create(AOwner: TComponent); override;{$ENDIF}{ public methods }{$IFDEF DMB_INDY10}procedure Connect; override;{$ELSE}procedure Connect(const ATimeout: Integer = IdTimeoutDefault); override;{$ENDIF}function ReadCoil(const RegNo: Word; out Value: Boolean): Boolean;function ReadCoils(const RegNo: Word; const Blocks: Word; out RegisterData: array of Boolean): Boolean;function ReadDouble(const RegNo: Word; out Value: Double): Boolean;function ReadDWord(const RegNo: Word; out Value: DWord): Boolean;function ReadHoldingRegister(const RegNo: Word; out Value: Word): Boolean;function ReadHoldingRegisters(const RegNo: Word; const Blocks: Word; out RegisterData: array of Word): Boolean;function ReadInputBits(const RegNo: Word; const Blocks: Word; out RegisterData: array of Boolean): Boolean;function ReadInputRegister(const RegNo: Word; out Value: Word): Boolean;function ReadInputRegisters(const RegNo: Word; const Blocks: Word; var RegisterData: array of Word): Boolean;function ReadSingle(const RegNo: Word; out Value: Single): Boolean;function ReadString(const RegNo: Word; const ALength: Word): String;function ReportSlaveID(const Blocks: Word; out RegisterData: array of Word):boolean;function WriteCoil(const RegNo: Word; const Value: Boolean): Boolean;function WriteCoils(const RegNo: Word; const Blocks: Word; const RegisterData: array of Boolean): Boolean;function WriteRegister(const RegNo: Word; const Value: Word): Boolean;function WriteRegisters(const RegNo: Word; const RegisterData: array of Word): Boolean;function WriteDouble(const RegNo: Word; const Value: Double): Boolean;function WriteDWord(const RegNo: Word; const Value: DWord): Boolean;function WriteSingle(const RegNo: Word; const Value: Single): Boolean;function WriteString(const RegNo: Word; const Text: String): Boolean;publishedproperty AutoConnect: Boolean read FAutoConnect write FAutoConnect default True;property BaseRegister: Word read FBaseRegister write FBaseRegister default 1; {$IFNDEF DMB_INDY10}property ConnectTimeOut: Integer read FConnectTimeOut write FConnectTimeOut default -1;{$ENDIF}property ReadTimeout: Integer read FReadTimeout write FReadTimeout default 0;property Port default MB_PORT;property TimeOut: Cardinal read FTimeOut write FTimeout default 15000;property UnitID: Byte read FUnitID write FUnitID default MB_IGNORE_UNITID;property Version: String read GetVersion write SetVersion stored False;{ events }property OnResponseError: TModbusClientErrorEvent read FOnResponseError write FOnResponseError;property OnResponseMismatch: TModBusClientResponseMismatchEvent read FOnResponseMismatch write FOnResponseMismatch;end;implementationusesModbusUtils;{ TIdModBusClient }{$IFDEF DMB_INDY10}
procedure TIdModBusClient.Connect;
{$ELSE}
procedure TIdModBusClient.Connect(const ATimeout: Integer = IdTimeoutDefault);
{$ENDIF}
begininherited;FLastTransactionID := 0;
end;{$IFDEF DMB_INDY10}
procedure TIdModBusClient.InitComponent;
{$ELSE}
constructor TIdModBusClient.Create(AOwner: TComponent);
{$ENDIF}
begin
{$IFDEF DMB_INDY10}inherited;
{$ELSE}inherited Create(AOwner);FConnectTimeOut := -1;
{$ENDIF}FAutoConnect := True;FBaseRegister := 1;FLastTransactionID := 0;FReadTimeout := 0;FUnitID := MB_IGNORE_UNITID;FTimeOut := 15000;Port := MB_PORT;FOnResponseError := nil;FOnResponseMismatch := nil;
end;procedure TIdModBusClient.DoResponseError(const FunctionCode: Byte; const ErrorCode: Byte;const ResponseBuffer: TModBusResponseBuffer);
beginif Assigned(FOnResponseError) thenFOnResponseError(FunctionCode, ErrorCode, ResponseBuffer);
end;procedure TIdModBusClient.DoResponseMismatch(const RequestFunctionCode: Byte;const ResponseFunctionCode: Byte; const ResponseBuffer: TModBusResponseBuffer);
beginif Assigned(FOnResponseMismatch) thenFOnResponseMismatch(RequestFunctionCode, ResponseFunctionCode, ResponseBuffer);
end;function TIdModBusClient.SendCommand(const AModBusFunction: TModBusFunction;const ARegNumber: Word; const ABlockLength: Word; var Data: array of Word): Boolean;
varSendBuffer: TModBusRequestBuffer;ReceiveBuffer: TModBusResponseBuffer;BlockLength: Word;RegNumber: Word;dtTimeOut: TDateTime;
{$IFDEF DMB_INDY10}Buffer: TIdBytes;RecBuffer: TIdBytes;iSize: Integer;
{$ENDIF}
begin
{$IFDEF DMB_INDY10}CheckForGracefulDisconnect(True);
{$ELSE}CheckForDisconnect(True, True);
{$ENDIF}SendBuffer.Header.TransactionID := GetNewTransactionID;SendBuffer.Header.ProtocolID := MB_PROTOCOL;
{ Initialise data related variables }RegNumber := ARegNumber - FBaseRegister;
{ Perform function code specific operations }case AModBusFunction ofmbfReadCoils,mbfReadInputBits:beginBlockLength := ABlockLength;{ Don't exceed max length }if (BlockLength > 2000) thenBlockLength := 2000;{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.MBPData[0] := Hi(RegNumber);SendBuffer.MBPData[1] := Lo(RegNumber);SendBuffer.MBPData[2] := Hi(BlockLength);SendBuffer.MBPData[3] := Lo(BlockLength);SendBuffer.Header.RecLength := Swap16(6); { This includes UnitID/FuntionCode }end;mbfReadHoldingRegs,mbfReadInputRegs:beginBlockLength := ABlockLength;if (BlockLength > 125) thenBlockLength := 125; { Don't exceed max length }{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.MBPData[0] := Hi(RegNumber);SendBuffer.MBPData[1] := Lo(RegNumber);SendBuffer.MBPData[2] := Hi(BlockLength);SendBuffer.MBPData[3] := Lo(BlockLength);SendBuffer.Header.RecLength := Swap16(6); { This includes UnitID/FuntionCode }end;mbfReportSlaveID:beginBlockLength := ABlockLength;if (BlockLength > 125) thenBlockLength := 125; { Don't exceed max length }{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.Header.RecLength := Swap16(2); { This includes UnitID/FuntionCode }end;mbfWriteOneCoil:begin{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.MBPData[0] := Hi(RegNumber);SendBuffer.MBPData[1] := Lo(RegNumber);if (Data[0] <> 0) thenSendBuffer.MBPData[2] := 255elseSendBuffer.MBPData[2] := 0;SendBuffer.MBPData[3] := 0;SendBuffer.Header.RecLength := Swap16(6); { This includes UnitID/FuntionCode }end;mbfWriteOneReg:begin{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.MBPData[0] := Hi(RegNumber);SendBuffer.MBPData[1] := Lo(RegNumber);SendBuffer.MBPData[2] := Hi(Data[0]);SendBuffer.MBPData[3] := Lo(Data[0]);SendBuffer.Header.RecLength := Swap16(6); { This includes UnitID/FuntionCode }end;mbfWriteCoils:beginBlockLength := ABlockLength;{ Don't exceed max length }if (BlockLength > 1968) thenBlockLength := 1968;{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.MBPData[0] := Hi(RegNumber);SendBuffer.MBPData[1] := Lo(RegNumber);SendBuffer.MBPData[2] := Hi(BlockLength);SendBuffer.MBPData[3] := Lo(BlockLength);SendBuffer.MBPData[4] := Byte((BlockLength + 7) div 8);PutCoilsIntoBuffer(@SendBuffer.MBPData[5], BlockLength, Data);SendBuffer.Header.RecLength := Swap16(7 + SendBuffer.MBPData[4]);end;mbfWriteRegs:beginBlockLength := ABlockLength;{ Don't exceed max length }if (BlockLength > 120) thenBlockLength := 120;{ Initialise the data part }SendBuffer.FunctionCode := Byte(AModBusFunction); { Write appropriate function code }SendBuffer.Header.UnitID := FUnitID;SendBuffer.MBPData[0] := Hi(RegNumber);SendBuffer.MBPData[1] := Lo(RegNumber);SendBuffer.MBPData[2] := Hi(BlockLength);SendBuffer.MBPData[3] := Lo(BlockLength);SendBuffer.MbpData[4] := Byte(BlockLength shl 1);PutRegistersIntoBuffer(@SendBuffer.MBPData[5], BlockLength, Data);SendBuffer.Header.RecLength := Swap16(7 + SendBuffer.MbpData[4]);end;end;
{ Writeout the data to the connection }
{$IFDEF DMB_INDY10}Buffer := RawToBytes(SendBuffer, Swap16(SendBuffer.Header.RecLength) + 6);IOHandler.WriteDirect(Buffer);
{$ELSE}WriteBuffer(SendBuffer, Swap16(SendBuffer.Header.RecLength) + 6);
{$ENDIF}{*** Wait for data from the PLC ***}if (FTimeOut > 0) thenbegindtTimeOut := Now + (FTimeOut / 86400000);{$IFDEF DMB_INDY10}while (IOHandler.InputBuffer.Size = 0) do{$ELSE}while (InputBuffer.Size = 0) do{$ENDIF}begin{$IFDEF DMB_INDY10}IOHandler.CheckForDataOnSource(FReadTimeout);{$ELSE}if Socket.Binding.Readable(FReadTimeout) thenReadFromStack;{$ENDIF}if (Now > dtTimeOut) thenbeginResult := False;Exit;end;end;end;Result := True;
{$IFDEF DMB_INDY10}iSize := IOHandler.InputBuffer.Size;IOHandler.ReadBytes(RecBuffer, iSize);Move(RecBuffer[0], ReceiveBuffer, iSize);
{$ELSE}ReadBuffer(ReceiveBuffer, InputBuffer.Size);
{$ENDIF}
{ Check if the result has the same function code as the request }if (AModBusFunction = ReceiveBuffer.FunctionCode) thenbegincase AModBusFunction ofmbfReadCoils,mbfReadInputBits:beginBlockLength := ReceiveBuffer.MBPData[0] * 8;if (BlockLength > 2000) thenBlockLength := 2000;GetCoilsFromBuffer(@ReceiveBuffer.MBPData[1], BlockLength, Data);end;mbfReportSlaveID:beginBlockLength := Swap16(ReceiveBuffer.Header.RecLength) - 2;GetReportFromBuffer(@ReceiveBuffer.MBPData[0], BlockLength, Data);end;mbfReadHoldingRegs,mbfReadInputRegs:beginBlockLength := (ReceiveBuffer.MBPData[0] shr 1);if (BlockLength > 125) thenBlockLength := 125;GetRegistersFromBuffer(@ReceiveBuffer.MBPData[1], BlockLength, Data);end;end;endelsebeginif ((AModBusFunction or $80) = ReceiveBuffer.FunctionCode) thenDoResponseError(AModBusFunction, ReceiveBuffer.MBPData[0], ReceiveBuffer)elseDoResponseMismatch(AModBusFunction, ReceiveBuffer.FunctionCode, ReceiveBuffer);Result := False;end;
end;function TIdModBusClient.GetNewTransactionID: Word;
beginif (FLastTransactionID = $FFFF) thenFLastTransactionID := 0elseInc(FLastTransactionID);Result := FLastTransactionID;
end;function TIdModBusClient.ReadHoldingRegister(const RegNo: Word;out Value: Word): Boolean;
varData: array[0..0] of Word;  
beginResult := ReadHoldingRegisters(RegNo, 1, Data);Value := Data[0];
end;function TIdModBusClient.ReadHoldingRegisters(const RegNo, Blocks: Word;out RegisterData: array of Word): Boolean;
vari: Integer;Data: array of Word;bNewConnection: Boolean;
beginbNewConnection := False;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;trySetLength(Data, Blocks);FillChar(Data[0], Length(Data), 0);Result := SendCommand(mbfReadHoldingRegs, RegNo, Blocks, Data);for i := Low(Data) to High(Data) doRegisterData[i] := Data[i];finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.ReadInputBits(const RegNo, Blocks: Word;out RegisterData: array of Boolean): Boolean;
vari: Integer;Data: array of Word;bNewConnection: Boolean;
beginbNewConnection := False;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;SetLength(Data, Blocks);FillChar(Data[0], Length(Data), 0);tryResult := SendCommand(mbfReadInputBits, RegNo, Blocks, Data);for i := 0 to (Blocks - 1) doRegisterData[i] := (Data[i] = 1);finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.ReadInputRegister(const RegNo: Word;out Value: Word): Boolean;
varData: array[0..0] of Word;
beginResult := ReadInputRegisters(RegNo, 1, Data);Value := Data[0];
end;function TIdModBusClient.ReadInputRegisters(const RegNo, Blocks: Word;var RegisterData: array of Word): Boolean;
varbNewConnection: Boolean;
beginbNewConnection := False;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;FillChar(RegisterData[0], Length(RegisterData), 0);tryResult := SendCommand(mbfReadInputRegs, RegNo, Blocks, RegisterData);finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.ReadCoil(const RegNo: Word; out Value: Boolean): Boolean;
varData: array[0..0] of Boolean;
beginResult := ReadCoils(RegNo, 1, Data);Value := Data[0];
end;function TIdModBusClient.ReadCoils(const RegNo, Blocks: Word; out RegisterData: array of Boolean): Boolean;
vari: Integer;Data: array of Word;bNewConnection: Boolean;
beginbNewConnection := False;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;SetLength(Data, Blocks);FillChar(Data[0], Length(Data), 0);tryResult := SendCommand(mbfReadCoils, RegNo, Blocks, Data);for i := 0 to (Blocks - 1) doRegisterData[i] := (Data[i] = 1);finallyif bNewConnection thenDisConnect;end;
end;function TIdModbusClient.ReadDouble(const RegNo: Word; out Value: Double): Boolean;
varBuffer: array[0..3] of Word;
beginResult := ReadHoldingRegisters(RegNo, 4, Buffer);if Result thenMove(Buffer, Value, SizeOf(Value))elseValue := 0.0;
end;function TIdModbusClient.ReadDWord(const RegNo: Word; out Value: DWord): Boolean;
varBuffer: array[0..1] of Word;
beginResult := ReadHoldingRegisters(RegNo, 2, Buffer);if Result thenbeginLongRec(Value).Hi := Buffer[0];LongRec(Value).Lo := Buffer[1];endelseValue := 0;
end;function TIdModbusClient.ReadSingle(const RegNo: Word; out Value: Single): Boolean;
varBuffer: array[0..1] of Word;
beginResult := ReadHoldingRegisters(RegNo, 2, Buffer);if Result thenMove(Buffer, Value, SizeOf(Value))elseValue := 0.0;
end;function TIdModbusClient.ReadString(const RegNo: Word; const ALength: Word): String;
varBlockCount: Word;Data: array of Word;i: Integer;
beginResult := '';BlockCount := Round((ALength / 2) + 0.1);SetLength(Data, BlockCount);FillChar(Data[0], BlockCount, 0);if ReadHoldingRegisters(RegNo, BlockCount, Data) thenbeginfor i := 0 to (BlockCount - 1) dobeginResult := Result + Chr(WordRec(Data[i]).Hi);if (Length(Result) < ALength) thenResult := Result + Chr(WordRec(Data[i]).Lo);end;end;
end;function TIdModbusClient.ReportSlaveID(const Blocks: Word; out RegisterData: array of Word): Boolean;
varbNewConnection: Boolean;i: integer;
beginbNewConnection := False;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;FillChar(RegisterData[0], Length(RegisterData), 0);tryResult := SendCommand(mbfReportSlaveID, 1, 2, RegisterData);finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.GetVersion: String;
beginResult := DMB_VERSION;
end;procedure TIdModBusClient.SetVersion(const Value: String);
begin
{ This intentionally is a readonly property }
end;function TIdModBusClient.WriteDouble(const RegNo: Word; const Value: Double): Boolean;
varBuffer: array[0..3] of Word;
beginMove(Value, Buffer, SizeOf(Value));Result := WriteRegisters(RegNo, Buffer);
end;function TIdModBusClient.WriteDWord(const RegNo: Word; const Value: DWord): Boolean;
varBuffer: array[0..1] of Word;
beginBuffer[0] := LongRec(Value).Hi;Buffer[1] := LongRec(Value).Lo;Result := WriteRegisters(RegNo, Buffer);
end;function TIdModBusClient.WriteSingle(const RegNo: Word; const Value: Single): Boolean;
varBuffer: array[0..1] of Word;
beginMove(Value, Buffer, SizeOf(Value));Result := WriteRegisters(RegNo, Buffer);
end;function TIdModBusClient.WriteString(const RegNo: Word; const Text: String): Boolean;
varBuffer: array of Word;i: Integer;iIndex: Integer;
beginif (Text <> '') thenbeginSetLength(Buffer, Round((Length(Text) / 2) + 0.1));FillChar(Buffer[0], Length(Buffer), 0);for i := 0 to Length(Buffer) dobeginiIndex := (i * 2) + 1;if (iIndex <= Length(Text)) thenWordRec(Buffer[i]).Hi := Ord(Text[iIndex]);if ((iIndex + 1) <= Length(Text)) thenWordRec(Buffer[i]).Lo := Ord(Text[iIndex + 1]);end;Result := WriteRegisters(RegNo, Buffer);endelseResult := False;
end;function TIdModBusClient.WriteRegister(const RegNo, Value: Word): Boolean;
varData: array[0..0] of Word;bNewConnection: Boolean;
beginbNewConnection := False;Data[0] := Value;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;tryResult := SendCommand(mbfWriteOneReg, RegNo, 0, Data);finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.WriteRegisters(const RegNo: Word;const RegisterData: array of Word): Boolean;
vari: Integer;iBlockLength: Integer;Data: array of Word;bNewConnection: Boolean;
beginbNewConnection := False;iBlockLength := High(RegisterData) - Low(RegisterData) + 1;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;trySetLength(Data, Length(RegisterData));for i := Low(RegisterData) to High(RegisterData) doData[i] := RegisterData[i];Result := SendCommand(mbfWriteRegs, RegNo, iBlockLength, Data);finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.WriteCoil(const RegNo: Word; const Value: Boolean): Boolean;
varData: array[0..0] of Word;bNewConnection: Boolean;
beginbNewConnection := False;if Value thenData[0] := 1elseData[0] := 0;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;tryResult := SendCommand(mbfWriteOneCoil, RegNo, 0, Data);finallyif bNewConnection thenDisConnect;end;
end;function TIdModBusClient.WriteCoils(const RegNo, Blocks: Word; const RegisterData: array of Boolean): Boolean;
vari: Integer;iBlockLength: Integer;Data: array of Word;bNewConnection: Boolean;
beginbNewConnection := False;iBlockLength := High(RegisterData) - Low(RegisterData) + 1;if FAutoConnect and not Connected thenbegin{$IFDEF DMB_INDY10}Connect;{$ELSE}Connect(FConnectTimeOut);{$ENDIF}bNewConnection := True;end;trySetLength(Data, Length(RegisterData));for i := Low(RegisterData) to High(RegisterData) dobeginif RegisterData[i] thenData[i] := 1elseData[i] := 0;end;Result := SendCommand(mbfWriteCoils, RegNo, iBlockLength, Data);finallyif bNewConnection thenDisConnect;end;
end;end.

五、IdModBusServer.pas

{$I ModBusCompiler.inc}unit IdModBusServer;interfaceusesClasses,SysUtils
{$IFDEF DMB_INDY10},IdContext,IdCustomTCPServer,IdGlobal
{$ELSE},IdTCPClient,IdTCPServer
{$ENDIF},ModBusConsts,ModbusTypes,ModbusUtils,SyncObjs;typeTModRegisterData = array[0..MaxBlockLength] of Word;typeTModCoilData = array[0..MaxCoils] of ByteBool;{$IFDEF DMB_INDY10}
typeTModBusCoilReadEvent = procedure(const Sender: TIdContext;const RegNr, Count: Integer; var Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusRegisterReadEvent = procedure(const Sender: TIdContext;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusCoilWriteEvent = procedure(const Sender: TIdContext;const RegNr, Count: Integer; const Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusRegisterWriteEvent = procedure(const Sender: TIdContext;const RegNr, Count: Integer; const Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusErrorEvent = procedure(const Sender: TIdContext;const FunctionCode: Byte; const ErrorCode: Byte;const RequestBuffer: TModBusRequestBuffer) of object;TModBusInvalidFunctionEvent = procedure(const Sender: TIdContext;const FunctionCode: TModBusFunction;const RequestBuffer: TModBusRequestBuffer) of object;
{$ELSE}
typeTModBusCoilReadEvent = procedure(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusRegisterReadEvent = procedure(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusCoilWriteEvent = procedure(const Sender: TIdPeerThread;const RegNr, Count: Integer; const Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusRegisterWriteEvent = procedure(const Sender: TIdPeerThread;const RegNr, Count: Integer; const Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte) of object;TModBusErrorEvent = procedure(const Sender: TIdPeerThread;const FunctionCode: Byte; const ErrorCode: Byte;const RequestBuffer: TModBusRequestBuffer) of object;TModBusInvalidFunctionEvent = procedure(const Sender: TIdPeerThread;const FunctionCode: TModBusFunction;const RequestBuffer: TModBusRequestBuffer) of object;
{$ENDIF}type
{$I ModBusPlatforms.inc}
{$IFDEF DMB_INDY10}TIdModBusServer = class(TIdCustomTCPServer)
{$ELSE}TIdModBusServer = class(TIdTCPServer)
{$ENDIF}privateFBaseRegister: Word;FOneShotConnection: Boolean;FLogCriticalSection: TCriticalSection;FLogEnabled: Boolean;FLogFile: String;FLogTimeFormat: String;FMaxRegister: Word;FMinRegister: Word;FOnError: TModBusErrorEvent;FOnInvalidFunction: TModBusInvalidFunctionEvent;FOnReadCoils: TModBusCoilReadEvent;FOnReadHoldingRegisters: TModBusRegisterReadEvent;FOnReadInputBits: TModBusCoilReadEvent;FOnReadInputRegisters: TModBusRegisterReadEvent;FOnWriteCoils: TModBusCoilWriteEvent;FOnWriteRegisters: TModBusRegisterWriteEvent;FPause: Boolean;FUnitID: Byte;function GetVersion: String;procedure SetVersion(const Value: String);function IsLogTimeFormatStored: Boolean;procedure LogByteBuffer(const LogType: String; const PeerIP: String; const ByteBuffer: array of Byte; const Size: Integer);{$IFDEF DMB_INDY10}procedure InternalReadCoils(const AContext: TIdContext; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);procedure InternalReadInputBits(const AContext: TIdContext; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);procedure InternalWriteCoils(const AContext: TIdContext; const RegNr, Count: Integer;const Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);{$ELSE}procedure InternalReadCoils(const Sender: TIdPeerThread; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);procedure InternalReadInputBits(const Sender: TIdPeerThread; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);procedure InternalWriteCoils(const Sender: TIdPeerThread; const RegNr, Count: Integer;const Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);{$ENDIF}protected{$IFDEF DMB_INDY10}procedure InitComponent; override;{$ENDIF}{$IFDEF DMB_INDY10}procedure DoError(const AContext: TIdContext; const FunctionCode: Byte;const ErrorCode: Byte; const RequestBuffer: TModBusRequestBuffer); virtual;function DoExecute(AContext: TIdContext): Boolean; override;procedure DoInvalidFunction(const AContext: TIdContext;const FunctionCode: TModBusFunction; const RequestBuffer: TModBusRequestBuffer); virtual;procedure DoReadHoldingRegisters(const AContext: TIdContext; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoReadInputRegisters(const AContext: TIdContext; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoReadCoils(const AContext: TIdContext; const RegNr, Count: Integer;var Data: TModCoilData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoReadInputBits(const AContext: TIdContext; const RegNr, Count: Integer;var Data: TModCoilData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoWriteCoils(const AContext: TIdContext; const RegNr, Count: Integer;const Data: TModCoilData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoWriteRegisters(const AContext: TIdContext; const RegNr, Count: Integer;const Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure LogExceptionBuffer(const AContext: TIdContext; const Buffer: TModBusExceptionBuffer);procedure LogRequestBuffer(const AContext: TIdContext; const Buffer: TModBusRequestBuffer; const Size: Integer);procedure LogResponseBuffer(const AContext: TIdContext; const Buffer: TModBusResponseBuffer; const Size: Integer);procedure ReadCommand(const AContext: TIdContext);procedure SendError(const AContext: TIdContext; const ErrorCode: Byte;const ReceiveBuffer: TModBusRequestBuffer);procedure SendResponse(const AContext: TIdContext; const ReceiveBuffer: TModBusRequestBuffer;const Data: TModRegisterData);{$ELSE}procedure DoError(const Sender: TIdPeerThread; const FunctionCode: Byte;const ErrorCode: Byte; const RequestBuffer: TModBusRequestBuffer); virtual;function DoExecute(AThread: TIdPeerThread): Boolean; override;procedure DoInvalidFunction(const Sender: TIdPeerThread; const FunctionCode: TModBusFunction;const RequestBuffer: TModBusRequestBuffer); virtual;procedure DoReadHoldingRegisters(const Sender: TIdPeerThread; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoReadInputRegisters(const Sender: TIdPeerThread; const RegNr, Count: Integer;var Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoReadCoils(const Sender: TIdPeerThread; const RegNr, Count: Integer;var Data: TModCoilData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoReadInputBits(const Sender: TIdPeerThread; const RegNr, Count: Integer;var Data: TModCoilData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoWriteCoils(const Sender: TIdPeerThread; const RegNr, Count: Integer;const Data: TModCoilData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure DoWriteRegisters(const Sender: TIdPeerThread; const RegNr, Count: Integer;const Data: TModRegisterData; const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte); virtual;procedure LogExceptionBuffer(const AThread: TIdPeerThread; const Buffer: TModBusExceptionBuffer);procedure LogRequestBuffer(const AThread: TIdPeerThread; const Buffer: TModBusRequestBuffer; const Size: Integer);procedure LogResponseBuffer(const AThread: TIdPeerThread; const Buffer: TModBusResponseBuffer; const Size: Integer);procedure ReadCommand(const AThread: TIdPeerThread);procedure SendError(const AThread: TIdPeerThread; const ErrorCode: Byte;const ReceiveBuffer: TModBusRequestBuffer);procedure SendResponse(const AThread: TIdPeerThread; const ReceiveBuffer: TModBusRequestBuffer;const Data: TModRegisterData);{$ENDIF}public{$IFNDEF DMB_INDY10}constructor Create(AOwner: TComponent); override;{$ENDIF}destructor Destroy(); override;{ public properties }property Pause: Boolean read FPause write FPause;publishedproperty BaseRegister: Word read FBaseRegister write FBaseRegister default 1; property DefaultPort default MB_PORT;property LogEnabled: Boolean read FLogEnabled write FLogEnabled default False;property LogFile: String read FLogFile write FLogFile;property LogTimeFormat: String read FLogTimeFormat write FLogTimeFormat stored IsLogTimeFormatStored;property OneShotConnection: Boolean read FOneShotConnection write FOneShotConnection default False;property MaxRegister: Word read FMaxRegister write FMaxRegister default $FFFF;property MinRegister: Word read FMinRegister write FMinRegister default 1;property UnitID: Byte read FUnitID write FUnitID default MB_IGNORE_UNITID;property Version: String read GetVersion write SetVersion stored False;{ events }property OnError: TModBusErrorEvent read FOnError write FOnError;property OnInvalidFunction: TModBusInvalidFunctionEvent read FOnInvalidFunction write FOnInvalidFunction;property OnReadCoils: TModBusCoilReadEvent read FOnReadCoils write FOnReadCoils;property OnReadHoldingRegisters: TModBusRegisterReadEvent read FOnReadHoldingRegisters write FOnReadHoldingRegisters;property OnReadInputBits: TModBusCoilReadEvent read FOnReadInputBits write FOnReadInputBits;property OnReadInputRegisters: TModBusRegisterReadEvent read FOnReadInputRegisters write FOnReadInputRegisters;property OnWriteCoils: TModBusCoilWriteEvent read FOnWriteCoils write FOnWriteCoils;property OnWriteRegisters: TModBusRegisterWriteEvent read FOnWriteRegisters write FOnWriteRegisters;end; { TIdModBusServer }implementationusesMath;{ TIdModBusServer }{$IFDEF DMB_INDY10}
procedure TIdModBusServer.InitComponent;
{$ELSE}
constructor TIdModBusServer.Create(AOwner: TComponent);
{$ENDIF}
begin
{$IFDEF DMB_INDY10}inherited;
{$ELSE}inherited Create(AOwner);
{$ENDIF}FBaseRegister := 1;DefaultPort := MB_PORT;FLogCriticalSection := SyncObjs.TCriticalSection.Create;FLogEnabled := False;FLogFile := '';FLogTimeFormat := DefaultLogTimeFormat;FMaxRegister := $FFFF;FMinRegister := 1;FOneShotConnection := False;FOnError := nil;FOnInvalidFunction := nil;FOnReadCoils := nil;FOnReadHoldingRegisters := nil;FOnReadInputBits := nil;FOnReadInputRegisters := nil;FOnWriteCoils := nil;FOnWriteRegisters := nil;FPause := False;FUnitID := MB_IGNORE_UNITID;
end;destructor TIdModBusServer.Destroy();
begininherited;// freed AFTER inherited destructor because this will first stop the serverFLogCriticalSection.Free();
end;procedure TIdModBusServer.LogByteBuffer(const LogType: String;const PeerIP: String; const ByteBuffer: array of Byte; const Size: Integer);
varF: TextFile;
beginif FLogEnabled and (FLogFile <> '') thenbeginFLogCriticalSection.Enter;tryAssignFile(F, FLogFile);if FileExists(FLogFile) thenAppend(F)elseRewrite(F);tryWriteLn(F, FormatDateTime(FLogTimeFormat, Now),'; ', LogType,'; ', PeerIP,'; ', IntToStr(Size),'; ', BufferToHex(ByteBuffer));finallyCloseFile(F);end;finallyFLogCriticalSection.Leave;end;end;
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.InternalReadCoils(const AContext: TIdContext;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.InternalReadCoils(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
varCoilData: TModCoilData;i: Integer;
beginFillChar(CoilData, SizeOf(CoilData), 0);
{$IFDEF DMB_INDY10}DoReadCoils(AContext, RegNr, Count, CoilData, RequestBuffer, ErrorCode);
{$ELSE}DoReadCoils(Sender, RegNr, Count, CoilData, RequestBuffer, ErrorCode);
{$ENDIF}for i := 0 to (Count - 1) dobeginif CoilData[i] thenData[i] := 1;end;
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.InternalReadInputBits(const AContext: TIdContext;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.InternalReadInputBits(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
varCoilData: TModCoilData;i: Integer;
beginFillChar(CoilData, SizeOf(CoilData), 0);
{$IFDEF DMB_INDY10}DoReadInputBits(AContext, RegNr, Count, CoilData, RequestBuffer, ErrorCode);
{$ELSE}DoReadInputBits(Sender, RegNr, Count, CoilData, RequestBuffer, ErrorCode);
{$ENDIF}for i := 0 to (Count - 1) dobeginif CoilData[i] thenData[i] := 1;end;end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.InternalWriteCoils(const AContext: TIdContext;const RegNr, Count: Integer; const Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.InternalWriteCoils(const Sender: TIdPeerThread;const RegNr, Count: Integer; const Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
varCoilData: TModCoilData;i: Integer;
beginFillChar(CoilData, SizeOf(CoilData), 0);for i := 0 to (Count - 1) doCoilData[i] := (Data[i] = 1);
{$IFDEF DMB_INDY10}DoWriteCoils(AContext, RegNr, Count, CoilData, RequestBuffer, ErrorCode);
{$ELSE}DoWriteCoils(Sender, RegNr, Count, CoilData, RequestBuffer, ErrorCode);
{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.LogExceptionBuffer(const AContext: TIdContext;const Buffer: TModBusExceptionBuffer);
{$ELSE}
procedure TIdModBusServer.LogExceptionBuffer(const AThread: TIdPeerThread;const Buffer: TModBusExceptionBuffer);
{$ENDIF}
varPeerIP: String;ByteBuffer: array of Byte;
begin
{$IFDEF DMB_INDY10}PeerIP := AContext.Connection.Socket.Binding.PeerIP;
{$ELSE}PeerIP := AThread.Connection.Socket.Binding.PeerIP;
{$ENDIF}SetLength(ByteBuffer, SizeOf(Buffer));Move(Buffer, ByteBuffer[0], SizeOf(Buffer));LogByteBuffer('excp', PeerIP, ByteBuffer, SizeOf(Buffer));
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.LogRequestBuffer(const AContext: TIdContext;const Buffer: TModBusRequestBuffer; const Size: Integer);
{$ELSE}
procedure TIdModBusServer.LogRequestBuffer(const AThread: TIdPeerThread;const Buffer: TModBusRequestBuffer; const Size: Integer);
{$ENDIF}
varPeerIP: String;ByteBuffer: array of Byte;
begin
{$IFDEF DMB_INDY10}PeerIP := AContext.Connection.Socket.Binding.PeerIP;
{$ELSE}PeerIP := AThread.Connection.Socket.Binding.PeerIP;
{$ENDIF}SetLength(ByteBuffer, SizeOf(Buffer));Move(Buffer, ByteBuffer[0], SizeOf(Buffer));LogByteBuffer('recv', PeerIP, ByteBuffer, Size);
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.LogResponseBuffer(const AContext: TIdContext;const Buffer: TModBusResponseBuffer; const Size: Integer);
{$ELSE}
procedure TIdModBusServer.LogResponseBuffer(const AThread: TIdPeerThread;const Buffer: TModBusResponseBuffer; const Size: Integer);
{$ENDIF}
varPeerIP: String;ByteBuffer: array of Byte;
begin
{$IFDEF DMB_INDY10}PeerIP := AContext.Connection.Socket.Binding.PeerIP;
{$ELSE}PeerIP := AThread.Connection.Socket.Binding.PeerIP;
{$ENDIF}SetLength(ByteBuffer, SizeOf(Buffer));Move(Buffer, ByteBuffer[0], SizeOf(Buffer));LogByteBuffer('sent', PeerIP, ByteBuffer, Size);
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.ReadCommand(const AContext: TIdContext);
{$ELSE}
procedure TIdModBusServer.ReadCommand(const AThread: TIdPeerThread);
{$ENDIF}function GetRegNr(const RegNr: Integer): Integer;beginResult := RegNr;if (RegNr < 0) thenResult := Result + $FFFFelse if (RegNr > $FFFF) thenResult := RegNr - ($FFFF + 1);Result := Result + FBaseRegister;end; { GetRegNr }variCount: Integer;iRegNr: Integer;ErrorCode: Byte;ReceiveBuffer: TModBusRequestBuffer;Data: TModRegisterData;
{$IFDEF DMB_INDY10}Buffer: TIdBytes;
{$ENDIF}
begin
{ Initialize all register data to 0 }FillChar(Data[0], SizeOf(Data), 0);FillChar(ReceiveBuffer, SizeOf(ReceiveBuffer), 0);
{ Read the data from the peer connection }
{$IFDEF DMB_INDY10}
{ Ensure receiving databuffer is completely empty, and filled with zeros }SetLength(Buffer, SizeOf(ReceiveBuffer));FillChar(Buffer[0], SizeOf(ReceiveBuffer), 0);
{ Wait max. 250 msecs. for available data }AContext.Connection.IOHandler.CheckForDataOnSource(250);if not AContext.Connection.IOHandler.InputBufferIsEmpty thenbeginAContext.Connection.IOHandler.InputBuffer.ExtractToBytes(Buffer, -1, False, -1);iCount := Length(Buffer);if (iCount > 0) thenbeginMove(Buffer[0], ReceiveBuffer, Min(iCount, SizeOf(ReceiveBuffer)));if FLogEnabled thenLogRequestBuffer(AContext, ReceiveBuffer, iCount);endelseExit;endelseExit;
{$ELSE}iCount := AThread.Connection.Socket.Recv(ReceiveBuffer, SizeOf(ReceiveBuffer));if (iCount > 0) thenbeginif FLogEnabled thenLogRequestBuffer(AThread, ReceiveBuffer, iCount);endelseExit;
{$ENDIF}
{ Process the data }if ((FUnitID <> MB_IGNORE_UNITID) and (ReceiveBuffer.Header.UnitID <> FUnitID)) or(ReceiveBuffer.Header.ProtocolID <> MB_PROTOCOL)thenbegin// When listening for a specific UnitID, only except data for that ID{$IFDEF DMB_INDY10}SendError(AContext, mbeServerFailure, ReceiveBuffer);{$ELSE}SendError(AThread, mbeServerFailure, ReceiveBuffer);{$ENDIF}endelse if ((Byte(ReceiveBuffer.FunctionCode) and $80) <> 0) thenbeginErrorCode := Integer(ReceiveBuffer.MBPData[0]);{$IFDEF DMB_INDY10}DoError(AContext, ReceiveBuffer.FunctionCode and not $80, ErrorCode, ReceiveBuffer);{$ELSE}DoError(AThread, ReceiveBuffer.FunctionCode and not $80, ErrorCode, ReceiveBuffer);{$ENDIF}endelsebeginErrorCode := mbeOk;case ReceiveBuffer.FunctionCode ofmbfReadCoils,mbfReadInputBits:beginiRegNr := GetRegNr(Swap16(Word((@ReceiveBuffer.MBPData[0])^)));iCount := Swap16(Word((@ReceiveBuffer.MBPData[2])^));if ((iRegNr < FMinRegister) or ((iRegNr + iCount - 1) > FMaxRegister)) then{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalRegister, ReceiveBuffer){$ELSE}SendError(AThread, mbeIllegalRegister, ReceiveBuffer){$ENDIF}elsebegin{ Signal the user that data is needed }{$IFDEF DMB_INDY10}if (ReceiveBuffer.FunctionCode = mbfReadCoils) thenInternalReadCoils(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode)elseInternalReadInputBits(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AContext, ReceiveBuffer, Data)elseSendError(AContext, ErrorCode, ReceiveBuffer);{$ELSE}if (ReceiveBuffer.FunctionCode = mbfReadCoils) thenInternalReadCoils(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode)elseInternalReadInputBits(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AThread, ReceiveBuffer, Data)elseSendError(AThread, ErrorCode, ReceiveBuffer);{$ENDIF}end;end;mbfReadInputRegs,mbfReadHoldingRegs:beginiRegNr := GetRegNr(Swap16(Word((@ReceiveBuffer.MBPData[0])^)));iCount := Swap16(Word((@ReceiveBuffer.MBPData[2])^));if ((iRegNr < FMinRegister) or ((iRegNr + iCount - 1) > FMaxRegister)) then{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalRegister, ReceiveBuffer){$ELSE}SendError(AThread, mbeIllegalRegister, ReceiveBuffer){$ENDIF}elsebegin{ Signal the user that data is needed }{$IFDEF DMB_INDY10}if (ReceiveBuffer.FunctionCode = mbfReadInputRegs) thenDoReadInputRegisters(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode)elseDoReadHoldingRegisters(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AContext, ReceiveBuffer, Data)elseSendError(AContext, ErrorCode, ReceiveBuffer);{$ELSE}if (ReceiveBuffer.FunctionCode = mbfReadInputRegs) thenDoReadInputRegisters(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode)elseDoReadHoldingRegisters(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AThread, ReceiveBuffer, Data)elseSendError(AThread, ErrorCode, ReceiveBuffer);{$ENDIF}end;end;mbfWriteOneCoil:beginiRegNr := GetRegNr(Swap16(Word((@ReceiveBuffer.MBPData[0])^)));iCount := 1;if ((iRegNr < FMinRegister) or ((iRegNr + iCount - 1) > FMaxRegister)) then{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalRegister, ReceiveBuffer){$ELSE}SendError(AThread, mbeIllegalRegister, ReceiveBuffer){$ENDIF}elsebegin{ Decode the contents of the Registers }GetCoilsFromBuffer(@ReceiveBuffer.MBPData[2], iCount, Data);{ Send back the response to the master }{$IFDEF DMB_INDY10}InternalWriteCoils(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AContext, ReceiveBuffer, Data)elseSendError(AContext, ErrorCode, ReceiveBuffer);{$ELSE}InternalWriteCoils(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AThread, ReceiveBuffer, Data)elseSendError(AThread, ErrorCode, ReceiveBuffer);{$ENDIF}end;end;mbfWriteOneReg:begin{ Get the register number }iRegNr := GetRegNr(Swap16(Word((@ReceiveBuffer.MBPData[0])^)));{ Get the register value }Data[0] := Swap16(Word((@ReceiveBuffer.MBPData[2])^));{ This function always writes one register }iCount := 1;if ((iRegNr < FMinRegister) or ((iRegNr + iCount - 1) > FMaxRegister)) then{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalRegister, ReceiveBuffer){$ELSE}SendError(AThread, mbeIllegalRegister, ReceiveBuffer){$ENDIF}elsebegin{ Send back the response to the master }{$IFDEF DMB_INDY10}DoWriteRegisters(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AContext, ReceiveBuffer, Data)elseSendError(AContext, ErrorCode, ReceiveBuffer);{$ELSE}DoWriteRegisters(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AThread, ReceiveBuffer, Data)elseSendError(AThread, ErrorCode, ReceiveBuffer);{$ENDIF}end;end;mbfWriteRegs:beginiRegNr := GetRegNr(Swap16(Word((@ReceiveBuffer.MBPData[0])^)));iCount := Swap16(Word((@ReceiveBuffer.MBPData[2])^));if ((iRegNr < FMinRegister) or ((iRegNr + iCount - 1) > FMaxRegister)) then{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalRegister, ReceiveBuffer){$ELSE}SendError(AThread, mbeIllegalRegister, ReceiveBuffer){$ENDIF}elsebegin{ Decode the contents of the Registers }GetRegistersFromBuffer(@ReceiveBuffer.MbpData[5], iCount, Data);{ Send back the response to the master }{$IFDEF DMB_INDY10}DoWriteRegisters(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AContext, ReceiveBuffer, Data)elseSendError(AContext, ErrorCode, ReceiveBuffer);{$ELSE}DoWriteRegisters(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AThread, ReceiveBuffer, Data)elseSendError(AThread, ErrorCode, ReceiveBuffer);{$ENDIF}end;end;mbfWriteCoils:beginiRegNr := GetRegNr(Swap16(Word((@ReceiveBuffer.MBPData[0])^)));iCount := Swap16(Word((@ReceiveBuffer.MBPData[2])^));if ((iRegNr < FMinRegister) or ((iRegNr + iCount - 1) > FMaxRegister)) then{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalRegister, ReceiveBuffer){$ELSE}SendError(AThread, mbeIllegalRegister, ReceiveBuffer){$ENDIF}elsebegin{ Decode the contents of the Registers }GetCoilsFromBuffer(@ReceiveBuffer.MbpData[5], iCount, Data);{ Send back the response to the master }{$IFDEF DMB_INDY10}InternalWriteCoils(AContext, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AContext, ReceiveBuffer, Data)elseSendError(AContext, ErrorCode, ReceiveBuffer);{$ELSE}InternalWriteCoils(AThread, iRegNr, iCount, Data, ReceiveBuffer, ErrorCode);if (ErrorCode = mbeOk) thenSendResponse(AThread, ReceiveBuffer, Data)elseSendError(AThread, ErrorCode, ReceiveBuffer);{$ENDIF}end;end;elseif (ReceiveBuffer.FunctionCode <> 0) thenbegin{ Illegal or unsupported function code }{$IFDEF DMB_INDY10}SendError(AContext, mbeIllegalFunction, ReceiveBuffer);DoInvalidFunction(AContext, ReceiveBuffer.FunctionCode, ReceiveBuffer);{$ELSE}SendError(AThread, mbeIllegalFunction, ReceiveBuffer);DoInvalidFunction(AThread, ReceiveBuffer.FunctionCode, ReceiveBuffer);{$ENDIF}end;end;end;
{ If needed: the server terminates the connection, after the request has been handled }if FOneShotConnection then{$IFDEF DMB_INDY10}AContext.Connection.Disconnect;{$ELSE}AThread.Connection.Disconnect;{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoError(const AContext: TIdContext;const FunctionCode: Byte; const ErrorCode: Byte; const RequestBuffer: TModBusRequestBuffer);
{$ELSE}
procedure TIdModBusServer.DoError(const Sender: TIdPeerThread;const FunctionCode: Byte; const ErrorCode: Byte; const RequestBuffer: TModBusRequestBuffer);
{$ENDIF}
beginif Assigned(FOnError) then{$IFDEF DMB_INDY10}FOnError(AContext, FunctionCode, ErrorCode, RequestBuffer);{$ELSE}FOnError(Sender, FunctionCode, ErrorCode, RequestBuffer);{$ENDIF}
end;{$IFDEF DMB_INDY10}
function TIdModBusServer.DoExecute(AContext: TIdContext): Boolean;
{$ELSE}
function TIdModBusServer.DoExecute(AThread: TIdPeerThread): Boolean;
{$ENDIF}
beginResult := False;if not FPause thenbegin{$IFDEF DMB_INDY10}ReadCommand(AContext);Result := inherited DoExecute(AContext);{$ELSE}ReadCommand(AThread);Result := inherited DoExecute(AThread);{$ENDIF}end;
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoInvalidFunction(const AContext: TIdContext;const FunctionCode: TModBusFunction; const RequestBuffer: TModBusRequestBuffer);
{$ELSE}
procedure TIdModBusServer.DoInvalidFunction(const Sender: TIdPeerThread;const FunctionCode: TModBusFunction; const RequestBuffer: TModBusRequestBuffer);
{$ENDIF}
beginif Assigned(FOnInvalidFunction) then{$IFDEF DMB_INDY10}FOnInvalidFunction(AContext, FunctionCode, RequestBuffer);{$ELSE}FOnInvalidFunction(Sender, FunctionCode, RequestBuffer);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoReadCoils(const AContext: TIdContext;const RegNr, Count: Integer; var Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.DoReadCoils(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
beginif Assigned(FOnReadCoils) then{$IFDEF DMB_INDY10}FOnReadCoils(AContext, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ELSE}FOnReadCoils(Sender, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoReadInputBits(const AContext: TIdContext;const RegNr, Count: Integer; var Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.DoReadInputBits(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
beginif Assigned(FOnReadInputBits) then{$IFDEF DMB_INDY10}FOnReadInputBits(AContext, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ELSE}FOnReadInputBits(Sender, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoReadHoldingRegisters(const AContext: TIdContext;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.DoReadHoldingRegisters(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
beginif Assigned(FOnReadHoldingRegisters) then{$IFDEF DMB_INDY10}FOnReadHoldingRegisters(AContext, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ELSE}FOnReadHoldingRegisters(Sender, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoReadInputRegisters(const AContext: TIdContext;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.DoReadInputRegisters(const Sender: TIdPeerThread;const RegNr, Count: Integer; var Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
beginif Assigned(FOnReadInputRegisters) then{$IFDEF DMB_INDY10}FOnReadInputRegisters(AContext, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ELSE}FOnReadInputRegisters(Sender, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoWriteCoils(const AContext: TIdContext;const RegNr, Count: Integer; const Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.DoWriteCoils(const Sender: TIdPeerThread;const RegNr, Count: Integer; const Data: TModCoilData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
beginif Assigned(FOnWriteCoils) then{$IFDEF DMB_INDY10}FOnWriteCoils(AContext, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ELSE}FOnWriteCoils(Sender, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.DoWriteRegisters(const AContext: TIdContext;const RegNr, Count: Integer; const Data: TModRegisterData;const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ELSE}
procedure TIdModBusServer.DoWriteRegisters(const Sender: TIdPeerThread;
const RegNr, Count: Integer; const Data: TModRegisterData;
const RequestBuffer: TModBusRequestBuffer; var ErrorCode: Byte);
{$ENDIF}
beginif Assigned(FOnWriteRegisters) then{$IFDEF DMB_INDY10}FOnWriteRegisters(AContext, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ELSE}FOnWriteRegisters(Sender, RegNr, Count, Data, RequestBuffer, ErrorCode);{$ENDIF}
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.SendError(const AContext: TIdContext;const ErrorCode: Byte; const ReceiveBuffer: TModBusRequestBuffer);
{$ELSE}
procedure TIdModBusServer.SendError(const AThread: TIdPeerThread;const ErrorCode: Byte; const ReceiveBuffer: TModBusRequestBuffer);
{$ENDIF}
varSendBuffer: TModBusExceptionBuffer;
{$IFDEF DMB_INDY10}Buffer: TIdBytes;
{$ENDIF}
beginif Active thenbeginSendBuffer.Header := ReceiveBuffer.Header;SendBuffer.ExceptionFunction := ReceiveBuffer.FunctionCode or $80;SendBuffer.ExceptionCode := ErrorCode;SendBuffer.Header.RecLength := Swap16(3);{$IFDEF DMB_INDY10}Buffer := RawToBytes(SendBuffer, SizeOf(SendBuffer));AContext.Connection.Socket.WriteDirect(Buffer);if FLogEnabled thenLogExceptionBuffer(AContext, SendBuffer);{$ELSE}AThread.Connection.Socket.Send(SendBuffer, SizeOf(SendBuffer));if FLogEnabled thenLogExceptionBuffer(AThread, SendBuffer);{$ENDIF}end;
end;{$IFDEF DMB_INDY10}
procedure TIdModBusServer.SendResponse(const AContext: TIdContext;const ReceiveBuffer: TModBusRequestBuffer; const Data: TModRegisterData);
{$ELSE}
procedure TIdModBusServer.SendResponse(const AThread: TIdPeerThread;const ReceiveBuffer: TModBusRequestBuffer; const Data: TModRegisterData);
{$ENDIF}
varSendBuffer: TModBusResponseBuffer;L: Integer;ValidRequest : Boolean;
{$IFDEF DMB_INDY10}Buffer: TIdBytes;
{$ENDIF}
beginif Active thenbegin{Check Valid }ValidRequest  := false;FillChar(SendBuffer, SizeOf(SendBuffer), 0);SendBuffer.Header.TransactionID := ReceiveBuffer.Header.TransactionID;SendBuffer.Header.ProtocolID := ReceiveBuffer.Header.ProtocolID;SendBuffer.Header.UnitID := ReceiveBuffer.Header.UnitID;SendBuffer.FunctionCode := ReceiveBuffer.FunctionCode;SendBuffer.Header.RecLength := Swap16(0);case ReceiveBuffer.FunctionCode ofmbfReadCoils,mbfReadInputBits:beginL := Swap16(Word((@ReceiveBuffer.MBPData[2])^));if (L > 0) and (L <= MaxCoils) thenbeginSendBuffer.MBPData[0] := Byte((L + 7) div 8);PutCoilsIntoBuffer(@SendBuffer.MBPData[1], L, Data);SendBuffer.Header.RecLength := Swap16(3 + SendBuffer.MBPData[0]);ValidRequest  := true;end;end;mbfReadInputRegs,mbfReadHoldingRegs:beginL := Swap16(Word((@ReceiveBuffer.MBPData[2])^));if (L > 0) and (L <= MaxBlockLength) thenbeginSendBuffer.MBPData[0] := Byte(L shl 1);PutRegistersIntoBuffer(@SendBuffer.MBPData[1], L, Data);SendBuffer.Header.RecLength := Swap16(3 + SendBuffer.MBPData[0]);ValidRequest  := true;end;end;elsebeginSendBuffer.MBPData[0] := ReceiveBuffer.MBPData[0];SendBuffer.MBPData[1] := ReceiveBuffer.MBPData[1];SendBuffer.MBPData[2] := ReceiveBuffer.MBPData[2];SendBuffer.MBPData[3] := ReceiveBuffer.MBPData[3];SendBuffer.Header.RecLength := Swap16(6);ValidRequest  := true;end;end;{Send buffer if Request is Valid}if ValidRequest thenbegin{$IFDEF DMB_INDY10}Buffer := RawToBytes(SendBuffer, Swap16(SendBuffer.Header.RecLength) + 6);AContext.Connection.Socket.WriteDirect(Buffer);if FLogEnabled thenLogResponseBuffer(AContext, SendBuffer, Swap16(SendBuffer.Header.RecLength) + 6);{$ELSE}AThread.Connection.Socket.Send(SendBuffer, Swap16(SendBuffer.Header.RecLength) + 6);if FLogEnabled thenLogResponseBuffer(AThread, SendBuffer, Swap16(SendBuffer.Header.RecLength) + 6);{$ENDIF}endelsebegin{Send error for invalid request}{$IFDEF DMB_INDY10}SendError(AContext, mbeServerFailure, ReceiveBuffer);{$ELSE}SendError(AThread, mbeServerFailure, ReceiveBuffer);{$ENDIF}exit;end;end;
end;function TIdModBusServer.GetVersion: String;
beginResult := DMB_VERSION;
end;function TIdModBusServer.IsLogTimeFormatStored: Boolean;
beginResult := (FLogTimeFormat <> DefaultLogTimeFormat);
end;procedure TIdModBusServer.SetVersion(const Value: String);
begin
{ This intentionally is a readonly property }
end;end.

六、ModBusCompiler.inc


{ Logic to detect the used Delphi compiler version: }
{$IFDEF VER120}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI4_ONLY}
{$ENDIF}
{$IFDEF VER130}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI5_ONLY}
{$ENDIF}
{$IFDEF VER140}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI6_ONLY}
{$ENDIF}
{$IFDEF VER150}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI7_ONLY}
{$ENDIF}
{$IFDEF VER170}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2005_ONLY}
{$ENDIF}
{$IFDEF VER180}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$IFNDEF VER185}{$DEFINE DMB_DELPHI2006_ONLY}{$ENDIF}
{$ENDIF}
{$IFDEF VER185}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2007_ONLY}
{$ENDIF}
{$IFDEF VER200}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2009_ONLY}
{$ENDIF}
{$IFDEF VER210}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHI2010_ONLY}
{$ENDIF}
{$IFDEF VER220}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE_ONLY}
{$ENDIF}
{$IFDEF VER230}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE2_ONLY}
{$ENDIF}
{$IFDEF VER240}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE3_ONLY}
{$ENDIF}
{$IFDEF VER250}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE4_ONLY}
{$ENDIF}
{$IFDEF VER260}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE5_ONLY}
{$ENDIF}
{$IFDEF VER270}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE6_ONLY}
{$ENDIF}
{$IFDEF VER280}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE7_ONLY}
{$ENDIF}
{$IFDEF VER290}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHIXE8_ONLY}
{$ENDIF}
{$IFDEF VER300}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_SEATTLE_ONLY}
{$ENDIF}
{$IFDEF VER310}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_1_BERLIN}{$DEFINE DMB_DELPHI10_1_BERLIN_ONLY}
{$ENDIF}{$IFDEF VER320}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_1_BERLIN}{$DEFINE DMB_DELPHI10_2_TOKYO}{$DEFINE DMB_DELPHI10_2_TOKYO_ONLY}
{$ENDIF}{$IFDEF VER330}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_1_BERLIN}{$DEFINE DMB_DELPHI10_2_TOKYO}{$DEFINE DMB_DELPHI10_3_RIO}{$DEFINE DMB_DELPHI10_3_RIO_ONLY}
{$ENDIF}{$IFDEF VER340}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_1_BERLIN}{$DEFINE DMB_DELPHI10_2_TOKYO}{$DEFINE DMB_DELPHI10_3_RIO}{$DEFINE DMB_DELPHI10_4_SYDNEY}{$DEFINE DMB_DELPHI10_4_SYDNEY_ONLY}
{$ENDIF}{$IFDEF VER350}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_1_BERLIN}{$DEFINE DMB_DELPHI10_2_TOKYO}{$DEFINE DMB_DELPHI10_3_RIO}{$DEFINE DMB_DELPHI10_4_SYDNEY}{$DEFINE DMB_DELPHI11_ALEXANDRIA}
{$ENDIF}{$IFDEF VER360}{$DEFINE DMB_DELPHI1}{$DEFINE DMB_DELPHI2}{$DEFINE DMB_DELPHI3}{$DEFINE DMB_DELPHI4}{$DEFINE DMB_DELPHI5}{$DEFINE DMB_DELPHI6}{$DEFINE DMB_DELPHI7}{$DEFINE DMB_DELPHI2005}{$DEFINE DMB_DELPHI2006}{$DEFINE DMB_DELPHI2007}{$DEFINE DMB_DELPHI2009}{$DEFINE DMB_DELPHI2010}{$DEFINE DMB_DELPHIXE}{$DEFINE DMB_DELPHIXE2}{$DEFINE DMB_DELPHIXE3}{$DEFINE DMB_DELPHIXE4}{$DEFINE DMB_DELPHIXE5}{$DEFINE DMB_DELPHIXE6}{$DEFINE DMB_DELPHIXE7}{$DEFINE DMB_DELPHIXE8}{$DEFINE DMB_DELPHI10_SEATTLE}{$DEFINE DMB_DELPHI10_1_BERLIN}{$DEFINE DMB_DELPHI10_2_TOKYO}{$DEFINE DMB_DELPHI10_3_RIO}{$DEFINE DMB_DELPHI10_4_SYDNEY}{$DEFINE DMB_DELPHI11_ALEXANDRIA}{$DEFINE DMB_DELPHI12_ATHENS}{$DEFINE DMB_DELPHI12_ATHENS_ONLY}
{$ENDIF}{$IFDEF DMB_DELPHI2005}
{ By default use Indy 10 starting from Delphi 2005 }{$DEFINE DMB_INDY10}
{$ELSE}
{ Older Delphi versions use Indy 9 }{$DEFINE DMB_INDY9}
{$ENDIF}{$IFDEF FPC}
{ Force the Free Pascal Compiler in Delphi mode, and use Indy 10 }{$MODE DELPHI}{$UNDEF DMB_INDY9}{$DEFINE DMB_INDY10}
{$ENDIF}{ Allow user defines to overrule the Indy version being used }
{$IFDEF FORCE_INDY9}{$UNDEF DMB_INDY10}{$DEFINE DMB_INDY9}
{$ELSE}{$IFDEF FORCE_INDY10}{$UNDEF DMB_INDY9}{$DEFINE DMB_INDY10}{$ENDIF}
{$ENDIF}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/62872.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

计算机网络-网络安全

计算机网络-网络安全

网络安全介绍 端口扫描 安全包括那些方面&#xff1a; 数据存储安全、应用程序安全、操作系统安全、网络安全、物理安全、用户安全教育 一、网络安全问题概述 1. 计算机网络面临的安全性威胁 计算机网络上的通信面临以下的四种威胁&#xff1a; 截获——从网络上窃听他人…
阅读更多...
GEE Download Data——气温数据的下载

GEE Download Data——气温数据的下载

GEE数据下载第二弹！今天我们来分享气温数据的下载。 一、数据介绍 气温数据我们要用到的是MODIS数据产品，MOD11A2 V6.1 产品提供 1200 x 1200 公里网格内 8 天平均陆地表面温度 (LST)。 MOD11A2 中的每个像素值都是该 8 天内收集的所有相应 MOD11A1 LST 像素的简单平均值。…
阅读更多...
【第 1 章 初识 C 语言】1.8 使用 C 语言的 7 个步骤

【第 1 章 初识 C 语言】1.8 使用 C 语言的 7 个步骤

目录 1.8 使用 C 语言的 7 个步骤 1.8.1 第 1 步&#xff1a;定义程序的目标 1.8.2 第 2 步&#xff1a;设计程序 1.8.3 第 3 步&#xff1a;编写代码 1.8.4 第 4 步&#xff1a;编译 1.8.5 第 5 步&#xff1a;运行程序 1.8.6 第 6 步&#xff1a;测试和调试程序 1.8.…
阅读更多...
docker部署RustDesk自建服务器

docker部署RustDesk自建服务器

客户端&#xff1a; Releases rustdesk/rustdesk GitHub 服务端&#xff1a; 项目官方地址&#xff1a;GitHub - rustdesk/rustdesk-server: RustDesk Server Program 1、拉取RustDesk库 docker pull rustdesk/rustdesk-server:latest 阿里云库&#xff1a; docker pu…
阅读更多...
通义灵码走进北京大学创新课堂丨阿里云云原生 10 月产品月报

通义灵码走进北京大学创新课堂丨阿里云云原生 10 月产品月报

云原生月度动态 云原生是企业数字创新的最短路径。 《阿里云云原生每月动态》&#xff0c;从趋势热点、产品新功能、服务客户、开源与开发者动态等方面&#xff0c;为企业提供数字化的路径与指南。 趋势热点 &#x1f947; 通义灵码走进北京大学创新课堂&#xff0c;与 400…
阅读更多...
Java基础面向对象（String类）

Java基础面向对象（String类）

String 特点 是内存中常量, 值在内存中一旦创建, 不可改 更改String类型引用的值本质上是将引用指向了一个新的字符串地址 String s1 "abc";String s2 s1;//引用s1的地址赋值给了s2 ​s2 "edf";//让s2指向新字符串 ​System.out.println("s1: &q…
阅读更多...
【C++】深入优化计算题目分析与实现

【C++】深入优化计算题目分析与实现

博客主页&#xff1a; [小ᶻ☡꙳ᵃⁱᵍᶜ꙳] 本文专栏: C 文章目录 &#x1f4af;前言&#x1f4af;第一题&#xff1a;圆的计算我的代码实现代码分析改进建议改进代码 老师的代码实现代码分析可以改进的地方改进代码 &#x1f4af;第二题&#xff1a;对齐输出我的代码实现…
阅读更多...
6.824/6.5840 Lab 3: Raft——Part 3B3C

6.824/6.5840 Lab 3: Raft——Part 3B3C

芙蓉花又栖满了枝头 奈何蝶难留 漂泊如江水向东流 望断门前隔岸的杨柳 寂寞仍不休 我无言让眼泪长流 ——山外小楼夜听雨 完整代码见&#xff1a; https://github.com/SnowLegend-star/6.824 在完成Lab之前&#xff0c;务必把论文多读几遍&#xff0c;力求完全理解Leader选举、…
阅读更多...
LeetCode - #150 逆波兰表达式求值

LeetCode - #150 逆波兰表达式求值

文章目录 前言1. 描述2. 示例3. 答案关于我们 前言 我们社区陆续会将顾毅&#xff08;Netflix 增长黑客&#xff0c;《iOS 面试之道》作者&#xff0c;ACE 职业健身教练。&#xff09;的 Swift 算法题题解整理为文字版以方便大家学习与阅读。 LeetCode 算法到目前我们已经更新…
阅读更多...
【C++】continue语句、goto语句

【C++】continue语句、goto语句

1、continue 语句 作用&#xff1a;在循环语句中&#xff0c;跳过本次循环中余下尚未执行的语句。继续下一次循环。 注意&#xff1a;continue只能用于循环中。 示例&#xff1a; 代码&#xff1a; //continue的用法 #include<iostream> using namespace std; int ma…
阅读更多...
最长最短单词

最长最短单词

最长最短单词 C语言实现C实现Java实现Python实现 &#x1f490;The Begin&#x1f490;点点关注&#xff0c;收藏不迷路&#x1f490; 输入1行句子&#xff08;不多于200个单词&#xff0c;每个单词长度不超过100&#xff09;&#xff0c;只包含字母、空格和逗号。单词由至少一…
阅读更多...
ESP32项目 --- 智能门锁(WiFi 蓝牙 OTA)

ESP32项目 --- 智能门锁(WiFi 蓝牙 OTA)

1 项目简介 1.1 项目概述 本项目是实现一款智能门锁中的智能控制部分, 可以应用在家庭, 办公室等任何使用门锁的场所. 本项目实现了以下主要功能: &#xff08;1&#xff09;通过按键配置密码 &#xff08;2&#xff09;通过按键输入密码开锁 &#xff08;3&#xff09;录…
阅读更多...
洛谷题单-入门2-分支结构-python-下

洛谷题单-入门2-分支结构-python-下

找出出现的最早的最大值 count 0 list_number [] while True:list_number.append(list(map(int, input().split())))count 1if count 7:breaklist2_number_total []for i1,i2 in list_number:list2_number_total.append(i1i2)target max(list2_number_total)index 0 if…
阅读更多...
框架模块说明 #05 权限管理_03

框架模块说明 #05 权限管理_03

背景 权限设计可以分为两个主要方面&#xff1a;操作权限和数据权限。前两篇文章已经详细介绍了操作权限的设计与实现&#xff0c;以及如何将其与菜单关联起来的具体方法。本篇将聚焦于数据权限&#xff0c;为您深入讲解相关的设计与实现方式。 全局开关 Value("${syst…
阅读更多...
Linux网络编程之---多线程实现并发服务器

Linux网络编程之---多线程实现并发服务器

下面我们来使用tcp集合多线程实现并发服务器 一.服务端 #include <stdio.h> #include <arpa/inet.h> #include <unistd.h> #include <stdlib.h> #include <string.h> #include <pthread.h>typedef struct sockinfo {char ip[16];unsigne…
阅读更多...
Linux C/C++编程之静态库

Linux C/C++编程之静态库

【图书推荐】《Linux C与C一线开发实践&#xff08;第2版&#xff09;》_linux c与c一线开发实践pdf-CSDN博客《Linux C与C一线开发实践&#xff08;第2版&#xff09;&#xff08;Linux技术丛书&#xff09;》(朱文伟&#xff0c;李建英)【摘要 书评 试读】- 京东图书 (jd.com…
阅读更多...
网际协议（IP）与其三大配套协议（ARP、ICMP、IGMP）

网际协议（IP）与其三大配套协议（ARP、ICMP、IGMP）

网际协议&#xff08;Internet Protocol&#xff0c;IP&#xff09;&#xff0c;又称互联网协议。是OSI中的网络层通信协议&#xff0c;用于跨网络边界分组交换。它的路由功能实现了互联互通&#xff0c;并从本质上建立了互联网。网际协议IP是 TCP/IP 体系中两个最主要的协议之…
阅读更多...
uniapp实现加密Token并在每次请求前动态更新(vue、微信小程序、原生js也通用！）

uniapp实现加密Token并在每次请求前动态更新(vue、微信小程序、原生js也通用！）

导语&#xff1a;在Web开发中&#xff0c;Token作为一种身份验证的机制&#xff0c;被广泛应用于前后端交互过程中。本文将为大家介绍如何在每次请求前动态设置加密的Token&#xff0c;并在请求一次后使Token值加1&#xff08;或其他动态改变的逻辑&#xff09;&#xff0c;从而…
阅读更多...
IDL学习笔记（二）IDL处理卫星数据

IDL学习笔记（二）IDL处理卫星数据

IDL处理卫星数据 HDF文件数据集属性通用属性 常用HDF4操作函数常用的HDF5操作函数读取HDF文件的一般步骤 HDF4文件读取-----数据信息查询HDF4文件读取示例-----目标数据TIFF输出 HDF文件 数据集属性 数据集名称&#xff0c;是“&#xff1a;”前的一部分&#xff0c;不是long_…
阅读更多...
论文阅读——量子退火Experimental signature of programmable quantum annealing

论文阅读——量子退火Experimental signature of programmable quantum annealing

摘要&#xff1a;量子退火是一种借助量子绝热演化解决复杂优化问题的通用策略。分析和数值证据均表明&#xff0c;在理想化的封闭系统条件下&#xff0c;量子退火可以胜过基于经典热化的算法&#xff08;例如模拟退火&#xff09;。当前设计的量子退火装置的退相干时间比绝热演…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023