● [zz]多线程阻塞式 Socket - 荔园在线 | 深圳大学学生论坛,荔园晨风BBS,深大在线网站

荔园之美，在春之萌芽，在夏之绽放，在秋之收获，在冬之沉淀

发信人: oopilix (PADRAD), 信区: Visual
标  题: [zz]多线程阻塞式 Socket
发信站: 荔园晨风BBS站 (Fri May 30 23:14:15 2003), 站内信件

多线程阻塞式 Socket ，服务器端如何把在某一个线程中接受到来的信息，
再发送给其它线程呢

问题：多线程阻塞式 Socket ，服务器端如何把在某一个线程中接受到来的信息，再发送
给其它线程呢？ ( 积分：200, 回复：6, 阅读：130 )
分类：Internet/TCPIP ( 版主：luyear, robertcool )
来自：Orber, 时间：2002-9-11 23:20:00, ID：1319742 [显示：小字体 | 大字体]

多线程阻塞式 Socket ，服务器端如何把在某一个线程中接受到来的信息，再发送给其它
线程呢？

来自：beta, 时间：2002-9-12 2:07:00, ID：1319849
服务器端用一个列表，每建立一个联接，就记录下该联接线程的线程句柄
然后当要发送信息的时候，就可以 SendMessage 了啊。猜的：）

来自：Orber, 时间：2002-9-12 2:25:00, ID：1319851
我现在就是用的这种办法。
但是当只有一个线程的时候，数据可以正确的返回到客户端，
但是当有大于一个线程的时候，服务器端的每个线称好像都被堵住似的，连每个线程
接收数据都不成功了。

例如：
当只有客户端1连接到服务器上后，输入信息，可以正确被返回。
当客户端2连接到服务器后，输入信息，客户端1可以看到此信息，但根据跟踪发现当
服务器短通过保存的线程句柄向客户端2发送的时候，没有成功，好像被堵住的感觉。
这时候使用客户端2继续发送的话，好像数据全部都被堵住了，已连接的服务器都看不到。
但当客户端1发送信息时候，刚才被堵住的那些信息，又全部一骨脑全都发送出来了。
很奇怪：（

附上代码

procedure TCMServerThread.ClientExecute;
var
Data: array[0..1023] of char;
SocketStream: TWinSocketStream;
ADOQuery: TADOQuery;
ADOConnection: TADOConnection;
t:_Recordset;
ReceiveMessage :String;
begin
   Synchronize(RegisterForm);
   SocketStream := TWinSocketStream.Create(ClientSocket, 600000);
while not Terminated and ClientSocket.Connected do
   try
     FillChar(Data, SizeOf(Data), 0);
     if SocketStream.Read(Data, SizeOf(Data)) = 0 then
     begin
       ClientSocket.Close;
       Synchronize(RemoveForm);
       Terminate;
     end;
       ReceiveMessage := Data;
       Send(ReceiveMessage);
   except
       ClientSocket.Close;
       Synchronize(RemoveForm);
       Terminate;
   end;
end;

procedure TForm1.ServerSocketGetThread(Sender: TObject;
ClientSocket: TServerClientWinSocket;
var SocketThread: TServerClientThread);
begin
SocketThread := TCMServerThread.Create(False, ClientSocket);
end;

procedure TForm1.ServerSocketThreadEnd(Sender: TObject;
Thread: TServerClientThread);
begin
   ThreadCount.Text := IntToStr(StrToInt(ThreadCount.Text) - 1);
end;

procedure TForm1.ServerSocketThreadStart(Sender: TObject;
Thread: TServerClientThread);
begin
ThreadCount.Text := IntToStr(StrToInt(ThreadCount.Text) + 1);
end;

procedure TForm1.RegisterThread(Thread: TServerClientThread);
begin
if Listbox1.Items.IndexOfObject(Thread) = -1 then
   ListBox1.Items.AddObject(inttostr(Listbox1.Items.Count), Thread);
end;

procedure TCMServerThread.RegisterForm;
begin
Form1.RegisterThread(self);
end;

procedure TCMServerThread.RemoveForm;
begin
Form1.RemoveThread(self);
end;

procedure TCMServerThread.Send(SMessage:String);
begin
Form1.SendAllMessage(SMessage);
end;

procedure TForm1.RemoveThread(Thread: TServerClientThread );
var
INdex: Integer;
begin
Index := ListBox1.Items.IndexOfObject(Thread);
if Index <> -1 then
   Listbox1.Items.Delete(Index);
end;

procedure TForm1.SendAllMessage(SMessage:String);
var
i: Integer;
begin
   for i := 0 to ListBox1.Items.Count - 1 do
   begin
       with TServerClientThread(ListBox1.Items.Objects[i]) do
       begin
           Memo1.Lines.Add('index:' + inttostr(i) + ' Message'+SMessage);
           ClientSocket.SendText(SMessage);
       end;
   end;
end;

procedure TForm1.Button1Click(Sender: TObject);
begin
   ServerSocket.Open;
end;

来自：beta, 时间：2002-9-12 4:23:00, ID：1319865
你的 TCMServerThread.ClientExecute; 的循环取数据好像太“霸道”了吧：）
在每个循环里面 Sleep(100); 一下，否则资源占用太高了吧。
或者用 WaitForData

来自：Orber, 时间：2002-9-12 6:21:00, ID：1319870
我加上 waitfordata 试验了一下，似乎成功了。但是请问我写的那个
Send(SMessage:String)方法，是否需要在
在线程中用 Synchronize() 来调用呢？
但是由于我那个方法需要有一个参数的，所以调用起来会出错误.

请指教。

来自：eMetal, 时间：2003-5-21 11:17:00, ID：1881038
你的代码好像有很多漏洞嘛该free的没有释放

来自：qsilence, 时间：2003-5-21 17:14:00, ID：1882782
多线程数据共享，需要临界量，数据更新完后，用POSTTHREADMESSAGE通知目标线程读

--
※ 来源:·荔园晨风BBS站 bbs.szu.edu.cn·[FROM: 61.144.235.39]

荔园在线首页友情链接：深圳大学深大招生荔园晨风BBS S-Term软件网络书店