?? cmppsocket_bcb.cpp
字號(hào):
/******************************************************************************
FileName : CcmppSocket.cpp
Description : 短消息發(fā)送程序
Version : 1.0
Date : 2004年4月6日
Author : 潘昱宇
Other : 只支持CMPP 3.0 for BCB6
編譯條件: 單字節(jié)對(duì)齊，取消循環(huán)變量作用域限定,MFC兼容模式
EMail : rebbie@163.com
******************************************************************************/
#include <stdlib.h>
#ifdef _DEBUG
#include <iterator>
#include <list>
#include <string>
#include <iostream>
#include <fstream>
#include <ostream>
#endif
#include <time.h>
#include "md5.h"
#include "cmppsocket_bcb.h"
//將接收的數(shù)據(jù)dump 到 _revdebug[]
#ifdef _DEBUG
using namespace std;
char _revdebug[1024*1024];
char * _revp=_revdebug;
std::list<std::string> _dbgeventlst;
char _dbgtemp[100];
std::ostream& operator<<(std::ostream& out, const std::list<std::string>& l)
{
std::copy(l.begin(), l.end(),
ostream_iterator<std::string,char> (out,"\n"));
return out;
}
#endif
CcmppSocket::CcmppSocket()
{
#ifdef _DEBUG
_dbgeventlst.push_back("Begin Class CcmppSocket Constructor.");
#endif
// 初始化私有變量
_binitialized = false;
_bexitting = false;
_seqid = 0;
memset( (void *)_window, 0, sizeof( _window));
InitializeCriticalSection( &_csec_wnd);
InitializeCriticalSection( &_csec_snd);
InitializeCriticalSection( &_csec_recv);
InitializeCriticalSection( &_csec_seq);
_hsema_wnd = CreateSemaphore( // 創(chuàng)建計(jì)數(shù)信號(hào)量
NULL,
nCMPP_WINDOW_SIZE,
nCMPP_WINDOW_SIZE,
NULL);
_hevnt_data = CreateEvent( // 創(chuàng)建提示發(fā)送的事件
NULL,
false,
false,
NULL);
// 初始化網(wǎng)絡(luò)
WSADATA wsaData;
WSAStartup( MAKEWORD( 2, 2 ), &wsaData );
#ifdef _DEBUG
_dbgeventlst.push_back("End Class CcmppSocket Constructor.");
#endif
}
CcmppSocket::~CcmppSocket()
{
// 發(fā)送CMPP_TERMINATE，從服務(wù)器注銷(xiāo)
#ifdef _DEBUG
_dbgeventlst.push_back("Begin Class CcmppSocket Desstructor.");
#endif
if( _binitialized)
_exit();
WSACleanup();
// 清除臨界區(qū)等
DeleteCriticalSection( &_csec_wnd);
DeleteCriticalSection( &_csec_snd);
DeleteCriticalSection( &_csec_recv);
DeleteCriticalSection( &_csec_seq);
CloseHandle( _hsema_wnd);
CloseHandle( _hevnt_data);
#ifdef _DEBUG
_dbgeventlst.push_back("Begin Class CcmppSocket Desstructor.");
#endif
}
/******************************************************************************
spid 企業(yè)代碼 例如：901001
passwd 登陸口令 例如：test
ismg 短信網(wǎng)關(guān)的地址，例如：127.0.0.1
port 短信網(wǎng)關(guān)的端口，例如：7890
******************************************************************************/
int CcmppSocket::init( char *spid, char *passwd, char *ismg, unsigned short port)
{
// 如果接口已經(jīng)初始化，則先刪除接口
#ifdef _DEBUG
_dbgeventlst.push_back("Connection Initializtion Begin.");
#endif
if( _binitialized)
_exit();
int err;
#ifdef _DEBUG
_dbgeventlst.push_back("Connect To GateWay Server.");
#endif
err = _connect( ismg, port);
if( err != 0)
{
#ifdef _DEBUG
sprintf(_dbgtemp,"Connect To GateWay Server Fail. Error Code=%d.",WSAGetLastError());
_dbgeventlst.push_back(_dbgtemp);
#endif
return eCMPP_INIT_CONNECT;
}
#ifdef _DEBUG
_dbgeventlst.push_back("Login To GateWay Server Begin.");
#endif
err = _login( spid, passwd);
if( err != 0)
{
#ifdef _DEBUG
sprintf(_dbgtemp," Connect To GateWay Server Fail Return Code=%d Error Code=%d.",err,WSAGetLastError());
_dbgeventlst.push_back(_dbgtemp);
#endif
closesocket( _soc);
return err;
}
#ifdef _DEBUG
_dbgeventlst.push_back("Login To GateWay Server Success.");
#endif
// 保存配置，以備后用
strcpy( _spid, spid);
strcpy( _passwd,passwd);
strcpy( _ismg, ismg);
_port = port;
// 啟動(dòng)發(fā)送、接收數(shù)據(jù)的線程
#ifdef _DEBUG
_dbgeventlst.push_back("Begin Thread Send SMS.");
#endif
_hsend = CreateThread( // 短信發(fā)送線程
NULL,
NULL,
thread_send,
(LPVOID)this,
0,
NULL);
#ifdef _DEBUG
_dbgeventlst.push_back("Begin Thread Recieve SMS.");
#endif
_hrecv = CreateThread( // 短信接收線程
NULL,
NULL,
thread_recv,
(LPVOID)this,
0,
NULL);
#ifdef _DEBUG
_dbgeventlst.push_back("Begin Thread Activate.");
#endif
_hactv = CreateThread( // 鏈路檢查
NULL,
NULL,
thread_actv,
(LPVOID)this,
0,
NULL);
// 初始化成功，設(shè)置成功標(biāo)志
_binitialized = true;
// 放棄當(dāng)前時(shí)間片
Sleep( 0);
#ifdef _DEBUG
_dbgeventlst.push_back("Connection Initializtion Success.");
#endif
return eCMPP_INIT_OK;
}
/******************************************************************************
msg 向服務(wù)器提交的數(shù)據(jù)
dwMilliseconds 在成功的將數(shù)據(jù)插入數(shù)據(jù)窗口前等待的時(shí)間
返回值 描述
=============== ==============================
0 成功
eCMPP_NEED_INIT 接口未初始化
WAIT_TIMEOUT 操作超時(shí)
WAIT_ABANDONED 工作線程異常退出，可能是網(wǎng)絡(luò)故障
******************************************************************************/
int CcmppSocket::Submit( CMPP_SUBMIT &msg, DWORD dwMilliseconds)
{
CMPP_PACKAGE pkg;
CMPP_HEAD &head = (CMPP_HEAD &)pkg.head;
int err, nsize;
if(!_binitialized)
return eCMPP_NEED_INIT;
pkg.n = 3; // 發(fā)送失敗，則重發(fā)兩次
pkg.t = time( NULL); // 立即發(fā)送
nsize = sizeof( CMPP_HEAD) + sizeof( CMPP_SUBMIT);
// 因?yàn)镃MPP協(xié)議中包的長(zhǎng)度是可變的，而我定義的數(shù)據(jù)結(jié)構(gòu)中
// 包的長(zhǎng)度采用的是最大長(zhǎng)度，所以這里需要修正
nsize = nsize + msg.msglen - sizeof( msg.msgcontent);
head.size = htonl( nsize);
head.cmdid= htonl( nCMPP_SUBMIT);
head.seqid= htonl( _getseqid());
memcpy( (void *)pkg.data, (void *)&msg, sizeof( msg));
// 將最后8個(gè)字節(jié)的保留數(shù)據(jù)拷貝到適當(dāng)?shù)奈恢? memcpy(
(void *)(pkg.data + nsize - sizeof( msg.reserve) - sizeof( CMPP_HEAD)),
(void *)msg.reserve,
sizeof( msg.reserve));
// 等候數(shù)據(jù)發(fā)送窗口的空位
err = WaitForSingleObject( _hsema_wnd, dwMilliseconds);
// 等待超時(shí)或程序異常
if( err != WAIT_OBJECT_0)
return err;
// 申請(qǐng)數(shù)據(jù)發(fā)送窗口的使用權(quán)
EnterCriticalSection( &_csec_wnd);
for( int i=0; i<nCMPP_WINDOW_SIZE; i++)
{
// 找到一個(gè)空位
if( _window[i].head.cmdid == 0)
break;
}
memcpy( (void *)&_window[i], (void *)&pkg, sizeof( pkg));
LeaveCriticalSection( &_csec_wnd);
// 喚醒數(shù)據(jù)發(fā)送線程
PulseEvent( _hevnt_data);
return 0;
}
int CcmppSocket::_connect( char *ismg, unsigned short port)
{
int err;
struct sockaddr_in addr;
_soc = socket( AF_INET, SOCK_STREAM, 0);
addr.sin_family = AF_INET;
addr.sin_port = htons( port);
addr.sin_addr.s_addr = inet_addr( ismg);
err = connect( _soc, (struct sockaddr *)&addr, sizeof( addr));
return err;
}
int CcmppSocket::_login( char *spid, char *passwd)
{
CMPP_PACKAGE pkg;
CMPP_CONNECT &msg = *(CMPP_CONNECT *)pkg.data;
int err, nsize;
MD5 ctx;
char authsrc[50], *pos, timestr[20];
memset( (void *)&msg, 0, sizeof( &msg));
nsize = sizeof( CMPP_HEAD) + sizeof( CMPP_CONNECT);
pkg.head.size = htonl( nsize);
pkg.head.cmdid = htonl( nCMPP_CONNECT);
pkg.head.seqid = htonl( _getseqid());
strcpy( (char *)msg.spid, spid);
// 計(jì)算單向HASH函數(shù)的值
memset( authsrc, 0, sizeof( authsrc));
strcpy( authsrc, spid);
pos = authsrc + strlen( spid) + 9;
strcpy( (char *)pos, passwd);
pos += strlen( passwd);
strcpy( pos, _timestamp( timestr ));
pos += strlen( timestr);
ctx.update( (unsigned char *)authsrc, (int)(pos - authsrc) );
ctx.finalize();
ctx.raw_digest( msg.digest);
msg.ver = nCMPP_VERSION;
msg.timestamp = htonl( atol( timestr));
// 發(fā)送身份驗(yàn)證數(shù)據(jù)
err = _send( (char *)&pkg, nsize);
if( err != nsize)
return eCMPP_INIT_CONNECT;
// 接收返回的數(shù)據(jù)包
CMPP_CONNECT_RESP &msgresp = *(CMPP_CONNECT_RESP *)pkg.data;
nsize = sizeof( CMPP_HEAD) + sizeof( CMPP_CONNECT_RESP);
err = _recv( (char *)&pkg, nsize);
if( err != nsize )
return eCMPP_INIT_CONNECT;
return ntohl( msgresp.status);
}
void CcmppSocket::_exit()
{
HANDLE threads[] = { _hsend, _hrecv, _hactv};
int i,
nthreads;
// 請(qǐng)求工作線程退出
_bexitting = true;
Sleep( 1000);
// 關(guān)閉請(qǐng)求，強(qiáng)制結(jié)束所有尚未退出的線程
_bexitting = false;
nthreads = sizeof( threads) / sizeof( HANDLE);
for( i=0; i<nthreads; i++)
{
TerminateThread( threads[i], 0);
CloseHandle( threads[i]);
}
// 注銷(xiāo)
_logout();
closesocket( _soc);
}
void CcmppSocket::_logout()
{
CMPP_HEAD msg;
int err, nsize;
nsize = sizeof( msg);
msg.size = htonl( nsize);
msg.cmdid = htonl( nCMPP_TERMINATE);
msg.seqid = htonl( _getseqid());
err = _send( (char *)&msg, sizeof( msg));
if( err != nsize)
return;
err = _recv( (char *)&msg, sizeof( msg));
return;
}
/******************************************************************************
數(shù)據(jù)發(fā)送線程
對(duì)于新提交的數(shù)據(jù)報(bào)，立即發(fā)送
超過(guò)60秒未收到回應(yīng)，則重發(fā)
******************************************************************************/
DWORD WINAPI CcmppSocket::thread_send( LPVOID pdata)
{
CcmppSocket &cmpp = *( CcmppSocket *)pdata;
CMPP_PACKAGE window[nCMPP_WINDOW_SIZE];
int i;
int err;
int nsize;
int dwMilliseconds = 1000; // 輪詢間隔為1000毫秒
for( ;;)
{
// 輪詢間隔1秒
err = WaitForSingleObject(
cmpp._hevnt_data,
dwMilliseconds);
// 出錯(cuò)了，結(jié)束線程
if( err == WAIT_FAILED)
break;
// 申請(qǐng)數(shù)據(jù)發(fā)送窗口的使用權(quán)
EnterCriticalSection( &cmpp._csec_wnd);
?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -