实例解析SOCKET编程模型（二）

以下是同步聊天程序的客户端源代码。其中的一些过程可以参考服务器端源码

using System;

using System.Drawing;

using System.Collections;

using System.ComponentModel;

using System.Windows.Forms;

using System.Data;

using System.Net;

using System.Net.Sockets;

using System.Threading;

using System.Text;

namespace 聊天_socket_client

{

/// <summary>

/// Form1 的摘要说明。

/// </summary>

public class Form1 : System.Windows.Forms.Form

{

private System.Windows.Forms.Label label4;

private System.Windows.Forms.Label label3;

private System.Windows.Forms.Label label2;

private System.Windows.Forms.Label label1;

private System.Windows.Forms.Button btnStop;

private System.Windows.Forms.Button btnSend;

private System.Windows.Forms.TextBox txtPort;

private System.Windows.Forms.TextBox txtServer;

private System.Windows.Forms.RichTextBox rtbSend;

private System.Windows.Forms.RichTextBox rtbReceive;

private System.Windows.Forms.StatusBar statusBar1;

private System.Windows.Forms.Button btnConnect;

private IPAddress hostIPAddress;

private IPEndPoint Server;

private Socket sock;

/// <summary>

/// 必需的设计器变量。

/// </summary>

private System.ComponentModel.Container components = null;

public Form1()

{

//

// Windows 窗体设计器支持所必需的

//

InitializeComponent();

//

// TODO: 在 InitializeComponent 调用后添加任何构造函数代码

//

}

/// <summary>

/// 清理所有正在使用的资源。

/// </summary>

protected override void Dispose( bool disposing )

{

if( disposing )

{

if (components != null)

{

components.Dispose();

}

}

base.Dispose( disposing );

}

#region Windows 窗体设计器生成的代码

/// <summary>

/// 设计器支持所需的方法 - 不要使用代码编辑器修改

/// 此方法的内容。

/// </summary>

private void InitializeComponent()

{

this.label4 = new System.Windows.Forms.Label();

this.label3 = new System.Windows.Forms.Label();

this.label2 = new System.Windows.Forms.Label();

this.label1 = new System.Windows.Forms.Label();

this.btnStop = new System.Windows.Forms.Button();

this.btnSend = new System.Windows.Forms.Button();

this.btnConnect = new System.Windows.Forms.Button();

this.txtPort = new System.Windows.Forms.TextBox();

this.txtServer = new System.Windows.Forms.TextBox();

this.rtbSend = new System.Windows.Forms.RichTextBox();

this.rtbReceive = new System.Windows.Forms.RichTextBox();

this.statusBar1 = new System.Windows.Forms.StatusBar();

this.SuspendLayout();

//

// label4

//

this.label4.Location = new System.Drawing.Point(16, 152);

this.label4.Name = "label4";

this.label4.Size = new System.Drawing.Size(64, 23);

this.label4.TabIndex = 22;

this.label4.Text = "发送信息:";

//

// label3

//

this.label3.Location = new System.Drawing.Point(16, 64);

this.label3.Name = "label3";

this.label3.Size = new System.Drawing.Size(64, 23);

this.label3.TabIndex = 21;

this.label3.Text = "接收信息:";

//

// label2

//

this.label2.Location = new System.Drawing.Point(216, 16);

this.label2.Name = "label2";

this.label2.Size = new System.Drawing.Size(64, 23);

this.label2.TabIndex = 20;

this.label2.Text = "监听端口:";

//

// label1

//

this.label1.Location = new System.Drawing.Point(16, 16);

this.label1.Name = "label1";

this.label1.Size = new System.Drawing.Size(56, 23);

this.label1.TabIndex = 19;

this.label1.Text = "服务器:";

//

// btnStop

//

this.btnStop.Location = new System.Drawing.Point(256, 256);

this.btnStop.Name = "btnStop";

this.btnStop.TabIndex = 18;

this.btnStop.Text = "关闭连接";

this.btnStop.Click += new System.EventHandler(this.btnStop_Click);

//

// btnSend

//

this.btnSend.Location = new System.Drawing.Point(144, 256);

this.btnSend.Name = "btnSend";

this.btnSend.TabIndex = 17;

this.btnSend.Text = "发送信息";

this.btnSend.Click += new System.EventHandler(this.btnSend_Click);

//

// btnConnect

//

this.btnConnect.Location = new System.Drawing.Point(32, 256);

this.btnConnect.Name = "btnConnect";

this.btnConnect.TabIndex = 16;

this.btnConnect.Text = "请求连接";

this.btnConnect.Click += new System.EventHandler(this.btnConnect_Click);

//

// txtPort

//

this.txtPort.Location = new System.Drawing.Point(288, 16);

this.txtPort.Name = "txtPort";

this.txtPort.Size = new System.Drawing.Size(48, 21);

this.txtPort.TabIndex = 15;

this.txtPort.Text = "19811";

//

// txtServer

//

this.txtServer.Location = new System.Drawing.Point(72, 16);

this.txtServer.Name = "txtServer";

this.txtServer.TabIndex = 14;

this.txtServer.Text = "127.0.0.1";

//

// rtbSend

//

this.rtbSend.Location = new System.Drawing.Point(80, 152);

this.rtbSend.Name = "rtbSend";

this.rtbSend.Size = new System.Drawing.Size(264, 96);

this.rtbSend.TabIndex = 13;

this.rtbSend.Text = "";

//

// rtbReceive

//

this.rtbReceive.Location = new System.Drawing.Point(80, 56);

this.rtbReceive.Name = "rtbReceive";

this.rtbReceive.Size = new System.Drawing.Size(264, 96);

this.rtbReceive.TabIndex = 12;

this.rtbReceive.Text = "";

//

// statusBar1

//

this.statusBar1.Location = new System.Drawing.Point(0, 287);

this.statusBar1.Name = "statusBar1";

this.statusBar1.ShowPanels = true;

this.statusBar1.Size = new System.Drawing.Size(360, 22);

this.statusBar1.TabIndex = 23;

this.statusBar1.Text = "statusBar1";

//

// Form1

//

this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);

this.ClientSize = new System.Drawing.Size(360, 309);

this.Controls.Add(this.statusBar1);

this.Controls.Add(this.label4);

this.Controls.Add(this.label3);

this.Controls.Add(this.label2);

this.Controls.Add(this.label1);

this.Controls.Add(this.btnStop);

this.Controls.Add(this.btnSend);

this.Controls.Add(this.btnConnect);

this.Controls.Add(this.txtPort);

this.Controls.Add(this.txtServer);

this.Controls.Add(this.rtbSend);

this.Controls.Add(this.rtbReceive);

this.Name = "Form1";

this.Text = "聊天程序－客户端";

this.Closing += new System.ComponentModel.CancelEventHandler(this.Form1_Closing);

this.ResumeLayout(false);

}

#endregion

/// <summary>

/// 应用程序的主入口点。

/// </summary>

[STAThread]

static void Main()

{

Application.Run(new Form1());

}

private void btnConnect_Click(object sender, System.EventArgs e)

{

try

{

hostIPAddress=IPAddress.Parse(txtServer.Text);

}

catch{MessageBox.Show("请输入正确的IP地址格式。");}

try

{

Server=new IPEndPoint(hostIPAddress,Int32.Parse(txtPort.Text));

sock=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

sock.Connect(Server);

statusBar1.Text="与主机"+txtServer.Text+"端口"+txtPort.Text+"连接成功";

Thread thread=new Thread(new ThreadStart(ThreadProc));

thread.Start();

}

catch(Exception ee){MessageBox.Show(ee.Message);}

}

private void ThreadProc()

{

while(true)

{

Byte[] ByteRecv=new Byte[256];

sock.Receive(ByteRecv,ByteRecv.Length,0);

string strRecv=Encoding.BigEndianUnicode.GetString(ByteRecv);

rtbReceive.AppendText(strRecv+"\r\n");

}

}

private void btnSend_Click(object sender, System.EventArgs e)

{

try

{

string strSend ="Client--->"+rtbSend.Text+"\r\n";

Byte[] ByteSend = Encoding.BigEndianUnicode.GetBytes(strSend);

sock.Send(ByteSend,ByteSend.Length,0);

}

catch{MessageBox.Show("连接尚未建立,无法发送.");}

}

private void btnStop_Click(object sender, System.EventArgs e)

{

try

{

sock.Close();

statusBar1.Text="与主机"+txtServer.Text+"端口"+txtPort.Text+"断开连接";

}

catch{MessageBox.Show("连接尚未建立,关闭无效");}

}

private void Form1_Closing(object sender, System.ComponentModel.CancelEventArgs e)

{

try

{

sock.Close();

}

catch{}

}

}

}

• ·通用查询组件设计（续三）
• ·探测远程Windows主机的NetBIOS信息
• ·初探数据包分析程序设计
• ·无进程DLL木马的又一开发思路与实现
• ·初探DNS
• ·实例解析SOCKET编程模型（－）
• ·asp.net生成缩略图
• ·两个动态链接库(MFC扩展库)及其测试程序的例
• ·Java陷阱一箩筐 -- 第一日
• ·设计模式略谈