日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

C#異步套接字實(shí)現(xiàn)是如何的呢?讓我們開始從實(shí)例開始：

創(chuàng)新互聯(lián)公司-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比平昌網(wǎng)站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式平昌網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋平昌地區(qū)。費(fèi)用合理售后完善，10余年實(shí)體公司更值得信賴。

下面的C#異步套接字實(shí)現(xiàn)實(shí)例程序創(chuàng)建一個(gè)連接到服務(wù)器的客戶端。該客戶端是用C#異步套接字生成的，因此在等待服務(wù)器返回響應(yīng)時(shí)不掛起客戶端應(yīng)用程序的執(zhí)行。該應(yīng)用程序?qū)⒆址l(fā)送到服務(wù)器，然后在控制臺(tái)顯示該服務(wù)器返回的字符串。

 
 
 

  
  
  
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);       
  
  
  
// Create a TCP/IP socket.       
  
  
  
Socket client = new Socket(AddressFamily.InterNetwork,       
  
  
  
SocketType.Stream, ProtocolType.Tcp);       
  
  
  
// Connect to the remote endpoint.       
  
  
  
client.BeginConnect( remoteEP,       
  
  
  
new AsyncCallback(ConnectCallback), client);       
  
  
  
connectDone.WaitOne();       
  
  
  
// Send test data to the remote device.       
  
  
  
Send(client,"This is a test< EOF>");       
  
  
  
sendDone.WaitOne();       
  
  
  
// Receive the response from the remote device.       
  
  
  
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();       
  
  
  
} catch (Exception e) {       
  
  
  
Console.WriteLine(e.ToString());       
  
  
  
}       
  
  
  
}       
  
  
  
private static void ConnectCallback(IAsyncResult ar) {       
  
  
  
try {       
  
  
  
// Retrieve the socket from the state object.       
  
  
  
Socket client = (Socket) ar.AsyncState;       
  
  
  
// Complete the connection.       
  
  
  
client.EndConnect(ar);       
  
  
  
Console.WriteLine("Socket connected to {0}",       
  
  
  
client.RemoteEndPoint.ToString());       
  
  
  
// Signal that the connection has been made.       
  
  
  
connectDone.Set();       
  
  
  
} catch (Exception e) {       
  
  
  
Console.WriteLine(e.ToString());       
  
  
  
}       
  
  
  
}       
  
  
  
private static void Receive(Socket client) {       
  
  
  
try {       
  
  
  
// Create the state object.       
  
  
  
StateObject state = new StateObject();       
  
  
  
state.workSocket = client;       
  
  
  
// Begin receiving the data from the remote device.       
  
  
  
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 ) {       
  
  
  
try {       
  
  
  
// Retrieve the state object and the client socket       
  
  
  
// from the asynchronous state object.       
  
  
  
StateObject state = (StateObject) ar.AsyncState;       
  
  
  
Socket client = state.workSocket;       
  
  
  
// Read data from the remote device.       
  
  
  
int bytesRead = client.EndReceive(ar);       
  
  
  
if (bytesRead > 0) {       
  
  
  
// There might be more data, so store the data received so far.       
  
  
  
    
  
  
  
state.sb.Append(Encoding.ASCII.GetString(      
  
  
  
state.buffer,0,bytesRead));       
  
  
  
// Get the rest of the data.       
  
  
  
client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,       
  
  
  
new AsyncCallback(ReceiveCallback), state);       
  
  
  
} else {       
  
  
  
// All the data has arrived; put it in response.       
  
  
  
if (state.sb.Length > 1) {       
  
  
  
response = state.sb.ToString();       
  
  
  
}       
  
  
  
// Signal that all bytes have been received.       
  
  
  
receiveDone.Set();       
  
  
  
}       
  
  
  
} catch (Exception e) {       
  
  
  
Console.WriteLine(e.ToString());       
  
  
  
}       
  
  
  
}       
  
  
  
private static void Send(Socket client, String data) {       
  
  
  
// Convert the string data to byte data using ASCII encoding.       
  
  
  
byte[] byteData = Encoding.ASCII.GetBytes(data);       
  
  
  
// Begin sending the data to the remote device.       
  
  
  
client.BeginSend(byteData, 0, byteData.Length, 0,       
  
  
  
new AsyncCallback(SendCallback), client);       
  
  
  
}       
  
  
  
