您好,登錄后才能下訂單哦!
這篇文章將為大家詳細(xì)講解有關(guān)C#中怎么利用Socket實(shí)現(xiàn)異步通訊,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個(gè)參考,希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。
C# Socket異步通訊客戶端之主程序:
using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Text;
// State object for receiving data from remote device.
public class StateObject {
// Client socket.
public Socket workSocket = null;
// Size of receive buffer.
public const int BufferSize = 256;
// Receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
}
public class AsynchronousClient {
// The port number for the remote device.
private const int port = 11000;
// ManualResetEvent instances signal completion.
private static ManualResetEvent connectDone =
new ManualResetEvent(false);
private static ManualResetEvent sendDone =
new ManualResetEvent(false);
private static ManualResetEvent receiveDone =
new ManualResetEvent(false);
// The response from the remote device.
private static String response = String.Empty;
private static void StartClient() {
// Connect to a remote device.
try {// Establish the remote endpoint for the socket.
// The name of the
// remote device is "host.contoso.com".
IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);// 生成一個(gè)TCP/IP socket.
Socket client = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
// 與目標(biāo)終端連接.
client.BeginConnect(remoteEP,
new AsyncCallback(ConnectCallback), client);
//等待,直到連接程序完成。在ConnectCallback中適當(dāng)位置有connecDone.Set()語(yǔ)句
connectDone.WaitOne();
// 發(fā)送數(shù)據(jù)到遠(yuǎn)程終端.
Send(client, "This is a test<EOF>");
sendDone.WaitOne();
// 接收返回?cái)?shù)據(jù).
Receive(client);
receiveDone.WaitOne();
// Write the response to the console.
Console.WriteLine("Response received : {0}", response);
// Release the socket.
client.Shutdown(SocketShutdown.Both);
client.Close();
return 0;
}
C# Socket異步通訊客戶端之連接部分Callback:
private static void ConnectCallback(IAsyncResult ar)
{
// 從state對(duì)象獲取socket.
Socket client = (Socket)ar.AsyncState;
// 完成連接.
client.EndConnect(ar);
Console.WriteLine("Socket connected to {0}",
client.RemoteEndPoint.ToString());
// 連接已完成,主線程繼續(xù).
connectDone.Set();
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
C# Socket異步通訊客戶端之?dāng)?shù)據(jù)接收:
private static void Receive(Socket client)
try {{
// 構(gòu)造容器state.
StateObject state = new StateObject();
state.workSocket = client;
// 從遠(yuǎn)程目標(biāo)接收數(shù)據(jù).
client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReceiveCallback), state);
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
private static void ReceiveCallback(IAsyncResult ar)
{
// 從輸入?yún)?shù)異步state對(duì)象中獲取state和socket對(duì)象
StateObject state = (StateObject)ar.AsyncState;
Socket client = state.workSocket;
//從遠(yuǎn)程設(shè)備讀取數(shù)據(jù)
int bytesRead = client.EndReceive(ar);
if (bytesRead > 0)
{
// 有數(shù)據(jù),存儲(chǔ).
state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
// 繼續(xù)讀取.
client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReceiveCallback), state);
}
else
{
// 所有數(shù)據(jù)讀取完畢.
if (state.sb.Length > 1)
{
response = state.sb.ToString();
}
// 所有數(shù)據(jù)讀取完畢的指示信號(hào).
receiveDone.Set();
}
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
C# Socket異步通訊客戶端之發(fā)送數(shù)據(jù):
private static void Send(Socket client, String data)
{
// 格式轉(zhuǎn)換.
byte[] byteData = Encoding.ASCII.GetBytes(data);
// 開(kāi)始發(fā)送數(shù)據(jù)到遠(yuǎn)程設(shè)備.
client.BeginSend(byteData, 0, byteData.Length, 0,
new AsyncCallback(SendCallback), client);
}
private static void SendCallback(IAsyncResult ar)
{
// 從state對(duì)象中獲取socket
Socket client = (Socket)ar.AsyncState;
// 完成數(shù)據(jù)發(fā)送.
int bytesSent = client.EndSend(ar);
Console.WriteLine("Sent {0} bytes to server.", bytesSent);
// 指示數(shù)據(jù)已經(jīng)發(fā)送完成,主線程繼續(xù).
sendDone.Set();
}
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
public static int Main(String[] args) {
StartClient();
return 0;
}
}
關(guān)于C#中怎么利用Socket實(shí)現(xiàn)異步通訊就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò),可以把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。