【发布时间】:2014-10-17 13:28:13
【问题描述】:
我正在尝试使用 TIdTCP 在 Internet 上创建聊天室!
当client发送消息给server,server会继续发送给其他clients,这里我的代码:
服务器
var
List: TIdContextList;
Context: TIdContext;
i: Integer;
Msg: String;
Procedure TSForm.SendALL(text: string);
begin
MSG:= Trim(text);
List := Server.Contexts.LockList;
try
for i := 0 to List.Count - 1 do
begin
Context := TIDContext(List[i]);
Context.Connection.IOHandler.WriteLn(UTF8Encode(msg));
end;
finally
Server.Contexts.UnlockList;
end;
end;
procedure TSForm.ServerExecute(AContext: TIdContext);
var m: string;
Begin
m:= acontext.Connection.IOHandler.ReadLn();
begin
SForm.log.Lines.Add(Acontext.Connection.Socket.Binding.PeerIP+' > '+m); //Log is MEMO
SendALL(m);
end;
end;
和客户
type
TReadingThread = class(TThread)
protected
FConn: TIdTCPConnection;
procedure Execute; override;
procedure DoTerminate; override;
public
constructor Create(AConn: TIdTCPConnection); reintroduce;
end;
var readthread: TReadingThread = Nil;
constructor TReadingThread.Create(AConn: TIdTCPConnection);
begin
FConn := AConn;
inherited Create(False);
end;
procedure TReadingThread.Execute;
var
cmd: string;
begin
while not Terminated do
begin
cmd := UTF8ToUnicodeString(FConn.IOHandler.ReadLn());
Trim(cmd);
if cmd <> '' then
begin
CForm.Memo1.Lines.Add(cmd); //Memo1 to show messages
end;
end;
Application.ProcessMessages;
end;
procedure TReadingThread.DoTerminate;
begin
inherited;
end;
procedure TCForm.ClientConnected(Sender: TObject);
begin
readthread:= TReadingThread.Create(Client);
end;
procedure TCForm.ClientDisconnected(Sender: TObject);
begin
if readthread<> nil then
begin
readthread.Terminate;
readthread.WaitFor;
FreeAndNil(readthread);
end;
end;
一切看起来都很好,但是当服务器重新发送消息时,其他客户端得到它并正常显示在备忘录中发送该消息的客户端似乎冻结,必须单击备忘录才能使文字出现!
不知道哪里出错了,希望得到你的帮助,谢谢!
【问题讨论】:
-
为什么要直接从线程访问控件?
-
那么您认为如何在备忘录中添加消息?使用定时器?
标签: multithreading delphi firemonkey indy delphi-xe6