Chinaunix

标题: [求助] MQ分包发送的解决办法 [打印本页]
作者: wiisola    时间: 2010-12-16 10:54
标题: [求助] MQ分包发送的解决办法
请各位帮忙分析解决下MQ分包发送的问题。

个人感觉可能有些选项设置有问题，报文通过MQ发送过去，对方收不到。

具体函数如下：
  1. #define MQ_MAXSIZE 1024

  3. int mq_sendfile(MQH mqh, const char *filename,char * msg_id, char * cor_id)
  4. {
  5.         
  6.     /* Declare MQI structures needed */
  7.     MQMD        md = {MQMD_DEFAULT};                /* Message Descriptor        */
  8.     MQPMO        pmo = {MQPMO_DEFAULT};                /* put message options        */
  9.     MQLONG        RetCode;                        /* completion code        */
  10.     MQLONG        Reason;                                /* reason code                */
  11.     MQLONG  msglen;

  13.     FILE    *hFile;
  14.     MQLONG  lSendLeng,lDatalen;
  15.     MQLONG  iCount;    /* File Segment count*/
  16.     char    msgbuf[MQ_MAXSIZE+1]; /* Temp Buffer*/
  17.         

  19.     if( mqh.obj_snd_flag == FALSE ) return(-1); /* object have not opend*/

  21.     md.Encoding       = MQENC_NATIVE;
  22.     md.CodedCharSetId = 819;
  23.    
  24.     memcpy( md.MsgId, MQMI_NONE, sizeof(md.MsgId) );
  25.     memcpy( md.CorrelId, MQCI_NONE, sizeof(md.CorrelId) );
  26.     memcpy( md.Format, MQFMT_STRING, (size_t)MQ_FORMAT_LENGTH );

  28.     /* put MsgId and CorrelId for match condition */
  29.     if( msg_id[0] != 0x00 ) {
  30.               memset( md.MsgId, 0x00, sizeof(md.MsgId) );
  31.               strncpy( (char *)md.MsgId, msg_id, sizeof(md.MsgId) );
  32.     }

  34.     if( cor_id[0] != 0x00 ) {
  35.              memset( md.CorrelId, 0x00, sizeof(md.CorrelId) );
  36.              strncpy( (char *)md.CorrelId, cor_id, sizeof(md.CorrelId) );
  37.     }
  38.    
  39.    

  41.     iCount   = 0;
  42.     lSendLeng = 0;
  43.     hFile     = NULL;
  44.     lDatalen = 0;
  45.    
  46.     if( filename == NULL) {
  47.        swVdebug(0,"filename is null!");
  48.        return (0);
  49.     }
  50.       
  51.     if((hFile = fopen(filename,"rb"))==NULL){
  52.        swVdebug(0,"open filename :%s error !",filename);
  53.        return (-1);        
  54.     }
  55.      
  56.             
  57. /***
  58.     md.Version         = MQMD_VERSION_2;
  59.     md.MsgFlags         = MQMF_SEGMENT;

  61.     pmo.Version         = MQMD_VERSION_2;
  62.     pmo.Options |=  MQPMO_LOGICAL_ORDER;
  63. ***/
  64.    
  65.             
  66.     int iTotal=0, iNum=0;

  68.     while(1) {               
  69.          lSendLeng = fread(msgbuf,1,MQ_MAXSIZE,hFile);
  70.                
  71.          swVdebug(3,"read file :%s ,result:%ld !",filename, lSendLeng);

  73.          md.Version   = MQMD_VERSION_2;
  74.          md.MsgFlags  = MQMF_SEGMENT;

  76.          pmo.Version   = MQMD_VERSION_2;
  77. /*
  78.          pmo.Options  |= MQPMO_LOGICAL_ORDER|MQPMRF_GROUP_ID;
  79.          pmo.Options  = MQPMO_LOGICAL_ORDER ;
  80.          pmo.PutMsgRecFields  = MQPMRF_GROUP_ID;
  81.          pmo.Options  = MQPMO_LOGICAL_ORDER + MQPMO_SYNCPOINT ;
  82.          pmo.Options  = MQPMO_LOGICAL_ORDER|MQPMRF_GROUP_ID;
  83.          pmo.Options  = MQPMO_LOGICAL_ORDER ;
  84.          pmo.PutMsgRecFields  = MQPMRF_GROUP_ID;
  85. */

  87.          pmo.Options  = MQPMO_LOGICAL_ORDER ;
  88.          pmo.PutMsgRecFields  = MQPMRF_GROUP_ID;
  89.          pmo.PutMsgRecOffset = iTotal;
  90.          pmo.RecsPresent = iNum;

  92.          if (lSendLeng < 0) {
  93.           swVdebug(0,"read file  error!");
  94.           iCount = -1;
  95.           break;   
  96.          }  
  97.          if ( lSendLeng == 0)
  98.           break;

  100.          if(lSendLeng < MQ_MAXSIZE)
  101.            md.MsgFlags = MQMF_LAST_MSG_IN_GROUP;        
  102.          else      
  103.            md.MsgFlags = MQMF_MSG_IN_GROUP;   
  104.                      
  105.          msglen = lSendLeng;

  107.          MQPUT( mqh.hcon,                /* connection handle                */
  108.                       mqh.hobj_snd,        /* object handle                */
  109.                       &md,                        /* message descriptor                */
  110.                       &pmo,                /* default options (datagram)        */
  111.                       msglen,                /* message length                */
  112.                       msgbuf,                /* message buffer                */
  113.                       &RetCode,                /* completion code                */
  114.                       &Reason );                /* reason code                        */
  115.               
  116.                   /* report reason, if any */
  117.          swVdebug(3,"send mq  count:%ld ,total:%ld,result:%d RetCode:%d !",iCount,lDatalen,Reason,RetCode);
  118.          if(Reason != MQRC_NONE || RetCode == MQCC_FAILED || RetCode == MQCC_UNKNOWN) {
  119.                   mqh.reason = Reason;
  120.                   break;
  121.                       
  122.          }
  123.               
  124.                  
  125.          iCount++;
  126.          iNum ++;
  127.          lDatalen += lSendLeng;
  128.          iTotal += lSendLeng;
  129.          swVdebug(3,"send mq  OK ,count:%ld ,total:%ld,result:%d !",iCount,lDatalen,Reason);
  130.     }
  131.                
  132.         
  133.     fclose(hFile);      
  134.     return (lDatalen);
  135. }
复制代码




欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2