蛙蛙推荐:c#使用winsock api实现同步Socket服务端
2008-07-12 10:40
781 查看
由于大多讲解winsock的代码都是c++的,而winsock只是一些windows api的使用,为了帮助.net程序员深入的理解winsock2,我把.net下同步socket的实现代码拆了出来,简化了一下,大家有空可以调试一下看看。
注意
1、只能跑在win2000以上的系统
2、只支持tcp协议,
3、支持ipv4
改动
1、去掉计数器、日志等逻辑
2、不支持异步,完成端口模型,等有时间了,把完成端口那部分也拆分出来给大家。
为了不让本帖太短,贴一些代码中使用到的winsock函数的原型,大家要想开发高性能的网络程序,就得去深入理解winsock的那几个函数,可以看看《windows网络编程》的第7、8、9章
OSSOCK#region OSSOCK
[SuppressUnmanagedCodeSecurity]
internal static class OSSOCK
{
[DllImport("ws2_32.dll", CharSet = CharSet.Ansi, SetLastError = true)]
internal static extern SocketError WSAStartup([In] short wVersionRequested, out WSAData lpWSAData);
[DllImport("ws2_32.dll", CharSet = CharSet.Auto, SetLastError = true)]
internal static extern SafeCloseSocket.InnerSafeCloseSocket WSASocket([In] AddressFamily addressFamily, [In] SocketType socketType, [In] ProtocolType protocolType, [In] IntPtr protocolInfo, [In] uint group, [In] SocketConstructorFlags flags);
[DllImport("ws2_32.dll", CharSet = CharSet.Auto, SetLastError = true)]
internal static extern unsafe SafeCloseSocket.InnerSafeCloseSocket WSASocket([In] AddressFamily addressFamily, [In] SocketType socketType, [In] ProtocolType protocolType, [In] byte* pinnedBuffer, [In] uint group, [In] SocketConstructorFlags flags);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError bind([In] SafeCloseSocket socketHandle, [In] byte[] socketAddress, [In] int socketAddressSize);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError listen([In] SafeCloseSocket socketHandle, [In] int backlog);
[ReliabilityContract(Consistency.WillNotCorruptState, Cer.MayFail), DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError ioctlsocket([In] SafeCloseSocket socketHandle, [In] int cmd, [In, Out] ref int argp);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern unsafe int recv([In] IntPtr socketHandle, [In] byte* pinnedBuffer, [In] int len, [In] SocketFlags socketFlags);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern unsafe int send([In] IntPtr socketHandle, [In] byte* pinnedBuffer, [In] int len, [In] SocketFlags socketFlags);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError shutdown([In] SafeCloseSocket socketHandle, [In] int how);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError setsockopt([In] SafeCloseSocket socketHandle, [In] SocketOptionLevel optionLevel, [In] SocketOptionName optionName, [In] ref int optionValue, [In] int optionLength);
}
#endregion
WawaSocket.zip
研究了几天.net socket里对IOCP的封装,发现确实有些复杂,不打算往出拆代码了,自己理解IOCP的代码,用平台调用写一个示例吧。甭管.net再发展,remoting,wcf啥的,底层还是有限的这么几个函数,真的推荐大家好好看看,到时候网络程序出问题了,抓dump,看调用栈也知道到底阻塞到哪个API了,为什么会阻塞。学windbg也就是那几个命令而已,关键你还得了解clr的内部运行机理,win32api,crt,il甚至汇编等。
注意
1、只能跑在win2000以上的系统
2、只支持tcp协议,
3、支持ipv4
改动
1、去掉计数器、日志等逻辑
2、不支持异步,完成端口模型,等有时间了,把完成端口那部分也拆分出来给大家。
为了不让本帖太短,贴一些代码中使用到的winsock函数的原型,大家要想开发高性能的网络程序,就得去深入理解winsock的那几个函数,可以看看《windows网络编程》的第7、8、9章
OSSOCK#region OSSOCK
[SuppressUnmanagedCodeSecurity]
internal static class OSSOCK
{
[DllImport("ws2_32.dll", CharSet = CharSet.Ansi, SetLastError = true)]
internal static extern SocketError WSAStartup([In] short wVersionRequested, out WSAData lpWSAData);
[DllImport("ws2_32.dll", CharSet = CharSet.Auto, SetLastError = true)]
internal static extern SafeCloseSocket.InnerSafeCloseSocket WSASocket([In] AddressFamily addressFamily, [In] SocketType socketType, [In] ProtocolType protocolType, [In] IntPtr protocolInfo, [In] uint group, [In] SocketConstructorFlags flags);
[DllImport("ws2_32.dll", CharSet = CharSet.Auto, SetLastError = true)]
internal static extern unsafe SafeCloseSocket.InnerSafeCloseSocket WSASocket([In] AddressFamily addressFamily, [In] SocketType socketType, [In] ProtocolType protocolType, [In] byte* pinnedBuffer, [In] uint group, [In] SocketConstructorFlags flags);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError bind([In] SafeCloseSocket socketHandle, [In] byte[] socketAddress, [In] int socketAddressSize);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError listen([In] SafeCloseSocket socketHandle, [In] int backlog);
[ReliabilityContract(Consistency.WillNotCorruptState, Cer.MayFail), DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError ioctlsocket([In] SafeCloseSocket socketHandle, [In] int cmd, [In, Out] ref int argp);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern unsafe int recv([In] IntPtr socketHandle, [In] byte* pinnedBuffer, [In] int len, [In] SocketFlags socketFlags);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern unsafe int send([In] IntPtr socketHandle, [In] byte* pinnedBuffer, [In] int len, [In] SocketFlags socketFlags);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError shutdown([In] SafeCloseSocket socketHandle, [In] int how);
[DllImport("ws2_32.dll", SetLastError = true)]
internal static extern SocketError setsockopt([In] SafeCloseSocket socketHandle, [In] SocketOptionLevel optionLevel, [In] SocketOptionName optionName, [In] ref int optionValue, [In] int optionLength);
}
#endregion
WawaSocket.zip
研究了几天.net socket里对IOCP的封装,发现确实有些复杂,不打算往出拆代码了,自己理解IOCP的代码,用平台调用写一个示例吧。甭管.net再发展,remoting,wcf啥的,底层还是有限的这么几个函数,真的推荐大家好好看看,到时候网络程序出问题了,抓dump,看调用栈也知道到底阻塞到哪个API了,为什么会阻塞。学windbg也就是那几个命令而已,关键你还得了解clr的内部运行机理,win32api,crt,il甚至汇编等。
相关文章推荐
- 蛙蛙推荐:c#使用winsock api实现同步Socket服务端
- 用WINSOCK API实现同步非阻塞方式的网络通讯
- 如何使用WINSOCK Api hook拦截修改socket数据包
- 用WINSOCK API实现同步阻塞方式的网络通讯
- 用WINSOCK API实现同步非阻塞方式的网络通讯
- 使用socket实现简单的客户端和服务端通信(C#语言)
- 用WINSOCK API实现同步阻塞方式的网络通讯
- 用WINSOCK API实现同步阻塞方式的网络通讯
- Visual Basic Winsock API操作模块(基于API方式的socket同步阻塞通讯类)
- 如何使用WINSOCK Api hook拦截修改socket数据包
- SqlServer开启CLR使用(C#)DLL实现实时Socket通知
- C# socket编程 使用fleck轻松实现对话
- Telnet协议详解及使用C# 用Socket 编程来实现Telnet协议
- 如何在DEV-CPP中使用winsocket API
- 在C#中使用异步Socket编程实现TCP网络服务的C/S的通讯构架(一)----基础类库部分
- [转载]在C#中使用异步Socket编程实现TCP网络服务的C/S的通讯构架(二)----使用方法
- 蛙蛙推荐:c#下使用ADO
- 在C#中使用异步Socket编程实现TCP网络服务的C/S的通讯构架(一)
- C#实现多级子目录Zip压缩解压实例 NET4.6下的UTC时间转换 [译]ASP.NET Core Web API 中使用Oracle数据库和Dapper看这篇就够了 asp.Net Core免费开源分布式异常日志收集框架Exceptionless安装配置以及简单使用图文教程 asp.net core异步进行新增操作并且需要判断某些字段是否重复的三种解决方案 .NET Core开发日志
- C#使用socket实现FTP、POP3、SMTP的客户端 (二)