private static void SendCallback(IAsyncResult ar) {       
  
  
  
try {       
  
  
  
// Retrieve the socket from the state object.       
  
  
  
Socket client = (Socket) ar.AsyncState;       
  
  
  
// Complete sending the data to the remote device.       
  
  
  
int bytesSent = client.EndSend(ar);       
  
  
  
Console.WriteLine("Sent {0} bytes to server.", bytesSent);       
  
  
  
// Signal that all bytes have been sent.       
  
  
  
sendDone.Set();       
  
  
  
} catch (Exception e) {       
  
  
  
Console.WriteLine(e.ToString());       
  
  
  
}       
  
  
  
}       
  
  
  
public static int Main(String[] args) {       
  
  
  
StartClient();       
  
  
  
return 0;       
  
  
  
}       
  
  
  
}    
 
 
 

C#異步套接字在服務(wù)器的示例 下面的示例程序創(chuàng)建一個(gè)接收來(lái)自客戶端的連接請(qǐng)求的服務(wù)器。該服務(wù)器是用C#異步套接字生成的

因此在等待來(lái)自客戶端的連接時(shí)不掛起服務(wù)器應(yīng)用程序的執(zhí)行。該應(yīng)用程序接收來(lái)自客戶端的字符串

在控制臺(tái)顯示該字符串，然后將該字符串回顯到客戶端。來(lái)自客戶端的字符串必須包含字符串“”

以發(fā)出表示消息結(jié)尾的信號(hào)。

 
 
 

  
  
  
using System;       
  
  
  
using System.Net;       
  
  
  
using System.Net.Sockets;       
  
  
  
using System.Text;       
  
  
  
using System.Threading;       
  
  
  
// State object for reading client data asynchronously       
  
  
  
public class StateObject {       
  
  
  
// Client socket.       
  
  
  
public Socket workSocket = null;       
  
  
  
// Size of receive buffer.       
  
  
  
public const int BufferSize = 1024;       
  
  
  
// Receive buffer.       
  
  
  
public byte[] buffer = new byte[BufferSize];       
  
  
  
// Received data string.       
  
  
  
public StringBuilder sb = new StringBuilder();       
  
  
  
}       
  
  
  
public class AsynchronousSocketListener {       
  
  
  
// Thread signal.       
  
  
  
public static ManualResetEvent allDone =       
  
  
  
new ManualResetEvent(false);       
  
  
  
public AsynchronousSocketListener() {       
  
  
  
}       
  
  
  
public static void StartListening() {       
  
  
  
// Data buffer for incoming data.       
  
  
  
byte[] bytes = new Byte[1024];       
  
  
  
// Establish the local endpoint for the socket.       
  
  
  
// The DNS name of the computer       
  
  
  
// running the listener is "host.contoso.com".       
  
  
  
IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());       
  
  
  
IPAddress ipAddress = ipHostInfo.AddressList[0];       
  
  
  
IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);       
  
  
  
// Create a TCP/IP socket.       
  
  
  
Socket listener = new Socket(AddressFamily.InterNetwork,       
  
  
  
SocketType.Stream, ProtocolType.Tcp );       
  
  
  
// Bind the socket to the local       
  
  
  
//endpoint and listen for incoming connections.       
  
  
  
try {       
  
  
  
listener.Bind(localEndPoint);       
  
  
  
listener.Listen(100);       
  
  
  
while (true) {       
  
  
  
// Set the event to nonsignaled state.       
  
  
  
allDone.Reset();       
  
  
  
// Start an asynchronous socket to listen for connections.       
  
  
  
Console.WriteLine("Waiting for a connection...");       
  
  
  
listener.BeginAccept(       
  
  
  
new AsyncCallback(AcceptCallback),       
  
  
  
listener );       
  
  
  
// Wait until a connection is made before continuing.       
  
  
  
allDone.WaitOne();       
  
  
  
}       
  
  
  
} catch (Exception e) {       
  
  
  
Console.WriteLine(e.ToString());       
  
  
  
}       
  
  
  
Console.WriteLine("\nPress ENTER to continue...");       
  
  
  
