Blog @ Blog

當(dāng)華美的葉片落盡，生命的脈絡(luò)才歷歷可見(jiàn)。－－聶魯達(dá)

導(dǎo)航

公告

留言簿(20)

隨筆分類(156)

文章分類(1)

隨筆檔案(198)

文章檔案(2)

相冊(cè)

Meet or get-together

閱讀排行榜

評(píng)論排行榜

常用鏈接

統(tǒng)計(jì)

隨筆 - 198
文章 - 2
評(píng)論 - 156
引用 - 0

積分與排名

積分 - 663219
排名 - 25

BBS

Sohu Club

Blog

Web

CSDN
VC KBase

連接服務(wù)流程代碼

void CTCPUDPDlg::OnBtnConnect() //連接服務(wù)

bool CSocketComm::ConnectTo(LPCTSTR strDestination, LPCTSTR strServiceName, int nProtocol, int nType)

BOOL CSocketComm::WatchClientSocket()//啟動(dòng)Socket線程

UINT WINAPI CSocketComm::SocketClientThreadProc(LPVOID pParam)//客戶端線程

void CSocketComm::ClientRun()//Client主線程函數(shù)

//附件：

//連接服務(wù): socket();bind();connect()

bool CSocketComm::ConnectTo(LPCTSTR strDestination, LPCTSTR strServiceName, int nProtocol, int nType)

