网络上的两个程序通过一个双向的通信连接实现数据的交换，这个连接的一端称为一个socket。
建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(API)，对TCP/IP的封装，TCP/IP也要提供可供程序员做网络开发所用的接口，这就是Socket编程接口；HTTP是轿车，提供了封装或者显示数据的具体形式;Socket是发动机，提供了网络通信的能力。
更多关于Socket的详情，可以到百科了解其原理：http://baike.baidu.com/link?url=HaZW8GwMCCq9j3A5g6Umjd4iXNZMnSW69V2_95TSzqS1xT1mZ9dYUy621N4A5jCF4-ui8BdfsR6OWFCybRckTq
本文主要是基于Socket短连接（连接→数据传输→关闭连接）异步通讯的入门代码。至于使用短连接还是长连接要具体看实际需求。
废话不多说，直接贴上源码：
服务端：
新建项目后，先引用以下类库：
using System.Net.Sockets;
using System.Threading;
//创建套接字
static Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
private static byte[] result = new byte[1024];
static void Main(string[] args)
{
SocketServie();
}
public static void SocketServie()
{
Console.WriteLine("服务端已启动");
string host = "127.0.0.1";//IP地址
int port = 2000;//端口
socket.Bind(new IPEndPoint(IPAddress.Parse(host), port));
socket.Listen(100);//设定最多100个排队连接请求
Thread myThread = new Thread(ListenClientConnect);//通过多线程监听客户端连接
myThread.Start();
Console.ReadLine();
}
/// <summary>
/// 监听客户端连接
/// </summary>
private static void ListenClientConnect()
{
while (true)
{
Socket clientSocket = socket.Accept();
//clientSocket.Send(Encoding.UTF8.GetBytes("服务器连接成功"));
Thread receiveThread = new Thread(ReceiveMessage);
receiveThread.Start(clientSocket);
}
}
/// <summary>
/// 接收消息
/// </summary>
/// <param name="clientSocket"></param>
private static void ReceiveMessage(object clientSocket)
{
Socket myClientSocket = (Socket)clientSocket;
while (true)
{
try
{
//通过clientSocket接收数据
int receiveNumber = myClientSocket.Receive(result);
if (receiveNumber == 0)
return;
Console.WriteLine("接收客户端{0} 的消息：{1}", myClientSocket.RemoteEndPoint.ToString(), Encoding.UTF8.GetString(result, 0, receiveNumber));
//给Client端返回信息
string sendStr = "已成功接到您发送的消息";
byte[] bs = Encoding.UTF8.GetBytes(sendStr);//Encoding.UTF8.GetBytes()不然中文会乱码
myClientSocket.Send(bs, bs.Length, 0); //返回信息给客户端
myClientSocket.Close(); //发送完数据关闭Socket并释放资源
Console.ReadLine();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
myClientSocket.Shutdown(SocketShutdown.Both);//禁止发送和上传
myClientSocket.Close();//关闭Socket并释放资源
break;
}
}
}
客户端：
新建项目后，先引用以下类库：
using System.Net.Sockets;
using System.Threading;
static void Main(string[] args)
{
//设定服务器IP地址
IPAddress ip = IPAddress.Parse("127.0.0.1");
Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
clientSocket.Connect(new IPEndPoint(ip, 2000)); //配置服务器IP与端口
Console.WriteLine("连接服务器成功");
}
catch
{
Console.WriteLine("连接服务器失败，请按回车键退出！");
return;
}
string sendMessage = "你好";//发送到服务端的内容
clientSocket.Send(Encoding.UTF8.GetBytes(sendMessage));//向服务器发送数据，需要发送中文则需要使用Encoding.UTF8.GetBytes()，否则会乱码
Console.WriteLine("向服务器发送消息：" + sendMessage);
//接受从服务器返回的信息
string recvStr = "";
byte[] recvBytes = new byte[1024];
int bytes;
bytes = clientSocket.Receive(recvBytes, recvBytes.Length, 0); //从服务器端接受返回信息
recvStr += Encoding.UTF8.GetString(recvBytes, 0, bytes);
Console.WriteLine("服务端发来消息：{0}", recvStr); //回显服务器的返回信息
//关闭连接并释放资源
clientSocket.Close();
Console.ReadLine();
}
记得先启动服务端，再启动客户端。
服务端：
1.jpg
客户端：
2.jpg
