协议开发 中移动CMPP2.0协议API（三）

 

接上篇...

五、发送接口<!----><o:p></o:p>

对于API来说，最重要的一部分就是去做发送数据了。通过SOCKET套接字与网关相连接后，将自己的数据发送出去。

在发送数据前，组装好要发送的数据包，将数据COPY一份到发送窗口，对于不要回应的数据包，只要发送成功，就可以退出发送进程。对于要等待回应的包，启动一个时钟来作为检测是否收到了回应，并返回结果给发送窗口。设置发送的次数标志，如果发送第一次超时，按设定的发送次数，再发送。如果出现一次发送不成功，可以设置一个标志位，去发送一次链路检测标志，如果链路检测失败，应该重新连接或者是在用户发送时直接返回链路断开的结果。

 <o:p></o:p>

CMPP_PACKAGE * _pkg = ( CMPP_PACKAGE * )buf ;

    int err = API_E_UNKNOW_ERR ;

    if( _soc == INVALID_SOCKET ) return API_E_INVALT_SOC ;

    while( _pkg->n > 0 )

    {

        _pkg->n = _pkg->n - 1 ;   //发送次数

        _lastacttime = time( NULL ) ;

 <o:p></o:p>

        EnterCriticalSection( &_csec_soc ) ;

        try

        {

            err = send( _soc, buf, len, 0 ) ;

        }

        catch( ... )

        {

        }

        LeaveCriticalSection( &_csec_soc ) ;

 <o:p></o:p>

        if( err < len ) //发送不成功

        {

            err = API_E_SO_SENDERR ;

            continue ;

        }

 <o:p></o:p>

        //不要回应结果的直接跳出

        if( _pkg->resp == false )

        {

            err = 0 ;

            break ;

        }

 <o:p></o:p>

        //等待回应事件

        …………

    }

    //如果发送超时，设置发送链路检测标志开

    if( err == API_E_SO_OVETIME )

    {

        _needacttest = _needacttest + 1 ;

    }

       return err;

 <o:p></o:p>

六、接收接口<o:p></o:p>

        对于数据的接收，因为发送短信的接口的数据量并不是很大，所以可以采用接收到

一部分，解释一部分的功能，这样的就可以减少设计上的难度，当然也可以一次接收缓冲中的数据，再一段段去分析，也不是很难。

        对于接收，启用一个新的线程，这样也可以保证接收的及时性与可调度性。先接收包头信息确定整个数据包的长度，直到接收到一个完整的包的内容才进行下一个包的接收，有些包也可能是没有包体结构的，所以也可以在收到正确的包头后就进行分析结构如下：

 <o:p></o:p>

        //先接收包头部分，以确定包的大小、类型

        err = _pscoket->_recv( _pscoket->_rec_window, sizeof( CMPP_HEAD )) ;

        if( err == SOCKET_ERROR || err == API_E_INVALT_SOC ) continue ;

 <o:p></o:p>

        CMPP_PACKAGE * _recpkg = ( CMPP_PACKAGE * )_pscoket->_rec_window ;

        if( ntohl( _recpkg->head.size ) > 0 )

        {

            //接收包体

            _reclen = 0 ;   //已接收长度

            _recdatalen = ntohl( _recpkg->head.size ) - sizeof( _recpkg->head ) ;

            do

            {

                Sleep( 1 ) ;

                _recdatalen = _recdatalen - _reclen ;

                err = _pscoket->_recv( _recpkg->data + _reclen, _recdatalen );

                if( err == SOCKET_ERROR || err == API_E_INVALT_SOC ) continue ;

                _reclen = err ;

            } while( _recdatalen - _reclen > 0 ) ;

            if( _recdatalen > _reclen ) continue ;

        }

        try

        {

            _pscoket->_analysisrecpack( _recpkg ) ;  //分析包的内容

        }

        catch( ... )

        {

        }

 <o:p></o:p>

 <o:p></o:p>

七、分析协议包<o:p></o:p>

接收到CMPP的一个完整的协议包后，根据命令字去作分析，相对来说并不是一个很难的事情，不过要注意是就是要把网络数据流转化为主机数据流这个问题。

unsigned char _result = 0 ;

    CMPP_DELIVER * _msg = ( CMPP_DELIVER * )_recpkg->data ;

    DELIVER_CONTENT * _pcont = ( DELIVER_CONTENT *)_msg->msgcontent ;

 <o:p></o:p>

    if( _msg->msglen <= 0 )

    {

        _result = 4 ; //接收到的长度前误，要求网关服务器重发这个包

    }

    else if( _msg->msglen > 200 )

    {

        _result = 6 ; //接收到的长度前误，要求网关服务器重发这个包

    }

    else if( _msg->delivery ！= 0 || _msg->delivery ！=  1 )

    {

        _result = 1 ; //接收到的协议格式有误，要求网关服务器重发这个包

    }

 <o:p></o:p>

    //接收到错误的信息直接返回

    if( _result > 0 )

    {

        _deliverresp( _recpkg->head.seqid, _msg->msgid, _result ) ;

        return ;

    }

              

        if( _fCltGetDeliver )

{

//如果客户端程序采用的是回调函数来取得接收到的短信或状态，调用回

//调函数传递数据

……………

}

else

{

//如果客户端采用的是自已从队列中提取的方式，把数据直接PUSH到队//列中等待用户提取

………….

}

 待续.....

 <o:p></o:p>