C# socket 详解

Socket 类为网络通信提供了一套丰富的方法和属性。Socket 类允许您使用 ProtocolType 枚举中所列出的任何一种协议执行异步和同步数据传输。Socket 类遵循异步方法的 .NET Framework 命名模式；例如，同步 Receive 方法对应于异步 BeginReceive 和 EndReceive 方法。

如果应用程序在执行期间只需要一个线程，请使用下面的方法，这些方法适用于同步操作模式。

如果当前使用的是面向连接的协议（如 TCP），则服务器可以使用 Listen 方法侦听连接。Accept 方法处理任何传入的连接请求，并返回可用于与远程主机进行数据通信的 Socket。可以使用此返回的 Socket 来调用 Send 或 Receive 方法。如果要指定本地 IP 地址和端口号，请在调用 Listen 方法之前先调用 Bind 方法。如果您希望基础服务提供程序为您分配可用端口，请使用端口号 0。如果希望连接到侦听主机，请调用 Connect 方法。若要进行数据通信，请调用 Send 或 Receive 方法。

如果当前使用的是无连接协议（如 UDP），则根本不需要侦听连接。调用 ReceiveFrom 方法可接受任何传入的数据报。使用 SendTo 方法可将数据报发送到远程主机。

若要在执行过程中使用单独的线程处理通信，请使用下面的方法，这些方法适用于异步操作模式。

如果当前使用的是面向连接的协议（如 TCP），则可使用 Socket、BeginConnect 和 EndConnect 方法来连接侦听主机。通过使用 BeginSend 和 EndSend 方法，或者使用 BeginReceive 和 EndReceive 方法，可以进行异步数据通信。可以使用 BeginAccept 和 EndAccept 处理传入的连接请求。

如果您使用的是 UDP 等无连接协议，则可以使用 BeginSendTo 和 EndSendTo 来发送数据报，而使用 BeginReceiveFrom 和 EndReceiveFrom 来接收数据报。

如果对一个套接字执行多个异步操作，它们不一定按启动时的顺序完成。

当数据发送和数据接收完成之后，可使用 Shutdown 方法来禁用 Socket。在调用 Shutdown 之后，可调用 Close 方法来释放与 Socket 关联的所有资源。

通过 Socket 类，您可以使用 SetSocketOption 方法来配置 Socket。可以使用 GetSocketOption 方法来检索这些设置。

注意

如果要编写相对简单的应用程序，而且不需要最高的性能，则可以考虑使用 TcpClient、TcpListener 和 UdpClient。这些类为 Socket 通信提供了更简单、对用户更友好的接口。

Windows Mobile for Pocket PC, Windows Mobile for Smartphone, Windows CE 平台说明： 并非所有设备的操作系统会支持全部的套接字选项。

服务器端代码:

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Text;

using System.Windows.Forms;

using System.Threading;

using System.Net;

using System.Net.Sockets;

namespace ChatToolServer

