下面看看它的消息定義:CMPP中的消息分為消息頭和消息體。消息頭定義如下
字段名 |
字節(jié)數(shù) |
類型 |
描述 |
Total_Length |
4 |
Unsigned Integer |
消息總長度(含消息頭及消息體) |
Command_Id |
4 |
Unsigned Integer |
命令或響應類型 |
Sequence_Id |
4 |
Unsigned Integer |
消息流水號,順序累加,步長為1,循環(huán)使用(一對請求和應答消息的流水號必須相同) |
那么下面就是SP連接到ISMG上了,看它的Bind連接消息定義
字段名 |
字節(jié)數(shù) |
屬性 |
描述 |
Source_Addr |
6 |
Octet String |
源地址,此處為SP_Id,即SP的企業(yè)代碼。 |
AuthenticatorSource |
16 |
Octet String |
用于鑒別源地址。其值通過單向MD5 hash計算得出,表示如下: AuthenticatorSource = MD5(Source_Addr+9 字節(jié)的0 +shared secret+timestamp) Shared secret 由中國移動與源地址實體事先商定,timestamp格式為:MMDDHHMMSS,即月日時分秒,10位。 |
Version |
1 |
Unsigned Integer |
雙方協(xié)商的版本號(高位4bit表示主版本號,低位4bit表示次版本號),對于3.0的版本,高4bit為3,低4位為0 |
Timestamp |
4 |
Unsigned Integer |
時間戳的明文,由客戶端產(chǎn)生,格式為MMDDHHMMSS,即月日時分秒,10位數(shù)字的整型,右對齊 。 |
根據(jù)上的定義我們可以寫出的代碼,如下,在VC環(huán)境下編寫的
/*
*函數(shù)功能:建立和CMPP網(wǎng)關(guān)的直接通路
*輸入條件:SP用戶名const char *UserName,SP密碼const char *PWD
*/
void Ccmpp_API::CmppConnect(const char *UserName, const char *PWD)
{
{
char netbuf[100];
CMPP_CONNECT *bufer;
bufer=(CMPP_CONNECT*)netbuf;
memset(bufer, 0, 100);
CMPP_CONNECT *bufer;
bufer=(CMPP_CONNECT*)netbuf;
memset(bufer, 0, 100);
bufer->nTotalLength = htonl(39);//CMPP_CONNECT消息總長度
bufer->nCommandId = htonl(CMPP_CONNECT_tag);//消息標志
bufer->nCommandId = htonl(CMPP_CONNECT_tag);//消息標志
//自動產(chǎn)生SeqId號
if (sequenceid == 123456789i32)
{
sequenceid = 1;
}else{
sequenceid++;
}
bufer->nSeqId = htonl(sequenceid);
int MD5Len;
MD5_CTX md5;//MD5源字串
CTime TimeData = CTime::GetCurrentTime();
CString timestamp = TimeData.Format("%m%d%H%M%S");
unsigned char md5source[29];
int Len1 = strlen(UserName);
int Len2 = strlen(PWD);
MD5Len = Len1 + 9 +Len2 + timestamp.GetLength();
memset(md5source, 0, MD5Len);
memcpy(bufer->sSourceAddr, UserName, Len1);
memcpy(md5source, UserName, Len1);
for (int j = 0; j<Len2; j++)
{
md5source[j + Len1 + 9] = PWD[j];
}
if (sequenceid == 123456789i32)
{
sequenceid = 1;
}else{
sequenceid++;
}
bufer->nSeqId = htonl(sequenceid);
int MD5Len;
MD5_CTX md5;//MD5源字串
CTime TimeData = CTime::GetCurrentTime();
CString timestamp = TimeData.Format("%m%d%H%M%S");
unsigned char md5source[29];
int Len1 = strlen(UserName);
int Len2 = strlen(PWD);
MD5Len = Len1 + 9 +Len2 + timestamp.GetLength();
memset(md5source, 0, MD5Len);
memcpy(bufer->sSourceAddr, UserName, Len1);
memcpy(md5source, UserName, Len1);
for (int j = 0; j<Len2; j++)
{
md5source[j + Len1 + 9] = PWD[j];
}
for (int i=0;i<timestamp.GetLength();i++)
{
md5source[i + Len2 + Len1 + 9]=timestamp[i];
}
//進行md5加密轉(zhuǎn)換
md5.MD5Update(md5source, MD5Len);
md5.MD5Final(md5source);
memcpy(bufer->sAuthSource, md5source, 29);
bufer->cVersion = 0x30;
bufer->nTimeStamp = htonl(atoi(timestamp));
CmppSocket.Send(bufer, 39, 0);//把消息打包發(fā)送
return;
}
{
md5source[i + Len2 + Len1 + 9]=timestamp[i];
}
//進行md5加密轉(zhuǎn)換
md5.MD5Update(md5source, MD5Len);
md5.MD5Final(md5source);
memcpy(bufer->sAuthSource, md5source, 29);
bufer->cVersion = 0x30;
bufer->nTimeStamp = htonl(atoi(timestamp));
CmppSocket.Send(bufer, 39, 0);//把消息打包發(fā)送
return;
}
今天就到這,下次再寫,歡迎交流!