C#服務器端與客戶端通訊（初級）

一、套接字編程

Socket：套接字

套接字是支持TCP/IP協議的網絡通信的基本操做單元，能夠將套接字看作不一樣主機的進程進行雙向通信的端點，它構成了單個主機內及整個網絡間的編程界面。

IP地址（Internet Protacol）：

是互聯網設備之間傳輸數據的一種協議，IP地址就是給每一個鏈接在因特網的主機（或路由器）分配一個在全世界範圍內惟一的標識符（相似你的家庭住址）。

端口：

標識某臺計算機上的進程。

TCP/IP（傳輸控制協議/網際協議）：

是一組網絡通信協議的總稱，它規範了網絡上的全部通信設備，尤爲是一個主機與另外一個主機之間的數據交換格式以及傳輸方式

特色：

TCP(傳輸控制協議)  全雙工

基於鏈接的一種協議

UDP特色：

是一個基於無鏈接的協議，沒有生成鏈接的系統延遲，因此速度要比TCP快；

支持一對1、一對多的鏈接，能夠使用廣播的方式多地址的發送；

消耗的網絡帶寬更小；

UDP協議傳輸的數據有消息邊界，而TCP是沒有的

TCP服務器端代碼：

需引用命名空間

using System.Threading;
using System.Net;
using System.Net.Sockets;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace Server_Tcp
{
class Server
{
private Socket socket; //服務器監聽套接字
private bool isListen = true;//判斷服務器是否在監聽（目的是爲了方便退出）
public Server()
{
//定義網絡終結點（封裝IP和端口）
IPEndPoint endPoint =new IPEndPoint(IPAddress.Parse("127.0.0.1"),9999);
//實例化套接字（監聽套接字）
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp);
//服務器端綁定地址
socket.Bind(endPoint);
//開始監聽
socket.Listen(10);//10表示「監聽對列」的最大長度
Console.WriteLine("服務器端已經啓動");
try
{
while (isListen)
{
//Accept()接收客戶端的鏈接
//會阻斷當前線程的進行
Socket acceptSocket = socket.Accept();
Console.WriteLine("有一個客戶端鏈接。。。。。。");
//開啓一個後臺線程，進行客戶端的會話
Thread clientMsg = new Thread(ClientMsg);
clientMsg.IsBackground = true;//設置爲後臺線程
clientMsg.Name = "clientMsg";//設置線程名字
clientMsg.Start(acceptSocket);
}
}
catch (Exception)
{
}
}
/// <summary>
/// 服務器端和客戶端通信的後臺線程方法
/// </summary>
/// <param name="sockMsg"></param>
public void ClientMsg(object sockMsg)
{
Socket socketMsg = sockMsg as Socket;//通信Socket
while (true)
{
//準備一個「數據緩存（數組）」
byte[] msg = new byte[1024 * 1024];
//接收客戶端發來的數據，返回數據真實長度
int count = socketMsg.Receive(msg);
//byte數組轉換爲string
string str = Encoding.UTF8.GetString(msg, 0, count);
//顯示客戶端發過來的數據
Console.WriteLine("客戶端發過來的數據："+str);
}

}
static void Main(string[] args)
{
Server server = new Server();
}

 TCP客戶端代碼：

需引用命名空間

using System.Net;
using System.Net.Sockets;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

namespace Client_Tcp
{
class Client
{
private Socket clientSocket;//客戶端通信套接字
private IPEndPoint serverEndPoiint;//鏈接到的服務器IP和端口
public Client()
{
serverEndPoiint = new IPEndPoint(IPAddress.Parse("127.0.0.1"),9999);
clientSocket = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
try
{
clientSocket.Connect(serverEndPoiint);
}
catch (Exception)
{
}
}
public void SendMsg()
{
while (true)
{//輸入數據
string str = Console.ReadLine();
//轉換爲字節
byte[] byteArray = Encoding.UTF8.GetBytes(str);
//發送數據
clientSocket.Send(byteArray);
Console.WriteLine("我："+ str);
}
//關閉鏈接
clientSocket.Shutdown(SocketShutdown.Both);
//清理鏈接資源
clientSocket.Close();
}
static void Main(string[] args)
{
Client client = new Client();
client.SendMsg();
}
}
}

UDP接收端代碼：

需引用命名空間

using System.Net;
using System.Net.Sockets;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

namespace Server_Udp
{
class Server
{
private IPEndPoint serverEndPoint;
private Socket serverSocket;
public Server()
{
serverEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"),12345);
serverSocket = new Socket(AddressFamily.InterNetwork,SocketType.Dgram,ProtocolType.Udp);
serverSocket.Bind(serverEndPoint);
EndPoint ep = (EndPoint)serverEndPoint;
while (true)
{
byte[] byteArray = new byte[1024*1024];
int count = serverSocket.ReceiveFrom(byteArray,ref ep);
string str = Encoding.UTF8.GetString(byteArray,0,count);
Console.WriteLine("客戶端發來的信息："+str);
}
}
static void Main(string[] args)
{
Server server = new Server();
}
}
}

UDP發送端代碼：

需引用命名空間

using System.Net;
using System.Net.Sockets;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

namespace Client_Udp{ class Client { private IPEndPoint clientEndPoint; private Socket clientrSocket; public Client() { clientEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 12345); clientrSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); EndPoint ep = (EndPoint)clientEndPoint; while (true) { string str = Console.ReadLine(); byte[] byteArray = new byte[1024 * 1024]; byteArray = Encoding.UTF8.GetBytes(str); clientrSocket.SendTo(byteArray,ep); Console.WriteLine("我發的信息：" + str); } } static void Main(string[] args) { Client client = new Client(); } }}