c# socket 异步通信（客户端怎么接收消息）
using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Text;
public class StateObject {
public Socket workSocket = null;
public const int BufferSize = 256;
public byte[] buffer = new byte[BufferSize];
public StringBuilder sb = new StringBuilder();
}
public class AsynchronousClient {
private const int port = 11000;
private static ManualResetEvent connectDone =
new ManualResetEvent(false);
private static ManualResetEvent sendDone =
new ManualResetEvent(false);
private static ManualResetEvent receiveDone =
new ManualResetEvent(false);
private static String response = String.Empty;
private static void StartClient() {
try {
IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);
Socket client = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
client.BeginConnect( remoteEP,
new AsyncCallback(ConnectCallback), client);
connectDone.WaitOne();
Send(client,"This is a test<EOF>");
sendDone.WaitOne();
Receive(client);
receiveDone.WaitOne();
Console.WriteLine("Response received : {0}", response);
client.Shutdown(SocketShutdown.Both);
client.Close();
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
private static void Receive(Socket client) {
try {
StateObject state = new StateObject();
state.workSocket = client;
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 {
StateObject state = (StateObject) ar.AsyncState;
Socket client = 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();
}
// Signal that all bytes have been received.
receiveDone.Set();
}
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
private static void Send(Socket client, String data) {
byte[] byteData = Encoding.ASCII.GetBytes(data);
client.BeginSend(byteData, 0, byteData.Length, 0,
new AsyncCallback(SendCallback), client);
}
private static void SendCallback(IAsyncResult ar) {
try {
Socket client = (Socket) ar.AsyncState;
int bytesSent = client.EndSend(ar);
Console.WriteLine("Sent {0} bytes to server.", bytesSent);
sendDone.Set();
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
}
}
小弟对异步不是很了解。
这是微软给的例子，怎么才能实现 多次发送消息 和 怎么接受服务器主动发来的消息）。
谢谢各位了，先。
--------------------编程问答-------------------- 请各位大侠指点。 --------------------编程问答-------------------- 这个已经可以实现了，只是缺少一个将接受到的数据输出的事件 --------------------编程问答--------------------
他这个不是只运行一次么，我的主程序会一直执行，我要怎么继续发送和接收呢 --------------------编程问答-------------------- --------------------编程问答-------------------- 你提供的代码已经实现了持续接收数据的功能。
发送数据是需要主动调用send方法的，你调用一次，就发送一次。 --------------------编程问答-------------------- 我第二次发送好像就被阻塞了，不能触发回调函数 --------------------编程问答--------------------
我第二次发送好像就被阻塞了，不能触发回调函数 --------------------编程问答--------------------
public void Send(byte[] buff)
{
if (ClientSocket == null || !ClientSocket.Connected)
{
Debug.LogError("ClientSocket is null or ClientSocket unConnected.");
return;
}
ArraySegment<byte> b0 = new ArraySegment<byte>(headerBuff);
ArraySegment<byte> b1 = new ArraySegment<byte>(buff);
buffList.Add(b0);
buffList.Add(b1);
ClientSocket.BeginSend(buffList, 0, new AsyncCallback(SendCallback), ClientSocket);
}
private void SendCallback(IAsyncResult ar)
{
try
{
Debug.Log("start SendCallback.");
int bytesSent = ClientSocket.EndSend(ar);
Debug.Log("Sent " + bytesSent + " bytes to server.");
}
catch (Exception e)
{
Debug.Log("Exception SendCallback.");
Debug.LogError(e.ToString());
}
}
我第一调用send正常，也能收到服务器返回的消息，
可是第二次调用send，死活不进入SendCallback方法。
求解啊？ --------------------编程问答-------------------- --------------------编程问答-------------------- 我也遇到这种问题，解决了告诉了。 --------------------编程问答--------------------
你打个断点调试一下，看看是不是在if那里，满足条件，直接return了。 --------------------编程问答--------------------
没有 我的Debug.LogError就是输出错误信息，没有打印。
我也打过断点，程序确实执行到了
ClientSocket.BeginSend(buffList, 0, new AsyncCallback(SendCallback), ClientSocket);
这一步。
--------------------编程问答-------------------- 数据量不是特别大的话，用同步发送吧 --------------------编程问答--------------------
额，就是需要这样发送。 --------------------编程问答--------------------
那就是你的发送都没有成功。 --------------------编程问答--------------------
我找到原因了。
用BeginSend(IList <(Of <(ArraySegment <(Of <(Byte >)>)>)>), SocketFlags, AsyncCallback, Object) 这个发就只能发一次。
用BeginSend( array<Byte []()>[], Int32, Int32, SocketFlags, AsyncCallback, Object) 就可以再次多次发送。
这是怎么回事呢，请教， --------------------编程问答--------------------
第一次我发送成功了的啊，服务器都能接到我的消息。 --------------------编程问答-------------------- 问题解决了吗？
补充：.NET技术 , C#
