介绍资料:
http://www.pushframework.com/ 点击打开链接
codeproject 点击打开链接
buffer.Append((char*)strData.c_str(), strData.size());
这里是有问题的,如果strData不是字符串获得的长度可能是错误的,最好自己指定大小 buffer.Append((char*)strData.c_str(), size);
PushFramework函数理解
接受消息函数 OnReceiveComplete
派发收到的消息 dispatchRequest
注册一个服务器 registerService
包结构 class PUSHFRAMEWORK_API DataBuffer
前段连接服务器
bool Acceptor::handleAcceptedSocket( SOCKET clientSocket, SOCKADDR_IN address )
发包给前段
pChannel->PushPacket(pOutPacket);
消息监听函数
void DemuxImpl::proc()
打包解包
bool WebsocketDataMessage::Decode()
bool WebsocketDataMessage::Encode()
收到第一个包
bool AbstractDistributor::CheckMergeNewInsertedItems()
ProcessFirstPacket
--前段连接
void BroadcastStreamerManager::AddClient( LogicalConnection* pLogicalConnection )
断开连接
void BroadcastStreamer::AddItem( ItemPtr pItem )
发送消息 打包函数
int WebsocketProtocol::frameOutgoingPacket
发送消息 发送函数
bool PhysicalConnection::WriteBytes()
服务器消息函数回调
pHandler->handle(pClient, &packet);