关于c#的Socket异步网络编程问题
发布网友
发布时间：2022-04-30 04:20
共4个回答
懂视网
时间：2022-04-15 02:53
首先我们了解下关于异步编程的一些知识可以参考我在网上收集的一些资料C#异步Socket编程 我实现了基于异步通信的Socket服务器和客户端程序 下面是我的代码 第一步：首先新建一个服务端项目YBServerWindowsForms 然后在项目里添加一个自定义的类名为StateObje
首先我们了解下关于异步编程的一些知识可以参考我在网上收集的一些资料——C#异步Socket编程
我实现了基于异步通信的Socket服务器和客户端程序
下面是我的代码
第一步：首先新建一个服务端项目YBServerWindowsForms
然后在项目里添加一个自定义的类名为StateObject：
接着是界面设计代码ServerForm.Designer.cs
主要的逻辑控制代码ServerForm.cs
第二步 新建一个客户端项目名称为YBClientWindowsForms
下面是界面设计YBClientForm.Designer.cs：
主要的逻辑控制代码YBClientForm.cs：
本程序在Windows 7 下用VS2008调试通过
热心网友
时间：2022-04-15 00:01
这样的写法有点问题：
1）服务器端既然采用了异步方式Accept，就没有必要再启线程
2）估计allDone是一个ManualResetEvent。用ManualResetEvent的目的什么呢？
服务器端采用异步Accept的代码其实很简单，也不需要ManualResetEvent同步
public class AppTCPServer{
public AppTCPServer(string localIP, int port)
{
Socket socket = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
EndPoint localEP = new IPEndPoint(IPAddress.Parse(localIP), port);
socket.Bind(localEP);
socket.Listen(100);
socket.BeginAccept(AcceptAsync, socket);
}
private void AcceptAsync(IAsyncResult ar)
{
Socket socket = ar.AsyncState as Socket;
try
{
Socket client = socket.EndAccept(ar);
Console.WriteLine("客户端连接成功！客户端：{0}", client.RemoteEndPoint.ToString());
if (OnConnected != null)
{
OnConnected(this, new ClientConnectedEventArgs(client));
}
}
catch (Exception e)
{
Console.WriteLine("AcceptAsync发生异常，异常信息:\n{0}", e.Message);
}
finally
{
//继续异步Accept
socket.BeginAccept(AcceptAsync, socket);
}
}
//客户端连接后的事件 OnConnect
public event EventHandler<ClientConnectedEventArgs> OnConnected;
}
/// <summary>
/// 事件参数：接收客户端连接后的事件参数
/// </summary>
public class ClientConnectedEventArgs : EventArgs
{
public ClientConnectedEventArgs(Socket clientSocket)
{
ClientSocket = clientSocket;
}
public Socket ClientSocket { get; private set; }
}
class Program
{
static void Main(string[] args)
{
AppTCPServer server = new AppTCPServer("127.0.0.01", 8000);
server.OnConnected += server_OnConnected;
Console.WriteLine("按任意键结束程序……");
Console.ReadKey();
}
static void server_OnConnected(object sender, ClientConnectedEventArgs e)
{
Socket client = e.ClientSocket;
string hello = "Hello from AppTCPServer";
client.Send(Encoding.Default.GetBytes(hello));
}
}
客户端测试程序
class Program{
static void Main(string[] args)
{
//模拟100个客户连接服务器
for (int i = 0; i < 100; i++)
{
Socket socket = ConnectToServer("127.0.0.1", 8000);
byte[] buffer = new byte[1024];
int bytesRecevied = socket.Receive(buffer, buffer.Length, SocketFlags.None);
byte[] messageBytes = new byte[bytesRecevied];
Array.Copy(buffer, messageBytes, bytesRecevied);
Console.WriteLine(Encoding.Default.GetString(messageBytes));
socket.Disconnect(false);
socket.Close();
}
Console.ReadKey();
static Socket ConnectToServer(string serverIP, int serverPort)
{
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
EndPoint localEP = new IPEndPoint(IPAddress.Any, 0);
socket.Bind(localEP);
socket.Connect(new IPEndPoint(IPAddress.Parse(serverIP), serverPort));
return socket;
}
}
热心网友
时间：2022-04-15 01:19
热心网友
时间：2022-04-15 02:54
