如何编写一个利用Socket通信的程序?

设计思路

本例包括一个服务器端程序和一个客户端程序。客户端程序可以放到多个计算机上运行，同时与服务器端进行连接通信。

本例的重点，一是演示客户端与服务器端如何通信；二是当有多个客租返户端同时连接到服务器端时，服务器端如何识别每个客户端，并对请求给出相应的回复。为了保证一个客户端断开连接时不影响其它客户端与服务器端的通信，同时保证服务器端能够正确回复客户端的请求，在本例中声明了一个记录类型：

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.

程序清单 codes/ / /Client java

public class Client

{

public static void main（String[] args）

throws IOException

{

Socket socket = new Socket（ ）

//将Socket对应的输入流包装成BufferedReader

BufferedReader br = new BufferedReader（

new InputStreamReader（socket getInputStream（）））

//进行普通IO *** 作

String line = br readLine（）

System out println（ 来自服务器的数据 + line）

//关闭输入流 socket

br close（）

socket close（）

}

}

上面程序中粗体字代码是使用ServerSocket和Socket建立网络连接的代码 斜体字代码是通过Socket获取输入流 输出流进行通信的代码 通过程序不难看出 一旦使用ServerSocket Socket建立网络连接之后 程序通过网络通信与普通IO并没有太大的区别

先运行上面程序中的Server类 将看到服务器一直处于等待状态 因为服务器使用了死循环来接受来自客户端的请求 再运行Client类 将可看到程序输出 来自服务器的数据 您好 您收到了服务器的新年祝福！ 这表明客户端和服务器端通信成功

上面程序为了档旅突出通过ServerSocket和Socket建立连接 并通过底层IO流进行通信的主题 程序没有进行异常处理 也没有使用finally块来关闭资源

实际应用中 程序可能不想让执行网络连接 读取服务器数据的进程一直阻塞 而是希望当网络连接 读取 *** 作超过合理时间之后 系统自动认为该 *** 作失败 这个合理时间就是超时时长 Socket对象提供了一个setSoTimeout（int timeout）来设置超时时长 如下的代码片段所示

Socket s = new Socket（ ）

//设置 秒之后即认为超时

s setSoTimeout（ ）

当我们为Socket对象指定了超时时长之后 如果在使用Socket进行读 写 *** 作完成之前已经超出了该时间限制 那么这些方法就会抛行御凳出SocketTimeoutException异常 程序可以对该异常进行捕捉 并进行适当处理 如下代码所示

try

{

//使用Scanner来读取网络输入流中的数据

Scanner scan = new Scanner（s getInputStream（））

//读取一行字符

String line = scan nextLine（）

…

}

//捕捉SocketTimeoutException异常

catch（SocketTimeoutException ex）

{

//对异常进行处理

…

}

假设程序需要为Socket连接服务器时指定超时时长 即经过指定时间后 如果该Socket还未连接到远程服务器 则系统认为该Socket连接超时 但Socket的所有构造器里都没有提供指定超时时长的参数 所以程序应该先创建一个无连接的Socket 再调用Socket的connect（）方法来连接远程服务器 而connect方法就可拆兄以接受一个超时时长参数 如下代码所示

//创建一个无连接的Socket

Socket s = new Socket（）

//让该Socket连接到远程服务器 如果经过 秒还没有连接到 则认为连接超时

s connconnect（new InetAddress（host port） ）

       返回目录 疯狂Java讲义

       编辑推荐

       Java程序性能优化 让你的Java程序更快 更稳定

       新手学Java 编程

       Java程序设计培训视频教程

lishixinzhi/Article/program/Java/hx/201311/27265

---