c#(Socket)非同步套接字程式碼範例-java教程-PHP中文網

非同步客戶端套接字範例

下面的範例程式建立一個連接到伺服器的客戶端。該客戶端是用非同步套接字產生的，因此在等待伺服器回傳回應時不掛起客戶端應用程式的執行。該應用程式將字串傳送到伺服器，然後在控制台顯示該伺服器傳回的字串。

C#

using System;
using System.Net;
using System.Net.Sockets;
using System.Threading; p. eiving data from remote device.
public class StateObject {
// Client socket.
public Socket workSocket = null;
// Size of receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
}
public class AsynchronousClient  port = 11000;
// ManualResetEvent instances signal completion.
private static ManualResetEvent connectDone =
new ManualResetEvent(false);
private static ManualResetEvent sendcom iveDone =
new ManualResetEvent(false);
// The response from the remote device.
private static String response = String.Empty;
private static void StartClient() {
// Connect to a remotec/pointo. the socket.
// The name of the
// remote device is "host.contoso.com".
IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
IPAddress ipAddressP=cListip.com");
IPAddress Address, port) ;
// Create a TCP/IP socket.
Socket client = new Socket(AddressFamily.InterNetwork,
client.BeginConnect( remoteEP,
new AsyncCallback(ConnectCallback), client);
connectDone.WaitOne();
// Send test data to the remote device.
Send(client,"This) ;
// Receive the response from the remote device.
Receive(client);
receiveDone.WaitOne();
//  : {0}", response);
// Release the socket.
client.Shutdown(SocketShutdown.Both);
client.Close();
} catch (ExceptionStringC) {
private static void ConnectCallback(IAsyncResult ar) {
try {
// Retrieve the socket from the  the connection.
client.EndConnect(ar);
Console .WriteLine("Socket connected to {0}",
client.RemoteEndPoint.ToString());
// Signal that the connection  been made. {
Console .WriteLine(e.ToString());
}
}
private static void Receive(Socket client) {
try { 🠎/
state.workSocket = client ;
// Begin receiving the data from the remote device.
client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReceiveCallback), state);
} catch (異常e) {
Console.WriteLinee.
private static void ReceiveCallback( IAsyncResult ar ) {
try {
// 從非同步狀態物件擷取狀態物件與客戶端套接字
// 從非同步狀態物件擷取狀態物件和客戶端套接字
///
///
//。
StateObject 狀態 = (StateObject) ar.AsyncState;
Socket 用戶端 = state.workSocket;
//從遠端裝置讀取資料。
int bytesRead = client.EndReceive(ar);
if (bytesRead > 0) {
//可能有更多數據，因此儲存目前收到的資料。
state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));
//取得其餘資料。
client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
new AsyncCallback(ReceiveCallback), state);
} else {
// 所有資料已到達中。
if (state.sb.Length > 1) {
response = state.sb.ToString();
}
// 表示所有位元組都已收到。
receiveDone.Set();
}
} catch（異常e）{
Console.WriteLine(e.ToString());
}
}
private statSoid Soidsprivate statS）, private statS/oid, private statS）, private statS）, private statS oid/S; ASCII 編碼將字串資料轉換為位元組資料。
byte[] byteData = Encoding.ASCII.GetBytes(data);
//開始將資料傳送至遠端設備。
client.BeginSend(byteData, 0, byteData.Length, 0,
new AsyncCallback(SendCallback), client);
}
狀態物件檢索套接字。
Socket 用戶端=(Socket) ar.AsyncState;
//完成將資料傳送至遠端裝置。
int bytesSent = client.EndSend(ar);
Console.WriteLine("已發送 {0} 個位元組到伺服器。", bytesSent);
// 發出所有位元組已傳送的訊號。
sendDone.Set();
} catch (異常e) {
Console.WriteLine(e.ToString());
}
}
public static int Main(String[) 0；
}
}
非同步架構範例下面的範例程式建立接收來自客戶端的連線請求的伺服器。該伺服器是使用非同步架構產生的，
因此等待在來自客戶端的連接時不掛起伺服器應用程式的執行。該應用程式接收來自客戶端的字串，
在控制台顯示該字串，然後將字串回顯到客戶端。來自客戶端的字串必須包含字串“” ，
以發出表示訊息結束的訊號。



