158 lines
7.2 KiB
C++
158 lines
7.2 KiB
C++
#ifndef HGL_SOCKET_INCLUDE
|
||
#define HGL_SOCKET_INCLUDE
|
||
|
||
#include<hgl/network/IP.h>
|
||
|
||
//#define HGL_RECV_BYTE_COUNT ///<接收字节数统计(调试用)
|
||
//#define HGL_SEND_BYTE_COUNT ///<发送字节数统计(调试用)
|
||
|
||
//#define HGL_SOCKET_SEND_LIMIT_SIZE ///<发送限制包尺寸,默认为不限制
|
||
|
||
namespace hgl
|
||
{
|
||
namespace io
|
||
{
|
||
class DataInputStream;
|
||
class DataOutputStream;
|
||
}//namespace io
|
||
|
||
namespace network ///网络相关处理模块名字空间
|
||
{
|
||
constexpr uint HGL_NETWORK_MAX_PORT =65535; ///<最大端口号
|
||
constexpr uint HGL_NETWORK_IPv4_STR_MIN =7; ///<IPv4字符串最小字符数(0.0.0.0)
|
||
constexpr uint HGL_NETWORK_IPV4_STR_MAX =21; ///<IPv4字符串最大长度(255.255.255.255:65535)
|
||
|
||
enum SocketError
|
||
{
|
||
nseNoError =0, ///<没有错误
|
||
|
||
nseInt =4, ///<系统中断呼叫，一般出现在Debug时的人工中断
|
||
nseIOError =5, ///<I/O错误
|
||
|
||
nseTooManyLink =24, ///<太多连接
|
||
|
||
nseBrokenPipe =32, ///<管道破裂，一般是因为发送到一半对方断开所引起
|
||
|
||
#if HGL_OS == HGL_OS_Windows
|
||
nseWouldBlock =WSAEWOULDBLOCK,
|
||
nseSoftwareBreak=WSAECONNABORTED, ///<我方软件主动断开
|
||
nsePeerBreak =WSAECONNRESET, ///<对方主动断开
|
||
nseTimeOut =WSAETIMEDOUT, ///<超时
|
||
#else
|
||
nseWouldBlock =EWOULDBLOCK, ///<请再次尝试(EAGIN/EWOULDBLACK值是一样的)
|
||
nseSoftwareBreak=ECONNABORTED, ///<我方软件主动断开
|
||
nsePeerBreak =ECONNRESET, ///<对方主动断开
|
||
nseTimeOut =ETIMEDOUT, ///<超时
|
||
#endif//
|
||
};//enum SocketError
|
||
|
||
/**
|
||
* Raw Packet length:
|
||
* UDP: MTU - IPHeader(20) - UDPHeader(8)
|
||
* TCP: MTU - IPHeader(20) - TCPHeader(20)
|
||
*
|
||
* Normal MTU:
|
||
* 1500 (Ethernet, DSL broadband)
|
||
* 1492 (PPPoE broadband)
|
||
* 576 (dial-up)
|
||
*/
|
||
|
||
constexpr uint HGL_SERVER_LISTEN_COUNT =SOMAXCONN; ///<Server最大监听数量
|
||
//Linux 是 128
|
||
//winsock 1.x SOMAXCONN是5
|
||
//winsock 2.x SOMAXCONN是0x7fffffff
|
||
|
||
constexpr uint HGL_NETWORK_TIME_OUT =HGL_TIME_ONE_MINUTE; ///<默认超时时间
|
||
constexpr uint HGL_NETWORK_HEART_TIME =HGL_NETWORK_TIME_OUT/2; ///<默认心跳时间(注：心跳并不是每隔指定时间都发送，而是离上一次发送任意封包超过指定时间才发送)
|
||
constexpr uint HGL_NETWORK_DOUBLE_TIME_OUT =HGL_NETWORK_TIME_OUT*2; ///<2次超时时间
|
||
|
||
constexpr uint HGL_SERVER_OVERLOAD_RESUME_TIME =10; ///<服务器超载再恢复等待时间
|
||
|
||
constexpr uint HGL_TCP_BUFFER_SIZE =HGL_SIZE_1KB*256; ///<TCP缓冲区大小
|
||
|
||
typedef int32 HGL_PACKET_SIZE; ///<包长度数据类型定义
|
||
typedef uint32 HGL_PACKET_TYPE; ///<包类型数据类型定义
|
||
|
||
constexpr uint HGL_PACKET_SIZE_BYTES =sizeof(HGL_PACKET_SIZE); ///<包长度数据类型字节数
|
||
constexpr uint HGL_PACKET_TYPE_BYTES =sizeof(HGL_PACKET_TYPE); ///<包类型数据类型字节数
|
||
constexpr uint HGL_PACKET_HEADER_BYTES =HGL_PACKET_SIZE_BYTES+HGL_PACKET_TYPE_BYTES; ///<包头数据类型字节数
|
||
|
||
class Socket;
|
||
class IOSocket;
|
||
|
||
#if HGL_OS == HGL_OS_Windows
|
||
bool InitWinSocket();
|
||
#endif//HGL_OS == HGL_OS_Windows
|
||
}//namespace network
|
||
|
||
namespace network
|
||
{
|
||
const uint16 GetPort(const char *scheme);
|
||
|
||
int CreateSocket(const IPAddress *); ///<创建Socket
|
||
void CloseSocket(int); ///<关闭socket
|
||
|
||
bool Connect(int,IPAddress *); ///<连接一个地址
|
||
void SetSocketBlock(int ThisSocket,bool block,double send_time_out=HGL_NETWORK_TIME_OUT,
|
||
double recv_time_out=HGL_NETWORK_TIME_OUT); ///<设置socket是否使用阻塞方式
|
||
|
||
void SetSocketLinger(int ThisSocket,int time_out); ///<设置Socket关闭时的确认数据发送成功超时时间
|
||
|
||
const os_char *GetSocketString(int);
|
||
|
||
#define GetLastSocketErrorString() GetSocketString(GetLastSocketError())
|
||
|
||
bool Read(io::DataInputStream *dis,IPAddress *addr);
|
||
bool Write(io::DataOutputStream *dos,const IPAddress *addr);
|
||
|
||
/**
|
||
* 所有Socket通信类的基类
|
||
*/
|
||
class Socket ///Socket基类
|
||
{
|
||
protected:
|
||
|
||
IPAddress *ThisAddress; ///<本Socket地址
|
||
|
||
bool InitSocket(const IPAddress *); ///<创建Socket
|
||
|
||
public: //属性
|
||
|
||
int ThisSocket; ///<当前socket编号
|
||
|
||
public: //方法
|
||
|
||
Socket();
|
||
Socket(int,const IPAddress *);
|
||
virtual ~Socket();
|
||
|
||
const IPAddress *GetAddress()const{return ThisAddress;} ///<取得当前Socket的IP地址
|
||
|
||
virtual bool UseSocket(int,const IPAddress *); ///<使用这个Socket与地址
|
||
|
||
virtual bool ReCreateSocket(); ///<使用现有地址重新创建Socket
|
||
|
||
virtual void CloseSocket(); ///<关闭连接
|
||
|
||
/**
|
||
* 设置是否使用堵塞方式传输
|
||
* @param block 是否使用堵塞方式(true/false)
|
||
* @param sto 发送数据超时时间(单位: 秒)
|
||
* @param rto 接收数据超时时间(单位: 秒)
|
||
*/
|
||
void SetBlock(bool block,double sto=HGL_NETWORK_TIME_OUT,
|
||
double rto=HGL_NETWORK_TIME_OUT) ///<设置是否使用堵塞方式
|
||
{
|
||
SetSocketBlock(ThisSocket,block,sto,rto);
|
||
}
|
||
|
||
// public: //被动事件函数
|
||
//
|
||
// virtual void ProcDisconnect()=0; ///<断线事件处理函数
|
||
};//class Socket
|
||
}//namespace network
|
||
|
||
using namespace network;
|
||
}//namespace hgl
|
||
#endif//HGL_SOCKET_INCLUDE
|