ServerSocket类提供如下构造器:
当ServerSocket使用完毕,应使用 close() 方法来关闭此ServerSocket。通常情况下,服务器不应该只接收一个客户端请求,而应该不断接收来自客户端的请求,所以程序可以通过循环,不断调用ServerSocket的accept方法:
Socket 常用构造器
注:上面两个构造器指定远程主机时既可以使用InetAddress来指定,也可以直接使用String对象来指定远程IP。本地主机只有一个IP地址时,使用第一个方法更简单。
在与服务器进行通讯的时候,无法判断远程的服务器是否断开连接。如果使用 OutputStream 发送数据则会影响正常的数据发送(无法区分)。所以就引入了一个心跳机制。
心跳机制实现,使用 Socket.sendUrgentData() 方法发送一个字节流数据(紧急数据)。可以通过判断服务端的 OOBINLINE 属性是否打开,来确定是否断开连接;
setSoTimeout()理解 :设置超时时间;例如:设置为2s,如果阻塞的时间>2s ,那么就会报错。
设计思路本例包括一个服务器端程序和一个客户端程序。客户端程序可以放到多个计算机上运行,同时与服务器端进行连接通信。
本例的重点,一是演示客户端与服务器端如何通信;二是当有多个客户端同时连接到服务器端时,服务器端如何识别每个客户端,并对请求给出相应的回复。为了保证一个客户端断开连接时不影响其它客户端与服务器端的通信,同时保证服务器端能够正确回复客户端的请求,在本例中声明了一个记录类型:
type
client_record=record
CHandle: integer//客户端套接字句柄
CSocket:TCustomWinSocket//客户端套接字
CName:string//客户端计算机名称
CAddress:string//客户端计算机IP地址
CUsed: boolean//客户端联机标志
end
利用这个记录类型数据保存客户端的信息,同时保存当前客户端的连接状态。其中,CHandle保存客户端套接字句柄,以便准确定位每个与服务器端保持连接的客户端;Csocket保存客户端套接字,通过它可以对客户端进行回复。Cused记录当前客户端是否与服务器端保持连接。
下面对组件ServerSocket和ClientSocket的属性设置简单说明。
ServerSocket的属性:
· Port,是通信的端口,必须设置。在本例中设置为1025;
· ServerTypt,服务器端读写信息类型,设置为stNonBlocking表示异步读写信息,本例中采用这种方式。
· ThreadCacheSize,客户端的最大连接数,就是服务器端最多允许多少客户端同时连接。本例采用默认值10。
其它属性采用默认设置即可。
ClientSocket的属性:
· Port,是通信的端口,必须与服务器端的设置相同。在本例中设置为1025;
· ClientType,客户端读写信息类型,应该与服务器端的设置相同,为stNonBlocking表示异步读写信息。
· Host,客户端要连接的服务器的IP地址。必须设置,当然也可以在代码中动态设置。
其它属性采用默认设置即可。
程序源代码:
· 服务器端源码(uServerMain.pas):
unit uServerMain
interface
uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
ScktComp, ToolWin, ComCtrls, ExtCtrls, StdCtrls, Buttons
const
CMax=10//客户端最大连接数
type
client_record=record
CHandle: integer//客户端套接字句柄
CSocket:TCustomWinSocket//客户端套接字
CName:string//客户端计算机名称
CAddress:string//客户端计算机IP地址
CUsed: boolean//客户端联机标志
end
type
TfrmServerMain = class(TForm)
ServerSocket: TServerSocket
ControlBar1: TControlBar
ToolBar1: TToolBar
tbConnect: TToolButton
tbClose: TToolButton
tbDisconnected: TToolButton
Edit1: TEdit
Memo1: TMemo
StatusBar: TStatusBar
procedure tbConnectClick(Sender: TObject)
procedure tbDisconnectedClick(Sender: TObject)
procedure ServerSocketClientRead(Sender: TObjectSocket: TCustomWinSocket)
procedure ServerSocketListen(Sender: TObjectSocket: TCustomWinSocket)
procedure ServerSocketClientConnect(Sender: TObjectSocket: TCustomWinSocket)
procedure ServerSocketClientDisconnect(Sender: TObjectSocket: TCustomWinSocket)
procedure tbCloseClick(Sender: TObject)
procedure FormCreate(Sender: TObject)
procedure FormClose(Sender: TObjectvar Action: TCloseAction)
procedure ServerSocketGetSocket(Sender: TObjectSocket: Integer
var ClientSocket: TServerClientWinSocket)
procedure ServerSocketClientError(Sender: TObject
Socket: TCustomWinSocketErrorEvent: TErrorEvent
var ErrorCode: Integer)
private
{
Private declarations
}
public
{
Public declarations
}
session: array[0..CMax] of client_record//客户端连接数组
Sessions: integer//客户端连接数
end
var
frmServerMain: TfrmServerMain
implementation
{$R *.DFM}
//打开套接字连接,并使套接字进入监听状态
procedure TfrmServerMain.tbConnectClick(Sender: TObject)
begin
ServerSocket.Open
end
//关闭套接字连接,不再监听客户端的请求
procedure TfrmServerMain.tbDisconnectedClick(Sender: TObject)
begin
ServerSocket.Close
StatusBar.Panels[0].Text :='服务器套接字连接已经关闭,无法接受客户端的连接请求.'
end
//从客户端读取信息
procedure TfrmServerMain.ServerSocketClientRead(Sender: TObjectSocket: TCustomWinSocket)
var
i:integer
begin
//将从客户端读取的信息添加到Memo1中
Memo1.Lines.Add(Socket.ReceiveText)
for i:=0 to sessions do
begin
//取得匹配的客户端
if session[i].CHandle = Socket.SocketHandle then
begin
session[i].CSocket.SendText('回复客户端'+session[i].CAddress+' ==>'+Edit1.Text)
end
end
end
//服务器端套接字进入监听状态,以便监听客户端的连接
procedure TfrmServerMain.ServerSocketListen(Sender: TObjectSocket: TCustomWinSocket)
begin
StatusBar.Panels[0].Text :='等待客户端连接...'
end
//当客户端连接到服务器端以后
procedure TfrmServerMain.ServerSocketClientConnect(Sender: TObject
Socket: TCustomWinSocket)
var
i,j:integer
begin
j:=-1
for i:=0 to sessions do
begin
//在原有的客户端连接数组中有中断的客户端连接
if not session[i].CUsed then
begin
session[i].CHandle := Socket.SocketHandle //客户端套接字句柄
session[i].CSocket := Socket//客户端套接字
session[i].CName := Socket.RemoteHost //客户端计算机名称
session[i].CAddress := Socket.RemoteAddress //客户端计算机IP
session[i].CUsed := True//连接数组当前位置已经占用
Break
end
j:=i
end
if j=sessions then
begin
inc(sessions)
session[j].CHandle := Socket.SocketHandle
session[j].CSocket := Socket
session[j].CName := Socket.RemoteHost
session[j].CAddress := Socket.RemoteAddress
session[j].CUsed := True
end
StatusBar.Panels[0].Text := '客户端 '+Socket.RemoteHost + ' 已经连接'
end
//当客户端断开连接时
procedure TfrmServerMain.ServerSocketClientDisconnect(Sender: TObject
Socket: TCustomWinSocket)
var
i:integer
begin
for i:=0 to sessions do
begin
if session[i].CHandle =Socket.SocketHandle then
begin
session[i].CHandle :=0
session[i].CUsed := False
Break
end
end
StatusBar.Panels[0].Text :='客户端 '+Socket.RemoteHost + ' 已经断开'
end
//关闭窗口
procedure TfrmServerMain.tbCloseClick(Sender: TObject)
begin
Close
end
procedure TfrmServerMain.FormCreate(Sender: TObject)
begin
sessions := 0
end
procedure TfrmServerMain.FormClose(Sender: TObjectvar Action: TCloseAction)
begin
ServerSocket.Close
end
//当客户端正在与服务器端连接时
procedure TfrmServerMain.ServerSocketGetSocket(Sender: TObject
Socket: Integervar ClientSocket: TServerClientWinSocket)
begin
StatusBar.Panels[0].Text :='客户端正在连接...'
end
//客户端发生错误
procedure TfrmServerMain.ServerSocketClientError(Sender: TObject
Socket: TCustomWinSocketErrorEvent: TErrorEvent
var ErrorCode: Integer)
begin
StatusBar.Panels[0].Text :='客户端'+Socket.RemoteHost +'发生错误!'
ErrorCode := 0
end
end.
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)