C#
使用系統複製程式碼

;
使用System.
// 用於非同步讀取客戶端資料的狀態物件
public class StateObject {
// 客戶端套接字。
public Socket workSocket = null;
//接收緩衝區的大小。
公 const int BufferSize = 1024；
//接收緩衝區。
public byte[] buffer = new byte[BufferSize];
//收到資料字串。
public StringBuilder sb = new StringBuilder();
}
公共類別 AsynchronousSocketListener {
// 執行緒訊號。
public static ManualResetEvent allDone = new ManualResetEvent(false);
public AsynchronousSocketListener() {
}
public static void StartListening() {
// 用於傳入資料的資料緩衝區。
byte[]位元組=新位元組[1024]；
// 為套接字建立本地端點。
// 執行偵聽器的電腦的 DNS 名稱是「host.contoso.com」。
IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint localEndPoint = new IP 1(ip/pcom
Socket 監聽器 = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
//將套接字綁定到本地端點並偵聽傳入連線。
嘗試{
listener.Bind(localEndPoint);
listener.Listen(100);
while (true) {
//將事件設為無訊號狀態。
allDone.Reset();
//啟動非同步套接字來偵聽連線。
Console.WriteLine("正在等待連線...");
listener.BeginAccept(
new AsyncCallback(AcceptCallback),
listener);
//等待連線建立後再繼續。
allDone.WaitOne();
}
} catch（異常e）{
Console.WriteLine(e.ToString());
}
Console.WriteLine("n) 按下
}
Console.WriteLine("n)。 Read();
}
public static void AcceptCallback(IAsyncResult ar) {
// 向主執行緒發出訊號繼續。
allDone.Set();
//取得處理客戶端請求的套接字。
Socket 監聽器 = (Socket) ar.AsyncState;
Socket 處理程序=listener.EndAccept(ar);
//建立狀態物件。
StateObject 狀態= new StateObject();
state.workSocket = 處理程序；
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncmCallback(Readallback)
}; ReadCallback(IAsyncResult ar){
String content = String.Empty;
//從非同步狀態物件擷取狀態物件和處理程序套接字。
StateObject 狀態 = (StateObject) ar.AsyncState;
Socket 處理程序 = state.workSocket;
//從客戶端套接字讀取資料。
int bytesRead = handler.EndReceive(ar);
if (bytesRead > 0) {
//可能有更多數據，因此儲存目前收到的資料。
state.sb.Append(Encoding.ASCII.GetString(
state.buffer,0,bytesRead));
//檢查檔案結尾標記。如果不存在，請閱讀
//更多資料。
內容 = state.sb.ToString();
if (content.IndexOf("") > -1) {
// 所有資料已從
// 客戶端讀取。將其顯示在控制台上。
Console.WriteLine("從套接字讀取 {0} 個位元組。資料：{1}",
content.Length, content);
//將資料回顯給客戶端。
寄送（處理程序，內容）；
} 其他 {
// 未收到所有資料。得到更多。
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReadCallback), state);
}
}
}
private statis vleal vk oid, 片
ASCII 編碼將字串資料轉換為位元組資料。
byte[] byteData = Encoding.ASCII.GetBytes(data);
// Begin sending the data to the remote device. 🟜handler.Beginend(byteData,c.com)(byc),com SendCallback), handler) ;
}
private static void SendCallback(IAsyncResult ar) {
try {
// Retrieve the socket. ncState;
// Complete sending the data to the remote device.
int bytesSent = handler.EndSend(ar);
Console.WriteLine("Sent {0} bytes to client.", bytesSent);
handler.Shutdown(SocketShutler. (Exception e) {
Console.WriteLine(e.ToString());
}
}
public static int Main(String[]

以上就是c#(Socket)非同步套接字程式碼範例的內容，更多相關內容請關注PHP中文網（www.php.cn）！