{

// 如果socket已經(jīng)打開(kāi)

if ( IsOpen() )

return false;

SOCKADDR_IN sockAddr = {0};

//創(chuàng)建一個(gè)SOCKET

SOCKET sock = ::socket(nProtocol, nType, 0);

if(sock != INVALID_SOCKET)

{

// 讓socket綁定一個(gè)地址

TCHAR strHost[HOSTNAME_SIZE] = { 0 };

if (false == CSocketComm::GetLocalName( strHost, sizeof(strHost)/sizeof(TCHAR)))

{

closesocket( sock );

return false;

}

//獲取本機(jī)IP

sockAddr.sin_addr.s_addr = htonl( CSocketComm::GetIPAddress( strHost ) );

sockAddr.sin_family = nProtocol;

if ( SOCKET_ERROR == bind(sock, (LPSOCKADDR)&sockAddr, sizeof(SOCKADDR_IN)))

{

closesocket( sock );

return false;

}

// 獲得目標(biāo)地址

if ( strDestination[0])

{

sockAddr.sin_addr.s_addr = htonl(CSocketComm::GetIPAddress( strDestination ) );

}

// 獲得端口

sockAddr.sin_port = htons( GetPortNumber( strServiceName ));

if ( 0 != sockAddr.sin_port )

{

// 連接服務(wù)器

if (SOCKET_ERROR == connect( sock, (LPSOCKADDR)&sockAddr, sizeof(SOCKADDR_IN)))

{

closesocket( sock );

return false;

}

// 保存socket

m_hSocket = (HANDLE) sock;

return true;

}

else

{

CString strError;

strError.Format("Create Socket Error Code: %d",GetLastError());

AfxMessageBox(strError,MB_ICONERROR);

}

return false;

}

//啟動(dòng)Socket線程

BOOL CSocketComm::WatchClientSocket()

{

//首先判斷線程是否啟動(dòng)

if(!IsStart())

{

//判斷是否打開(kāi)通信，即socket是否成功創(chuàng)建

if(IsOpen())

{

HANDLE hThread;

UINT uiThreadId = 0;

//啟動(dòng)線程，使用_beginthreadex

hThread = (HANDLE)_beginthreadex(NULL, // 安全參數(shù)

0, // 堆棧

SocketClientThreadProc, // 線程程序

this, // 線程參數(shù)

CREATE_SUSPENDED, //創(chuàng)建模式

&uiThreadId); // 線程ID

//如果線程不為空

if(hThread != NULL)

{

//繼續(xù)線程

::ResumeThread(hThread);

m_hThread = hThread;

return TRUE;

}

return false;

}

//客戶端線程

UINT WINAPI CSocketComm::SocketClientThreadProc(LPVOID pParam)

{

//reinterpret_cast用于各種指針的轉(zhuǎn)化

CSocketComm* pThis = reinterpret_cast<CSocketComm*>(pParam);

_ASSERTE( pThis != NULL );

pThis->ClientRun();

return 1L;

}

//Client主線程函數(shù)ReadComm():

void CSocketComm::ClientRun()

{

BYTE buffer[BUFFER_SIZE];

DWORD dwBytes = 0L;

HANDLE hThread = ::GetCurrentThread();

DWORD dwTimeout = DEFAULT_TIMEOUT;

//如果SOCKET 已經(jīng)創(chuàng)建

while(IsOpen())

{

//采用阻塞式SOCKET，等待事件通知

dwBytes = ReadComm(buffer,sizeof(buffer),dwTimeout);

// 如果有錯(cuò)誤發(fā)生

if (dwBytes == (DWORD)-1)

{

// 如果要關(guān)閉，則不發(fā)送事件

if(IsOpen())

OnEvent( EVT_CONDROP,ServerSockAddr); // 失去連接

break;

}

// 是否有數(shù)據(jù)收到

if (IsSmartAddressing() && dwBytes == sizeof(SOCKADDR_IN))

OnEvent( EVT_ZEROLENGTH,ServerSockAddr);

else if(dwBytes > 0L)

{

OnDataReceived(buffer, dwBytes);

}

Sleep(0);

}

//讀數(shù)據(jù)函數(shù)select();recvfrom();recv()

DWORD CSocketComm::ReadComm(LPBYTE lpBuffer, DWORD dwSize, DWORD dwTimeout)

{

_ASSERTE(IsOpen());

_ASSERTE(lpBuffer != NULL);

if(lpBuffer == NULL || dwSize<1L)

return 0L;

fd_set fdRead = {0};

TIMEVAL stTime;

TIMEVAL *pstTime = NULL;

if(INFINITE != dwTimeout)

{

stTime.tv_sec=0;

stTime.tv_usec=dwTimeout*1000;

pstTime = &stTime;

}

SOCKET s=(SOCKET)m_hSocket;

//設(shè)定描述符

if(!FD_ISSET(s,&fdRead))

FD_SET(s,&fdRead);

//選擇函數(shù)，設(shè)定超時(shí)時(shí)間

DWORD dwBytesRead = 0L;

int res = select(s+1,&fdRead,NULL,NULL,pstTime);

if(res > 0)

{

if(IsBroadCast() || IsSmartAddressing())

{

SOCKADDR_IN sockAddr = {0};//獲得地址

int nOffset = IsSmartAddressing()?sizeof(sockAddr):0;

int nLen = sizeof(sockAddr);

if(dwSize < (DWORD)nLen)//緩沖區(qū)太小

{

::SetLastError(ERROR_INVALID_USER_BUFFER);

return -1L;

}

//獲得數(shù)據(jù)

res = ::recvfrom(s,(LPSTR)&lpBuffer[nOffset],dwSize,0,(LPSOCKADDR)&sockAddr,&nLen);

memset(&sockAddr.sin_addr,0,sizeof(sockAddr.sin_zero));

if(res>=0)

{

LockList();//鎖定地址列表

//刪除調(diào)重復(fù)地址

SockAddrIn sockin;

sockin.SetAddr(&sockAddr);

m_AddrList.remove(sockin);

m_AddrList.insert(m_AddrList.end(),sockin);

if(IsSmartAddressing())

{

memcpy(lpBuffer,&sockAddr,sizeof(sockAddr));

res+=sizeof(sockAddr);

}

UnlockList();//解開(kāi)地址列表

}

else

{

res = recv(s,(LPSTR)lpBuffer,dwSize,0);

}

dwBytesRead = (DWORD)((res>0)?(res):(-1));

}

return dwBytesRead;//返回記錄長(zhǎng)度

}

posted on 2008-05-02 10:10 isabc 閱讀(737) 評(píng)論(1) 編輯收藏引用所屬分類: 分享代碼

評(píng)論

# re: 連接服務(wù)流程代碼[未登錄](méi) 2008-11-18 10:39 1

11111 回復(fù) 更多評(píng)論

刷新評(píng)論列表

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。


相關(guān)文章: 存儲(chǔ)過(guò)程示例 SQL創(chuàng)建數(shù)據(jù)庫(kù)示例代碼封裝ADO編程Connection對(duì)象的類連接服務(wù)流程代碼 GSM短信息部分代碼！簡(jiǎn)單封裝的串口通信類

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問(wèn) Chat2DB 管理

# re: 連接服務(wù)流程代碼[未登錄](méi) 2008-11-18 10:39 1

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

Blog @ Blog

導(dǎo)航

公告

留言簿(20)

隨筆分類(156)

文章分類(1)

隨筆檔案(198)

文章檔案(2)

相冊(cè)

閱讀排行榜

評(píng)論排行榜

常用鏈接

統(tǒng)計(jì)

積分與排名

BBS

Blog

Web

最新評(píng)論

連接服務(wù)流程代碼

評(píng)論