{

public partial class Form1 : Form

{

//server-用于处理客户端连接请求的socket

Socket clientSocket = null;

delegate void del();

public Form1()

{

InitializeComponent();

}

//server-侦听方法

private void listen()

{

//获取服务器IP

string hostName = Dns.GetHostName();

IPAddress[] ip = Dns.GetHostAddresses(hostName);

IPAddress HostIp = ip[0];

//创建一个网络端点

IPEndPoint iep = new IPEndPoint(HostIp, 82);

//创建服务端服务端套接字

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

//将套接字与网络端点绑定

serverSocket.Bind(iep);

//将套接字置为侦听状态，并设置最大队列数为10

serverSocket.Listen(10);

//以同步方式从侦听套接字的连接请求队列中提取第一个挂起的连接请求，然后创建并返回新的 Socket

//新的套接字：包含对方计算机的IP和端口号，可使用这个套接字与本机进行通信

clientSocket = serverSocket.Accept();

if (clientSocket != null)

{

MessageBox.Show("连接成功！");

}

}

private void send_Click(object sender, EventArgs e)

{

if (this.textBox1.Text != "")//不能发送空消息

{

try

{

//发送数据

string message = textBox1.Text;

byte[] sendbytes = System.Text.Encoding.UTF8.GetBytes(message);

int successSendBtyes = clientSocket.Send(sendbytes, sendbytes.Length, SocketFlags.None);

}

catch (Exception exp)

{

MessageBox.Show(exp.Message);

}

//将发送的数据显示到对话窗口并使对话窗口的滚动条一直停留在最下方

this.textBox2.Text +="服务器:"+"\r\n" +textBox1.Text + "\r\n";//发完一条消息就换行显示

this.textBox2.SelectionStart = this.textBox2.Text.Length;

this.textBox2.ScrollToCaret();

this.textBox1.Text = "";//将发送窗口清空

}

else

{

MessageBox.Show("发送内容不能为空");

}

}

private void Form1_Load(object sender, EventArgs e)

{

//server-创建并运行侦听线程

Thread threadListen = new Thread(new ThreadStart(listen));

threadListen.Start();

}

private void timer1_Tick(object sender, EventArgs e)

{

byte[] receiveBytes = new byte[1024];

//如果侦听后取得客户端连接，并且客户端的缓冲区中有内容可读,开始接收数据

if (clientSocket != null)

{

if (clientSocket.Poll(100, SelectMode.SelectRead))

{

int successReceiveBytes = clientSocket.Receive(receiveBytes);

this.textBox2.Text += "客户端:" +"("+ clientSocket.RemoteEndPoint.ToString()+")"+"\r\n" +

System.Text.Encoding.UTF8.GetString(receiveBytes, 0, successReceiveBytes) + "\r\n";

this.textBox2.SelectionStart = this.textBox2.Text.Length;//使对话窗口的滚动条一直停留在最下方

this.textBox2.ScrollToCaret();

}

}

}

}

}

客户端代码;

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Text;

using System.Windows.Forms;

using System.Net;

using System.Net.Sockets;

using System.Threading;

namespace ChatToolClient

{

public partial class Form1 : Form

{

Socket clientSocket = null;//客户端套接字

public Form1()

{

InitializeComponent();

}

private void Form1_Load(object sender, EventArgs e)

{

try

{

//建立与服务器连接的套接字

IPAddress ip = IPAddress.Parse("172.16.94.134");

IPEndPoint iep = new IPEndPoint(ip, 82);

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

clientSocket.Connect(iep);

textBox2.Text = "连接成功" + "\r\n";

}

catch (Exception exp)

{

MessageBox.Show(exp.Message);

}

}

private void send_Click(object sender, EventArgs e)

{

if (textBox1.Text != "")

{

try

{

//发送数据

string message = textBox1.Text;

byte[] sendbytes = System.Text.Encoding.UTF8.GetBytes(message);

int successSendBtyes = clientSocket.Send(sendbytes, sendbytes.Length, SocketFlags.None);

}

catch (Exception exp)

{

MessageBox.Show(exp.Message);

}

//将发送的数据显示到对话窗口并使对话窗口的滚动条一直停留在最下方

this.textBox2.Text += "我自己:"+"\r\n"+textBox1.Text + "\r\n";//发完一条消自己息就换行显示

this.textBox2.SelectionStart = this.textBox2.Text.Length;

this.textBox2.ScrollToCaret();

this.textBox1.Text = "";//将发送窗口清空

}

else

{

MessageBox.Show("发送内容不能为空");

}

}

private void timer1_Tick(object sender, EventArgs e)

{

byte[] receiveBytes = new byte[1024];

if (clientSocket.Poll(100, SelectMode.SelectRead))

{

int successReceiveBytes = clientSocket.Receive(receiveBytes);

this.textBox2.Text +="服务器:"+"\r\n"+

System.Text.Encoding.UTF8.GetString(receiveBytes, 0, successReceiveBytes) + "\r\n";

this.textBox2.SelectionStart = this.textBox2.Text.Length;//使对话窗口的滚动条一直停留在最下方

this.textBox2.ScrollToCaret();

}

}

}

}

鹏仔微信 15129739599 鹏仔QQ344225443 鹏仔前端 pjxi.com 共享博客 sharedbk.com