关于c#的socket
主 题： 关于c#的socket
作 者： adow (adow)
等 级： ^
信 誉 值： 100
所属社区： .NET技术 C#
问题点数： 30
回复次数： 6
发表时间： 2004-10-25 16:16:42
请问在客户端中什么时候开始接受数据。在win32api下可以设置消息::WSAAsyncSelect (GbSocket,hWnd,UM_SOCK,FD_READ|FD_WRITE|FD_ACCEPT);
但在.net中好象没有消息。那我什么时候接受数据呢。
回复人： wanliguout() ( 一级(初级)) 信誉：100 2004-10-25 16:21:29 得分: 0
我也好想知道，如何得到这样的win消息
回复人： Lastcsdner(外行) ( 二级(初级)) 信誉：100 2004-10-25 16:44:42 得分: 5
class MytcpClinet : TcpClient
{
string recv()
{
if(Clinet.Poll(0,SelectRead))
{
//收数据。
}
}
}
回复人： songhtao(三十年孤独) ( 四级(中级)) 信誉：100 2004-10-25 16:49:42 得分: 10
.net下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);
// 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;
}
}
回复人： possible_Y(████本人签名需要刮开,方可看到) ( 五级(中级)) 信誉：100 2004-10-25 17:01:32 得分: 5
listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
listener.Bind(new IPEndPoint(IPAddress.Parse(_ip), _port));
listener.Listen(10);
listener.BeginAccept(new AsyncCallback(ConnectRequest), listener);
……
private void ConnectRequest(object sender, MOLService.ConnectRequestEventArgs e)
{
Socket client = e.Client;
client.BeginReceive(....);
}
利用委托的异步回调，通过
listener.BeginAccept(new AsyncCallback(ConnectRequest), listener);来指定当有请求时由那个方法来处理（这里指定由ConnectRequest方法处理）
回复人： sarcophile(食肉动物) ( 五级(中级)) 信誉：100 2004-10-25 18:06:47 得分: 5
另开一个线程，Read 什么的是阻塞的，有了数据才继续运行，没有的话线程阻塞。
回复人： Lastcsdner(外行) ( 二级(初级)) 信誉：100 2004-10-26 9:38:23 得分: 5
另开一个线程，Read 什么的是阻塞的，有了数据才继续运行，没有的话线程阻塞。
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
在连接数不多的情况下可以这么做，多了线程数就大多了，因为你还要开一个写的线程，每个连接就要开二个线程。
该问题已经结贴 ，得分记录： Lastcsdner (5)、 songhtao (10)、 possible_Y (5)、 sarcophile (5)、 Lastcsdner (5)、