Console.Read();       
  
  
  
}       
  
  
  
public static void AcceptCallback(IAsyncResult ar) {       
  
  
  
// Signal the main thread to continue.       
  
  
  
allDone.Set();       
  
  
  
// Get the socket that handles the client request.       
  
  
  
Socket listener = (Socket) ar.AsyncState;       
  
  
  
Socket handler = listener.EndAccept(ar);       
  
  
  
// Create the state object.       
  
  
  
StateObject state = new StateObject();       
  
  
  
state.workSocket = handler;       
  
  
  
handler.BeginReceive( state.buffer,       
  
  
  
0, StateObject.BufferSize, 0,       
  
  
  
new AsyncCallback(ReadCallback), state);       
  
  
  
}       
  
  
  
public static void ReadCallback(IAsyncResult ar) {       
  
  
  
String content = String.Empty;       
  
  
  
// Retrieve the state object and the handler socket       
  
  
  
// from the asynchronous state object.       
  
  
  
StateObject state = (StateObject) ar.AsyncState;       
  
  
  
Socket handler = state.workSocket;       
  
  
  
// Read data from the client socket.       
  
  
  
int bytesRead = handler.EndReceive(ar);       
  
  
  
if (bytesRead > 0) {       
  
  
  
// There might be more data, so store the data received so far.       
  
  
  
state.sb.Append(Encoding.ASCII.GetString(       
  
  
  
state.buffer,0,bytesRead));       
  
  
  
// Check for end-of-file tag. If it is not there, read       
  
  
  
// more data.       
  
  
  
content = state.sb.ToString();       
  
  
  
if (content.IndexOf("< EOF>") > -1) {       
  
  
  
// All the data has been read from the       
  
  
  
// client. Display it on the console.       
  
  
  
Console.WriteLine("Read {0} bytes from socket. \n Data : {1}",       
  
  
  
content.Length, content );       
  
  
  
// Echo the data back to the client.       
  
  
  
Send(handler, content);       
  
  
  
} else {       
  
  
  
// Not all data received. Get more.       
  
  
  
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,       
  
  
  
new AsyncCallback(ReadCallback), state);       
  
  
  
}       
  
  
  
}       
  
  
  
}       
  
  
  
private static void Send(Socket handler, String data) {       
  
  
  
// Convert the string data to byte data using ASCII encoding.       
  
  
  
byte[] byteData = Encoding.ASCII.GetBytes(data);       
  
  
  
// Begin sending the data to the remote device.       
  
  
  
handler.BeginSend(byteData, 0, byteData.Length, 0,       
  
  
  
new AsyncCallback(SendCallback), handler);       
  
  
  
}       
  
  
  
private static void SendCallback(IAsyncResult ar) {       
  
  
  
try {       
  
  
  
// Retrieve the socket from the state object.       
  
  
  
Socket handler = (Socket) ar.AsyncState;       
  
  
  
// Complete sending the data to the remote device.       
  
  
  
int bytesSent = handler.EndSend(ar);       
  
  
  
Console.WriteLine("Sent {0} bytes to client.", bytesSent);       
  
  
  
handler.Shutdown(SocketShutdown.Both);       
  
  
  
handler.Close();       
  
  
  
} catch (Exception e) {       
  
  
  
Console.WriteLine(e.ToString());       
  
  
  
}       
  
  
  
}       
  
  
  
public static int Main(String[] args) {       
  
  
  
StartListening();       
  
  
  
return 0;       
  
  
  
}       
  
  
  
}    
 
 
 

C#異步套接字的相關(guān)內(nèi)容就向你介紹到這里，希望對(duì)你了解和學(xué)習(xí)C#異步套接字有所幫助。

【編輯推薦】

1. 總結(jié)C#語(yǔ)言命名規(guī)范
2. C#反射相關(guān)知識(shí)學(xué)習(xí)
3. 大話F#和C#：是否會(huì)重蹈C#失敗的覆轍？
4. 總結(jié)和學(xué)習(xí)C#接口
5. 學(xué)習(xí)C#程序有感

新聞標(biāo)題：淺析C#異步套接字的實(shí)現(xiàn)過程
URL網(wǎng)址：http://www.dlmjj.cn/article/djdccsh.html