[求助] MQ分包发送的解决办法

Question

请各位帮忙分析解决下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. }

复制代码