這個例子只是簡單實現了如何使用 Socket 類實現面向連接的通信。
注意：此例子的目的只是為了說明用套接字寫程序的大概思路，而不是實際項目中的使用程序。在這個例子中，實際上還有很多問題沒有解決，如消息邊界問題、端口號是否被占用、消息命令的解析問題等。。
下面是兩個程序的代碼，（兩個程序均為控制台程序）
先發服務端的（Server)完整代碼如下：
引入命名空間：
|
1
2
3
|
using
System.Net.Sockets;
using
System.Net;
using
System.Threading;
|
完整代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
namespace
SocketServer
{
class
Program
{
private
static
byte
[] result =
new
byte
[1024];
private
static
int
myProt = 8885;
//端口
static
Socket serverSocket;
static
void
Main(
string
[] args)
{
//服務器IP地址
IPAddress ip = IPAddress.Parse(
"127.0.0.1"
);
serverSocket =
new
Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
serverSocket.Bind(
new
IPEndPoint(ip, myProt));
//綁定IP地址：端口
serverSocket.Listen(10);
//設定最多10個排隊連接請求
Console.WriteLine(
"啟動監聽{0}成功"
, serverSocket.LocalEndPoint.ToString());
//通過Clientsoket發送數據
Thread myThread =
new
Thread(ListenClientConnect);
myThread.Start();
Console.ReadLine();
}
/// <summary>
/// 監聽客戶端連接
/// </summary>
private
static
void
ListenClientConnect()
{
while
(
true
)
{
Socket clientSocket = serverSocket.Accept();
clientSocket.Send(Encoding.ASCII.GetBytes(
"Server Say Hello"
));
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);
Console.WriteLine(
"接收客戶端{0}消息{1}"
, myClientSocket.RemoteEndPoint.ToString(), Encoding.ASCII.GetString(result, 0, receiveNumber));
}
catch
(Exception ex)
{
Console.WriteLine(ex.Message);
myClientSocket.Shutdown(SocketShutdown.Both);
myClientSocket.Close();
break
;
}
}
}
}
}
|
以上是服務端（server）的完整代碼。
客戶端（Client）的完整代碼如下：
引入命名空間：
|
1
2
3
|
using
System.Net;
using
System.Net.Sockets;
using
System.Threading;
|
完整代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
namespace
SocketClient
{
class
Program
{
private
static
byte
[] result =
new
byte
[1024];
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, 8885));
//配置服務器IP與端口
Console.WriteLine(
"連接服務器成功"
);
}
catch
{
Console.WriteLine(
"連接服務器失敗，請按回車鍵退出！"
);
return
;
}
//通過clientSocket接收數據
int
receiveLength = clientSocket.Receive(result);
Console.WriteLine(
"接收服務器消息：{0}"
,Encoding.ASCII.GetString(result,0,receiveLength));
//通過 clientSocket 發送數據
for
(
int
i = 0; i < 10; i++)
{
try
{
Thread.Sleep(1000);
//等待1秒鍾
string
sendMessage =
"client send Message Hellp"
+ DateTime.Now;
clientSocket.Send(Encoding.ASCII.GetBytes(sendMessage));
Console.WriteLine(
"向服務器發送消息：{0}"
+ sendMessage);
}
catch
{
clientSocket.Shutdown(SocketShutdown.Both);
clientSocket.Close();
break
;
}
}
Console.WriteLine(
"發送完畢，按回車鍵退出"
);
Console.ReadLine();
}
}
}
|
編譯成功后，先運行 服務端（server），再運行客戶端（client）即可達到通信效果。
效果如下圖：
該程序已在局域網測試通過。（192.168.X.X）